com.hazelcast.nio

Class DefaultSocketChannelWrapper

java.lang.Object

com.hazelcast.nio.DefaultSocketChannelWrapper

All Implemented Interfaces:

SocketChannelWrapper

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

Methods

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)
long	read(ByteBuffer[] byteBuffers)
long	read(ByteBuffer[] byteBuffers, int i, int i1)
SelectionKey	register(Selector selector, int i, Object o)
Socket	socket()
int	validOps()
int	write(ByteBuffer byteBuffer)
long	write(ByteBuffer[] byteBuffers)
long	write(ByteBuffer[] byteBuffers, int i, int i1)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, 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

read

public long read(ByteBuffer[] byteBuffers,
        int i,
        int i1)
          throws IOException

Specified by:

read in interface SocketChannelWrapper

Throws:

IOException

read

public long read(ByteBuffer[] byteBuffers)
          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

write

public long write(ByteBuffer[] byteBuffers,
         int i,
         int i1)
           throws IOException

Specified by:

write in interface SocketChannelWrapper

Throws:

IOException

write

public long write(ByteBuffer[] byteBuffers)
           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

Throws:

IOException

keyFor

public SelectionKey keyFor(Selector selector)

Specified by:

keyFor in interface SocketChannelWrapper

register

public SelectionKey register(Selector selector,
                    int i,
                    Object o)
                      throws ClosedChannelException

Specified by:

register in interface SocketChannelWrapper

Throws:

ClosedChannelException