| Package | Description |
|---|---|
| org.apache.ignite.internal.util.nio |
NIO server interfaces and common utility classes for NIO.
|
| org.apache.ignite.internal.util.nio.ssl |
Implementation of Secure Socket Layer filter for NIO server based on SSLEngine class.
|
| Modifier and Type | Class and Description |
|---|---|
class |
GridNioEmbeddedFuture<R>
Future that delegates to some other future.
|
class |
GridNioFinishedFuture<R>
Future that represents already completed result.
|
class |
GridNioFutureImpl<R>
Default future implementation.
|
| Modifier and Type | Method and Description |
|---|---|
GridNioFuture<Boolean> |
GridNioSession.close()
Performs a request for asynchronous session close.
|
GridNioFuture<Boolean> |
GridNioSessionImpl.close()
Performs a request for asynchronous session close.
|
GridNioFuture<Boolean> |
GridNioServer.close(GridNioSession ses) |
GridNioFuture<GridNioSession> |
GridNioServer.createSession(SocketChannel ch,
Map<Integer,?> meta)
Establishes a session.
|
GridNioFuture<?> |
GridNioFilterAdapter.onPauseReads(GridNioSession ses)
Pauses reads for session.
|
GridNioFuture<?> |
GridNioFilter.onPauseReads(GridNioSession ses)
Pauses reads for session.
|
GridNioFuture<?> |
GridNioFilterChain.onPauseReads(GridNioSession ses)
Starts chain notification from tail to head.
|
GridNioFuture<?> |
GridNioFilterAdapter.onResumeReads(GridNioSession ses)
Resumes reads for session.
|
GridNioFuture<?> |
GridNioFilter.onResumeReads(GridNioSession ses)
Resumes reads for session.
|
GridNioFuture<?> |
GridNioFilterChain.onResumeReads(GridNioSession ses)
Starts chain notification from tail to head.
|
GridNioFuture<Boolean> |
GridConnectionBytesVerifyFilter.onSessionClose(GridNioSession ses)
Invoked when a session close request is performed on session.
|
GridNioFuture<Boolean> |
GridNioCodecFilter.onSessionClose(GridNioSession ses)
Invoked when a session close request is performed on session.
|
GridNioFuture<Boolean> |
GridNioAsyncNotifyFilter.onSessionClose(GridNioSession ses)
Invoked when a session close request is performed on session.
|
GridNioFuture<Boolean> |
GridNioFilter.onSessionClose(GridNioSession ses)
Invoked when a session close request is performed on session.
|
GridNioFuture<Boolean> |
GridNioFilterChain.onSessionClose(GridNioSession ses)
Starts chain notification from tail to head.
|
GridNioFuture<?> |
GridConnectionBytesVerifyFilter.onSessionWrite(GridNioSession ses,
Object msg)
Invoked when a write request is performed on a session.
|
GridNioFuture<?> |
GridNioCodecFilter.onSessionWrite(GridNioSession ses,
Object msg)
Invoked when a write request is performed on a session.
|
GridNioFuture<?> |
GridNioAsyncNotifyFilter.onSessionWrite(GridNioSession ses,
Object msg)
Invoked when a write request is performed on a session.
|
GridNioFuture<?> |
GridNioFilter.onSessionWrite(GridNioSession ses,
Object msg)
Invoked when a write request is performed on a session.
|
GridNioFuture<?> |
GridNioFilterChain.onSessionWrite(GridNioSession ses,
Object msg)
Starts chain notification from tail to head.
|
GridNioFuture<?> |
GridNioSession.pauseReads()
Pauses reads.
|
GridNioFuture<?> |
GridNioSessionImpl.pauseReads()
Pauses reads.
|
GridNioFuture<?> |
GridNioFilterAdapter.proceedPauseReads(GridNioSession ses)
Pauses reads for session.
|
GridNioFuture<?> |
GridNioFilter.proceedPauseReads(GridNioSession ses)
Pauses reads for session.
|
GridNioFuture<?> |
GridNioFilterAdapter.proceedResumeReads(GridNioSession ses)
Resumes reads for session.
|
GridNioFuture<?> |
GridNioFilter.proceedResumeReads(GridNioSession ses)
Resumes reads for session.
|
GridNioFuture<Boolean> |
GridNioFilterAdapter.proceedSessionClose(GridNioSession ses)
Forwards session close request to the next logical filter in filter chain.
|
GridNioFuture<Boolean> |
GridNioFilter.proceedSessionClose(GridNioSession ses)
Forwards session close request to the next logical filter in filter chain.
|
GridNioFuture<?> |
GridNioFilterAdapter.proceedSessionWrite(GridNioSession ses,
Object msg)
Forwards write request to the next logical filter in filter chain.
|
GridNioFuture<?> |
GridNioFilter.proceedSessionWrite(GridNioSession ses,
Object msg)
Forwards write request to the next logical filter in filter chain.
|
GridNioFuture<?> |
GridNioSession.resumeReads()
Resumes session reads.
|
GridNioFuture<?> |
GridNioSessionImpl.resumeReads()
Resumes session reads.
|
GridNioFuture<?> |
GridNioSession.send(Object msg)
Performs a request for asynchronous data send.
|
GridNioFuture<?> |
GridNioSessionImpl.send(Object msg)
Performs a request for asynchronous data send.
|
GridNioFuture<?> |
GridNioServer.sendSystem(GridNioSession ses,
Message msg)
Adds message at the front of the queue without acquiring back pressure semaphore.
|
GridNioFuture<?> |
GridNioServer.sendSystem(GridNioSession ses,
Message msg,
IgniteInClosure<? super IgniteInternalFuture<?>> lsnr)
Adds message at the front of the queue without acquiring back pressure semaphore.
|
| Modifier and Type | Method and Description |
|---|---|
Deque<GridNioFuture<?>> |
GridNioRecoveryDescriptor.messagesFutures() |
| Modifier and Type | Method and Description |
|---|---|
boolean |
GridNioRecoveryDescriptor.add(GridNioFuture<?> fut) |
void |
GridNioEmbeddedFuture.onDone(GridNioFuture<R> res)
Callback to notify that future is finished.
|
void |
GridNioEmbeddedFuture.onDone(GridNioFuture<R> delegate,
Throwable err)
Callback to notify that future is finished.
|
| Modifier and Type | Method and Description |
|---|---|
GridNioFuture<Boolean> |
GridNioSslFilter.onSessionClose(GridNioSession ses)
Invoked when a session close request is performed on session.
|
GridNioFuture<?> |
GridNioSslFilter.onSessionWrite(GridNioSession ses,
Object msg)
Invoked when a write request is performed on a session.
|
Follow @ApacheIgnite
Ignite Fabric : ver. 1.0.0 Release Date : March 31 2015