Package | Description |
---|---|
org.apache.mina.transport.socket.nio |
Socket (TCP/IP) and Datagram (UDP/IP) support based on Java
NIO (New I/O) API.
|
Modifier and Type | Field and Description |
---|---|
protected IoProcessor<NioSession> |
NioSession.processor
The NioSession processor
|
Modifier and Type | Method and Description |
---|---|
protected NioSession |
NioSocketAcceptor.accept(IoProcessor<NioSession> processor,
java.nio.channels.ServerSocketChannel handle)
Accept a client connection for a server socket and return a new
IoSession
associated with the given IoProcessor |
protected NioSession |
NioDatagramConnector.newSession(IoProcessor<NioSession> processor,
java.nio.channels.DatagramChannel handle) |
protected NioSession |
NioDatagramAcceptor.newSession(IoProcessor<NioSession> processor,
java.nio.channels.DatagramChannel handle,
java.net.SocketAddress remoteAddress) |
protected NioSession |
NioSocketConnector.newSession(IoProcessor<NioSession> processor,
java.nio.channels.SocketChannel handle)
Create a new
IoSession from a connected socket client handle. |
Modifier and Type | Method and Description |
---|---|
protected java.util.Iterator<NioSession> |
NioProcessor.allSessions() |
IoProcessor<NioSession> |
NioSession.getProcessor() |
protected java.util.Iterator<NioSession> |
NioProcessor.selectedSessions() |
Modifier and Type | Method and Description |
---|---|
protected void |
NioProcessor.destroy(NioSession session) |
protected SessionState |
NioProcessor.getState(NioSession session)
Get the state of a session (preparing, open, closed)
|
protected void |
NioProcessor.init(NioSession session) |
protected boolean |
NioProcessor.isInterestedInRead(NioSession session) |
protected boolean |
NioProcessor.isInterestedInWrite(NioSession session) |
protected boolean |
NioProcessor.isReadable(NioSession session) |
protected boolean |
NioProcessor.isWritable(NioSession session) |
protected int |
NioProcessor.read(NioSession session,
IoBuffer buf) |
protected int |
NioDatagramAcceptor.send(NioSession session,
IoBuffer buffer,
java.net.SocketAddress remoteAddress) |
protected void |
NioProcessor.setInterestedInRead(NioSession session,
boolean isInterested)
register a session for reading
|
protected void |
NioProcessor.setInterestedInWrite(NioSession session,
boolean isInterested)
register a session for writing
|
protected void |
NioDatagramAcceptor.setInterestedInWrite(NioSession session,
boolean isInterested) |
protected int |
NioProcessor.transferFile(NioSession session,
FileRegion region,
int length) |
protected int |
NioProcessor.write(NioSession session,
IoBuffer buf,
int length) |
Modifier and Type | Method and Description |
---|---|
protected NioSession |
NioSocketAcceptor.accept(IoProcessor<NioSession> processor,
java.nio.channels.ServerSocketChannel handle)
Accept a client connection for a server socket and return a new
IoSession
associated with the given IoProcessor |
protected NioSession |
NioDatagramConnector.newSession(IoProcessor<NioSession> processor,
java.nio.channels.DatagramChannel handle) |
protected NioSession |
NioDatagramAcceptor.newSession(IoProcessor<NioSession> processor,
java.nio.channels.DatagramChannel handle,
java.net.SocketAddress remoteAddress) |
protected NioSession |
NioSocketConnector.newSession(IoProcessor<NioSession> processor,
java.nio.channels.SocketChannel handle)
Create a new
IoSession from a connected socket client handle. |
Constructor and Description |
---|
NioDatagramConnector(java.lang.Class<? extends IoProcessor<NioSession>> processorClass)
Constructor for
NioDatagramConnector with default configuration with default configuration which will use a built-in
thread pool executor to manage the default number of processor instances. |
NioDatagramConnector(java.lang.Class<? extends IoProcessor<NioSession>> processorClass,
int processorCount)
Constructor for
NioDatagramConnector with default configuration which will use a built-in
thread pool executor to manage the given number of processor instances. |
NioDatagramConnector(IoProcessor<NioSession> processor)
Creates a new instance.
|
NioSession(IoProcessor<NioSession> processor,
IoService service,
java.nio.channels.Channel channel)
Creates a new instance of NioSession, with its associated IoProcessor.
|
NioSocketAcceptor(java.util.concurrent.Executor executor,
IoProcessor<NioSession> processor)
Constructor for
NioSocketAcceptor with a given Executor for handling
connection events and a given IoProcessor for handling I/O events, useful for
sharing the same processor and executor over multiple IoService of the same type. |
NioSocketAcceptor(IoProcessor<NioSession> processor)
Constructor for
NioSocketAcceptor with default configuration but a
specific IoProcessor , useful for sharing the same processor over multiple
IoService of the same type. |
NioSocketConnector(java.lang.Class<? extends IoProcessor<NioSession>> processorClass)
Constructor for
NioSocketConnector with default configuration with default configuration which will use a built-in
thread pool executor to manage the default number of processor instances. |
NioSocketConnector(java.lang.Class<? extends IoProcessor<NioSession>> processorClass,
int processorCount)
Constructor for
NioSocketConnector with default configuration which will use a built-in
thread pool executor to manage the given number of processor instances. |
NioSocketConnector(java.util.concurrent.Executor executor,
IoProcessor<NioSession> processor)
Constructor for
NioSocketConnector with a given Executor for handling
connection events and a given IoProcessor for handling I/O events, useful for sharing
the same processor and executor over multiple IoService of the same type. |
NioSocketConnector(IoProcessor<NioSession> processor)
Constructor for
NioSocketConnector with default configuration but a
specific IoProcessor , useful for sharing the same processor over multiple
IoService of the same type. |
Copyright © 2004-2019 Apache MINA Project. All Rights Reserved.