rice.pastry.transport
Class AppSocketReceiverWrapper

java.lang.Object
  rice.pastry.transport.AppSocketReceiverWrapper

All Implemented Interfaces:

P2PSocketReceiver<NodeHandle>

public class AppSocketReceiverWrapper
extends java.lang.Object
implements P2PSocketReceiver<NodeHandle>

Constructor Summary

AppSocketReceiverWrapper(AppSocketReceiver receiver, SocketAdapter socket, Environment env)

Method Summary

void	receiveException(P2PSocket<NodeHandle> s, java.io.IOException ioe) Called when there is an error
void	receiveSelectResult(P2PSocket<NodeHandle> s, boolean canRead, boolean canWrite) Called when a socket is available for read/write

Methods inherited from class java.lang.Object

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

Constructor Detail

AppSocketReceiverWrapper

public AppSocketReceiverWrapper(AppSocketReceiver receiver,
                                SocketAdapter socket,
                                Environment env)

Method Detail

receiveException

public void receiveException(P2PSocket<NodeHandle> s,
                             java.io.IOException ioe)

Description copied from interface: P2PSocketReceiver

Called when there is an error

Specified by:

receiveException in interface P2PSocketReceiver<NodeHandle>

receiveSelectResult

public void receiveSelectResult(P2PSocket<NodeHandle> s,
                                boolean canRead,
                                boolean canWrite)
                         throws java.io.IOException

Description copied from interface: P2PSocketReceiver

Called when a socket is available for read/write

Specified by:

receiveSelectResult in interface P2PSocketReceiver<NodeHandle>

Throws:

java.io.IOException