com.couchbase.client.internal

Class HttpFuture<T>

java.lang.Object

net.spy.memcached.compat.SpyObject

com.couchbase.client.internal.HttpFuture<T>

All Implemented Interfaces:

java.util.concurrent.Future<T>

Direct Known Subclasses:

ViewFuture

public class HttpFuture<T>
extends SpyObject
implements java.util.concurrent.Future<T>

A future http response.

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.concurrent.CountDownLatch	latch
protected java.util.concurrent.atomic.AtomicReference<T>	objRef
protected HttpOperation	op
protected OperationStatus	status
protected long	timeout

Constructor Summary

Constructors

Constructor and Description
HttpFuture(java.util.concurrent.CountDownLatch latch, long timeout)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	cancel(boolean c)
T	get()
T	get(long duration, java.util.concurrent.TimeUnit units)
OperationStatus	getStatus()
boolean	isCancelled()
boolean	isDone()
void	set(T oper, OperationStatus s)
void	setOperation(HttpOperation to)
protected void	waitForAndCheckOperation(long duration, java.util.concurrent.TimeUnit units)

Methods inherited from class net.spy.memcached.compat.SpyObject

getLogger

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

objRef

protected final java.util.concurrent.atomic.AtomicReference<T> objRef

latch

protected final java.util.concurrent.CountDownLatch latch

timeout

protected final long timeout

status

protected OperationStatus status

op

protected HttpOperation op

Constructor Detail

HttpFuture

public HttpFuture(java.util.concurrent.CountDownLatch latch,
          long timeout)

Method Detail

cancel

public boolean cancel(boolean c)

Specified by:

cancel in interface java.util.concurrent.Future<T>

get

public T get()
      throws java.lang.InterruptedException,
             java.util.concurrent.ExecutionException

Specified by:

get in interface java.util.concurrent.Future<T>

Throws:

java.lang.InterruptedException

java.util.concurrent.ExecutionException

get

public T get(long duration,
    java.util.concurrent.TimeUnit units)
      throws java.lang.InterruptedException,
             java.util.concurrent.ExecutionException,
             java.util.concurrent.TimeoutException

Specified by:

get in interface java.util.concurrent.Future<T>

Throws:

java.lang.InterruptedException

java.util.concurrent.ExecutionException

java.util.concurrent.TimeoutException

waitForAndCheckOperation

protected void waitForAndCheckOperation(long duration,
                            java.util.concurrent.TimeUnit units)
                                 throws java.lang.InterruptedException,
                                        java.util.concurrent.TimeoutException,
                                        java.util.concurrent.ExecutionException

Throws:

java.lang.InterruptedException

java.util.concurrent.TimeoutException

java.util.concurrent.ExecutionException

getStatus

public OperationStatus getStatus()

set

public void set(T oper,
       OperationStatus s)

isDone

public boolean isDone()

Specified by:

isDone in interface java.util.concurrent.Future<T>

setOperation

public void setOperation(HttpOperation to)

isCancelled

public boolean isCancelled()

Specified by:

isCancelled in interface java.util.concurrent.Future<T>