org.mpisws.p2p.transport.util
Class BufferReader<Identifier>

java.lang.Object
  org.mpisws.p2p.transport.util.BufferReader<Identifier>

Type Parameters:

Identifier -

All Implemented Interfaces:

P2PSocketReceiver<Identifier>

public class BufferReader<Identifier>
extends java.lang.Object
implements P2PSocketReceiver<Identifier>

Reads a ByteBuffer to the socket then calls receiveResult().

Author:

Jeff Hoye

Constructor Summary

BufferReader(P2PSocket<Identifier> socket, Continuation<java.nio.ByteBuffer,java.lang.Exception> continuation)
Constructor for variable/unknown sized BB, it reads the size off the stream

BufferReader(P2PSocket<Identifier> socket, Continuation<java.nio.ByteBuffer,java.lang.Exception> continuation, int size)
Constructor for fixed size BB

Method Summary

void	receiveException(P2PSocket<Identifier> socket, java.lang.Exception ioe) Called when there is an error
void	receiveSelectResult(P2PSocket<Identifier> socket, 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

BufferReader

public BufferReader(P2PSocket<Identifier> socket,
                    Continuation<java.nio.ByteBuffer,java.lang.Exception> continuation)

Constructor for variable/unknown sized BB, it reads the size off the stream

Parameters:

socket -

continuation -

BufferReader

public BufferReader(P2PSocket<Identifier> socket,
                    Continuation<java.nio.ByteBuffer,java.lang.Exception> continuation,
                    int size)

Constructor for fixed size BB

Parameters:

socket -

continuation -

size - the fixed size buffer to read

Method Detail

receiveException

public void receiveException(P2PSocket<Identifier> socket,
                             java.lang.Exception ioe)

Description copied from interface: P2PSocketReceiver

Called when there is an error

Specified by:

receiveException in interface P2PSocketReceiver<Identifier>

receiveSelectResult

public void receiveSelectResult(P2PSocket<Identifier> 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<Identifier>

Throws:

java.io.IOException