org.apache.http.impl.nio.reactor

Class SessionRequestImpl

java.lang.Object

org.apache.http.impl.nio.reactor.SessionRequestImpl

All Implemented Interfaces:

SessionRequest

@Contract(threading=SAFE_CONDITIONAL)
public class SessionRequestImpl
extends java.lang.Object
implements SessionRequest

Default implementation of SessionRequest.

Since:

4.0

Field Summary

Fields

Modifier and Type	Field and Description
private java.lang.Object	attachment
private SessionRequestCallback	callback
private boolean	completed
private int	connectTimeout
private java.io.IOException	exception
private java.nio.channels.SelectionKey	key
private java.net.SocketAddress	localAddress
private java.net.SocketAddress	remoteAddress
private IOSession	session

Constructor Summary

Constructors

Constructor and Description
SessionRequestImpl(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, java.lang.Object attachment, SessionRequestCallback callback)

Method Summary

Modifier and Type	Method and Description
void	cancel() Cancels the request.
void	completed(IOSession session)
void	failed(java.io.IOException exception)
java.lang.Object	getAttachment() Returns attachment object will be added to the session's context upon initialization.
int	getConnectTimeout() Returns connect timeout value in milliseconds.
java.io.IOException	getException() Returns IOException instance if the request could not be successfully executed due to an I/O error or null if no error occurred to this point.
java.net.SocketAddress	getLocalAddress() Returns local socket address.
java.net.SocketAddress	getRemoteAddress() Returns socket address of the remote host.
IOSession	getSession() Returns IOSession instance created as a result of this request or null if the request is still pending.
boolean	isCompleted() Determines whether the request has been completed (either successfully or unsuccessfully).
void	setConnectTimeout(int timeout) Sets connect timeout value in milliseconds.
protected void	setKey(java.nio.channels.SelectionKey key)
void	timeout()
void	waitFor() Waits for completion of this session request.

Methods inherited from class java.lang.Object

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

Field Detail

completed

private volatile boolean completed

key

private volatile java.nio.channels.SelectionKey key

remoteAddress

private final java.net.SocketAddress remoteAddress

localAddress

private final java.net.SocketAddress localAddress

attachment

private final java.lang.Object attachment

callback

private final SessionRequestCallback callback

connectTimeout

private volatile int connectTimeout

session

private volatile IOSession session

exception

private volatile java.io.IOException exception

Constructor Detail

SessionRequestImpl

public SessionRequestImpl(java.net.SocketAddress remoteAddress,
                          java.net.SocketAddress localAddress,
                          java.lang.Object attachment,
                          SessionRequestCallback callback)

Method Detail

getRemoteAddress

public java.net.SocketAddress getRemoteAddress()

Description copied from interface: SessionRequest

Returns socket address of the remote host.

Specified by:

getRemoteAddress in interface SessionRequest

Returns:

socket address of the remote host

getLocalAddress

public java.net.SocketAddress getLocalAddress()

Description copied from interface: SessionRequest

Returns local socket address.

Specified by:

getLocalAddress in interface SessionRequest

Returns:

local socket address.

getAttachment

public java.lang.Object getAttachment()

Description copied from interface: SessionRequest

Returns attachment object will be added to the session's context upon initialization. This object can be used to pass an initial processing state to the protocol handler.

Specified by:

getAttachment in interface SessionRequest

Returns:

attachment object.

isCompleted

public boolean isCompleted()

Description copied from interface: SessionRequest

Determines whether the request has been completed (either successfully or unsuccessfully).

Specified by:

isCompleted in interface SessionRequest

Returns:

true if the request has been completed, false if still pending.

setKey

protected void setKey(java.nio.channels.SelectionKey key)

waitFor

public void waitFor()
             throws java.lang.InterruptedException

Description copied from interface: SessionRequest

Waits for completion of this session request.

Specified by:

waitFor in interface SessionRequest

Throws:

java.lang.InterruptedException - in case the execution process was interrupted.

getSession

public IOSession getSession()

Description copied from interface: SessionRequest

Returns IOSession instance created as a result of this request or null if the request is still pending.

Specified by:

getSession in interface SessionRequest

Returns:

I/O session or null if the request is still pending.

getException

public java.io.IOException getException()

Description copied from interface: SessionRequest

Returns IOException instance if the request could not be successfully executed due to an I/O error or null if no error occurred to this point.

Specified by:

getException in interface SessionRequest

Returns:

I/O exception or null if no error occurred to this point.

completed

public void completed(IOSession session)

failed

public void failed(java.io.IOException exception)

timeout

public void timeout()

getConnectTimeout

public int getConnectTimeout()

Description copied from interface: SessionRequest

Returns connect timeout value in milliseconds.

Specified by:

getConnectTimeout in interface SessionRequest

Returns:

connect timeout value in milliseconds.

setConnectTimeout

public void setConnectTimeout(int timeout)

Description copied from interface: SessionRequest

Sets connect timeout value in milliseconds.

Specified by:

setConnectTimeout in interface SessionRequest

Parameters:

timeout - connect timeout value in milliseconds.

cancel

public void cancel()

Description copied from interface: SessionRequest

Cancels the request. Invocation of this method will set the status of the request to completed and will unblock threads blocked in the {SessionRequest.waitFor()} method.

Specified by:

cancel in interface SessionRequest