rice.pastry.transport
Class SocketAdapter

java.lang.Object
  rice.pastry.transport.SocketAdapter

All Implemented Interfaces:

AppSocket

public class SocketAdapter
extends java.lang.Object
implements AppSocket

Constructor Summary

SocketAdapter(P2PSocket<NodeHandle> socket, Environment env)

Method Summary

void	close() Closes this socket.
long	read(java.nio.ByteBuffer[] dsts, int offset, int length) Reads a sequence of bytes from this channel into a subsequence of the given buffers.
void	register(boolean wantToRead, boolean wantToWrite, int timeout, AppSocketReceiver receiver) Must be called every time a Read/Write occurs to continue operation.
void	shutdownOutput() Disables the output stream for this socket.
long	write(java.nio.ByteBuffer[] srcs, int offset, int length) Writes a sequence of bytes to this channel from a subsequence of the given buffers.

Methods inherited from class java.lang.Object

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

Constructor Detail

SocketAdapter

public SocketAdapter(P2PSocket<NodeHandle> socket,
                     Environment env)

Method Detail

close

public void close()

Description copied from interface: AppSocket

Closes this socket.

Specified by:

close in interface AppSocket

read

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

Description copied from interface: AppSocket

Reads a sequence of bytes from this channel into a subsequence of the given buffers.

Specified by:

read in interface AppSocket

Throws:

java.io.IOException

register

public void register(boolean wantToRead,
                     boolean wantToWrite,
                     int timeout,
                     AppSocketReceiver receiver)

Description copied from interface: AppSocket

Must be called every time a Read/Write occurs to continue operation.

Specified by:

register in interface AppSocket

Parameters:

wantToRead - if you want to read from this socket

wantToWrite - if you want to write to this socket

timeout - // the socket's timeout value (this is a TCP level param)

receiver - will have receiveSelectResult() called on it note that you must call select() each time receiveSelectResult() is called. This is so your application can properly handle flow control

shutdownOutput

public void shutdownOutput()

Description copied from interface: AppSocket

Disables the output stream for this socket. Used to properly close down a socket used for bi-directional communication that can be initated by either side.

Specified by:

shutdownOutput in interface AppSocket

write

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

Description copied from interface: AppSocket

Writes a sequence of bytes to this channel from a subsequence of the given buffers.

Specified by:

write in interface AppSocket

Throws:

java.io.IOException