Deprecated
use NIO / EPOLL / KQUEUE transport.
ServerSocketChannel which accepts new connections and create the OioSocketChannel's for them.
This implementation use Old-Blocking-IO.
| Modifier and Type | Field and Description |
|---|---|
| private final OioServerSocketChannelConfig | config
Deprecated
as a consequence of
OioServerSocketChannelConfig being deprecated.
|
| private static final InternalLogger | |
| private static final ChannelMetadata | |
| pack-priv final ServerSocket |
| Access | Constructor and Description |
|---|---|
| public | |
| public | OioServerSocketChannel(ServerSocket
the socket)ServerSocket which is used by this instanceCreate a new instance from the given |
| Modifier and Type | Method and Description |
|---|---|
| pack-priv final void | |
| public OioServerSocketChannelConfig | config()
Implements io.
Deprecated
as a consequence of
Returns the configuration of this channel.
OioServerSocketChannelConfig being deprecated.
|
| protected void | doBind(SocketAddress localAddress)
Implements abstract io. Channel to the SocketAddress
|
| protected void | |
| protected void | doConnect(SocketAddress remoteAddress, SocketAddress localAddress)
Implements abstract io. null otherwise.
|
| protected void | doDisconnect()
Implements abstract io. Channel from its remote peer
|
| protected int | doReadMessages(List<Object> buf)
Implements abstract io. |
| protected void | doWrite(ChannelOutboundBuffer in)
Implements abstract io. |
| protected Object | filterOutboundMessage(Object msg)
Overrides io. ChannelOutboundBuffer of this AbstractChannel, so that
the Channel implementation converts the message to another.
|
| public boolean | isActive()
Implements io. true if the Channel is active and so connected.
|
| public boolean | isOpen()
Implements io. true if the Channel is open and may get active later
|
| public InetSocketAddress | localAddress()
Overrides io. Implements io. |
| protected SocketAddress | localAddress0()
Implements abstract io. SocketAddress which is bound locally.
|
| public ChannelMetadata | metadata()
Implements io. ChannelMetadata of the Channel which describe the nature of the Channel.
|
| private static ServerSocket | |
| public InetSocketAddress | remoteAddress()
Overrides io. Implements io. |
| protected SocketAddress | remoteAddress0()
Implements abstract io. SocketAddress which the Channel is connected to.
|
| protected void | setReadPending(boolean readPending)
Overrides io.
Deprecated
|
| config | back to summary |
|---|---|
| private final OioServerSocketChannelConfig config
Deprecated as a consequence of | |
| logger | back to summary |
|---|---|
| private static final InternalLogger logger | |
| METADATA | back to summary |
|---|---|
| private static final ChannelMetadata METADATA | |
| socket | back to summary |
|---|---|
| pack-priv final ServerSocket socket | |
| OioServerSocketChannel | back to summary |
|---|---|
| public OioServerSocketChannel() Create a new instance with an new | |
| OioServerSocketChannel | back to summary |
|---|---|
| public OioServerSocketChannel(ServerSocket socket) Create a new instance from the given
| |
| clearReadPending0 | back to summary |
|---|---|
| pack-priv final void clearReadPending0() | |
| config | back to summary |
|---|---|
| public OioServerSocketChannelConfig config() Implements io. Doc from io. Deprecated as a consequence of Returns the configuration of this channel.
| |
| doBind | back to summary |
|---|---|
| protected void doBind(SocketAddress localAddress) throws Exception Implements abstract io. Doc from io. Bind the
| |
| doClose | back to summary |
|---|---|
| protected void doClose() throws Exception Implements abstract io. Doc from io. Close the
| |
| doConnect | back to summary |
|---|---|
| protected void doConnect(SocketAddress remoteAddress, SocketAddress localAddress) throws Exception Implements abstract io. Doc from io. Connect to the remote peer using the given localAddress if one is specified or
| |
| doDisconnect | back to summary |
|---|---|
| protected void doDisconnect() throws Exception Implements abstract io. Doc from io. Disconnect this
| |
| doReadMessages | back to summary |
|---|---|
| protected int doReadMessages(List<Object> buf) throws Exception Implements abstract io. Doc from io. Read messages into the given array and return the amount which was read.
| |
| doWrite | back to summary |
|---|---|
| protected void doWrite(ChannelOutboundBuffer in) throws Exception Implements abstract io. Doc from io. Flush the content of the given buffer to the remote peer.
| |
| filterOutboundMessage | back to summary |
|---|---|
| protected Object filterOutboundMessage(Object msg) throws Exception Overrides io. Doc from io. Invoked when a new message is added to a
| |
| isActive | back to summary |
|---|---|
| public boolean isActive() Implements io. Doc from io. Return
| |
| isOpen | back to summary |
|---|---|
| public boolean isOpen() Implements io. Doc from io. Returns
| |
| localAddress | back to summary |
|---|---|
| public InetSocketAddress localAddress() Overrides io. Implements io. Doc from io. Returns the local address where this channel is bound to. The returned
| |
| localAddress0 | back to summary |
|---|---|
| protected SocketAddress localAddress0() Implements abstract io. Doc from io. Returns the
| |
| metadata | back to summary |
|---|---|
| public ChannelMetadata metadata() Implements io. Doc from io. Return the
| |
| newServerSocket | back to summary |
|---|---|
| private static ServerSocket newServerSocket() | |
| remoteAddress | back to summary |
|---|---|
| public InetSocketAddress remoteAddress() Overrides io. Implements io. Doc from io. Returns the remote address where this channel is connected to. The
returned
| |
| remoteAddress0 | back to summary |
|---|---|
| protected SocketAddress remoteAddress0() Implements abstract io. Doc from io. Return the
| |
| setReadPending | back to summary |
|---|---|
| protected void setReadPending(boolean readPending) Overrides io. Deprecated
| |