Package com.gigaspaces.lrmi.nio.async

Class AsyncContext

java.lang.Object

com.gigaspaces.lrmi.nio.async.AsyncContext

All Implemented Interfaces:

IWriteInterestManager, Context

public class AsyncContext
extends Object
implements Context

a client handler context implementation. stores the state of the async operation. a normal operation includes multiple write and read action. first operation is always a write followed by a sequence of read(class requests) and writes (class response). the last action is always a read of the final result. at the end of the operation the associated connection (CPeer) is returned to the pool.

Since:

6.5

Author:

asy ronen

Constructor Summary

Constructors

Constructor	Description
AsyncContext(ConnectionPool connPool, ClientHandler handler, RequestPacket packet, LRMIFuture result, CPeer cpeer, IRemoteClassProviderProvider remoteConnection, ClassLoader contextClassLoader, LRMIRemoteClassLoaderIdentifier remoteClassLoaderIdentifier, String monitoringId, ClientPeerWatchedObjectsContext watchedObjectContext)

Method Summary

Modifier and Type	Method	Description
void	close()	Release the CPeer when called on un register from the Selector
void	close(Throwable exception)
void	closeAndDisconnect()
SelectionKey	getSelectionKey()
void	handleRead()
void	handleSetReadInterest()
void	handleWrite()
void	removeWriteInterest(boolean restoreReadInterest)
void	setSelectionKey(SelectionKey key)
void	setWriteInterest()

Methods inherited from class java.lang.Object

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

Constructor Details

AsyncContext

public AsyncContext(ConnectionPool connPool,
 ClientHandler handler,
 RequestPacket packet,
 LRMIFuture result,
 CPeer cpeer,
 IRemoteClassProviderProvider remoteConnection,
 ClassLoader contextClassLoader,
 LRMIRemoteClassLoaderIdentifier remoteClassLoaderIdentifier,
 String monitoringId,
 ClientPeerWatchedObjectsContext watchedObjectContext)

Method Details

setSelectionKey

public void setSelectionKey(SelectionKey key)

Specified by:

setSelectionKey in interface Context

getSelectionKey

public SelectionKey getSelectionKey()

Specified by:

getSelectionKey in interface Context

handleRead

public void handleRead()

Specified by:

handleRead in interface Context

handleWrite

public void handleWrite()

Specified by:

handleWrite in interface Context

handleSetReadInterest

public void handleSetReadInterest()

Specified by:

handleSetReadInterest in interface Context

removeWriteInterest

public void removeWriteInterest(boolean restoreReadInterest)

Specified by:

removeWriteInterest in interface IWriteInterestManager

setWriteInterest

public void setWriteInterest()

Specified by:

setWriteInterest in interface IWriteInterestManager

close

public void close(Throwable exception)

Specified by:

close in interface Context

closeAndDisconnect

public void closeAndDisconnect()

Specified by:

closeAndDisconnect in interface Context

close

public void close()

Release the CPeer when called on un register from the Selector

Specified by:

close in interface Context