com.hazelcast.nio.tcp

Class DefaultSocketChannelWrapper

java.lang.Object

com.hazelcast.nio.tcp.DefaultSocketChannelWrapper

All Implemented Interfaces:

SocketChannelWrapper, Closeable, AutoCloseable

public class DefaultSocketChannelWrapper
extends Object
implements SocketChannelWrapper

Field Summary

Fields

Modifier and Type	Field and Description
protected SocketChannel	socketChannel

Constructor Summary

Constructors

Constructor and Description
DefaultSocketChannelWrapper(SocketChannel socketChannel)

Method Summary

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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

socketChannel

protected final SocketChannel socketChannel

Constructor Detail

DefaultSocketChannelWrapper

public DefaultSocketChannelWrapper(SocketChannel socketChannel)

Method Detail

isBlocking

public boolean isBlocking()

Specified by:

isBlocking in interface SocketChannelWrapper

See Also:

AbstractInterruptibleChannel.isOpen()

socket

public Socket socket()

Specified by:

socket in interface SocketChannelWrapper

See Also:

SocketChannel.socket()

isConnected

public boolean isConnected()

Specified by:

isConnected in interface SocketChannelWrapper

See Also:

()

connect

public boolean connect(SocketAddress socketAddress)
                throws IOException

Specified by:

connect in interface SocketChannelWrapper

Throws:

IOException

See Also:

SocketChannel.connect(java.net.SocketAddress)

read

public int read(ByteBuffer dst)
         throws IOException

Specified by:

read in interface SocketChannelWrapper

Throws:

IOException

See Also:

SocketChannel.read(ByteBuffer)

write

public int write(ByteBuffer src)
          throws IOException

Specified by:

write in interface SocketChannelWrapper

Throws:

IOException

See Also:

SocketChannel.write(ByteBuffer)

configureBlocking

public SelectableChannel configureBlocking(boolean block)
                                    throws IOException

Specified by:

configureBlocking in interface SocketChannelWrapper

Throws:

IOException

See Also:

AbstractSelectableChannel.configureBlocking(boolean)

isOpen

public boolean isOpen()

Specified by:

isOpen in interface SocketChannelWrapper

See Also:

AbstractInterruptibleChannel.isOpen()

closeInbound

public void closeInbound()
                  throws IOException

Description copied from interface: SocketChannelWrapper

Closes inbound.

Not thread safe. Should be called in channel reader thread.

Specified by:

closeInbound in interface SocketChannelWrapper

Throws:

IOException

closeOutbound

public void closeOutbound()
                   throws IOException

Description copied from interface: SocketChannelWrapper

Closes outbound.

Not thread safe. Should be called in channel writer thread.

Specified by:

closeOutbound in interface SocketChannelWrapper

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface SocketChannelWrapper

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException

See Also:

AbstractInterruptibleChannel.close()

keyFor

public SelectionKey keyFor(Selector selector)

Specified by:

keyFor in interface SocketChannelWrapper

See Also:

AbstractSelectableChannel.keyFor(Selector)

register

public SelectionKey register(Selector selector,
                             int ops,
                             Object attachment)
                      throws ClosedChannelException

Specified by:

register in interface SocketChannelWrapper

Throws:

ClosedChannelException

See Also:

AbstractSelectableChannel.register(Selector, int, Object)

toString

public String toString()

Overrides:

toString in class Object