org.jredis.ri.alphazero.connection

Class PendingRequest

java.lang.Object

org.jredis.ri.alphazero.connection.PendingRequest

All Implemented Interfaces:

java.util.concurrent.Future<Response>

Direct Known Subclasses:

ChunkedPipelineConnection.PendingCPRequest

public class PendingRequest
extends java.lang.Object
implements java.util.concurrent.Future<Response>

An implementation of Future for parameteric T type Response used for processing of pipelined responses from the server.

Note that this implementation does NOT support canceling of Requests.

Since:

alpha.0

Version:

alpha.0, Sep 7, 2009

Field Summary

Fields

Modifier and Type	Field and Description
(package private) byte[][]	args
(package private) Command	cmd Pending command
(package private) Signal	completion Used to signal completion of the request
private ClientRuntimeException	cre if excepted is true, this will be set to the cause.
private boolean	excepted true if response processor encountered exceptions
(package private) Response	response awaited response

Constructor Summary

Constructors

Constructor and Description
PendingRequest(Command cmd)
PendingRequest(Command cmd, byte[]... args)

Method Summary

Modifier and Type	Method and Description
boolean	cancel(boolean mayInterruptIfRunning) Pipeline does not support canceling of requests -- will always return false.
private void	checkStatus() Determines if a completed request encountered errors and will throw an ExecutionException wrapping the original cause.
Response	get()
Response	get(long timeout, java.util.concurrent.TimeUnit unit)
(package private) Command	getCommand()
boolean	isCancelled() Pipeline does not support canceling of requests -- will always return false.
boolean	isDone()
(package private) void	setCRE(ClientRuntimeException cre) Signals completion with error -- response will be null
(package private) void	setResponse(Response response) Signals completion without error.

Methods inherited from class java.lang.Object

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

Field Detail

completion

final Signal completion

Used to signal completion of the request

response

Response response

awaited response

cmd

final Command cmd

Pending command

excepted

private boolean excepted

true if response processor encountered exceptions

cre

private ClientRuntimeException cre

if excepted is true, this will be set to the cause.

args

final byte[][] args

Constructor Detail

PendingRequest

public PendingRequest(Command cmd)

PendingRequest

public PendingRequest(Command cmd,
                      byte[]... args)

Method Detail

getCommand

final Command getCommand()

setResponse

final void setResponse(Response response)

Signals completion without error.

Sets the response, which also signals the completion of this Future object. When this method is invoked, a call to get() will immediately return with the response.

Parameters:

response -

setCRE

final void setCRE(ClientRuntimeException cre)

Signals completion with error -- response will be null

Parameters:

cre -

checkStatus

private final void checkStatus()
                        throws java.util.concurrent.ExecutionException

Determines if a completed request encountered errors and will throw an ExecutionException wrapping the original cause. Called by the get() methods.

Throws:

java.util.concurrent.ExecutionException

get

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

Specified by:

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

Throws:

java.lang.InterruptedException

java.util.concurrent.ExecutionException

get

public Response get(long timeout,
                    java.util.concurrent.TimeUnit unit)
             throws java.lang.InterruptedException,
                    java.util.concurrent.ExecutionException,
                    java.util.concurrent.TimeoutException

Specified by:

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

Throws:

java.lang.InterruptedException

java.util.concurrent.ExecutionException

java.util.concurrent.TimeoutException

cancel

public boolean cancel(boolean mayInterruptIfRunning)

Pipeline does not support canceling of requests -- will always return false.

Specified by:

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

See Also:

Future.cancel(boolean)

isCancelled

public boolean isCancelled()

Pipeline does not support canceling of requests -- will always return false.

Specified by:

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

See Also:

cancel(boolean), Future.isCancelled()

isDone

public boolean isDone()

Specified by:

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