freenet.io.xfer

Class PartiallyReceivedBlock

java.lang.Object

freenet.io.xfer.PartiallyReceivedBlock

public class PartiallyReceivedBlock
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	PartiallyReceivedBlock.PacketReceivedListener

Field Summary

Fields

Modifier and Type	Field and Description
int	_packets
int	_packetSize

Constructor Summary

Constructors

Constructor and Description
PartiallyReceivedBlock(int packets, int packetSize)
PartiallyReceivedBlock(int packets, int packetSize, byte[] data)

Method Summary

Modifier and Type	Method and Description
byte[]	abort(int reason, java.lang.String description, boolean cancelledLocally) Abort the transfer.
boolean	abortedLocally()
java.util.Deque<java.lang.Integer>	addListener(PartiallyReceivedBlock.PacketReceivedListener listener)
void	addPacket(int position, Buffer packet)
boolean	allReceived()
boolean	allReceivedAndNotAborted()
java.lang.String	getAbortDescription()
int	getAbortReason()
byte[]	getBlock()
int	getNumPackets()
Buffer	getPacket(int x)
int	getPacketSize()
boolean	isAborted()
boolean	isReceived(int packetNo)
void	removeListener(PartiallyReceivedBlock.PacketReceivedListener listener)

Methods inherited from class java.lang.Object

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

Field Detail

_packets

public final int _packets

_packetSize

public final int _packetSize

Constructor Detail

PartiallyReceivedBlock

public PartiallyReceivedBlock(int packets,
                              int packetSize,
                              byte[] data)

PartiallyReceivedBlock

public PartiallyReceivedBlock(int packets,
                              int packetSize)

Method Detail

addListener

public java.util.Deque<java.lang.Integer> addListener(PartiallyReceivedBlock.PacketReceivedListener listener)
                                               throws AbortedException

Throws:

AbortedException

isReceived

public boolean isReceived(int packetNo)
                   throws AbortedException

Throws:

AbortedException

getNumPackets

public int getNumPackets()
                  throws AbortedException

Throws:

AbortedException

getPacketSize

public int getPacketSize()
                  throws AbortedException

Throws:

AbortedException

addPacket

public void addPacket(int position,
                      Buffer packet)
               throws AbortedException

Throws:

AbortedException

allReceivedAndNotAborted

public boolean allReceivedAndNotAborted()

allReceived

public boolean allReceived()
                    throws AbortedException

Throws:

AbortedException

getBlock

public byte[] getBlock()
                throws AbortedException

Throws:

AbortedException

getPacket

public Buffer getPacket(int x)
                 throws AbortedException

Throws:

AbortedException

removeListener

public void removeListener(PartiallyReceivedBlock.PacketReceivedListener listener)

abort

public byte[] abort(int reason,
                    java.lang.String description,
                    boolean cancelledLocally)

Abort the transfer.

Parameters:

reason -

description -

cancelledLocally - If true, the transfer was deliberately aborted by *this node*, not as the result of a timeout.

Returns:

Null if the PRB is aborted now. The data if it is not.

isAborted

public boolean isAborted()

getAbortReason

public int getAbortReason()

getAbortDescription

public java.lang.String getAbortDescription()

abortedLocally

public boolean abortedLocally()