Uses of Interface
org.apache.ignite.internal.util.nio.GridNioSession

Packages that use GridNioSession

Package	Description
org.apache.ignite.internal.client.router.impl
org.apache.ignite.internal.processors.odbc
org.apache.ignite.internal.processors.rest.handlers.redis
org.apache.ignite.internal.processors.rest.protocols.tcp	Adapters for TCP-based REST protocols.
org.apache.ignite.internal.processors.rest.protocols.tcp.redis
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.

Uses of GridNioSession in org.apache.ignite.internal.client.router.impl

Methods in org.apache.ignite.internal.client.router.impl with parameters of type GridNioSession

Modifier and Type	Method and Description
void	GridTcpRouterNioListenerAdapter.onConnected(GridNioSession ses) This method is called whenever a new client is connected and session is created.
void	GridTcpRouterNioListenerAdapter.onDisconnected(GridNioSession ses, Exception e) This method is called whenever client is disconnected due to correct connection close or due to IOException during network operations.
void	GridTcpRouterNioListenerAdapter.onMessage(GridNioSession ses, GridClientMessage msg) This method is called whenever a GridNioParser returns non-null value.
void	GridTcpRouterNioListenerAdapter.onSessionIdleTimeout(GridNioSession ses) Called when session did not receive any activity within timeout interval.
void	GridTcpRouterNioListenerAdapter.onSessionWriteTimeout(GridNioSession ses) Called when session has non-empty write queue and server did not send any data within timeout interval.

Uses of GridNioSession in org.apache.ignite.internal.processors.odbc

Methods in org.apache.ignite.internal.processors.odbc with parameters of type GridNioSession

Modifier and Type	Method and Description
byte[]	SqlListenerBufferedParser.decode(GridNioSession ses, ByteBuffer buf) This method is called when input bytes are available on the underlying network connection.
ByteBuffer	SqlListenerBufferedParser.encode(GridNioSession ses, Object msg) This method is called whenever a message should be sent to the network connection and network buffer is ready to be filled with bytes.
void	SqlListenerNioListener.onConnected(GridNioSession ses) This method is called whenever a new client is connected and session is created.
void	SqlListenerNioListener.onDisconnected(GridNioSession ses, Exception e) This method is called whenever client is disconnected due to correct connection close or due to IOException during network operations.
void	SqlListenerNioListener.onMessage(GridNioSession ses, byte[] msg) This method is called whenever a GridNioParser returns non-null value.

Uses of GridNioSession in org.apache.ignite.internal.processors.rest.handlers.redis

Methods in org.apache.ignite.internal.processors.rest.handlers.redis with parameters of type GridNioSession

Modifier and Type	Method and Description
IgniteInternalFuture<GridRedisMessage>	GridRedisRestCommandHandler.handleAsync(GridNioSession ses, GridRedisMessage msg)
IgniteInternalFuture<GridRedisMessage>	GridRedisConnectionCommandHandler.handleAsync(GridNioSession ses, GridRedisMessage msg)
IgniteInternalFuture<GridRedisMessage>	GridRedisCommandHandler.handleAsync(GridNioSession ses, GridRedisMessage msg)

Uses of GridNioSession in org.apache.ignite.internal.processors.rest.protocols.tcp

Methods in org.apache.ignite.internal.processors.rest.protocols.tcp with parameters of type GridNioSession

Modifier and Type	Method and Description
GridClientMessage	GridTcpRestParser.decode(GridNioSession ses, ByteBuffer buf) This method is called when input bytes are available on the underlying network connection.
ByteBuffer	GridTcpRestParser.encode(GridNioSession ses, Object msg0) This method is called whenever a message should be sent to the network connection and network buffer is ready to be filled with bytes.
protected GridClientMarshaller	GridTcpRestParser.marshaller(GridNioSession ses) Returns marshaller.
void	GridTcpRestNioListener.onConnected(GridNioSession ses) This method is called whenever a new client is connected and session is created.
void	GridTcpMemcachedNioListener.onConnected(GridNioSession ses) This method is called whenever a new client is connected and session is created.
void	GridTcpRestNioListener.onDisconnected(GridNioSession ses, Exception e) This method is called whenever client is disconnected due to correct connection close or due to IOException during network operations.
void	GridTcpMemcachedNioListener.onDisconnected(GridNioSession ses, Exception e) This method is called whenever client is disconnected due to correct connection close or due to IOException during network operations.
void	GridTcpRestNioListener.onMessage(GridNioSession ses, GridClientMessage msg) This method is called whenever a GridNioParser returns non-null value.
void	GridTcpMemcachedNioListener.onMessage(GridNioSession ses, GridMemcachedMessage req) This method is called whenever a GridNioParser returns non-null value.
void	GridTcpRestNioListener.onSessionIdleTimeout(GridNioSession ses) Closes the session by timeout (i.e. inactivity within the configured period of time).
protected GridClientMessage	GridTcpRestParser.parseClientMessage(GridNioSession ses, GridTcpRestParser.ParserState state) Parses GridClientMessage from raw bytes.

Uses of GridNioSession in org.apache.ignite.internal.processors.rest.protocols.tcp.redis

Methods in org.apache.ignite.internal.processors.rest.protocols.tcp.redis with parameters of type GridNioSession

Modifier and Type	Method and Description
void	GridRedisNioListener.onConnected(GridNioSession ses) This method is called whenever a new client is connected and session is created.
void	GridRedisNioListener.onDisconnected(GridNioSession ses, Exception e) This method is called whenever client is disconnected due to correct connection close or due to IOException during network operations.
void	GridRedisNioListener.onMessage(GridNioSession ses, GridRedisMessage msg) This method is called whenever a GridNioParser returns non-null value.

Uses of GridNioSession in org.apache.ignite.internal.util.nio

Classes in org.apache.ignite.internal.util.nio that implement GridNioSession

Modifier and Type	Class and Description
class	GridNioSessionImpl

Methods in org.apache.ignite.internal.util.nio that return GridNioSession

Modifier and Type	Method and Description
GridNioSession	GridTcpNioCommunicationClient.session()
GridNioSession	SessionWriteRequest.session()

Methods in org.apache.ignite.internal.util.nio that return types with arguments of type GridNioSession

Modifier and Type	Method and Description
GridNioFuture<GridNioSession>	GridNioServer.createSession(SocketChannel ch, Map<Integer,?> meta) Establishes a session.
Collection<? extends GridNioSession>	GridNioServer.sessions()

Methods in org.apache.ignite.internal.util.nio with parameters of type GridNioSession

Modifier and Type	Method and Description
GridNioFuture<Boolean>	GridNioServer.close(GridNioSession ses)
Object	GridDirectParser.decode(GridNioSession ses, ByteBuffer buf) This method is called when input bytes are available on the underlying network connection.
byte[]	GridBufferedParser.decode(GridNioSession ses, ByteBuffer buf) This method is called when input bytes are available on the underlying network connection.
Object	GridNioParser.decode(GridNioSession ses, ByteBuffer buf) This method is called when input bytes are available on the underlying network connection.
byte[]	GridDelimitedParser.decode(GridNioSession ses, ByteBuffer buf) This method is called when input bytes are available on the underlying network connection.
ByteBuffer	GridDirectParser.encode(GridNioSession ses, Object msg) This method is called whenever a message should be sent to the network connection and network buffer is ready to be filled with bytes.
ByteBuffer	GridBufferedParser.encode(GridNioSession ses, Object msg) This method is called whenever a message should be sent to the network connection and network buffer is ready to be filled with bytes.
ByteBuffer	GridNioParser.encode(GridNioSession ses, Object msg) This method is called whenever a message should be sent to the network connection and network buffer is ready to be filled with bytes.
ByteBuffer	GridDelimitedParser.encode(GridNioSession ses, Object msg) This method is called whenever a message should be sent to the network connection and network buffer is ready to be filled with bytes.
void	GridNioServerListener.onConnected(GridNioSession ses) This method is called whenever a new client is connected and session is created.
void	GridNioServerListener.onDisconnected(GridNioSession ses, Exception e) This method is called whenever client is disconnected due to correct connection close or due to IOException during network operations.
void	GridNioFilter.onExceptionCaught(GridNioSession ses, IgniteCheckedException ex) Invoked when exception is caught in filter processing.
void	GridNioCodecFilter.onExceptionCaught(GridNioSession ses, IgniteCheckedException ex) Invoked when exception is caught in filter processing.
void	GridNioFilterChain.onExceptionCaught(GridNioSession ses, IgniteCheckedException e) Starts chain notification from head to tail.
void	GridConnectionBytesVerifyFilter.onExceptionCaught(GridNioSession ses, IgniteCheckedException ex) Invoked when exception is caught in filter processing.
void	GridNioAsyncNotifyFilter.onExceptionCaught(GridNioSession ses, IgniteCheckedException ex) Invoked when exception is caught in filter processing.
void	GridNioServerListener.onMessage(GridNioSession ses, T msg) This method is called whenever a GridNioParser returns non-null value.
void	GridNioFilter.onMessageReceived(GridNioSession ses, Object msg) Invoked when a new messages received.
void	GridNioCodecFilter.onMessageReceived(GridNioSession ses, Object msg) Invoked when a new messages received.
void	GridNioFilterChain.onMessageReceived(GridNioSession ses, Object msg) Starts chain notification from head to tail.
void	GridConnectionBytesVerifyFilter.onMessageReceived(GridNioSession ses, Object msg) Invoked when a new messages received.
void	GridNioAsyncNotifyFilter.onMessageReceived(GridNioSession ses, Object msg) Invoked when a new messages received.
GridNioFuture<?>	GridNioFilter.onPauseReads(GridNioSession ses) Pauses reads for session.
GridNioFuture<?>	GridNioFilterChain.onPauseReads(GridNioSession ses) Starts chain notification from tail to head.
GridNioFuture<?>	GridNioFilterAdapter.onPauseReads(GridNioSession ses) Pauses 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<?>	GridNioFilterAdapter.onResumeReads(GridNioSession ses) Resumes reads for session.
GridNioFuture<Boolean>	GridNioFilter.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>	GridNioFilterChain.onSessionClose(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>	GridNioAsyncNotifyFilter.onSessionClose(GridNioSession ses) Invoked when a session close request is performed on session.
void	GridNioFilter.onSessionClosed(GridNioSession ses) Invoked after session get closed.
void	GridNioCodecFilter.onSessionClosed(GridNioSession ses) Invoked after session get closed.
void	GridNioFilterChain.onSessionClosed(GridNioSession ses) Starts chain notification from head to tail.
void	GridConnectionBytesVerifyFilter.onSessionClosed(GridNioSession ses) Invoked after session get closed.
void	GridNioAsyncNotifyFilter.onSessionClosed(GridNioSession ses) Invoked after session get closed.
void	GridNioFilter.onSessionIdleTimeout(GridNioSession ses) Called when session is idle for longer time that is allowed by NIO server.
void	GridNioServerListener.onSessionIdleTimeout(GridNioSession ses) Called when session did not receive any activity within timeout interval.
void	GridNioCodecFilter.onSessionIdleTimeout(GridNioSession ses) Called when session is idle for longer time that is allowed by NIO server.
void	GridNioFilterChain.onSessionIdleTimeout(GridNioSession ses) Called when session is idle for longer time that is allowed by NIO server.
void	GridNioServerListenerAdapter.onSessionIdleTimeout(GridNioSession ses) Called when session did not receive any activity within timeout interval.
void	GridConnectionBytesVerifyFilter.onSessionIdleTimeout(GridNioSession ses) Called when session is idle for longer time that is allowed by NIO server.
void	GridNioAsyncNotifyFilter.onSessionIdleTimeout(GridNioSession ses) Called when session is idle for longer time that is allowed by NIO server.
void	GridNioFilter.onSessionOpened(GridNioSession ses) Invoked when a new session was created.
void	GridNioCodecFilter.onSessionOpened(GridNioSession ses) Invoked when a new session was created.
void	GridNioFilterChain.onSessionOpened(GridNioSession ses) Starts chain notification from head to tail.
void	GridConnectionBytesVerifyFilter.onSessionOpened(GridNioSession ses) Invoked when a new session was created.
void	GridNioAsyncNotifyFilter.onSessionOpened(GridNioSession ses) Invoked when a new session was created.
GridNioFuture<?>	GridNioFilter.onSessionWrite(GridNioSession ses, Object msg, boolean fut, IgniteInClosure<IgniteException> ackC) Invoked when a write request is performed on a session.
GridNioFuture<?>	GridNioCodecFilter.onSessionWrite(GridNioSession ses, Object msg, boolean fut, IgniteInClosure<IgniteException> ackC) Invoked when a write request is performed on a session.
GridNioFuture<?>	GridNioFilterChain.onSessionWrite(GridNioSession ses, Object msg, boolean fut, IgniteInClosure<IgniteException> ackC) Starts chain notification from tail to head.
GridNioFuture<?>	GridConnectionBytesVerifyFilter.onSessionWrite(GridNioSession ses, Object msg, boolean fut, IgniteInClosure<IgniteException> ackC) Invoked when a write request is performed on a session.
GridNioFuture<?>	GridNioAsyncNotifyFilter.onSessionWrite(GridNioSession ses, Object msg, boolean fut, IgniteInClosure<IgniteException> ackC) Invoked when a write request is performed on a session.
void	GridNioFilter.onSessionWriteTimeout(GridNioSession ses) Called when session has not empty write buffer that has not been fully flushed during max timeout allowed by NIO server.
void	GridNioServerListener.onSessionWriteTimeout(GridNioSession ses) Called when session has non-empty write queue and server did not send any data within timeout interval.
void	GridNioCodecFilter.onSessionWriteTimeout(GridNioSession ses) Called when session has not empty write buffer that has not been fully flushed during max timeout allowed by NIO server.
void	GridNioFilterChain.onSessionWriteTimeout(GridNioSession ses) Called when session has not empty write buffer that has not been fully flushed during max timeout allowed by NIO server.
void	GridNioServerListenerAdapter.onSessionWriteTimeout(GridNioSession ses) Called when session has non-empty write queue and server did not send any data within timeout interval.
void	GridConnectionBytesVerifyFilter.onSessionWriteTimeout(GridNioSession ses) Called when session has not empty write buffer that has not been fully flushed during max timeout allowed by NIO server.
void	GridNioAsyncNotifyFilter.onSessionWriteTimeout(GridNioSession ses) Called when session has not empty write buffer that has not been fully flushed during max timeout allowed by NIO server.
void	GridNioFilter.proceedExceptionCaught(GridNioSession ses, IgniteCheckedException e) Forwards GridNioException event to the next logical filter in filter chain.
void	GridNioFilterAdapter.proceedExceptionCaught(GridNioSession ses, IgniteCheckedException e) Forwards GridNioException event to the next logical filter in filter chain.
void	GridNioFilter.proceedMessageReceived(GridNioSession ses, Object msg) Forwards received message to the next logical filter in filter chain.
void	GridNioFilterAdapter.proceedMessageReceived(GridNioSession ses, Object msg) Forwards received message to the next logical filter in filter chain.
GridNioFuture<?>	GridNioFilter.proceedPauseReads(GridNioSession ses) Pauses reads for session.
GridNioFuture<?>	GridNioFilterAdapter.proceedPauseReads(GridNioSession ses) Pauses reads for session.
GridNioFuture<?>	GridNioFilter.proceedResumeReads(GridNioSession ses) Resumes reads for session.
GridNioFuture<?>	GridNioFilterAdapter.proceedResumeReads(GridNioSession ses) Resumes reads for session.
GridNioFuture<Boolean>	GridNioFilter.proceedSessionClose(GridNioSession ses) Forwards session close request to the next logical filter in filter chain.
GridNioFuture<Boolean>	GridNioFilterAdapter.proceedSessionClose(GridNioSession ses) Forwards session close request to the next logical filter in filter chain.
void	GridNioFilter.proceedSessionClosed(GridNioSession ses) Forwards session closed event to the next logical filter in filter chain.
void	GridNioFilterAdapter.proceedSessionClosed(GridNioSession ses) Forwards session closed event to the next logical filter in filter chain.
void	GridNioFilter.proceedSessionIdleTimeout(GridNioSession ses) Forwards session idle notification to the next logical filter in filter chain.
void	GridNioFilterAdapter.proceedSessionIdleTimeout(GridNioSession ses) Forwards session idle notification to the next logical filter in filter chain.
void	GridNioFilter.proceedSessionOpened(GridNioSession ses) Forwards session opened event to the next logical filter in filter chain.
void	GridNioFilterAdapter.proceedSessionOpened(GridNioSession ses) Forwards session opened event to the next logical filter in filter chain.
GridNioFuture<?>	GridNioFilter.proceedSessionWrite(GridNioSession ses, Object msg, boolean fut, IgniteInClosure<IgniteException> ackC) Forwards write request to the next logical filter in filter chain.
GridNioFuture<?>	GridNioFilterAdapter.proceedSessionWrite(GridNioSession ses, Object msg, boolean fut, IgniteInClosure<IgniteException> ackC) Forwards write request to the next logical filter in filter chain.
void	GridNioFilter.proceedSessionWriteTimeout(GridNioSession ses) Forwards session write timeout notification to the next logical filter in filter chain.
void	GridNioFilterAdapter.proceedSessionWriteTimeout(GridNioSession ses) Forwards session write timeout notification to the next logical filter in filter chain.
MessageReader	GridNioMessageReaderFactory.reader(GridNioSession ses, MessageFactory msgFactory) Creates new reader.
void	GridNioServer.resend(GridNioSession ses)
void	SessionWriteRequest.resetSession(GridNioSession ses)
void	GridNioServer.sendSystem(GridNioSession ses, Message msg) Adds message at the front of the queue without acquiring back pressure semaphore.
void	GridNioServer.sendSystem(GridNioSession ses, Message msg, IgniteInClosure<? super IgniteInternalFuture<?>> lsnr) Adds message at the front of the queue without acquiring back pressure semaphore.
MessageWriter	GridNioMessageWriterFactory.writer(GridNioSession ses) Creates new writer.

Method parameters in org.apache.ignite.internal.util.nio with type arguments of type GridNioSession

Modifier and Type	Method and Description
IgniteInternalFuture<String>	GridNioServer.dumpNodeStats(String msg, IgnitePredicate<GridNioSession> p)
IgniteInternalFuture<String>	GridNioServer.dumpStats(String msg, IgnitePredicate<GridNioSession> p)
GridNioServer.Builder<T>	GridNioServer.Builder.messageQueueSizeListener(IgniteBiInClosure<GridNioSession,Integer> msgQueueLsnr)

Constructors in org.apache.ignite.internal.util.nio with parameters of type GridNioSession

Constructor and Description
GridNioMessageTracker(GridNioSession ses, int msgQueueLimit)
GridTcpNioCommunicationClient(int connIdx, GridNioSession ses, IgniteLogger log)

Uses of GridNioSession in org.apache.ignite.internal.util.nio.ssl

Methods in org.apache.ignite.internal.util.nio.ssl with parameters of type GridNioSession

Modifier and Type	Method and Description
ByteBuffer	GridNioSslFilter.encrypt(GridNioSession ses, ByteBuffer input)
boolean	GridNioSslFilter.lock(GridNioSession ses)
void	GridNioSslFilter.onExceptionCaught(GridNioSession ses, IgniteCheckedException ex) Invoked when exception is caught in filter processing.
void	GridNioSslFilter.onMessageReceived(GridNioSession ses, Object msg) Invoked when a new messages received.
GridNioFuture<Boolean>	GridNioSslFilter.onSessionClose(GridNioSession ses) Invoked when a session close request is performed on session.
void	GridNioSslFilter.onSessionClosed(GridNioSession ses) Invoked after session get closed.
void	GridNioSslFilter.onSessionIdleTimeout(GridNioSession ses) Called when session is idle for longer time that is allowed by NIO server.
void	GridNioSslFilter.onSessionOpened(GridNioSession ses) Invoked when a new session was created.
GridNioFuture<?>	GridNioSslFilter.onSessionWrite(GridNioSession ses, Object msg, boolean fut, IgniteInClosure<IgniteException> ackC) Invoked when a write request is performed on a session.
void	GridNioSslFilter.onSessionWriteTimeout(GridNioSession ses) Called when session has not empty write buffer that has not been fully flushed during max timeout allowed by NIO server.
void	GridNioSslFilter.unlock(GridNioSession ses)