public class DefaultSocketChannelWrapper extends Object implements SocketChannelWrapper
Modifier and Type | Field and Description |
---|---|
protected SocketChannel |
socketChannel |
Constructor and Description |
---|
DefaultSocketChannelWrapper(SocketChannel socketChannel) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
closeInbound()
Closes inbound.
|
void |
closeOutbound()
Closes outbound.
|
SelectableChannel |
configureBlocking(boolean block) |
boolean |
connect(SocketAddress socketAddress) |
boolean |
isBlocking() |
boolean |
isConnected() |
boolean |
isOpen() |
SelectionKey |
keyFor(Selector selector) |
int |
read(ByteBuffer dst) |
SelectionKey |
register(Selector selector,
int ops,
Object attachment) |
Socket |
socket() |
String |
toString() |
int |
write(ByteBuffer src) |
protected final SocketChannel socketChannel
public DefaultSocketChannelWrapper(SocketChannel socketChannel)
public boolean isBlocking()
isBlocking
in interface SocketChannelWrapper
AbstractInterruptibleChannel.isOpen()
public Socket socket()
socket
in interface SocketChannelWrapper
SocketChannel.socket()
public boolean isConnected()
isConnected
in interface SocketChannelWrapper
()
public boolean connect(SocketAddress socketAddress) throws IOException
connect
in interface SocketChannelWrapper
IOException
SocketChannel.connect(java.net.SocketAddress)
public int read(ByteBuffer dst) throws IOException
read
in interface SocketChannelWrapper
IOException
SocketChannel.read(ByteBuffer)
public int write(ByteBuffer src) throws IOException
write
in interface SocketChannelWrapper
IOException
SocketChannel.write(ByteBuffer)
public SelectableChannel configureBlocking(boolean block) throws IOException
configureBlocking
in interface SocketChannelWrapper
IOException
AbstractSelectableChannel.configureBlocking(boolean)
public boolean isOpen()
isOpen
in interface SocketChannelWrapper
AbstractInterruptibleChannel.isOpen()
public void closeInbound() throws IOException
SocketChannelWrapper
Not thread safe. Should be called in channel reader thread.
closeInbound
in interface SocketChannelWrapper
IOException
public void closeOutbound() throws IOException
SocketChannelWrapper
Not thread safe. Should be called in channel writer thread.
closeOutbound
in interface SocketChannelWrapper
IOException
public void close() throws IOException
close
in interface SocketChannelWrapper
close
in interface Closeable
close
in interface AutoCloseable
IOException
AbstractInterruptibleChannel.close()
public SelectionKey keyFor(Selector selector)
keyFor
in interface SocketChannelWrapper
AbstractSelectableChannel.keyFor(Selector)
public SelectionKey register(Selector selector, int ops, Object attachment) throws ClosedChannelException
register
in interface SocketChannelWrapper
ClosedChannelException
AbstractSelectableChannel.register(Selector, int, Object)
Copyright © 2016 Hazelcast, Inc.. All Rights Reserved.