com.hazelcast.nio

Class DefaultSocketChannelWrapper

java.lang.Object

com.hazelcast.nio.DefaultSocketChannelWrapper

All Implemented Interfaces:

SocketChannelWrapper, Closeable, AutoCloseable

Direct Known Subclasses:

SSLSocketChannelWrapper

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()
SelectableChannel	configureBlocking(boolean b)
boolean	connect(SocketAddress socketAddress)
boolean	finishConnect()
boolean	isBlocking()
boolean	isConnected()
boolean	isConnectionPending()
boolean	isOpen()
SelectionKey	keyFor(Selector selector)
int	read(ByteBuffer byteBuffer)
SelectionKey	register(Selector selector, int ops, Object attachment)
Socket	socket()
String	toString()
int	validOps()
int	write(ByteBuffer byteBuffer)

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

validOps

public int validOps()

Specified by:

validOps in interface SocketChannelWrapper

socket

public Socket socket()

Specified by:

socket in interface SocketChannelWrapper

isConnected

public boolean isConnected()

Specified by:

isConnected in interface SocketChannelWrapper

isConnectionPending

public boolean isConnectionPending()

Specified by:

isConnectionPending in interface SocketChannelWrapper

connect

public boolean connect(SocketAddress socketAddress)
                throws IOException

Specified by:

connect in interface SocketChannelWrapper

Throws:

IOException

finishConnect

public boolean finishConnect()
                      throws IOException

Specified by:

finishConnect in interface SocketChannelWrapper

Throws:

IOException

read

public int read(ByteBuffer byteBuffer)
         throws IOException

Specified by:

read in interface SocketChannelWrapper

Throws:

IOException

write

public int write(ByteBuffer byteBuffer)
          throws IOException

Specified by:

write in interface SocketChannelWrapper

Throws:

IOException

configureBlocking

public SelectableChannel configureBlocking(boolean b)
                                    throws IOException

Specified by:

configureBlocking in interface SocketChannelWrapper

Throws:

IOException

isOpen

public boolean isOpen()

Specified by:

isOpen in interface SocketChannelWrapper

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

keyFor

public SelectionKey keyFor(Selector selector)

Specified by:

keyFor in interface SocketChannelWrapper

register

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

Specified by:

register in interface SocketChannelWrapper

Throws:

ClosedChannelException

toString

public String toString()

Overrides:

toString in class Object