org.mpisws.p2p.transport.wire.magicnumber
Class MagicNumberTransportLayer.VerifyHeaderReceiver

java.lang.Object
  rice.selector.TimerTask
      org.mpisws.p2p.transport.wire.magicnumber.MagicNumberTransportLayer.VerifyHeaderReceiver

All Implemented Interfaces:

java.lang.Comparable, P2PSocketReceiver<Identity>, Cancellable, CancellableTask

Enclosing class:

MagicNumberTransportLayer<Identity>

protected class MagicNumberTransportLayer.VerifyHeaderReceiver
extends TimerTask
implements P2PSocketReceiver<Identity>

Field Summary

Fields inherited from class rice.selector.TimerTask

cancelled, fixedRate, period, selector, seq

Constructor Summary

MagicNumberTransportLayer.VerifyHeaderReceiver(P2PSocket<Identity> s)

Method Summary

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

Methods inherited from class rice.selector.TimerTask

cancel, compareTo, execute, isCancelled, scheduledExecutionTime, setNextExecutionTime, setSelectorManager

Methods inherited from class java.lang.Object

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

Constructor Detail

MagicNumberTransportLayer.VerifyHeaderReceiver

public MagicNumberTransportLayer.VerifyHeaderReceiver(P2PSocket<Identity> s)

Method Detail

receiveException

public void receiveException(P2PSocket<Identity> socket,
                             java.io.IOException ioe)

Description copied from interface: P2PSocketReceiver

Called when there is an error

Specified by:

receiveException in interface P2PSocketReceiver<Identity>

receiveSelectResult

public void receiveSelectResult(P2PSocket<Identity> socket,
                                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<Identity>

Throws:

java.io.IOException

run

public void run()

Specified by:

run in interface CancellableTask

Specified by:

run in class TimerTask