Package | Description |
---|---|
org.shared.net.nio |
A package for managed connections built on top of
java.nio . |
Modifier and Type | Method and Description |
---|---|
NioConnection |
NioConnection.get()
Waits until this connection has been initialized.
|
NioConnection |
NioConnection.get(long timeout,
TimeUnit unit)
Waits until this connection has been initialized.
|
Modifier and Type | Method and Description |
---|---|
List<NioConnection> |
NioManager.getConnections() |
protected Set<NioConnection> |
NioManagerDispatchThread.AcceptRegistry.Entry.getPending()
Gets the pending accepts.
|
<T> Future<NioConnection> |
NioManager.init(ConnectionManager.InitializationType type,
ConnectionHandler<? super NioConnection> handler,
T argument) |
Modifier and Type | Method and Description |
---|---|
protected void |
NioManagerDispatchThread.dispatch(NioConnection conn)
Dispatches the given connection to an
NioManagerIoThread . |
protected void |
NioManagerDispatchThread.doConnect(NioConnection conn)
Finishes the connect cycle on a ready connection.
|
protected void |
NioManagerDispatchThread.handleAccept(NioConnection conn,
InetSocketAddress address)
Handles a connection accept request.
|
protected void |
NioManagerThread.handleClose(NioConnection conn)
Handles a connection closure notification.
|
protected void |
NioManagerThread.handleClosingEos(NioConnection conn)
Handles a connection end-of-stream notification.
|
protected void |
NioManagerThread.handleClosingUser(NioConnection conn)
Handles a connection close request.
|
protected void |
NioManagerDispatchThread.handleConnect(NioConnection conn,
InetSocketAddress address)
Handles a connection connect request.
|
protected void |
NioManagerIoThread.handleDispatch(NioConnection conn)
Handles a connection dispatch notification.
|
protected void |
NioManagerThread.handleError(NioConnection conn,
Throwable exception)
Handles a connection error notification.
|
protected void |
NioManagerThread.handleOp(NioConnection conn,
int mask,
boolean enabled)
Handles a connection operation interest change request.
|
protected void |
NioManagerDispatchThread.handleRegister(NioConnection conn,
SocketChannel chan)
Handles a connection registration request.
|
protected abstract void |
NioManagerThread.purge(NioConnection conn)
A sequence of actions to take when deleting a connection, as far as this thread is concerned.
|
protected void |
NioManagerDispatchThread.purge(NioConnection conn) |
protected void |
NioManagerIoThread.purge(NioConnection conn) |
protected NioManagerDispatchThread.AcceptRegistry.Entry |
NioManagerDispatchThread.AcceptRegistry.register(NioConnection conn,
InetSocketAddress address)
Registers a connection.
|
protected void |
NioManagerDispatchThread.AcceptRegistry.removePending(NioConnection conn)
Removes a pending accept.
|
protected <I,O> Future<O> |
NioManagerThread.request(NioEvent.NioEventType type,
I argument,
NioConnection conn)
Retrieves this thread's internal state.
|
Modifier and Type | Method and Description |
---|---|
protected void |
NioManagerDispatchThread.handleGetConnections(NioManagerThread.Request<?,List<Future<List<NioConnection>>>> request)
Handles a request to get the list of connections, which consists of pending connections aggregated with the lists
reported by helper
NioManagerIoThread s. |
protected void |
NioManagerIoThread.handleGetConnections(NioManagerThread.Request<?,List<NioConnection>> request)
Handles a request to get the list of connections.
|
<T> Future<NioConnection> |
NioManager.init(ConnectionManager.InitializationType type,
ConnectionHandler<? super NioConnection> handler,
T argument) |
Constructor and Description |
---|
NioConnection(ConnectionHandler<? super NioConnection> handler,
int bufferSize,
NioManagerThread thread)
Default constructor.
|