Skip navigation links

com.tangosol.net
Class WrapperSocketChannel

java.lang.Object
java.nio.channels.spi.AbstractInterruptibleChannel
java.nio.channels.SelectableChannel
java.nio.channels.spi.AbstractSelectableChannel
java.nio.channels.SocketChannel
com.tangosol.net.WrapperSocketChannel

All Implemented Interfaces:

WrapperSelector.WrapperSelectableChannel, java.io.Closeable, java.nio.channels.ByteChannel, java.nio.channels.Channel, java.nio.channels.GatheringByteChannel, java.nio.channels.InterruptibleChannel, java.nio.channels.ReadableByteChannel, java.nio.channels.ScatteringByteChannel, java.nio.channels.WritableByteChannel

public class WrapperSocketChannel

extends java.nio.channels.SocketChannel

implements WrapperSelector.WrapperSelectableChannel

Wrapper SocketChannel implementation that delegates all operations to a delegate SocketChannel.

Author:

mf 2010.05.19

Field Summary

protected java.nio.channels.SocketChannel	m_delegate The delegate SocketChannel.
protected java.net.Socket	m_socket The associated WrapperSocket.

Constructor Summary

WrapperSocketChannel(java.nio.channels.SocketChannel channel, java.nio.channels.spi.SelectorProvider provider)

Method Summary

boolean	connect(java.net.SocketAddress remote)
boolean	finishConnect()
protected void	implCloseSelectableChannel()
protected void	implConfigureBlocking(boolean block)
boolean	isConnected()
boolean	isConnectionPending()
static java.nio.channels.SocketChannel	open() Unsupported.
int	read(java.nio.ByteBuffer dst)
long	read(java.nio.ByteBuffer[] dsts, int offset, int length)
WrapperSelector.WrapperSelectionKey	registerInternal(WrapperSelector selector, int ops, java.lang.Object att) Register with the specified selector.
java.net.Socket	socket()
protected java.net.Socket	wrapSocket(java.net.Socket socket) Produce a wrapper around the specified socket.
int	write(java.nio.ByteBuffer src)
long	write(java.nio.ByteBuffer[] srcs, int offset, int length)

Methods inherited from class java.nio.channels.SocketChannel

open, read, validOps, write

Methods inherited from class java.nio.channels.spi.AbstractSelectableChannel

blockingLock, configureBlocking, implCloseChannel, isBlocking, isRegistered, keyFor, provider, register

Methods inherited from class java.nio.channels.SelectableChannel

register

Methods inherited from class java.nio.channels.spi.AbstractInterruptibleChannel

begin, close, end, isOpen

Methods inherited from interface java.nio.channels.Channel

close, isOpen

Field Detail

m_delegate

protected java.nio.channels.SocketChannel m_delegate

The delegate SocketChannel.

m_socket

protected java.net.Socket m_socket

The associated WrapperSocket.

Constructor Detail

WrapperSocketChannel

public WrapperSocketChannel(java.nio.channels.SocketChannel channel,
                            java.nio.channels.spi.SelectorProvider provider)

Method Detail

wrapSocket

protected java.net.Socket wrapSocket(java.net.Socket socket)

Produce a wrapper around the specified socket.

Parameters:

socket - the socket to wrap

Returns:

the wrapper socket

open

public static java.nio.channels.SocketChannel open()

Unsupported.

Returns:

never

Throws:

java.lang.UnsupportedOperationException

socket

public java.net.Socket socket()

Specified by:

socket in class java.nio.channels.SocketChannel

isConnected

public boolean isConnected()

Specified by:

isConnected in class java.nio.channels.SocketChannel

isConnectionPending

public boolean isConnectionPending()

Specified by:

isConnectionPending in class java.nio.channels.SocketChannel

connect

public boolean connect(java.net.SocketAddress remote)
                throws java.io.IOException

Specified by:

connect in class java.nio.channels.SocketChannel

Throws:

java.io.IOException

finishConnect

public boolean finishConnect()
                      throws java.io.IOException

Specified by:

finishConnect in class java.nio.channels.SocketChannel

Throws:

java.io.IOException

read

public int read(java.nio.ByteBuffer dst)
         throws java.io.IOException

Specified by:

read in interface java.nio.channels.ReadableByteChannel

Specified by:

read in class java.nio.channels.SocketChannel

Throws:

java.io.IOException

read

public long read(java.nio.ByteBuffer[] dsts,
                 int offset,
                 int length)
          throws java.io.IOException

Specified by:

read in interface java.nio.channels.ScatteringByteChannel

Specified by:

read in class java.nio.channels.SocketChannel

Throws:

java.io.IOException

write

public int write(java.nio.ByteBuffer src)
          throws java.io.IOException

Specified by:

write in interface java.nio.channels.WritableByteChannel

Specified by:

write in class java.nio.channels.SocketChannel

Throws:

java.io.IOException

write

public long write(java.nio.ByteBuffer[] srcs,
                  int offset,
                  int length)
           throws java.io.IOException

Specified by:

write in interface java.nio.channels.GatheringByteChannel

Specified by:

write in class java.nio.channels.SocketChannel

Throws:

java.io.IOException

implCloseSelectableChannel

protected void implCloseSelectableChannel()
                                   throws java.io.IOException

Specified by:

implCloseSelectableChannel in class java.nio.channels.spi.AbstractSelectableChannel

Throws:

java.io.IOException

implConfigureBlocking

protected void implConfigureBlocking(boolean block)
                              throws java.io.IOException

Specified by:

implConfigureBlocking in class java.nio.channels.spi.AbstractSelectableChannel

Throws:

java.io.IOException

registerInternal

public WrapperSelector.WrapperSelectionKey registerInternal(WrapperSelector selector,
                                                            int ops,
                                                            java.lang.Object att)
                                                     throws java.io.IOException

Register with the specified selector.

Specified by:

registerInternal in interface WrapperSelector.WrapperSelectableChannel

Parameters:

selector - the selector to register with

ops - the operations of interest

att - the attachment

Returns:

the wrapper selection key

Throws:

java.io.IOException - if an I/O error occurs

Skip navigation links