com.hazelcast.internal.networking

Interface SocketChannelWrapper

All Superinterfaces:

AutoCloseable, Closeable

All Known Implementing Classes:

DefaultSocketChannelWrapper

public interface SocketChannelWrapper
extends Closeable

Wraps a SocketChannel. The reason this class exists is because for enterprise encryption. Ideally the SocketChannel should have been decorated with this encryption functionality, but unfortunately that isn't possible with this class. That is why a new 'wrapper' interface is introduced which acts like a SocketChannel and the implementations wrap a SocketChannel. In the future we should get rid of this class and rely on ReadHandler/WriteHandler chaining to add encryption. This will remove more artifacts from the architecture that can't carry their weight.

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()
int	write(ByteBuffer src)

Method Detail

isBlocking

boolean isBlocking()

See Also:

AbstractInterruptibleChannel.isOpen()

socket

Socket socket()

See Also:

SocketChannel.socket()

isConnected

boolean isConnected()

See Also:

()

connect

boolean connect(SocketAddress socketAddress)
         throws IOException

Throws:

IOException

See Also:

SocketChannel.connect(java.net.SocketAddress)

keyFor

SelectionKey keyFor(Selector selector)

See Also:

AbstractSelectableChannel.keyFor(Selector)

register

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

Throws:

ClosedChannelException

See Also:

AbstractSelectableChannel.register(Selector, int, Object)

read

int read(ByteBuffer dst)
  throws IOException

Throws:

IOException

See Also:

SocketChannel.read(ByteBuffer)

write

int write(ByteBuffer src)
   throws IOException

Throws:

IOException

See Also:

SocketChannel.write(ByteBuffer)

configureBlocking

SelectableChannel configureBlocking(boolean block)
                             throws IOException

Throws:

IOException

See Also:

AbstractSelectableChannel.configureBlocking(boolean)

isOpen

boolean isOpen()

See Also:

AbstractInterruptibleChannel.isOpen()

closeInbound

void closeInbound()
           throws IOException

Closes inbound.

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

Throws:

IOException

closeOutbound

void closeOutbound()
            throws IOException

Closes outbound.

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

Throws:

IOException

close

void close()
    throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException

See Also:

AbstractInterruptibleChannel.close()