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 | Description |
---|---|---|
protected IoProcessor<NioSession> |
NioSession.processor |
The NioSession processor
|
Modifier and Type | Method | Description |
---|---|---|
protected NioSession |
NioSocketAcceptor.accept(IoProcessor<NioSession> processor,
ServerSocketChannel handle) |
Accept a client connection for a server socket and return a new
IoSession
associated with the given IoProcessor |
protected NioSession |
NioDatagramAcceptor.newSession(IoProcessor<NioSession> processor,
DatagramChannel handle,
SocketAddress remoteAddress) |
|
protected NioSession |
NioDatagramConnector.newSession(IoProcessor<NioSession> processor,
DatagramChannel handle) |
|
protected NioSession |
NioSocketConnector.newSession(IoProcessor<NioSession> processor,
SocketChannel handle) |
Create a new
IoSession from a connected socket client handle. |
Modifier and Type | Method | Description |
---|---|---|
protected Iterator<NioSession> |
NioProcessor.allSessions() |
|
IoProcessor<NioSession> |
NioSession.getProcessor() |
|
protected Iterator<NioSession> |
NioProcessor.selectedSessions() |
Modifier and Type | Method | Description |
---|---|---|
void |
NioDatagramAcceptor.add(NioSession session) |
Adds the specified
session to the I/O processor so that
the I/O processor starts to perform any I/O operations related
with the session . |
protected void |
NioProcessor.destroy(NioSession session) |
|
void |
NioDatagramAcceptor.flush(NioSession session) |
Flushes the internal write request queue of the specified
session . |
protected SessionState |
NioProcessor.getState(NioSession session) |
Get the state of a session (One of OPENING, OPEN, CLOSING)
|
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) |
|
void |
NioDatagramAcceptor.remove(NioSession session) |
Removes and closes the specified
session from the I/O
processor so that the I/O processor closes the connection
associated with the session and releases any other related
resources. |
protected int |
NioDatagramAcceptor.send(NioSession session,
IoBuffer buffer,
SocketAddress remoteAddress) |
|
protected void |
NioProcessor.setInterestedInRead(NioSession session,
boolean isInterested) |
Set the session to be informed when a read event should be processed
|
protected void |
NioDatagramAcceptor.setInterestedInWrite(NioSession session,
boolean isInterested) |
|
protected void |
NioProcessor.setInterestedInWrite(NioSession session,
boolean isInterested) |
Set the session to be informed when a write event should be processed
|
protected int |
NioProcessor.transferFile(NioSession session,
FileRegion region,
int length) |
|
void |
NioDatagramAcceptor.updateTrafficControl(NioSession session) |
Controls the traffic of the specified
session depending of the
IoSession.isReadSuspended() and IoSession.isWriteSuspended()
flags |
void |
NioDatagramAcceptor.write(NioSession session,
WriteRequest writeRequest) |
Writes the WriteRequest for the specified
session . |
protected int |
NioProcessor.write(NioSession session,
IoBuffer buf,
int length) |
Modifier and Type | Method | Description |
---|---|---|
protected NioSession |
NioSocketAcceptor.accept(IoProcessor<NioSession> processor,
ServerSocketChannel handle) |
Accept a client connection for a server socket and return a new
IoSession
associated with the given IoProcessor |
protected NioSession |
NioDatagramAcceptor.newSession(IoProcessor<NioSession> processor,
DatagramChannel handle,
SocketAddress remoteAddress) |
|
protected NioSession |
NioDatagramConnector.newSession(IoProcessor<NioSession> processor,
DatagramChannel handle) |
|
protected NioSession |
NioSocketConnector.newSession(IoProcessor<NioSession> processor,
SocketChannel handle) |
Create a new
IoSession from a connected socket client handle. |
Constructor | Description |
---|---|
NioDatagramConnector(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(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,
Channel channel) |
Creates a new instance of NioSession, with its associated IoProcessor.
|
NioSocketAcceptor(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(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(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(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–2018 Apache MINA Project. All rights reserved.