freenet.io.xfer

Class BlockTransmitter

java.lang.Object

freenet.io.xfer.BlockTransmitter

public class BlockTransmitter
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	BlockTransmitter.BlockTimeCallback
static interface	BlockTransmitter.BlockTransmitterCompletion
static interface	BlockTransmitter.ReceiverAbortHandler

Field Summary

Fields

Modifier and Type	Field and Description
static BlockTransmitter.ReceiverAbortHandler	ALWAYS_CASCADE
static BlockTransmitter.ReceiverAbortHandler	NEVER_CASCADE
static int	SEND_TIMEOUT

Constructor Summary

Constructors

Constructor and Description
BlockTransmitter(MessageCore usm, Ticker ticker, PeerContext destination, long uid, PartiallyReceivedBlock source, ByteCounter ctr, BlockTransmitter.ReceiverAbortHandler abortHandler, BlockTransmitter.BlockTransmitterCompletion callback, boolean realTime, BlockTransmitter.BlockTimeCallback blockTimes)

Method Summary

Modifier and Type	Method and Description
void	abortSend(int reason, java.lang.String desc) Abort the send, and then send the sendAborted message.
void	callCallback(boolean success)
PeerContext	getDestination()
static int	getRunningSends()
void	innerSendAborted(int reason, java.lang.String desc)
boolean	maybeAllSent() LOCKING: Must be called with _senderThread held.
boolean	maybeComplete() Complete? maybeAllSent() must have already returned true.
freenet.io.xfer.BlockTransmitter.Future	maybeFail(int reason, java.lang.String description) Only fail once.
void	scheduleTimeoutAfterBlockSends()
void	sendAsync() Send the data, off-thread.
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

SEND_TIMEOUT

public static final int SEND_TIMEOUT

See Also:

Constant Field Values

ALWAYS_CASCADE

public static final BlockTransmitter.ReceiverAbortHandler ALWAYS_CASCADE

NEVER_CASCADE

public static final BlockTransmitter.ReceiverAbortHandler NEVER_CASCADE

Constructor Detail

BlockTransmitter

public BlockTransmitter(MessageCore usm,
                        Ticker ticker,
                        PeerContext destination,
                        long uid,
                        PartiallyReceivedBlock source,
                        ByteCounter ctr,
                        BlockTransmitter.ReceiverAbortHandler abortHandler,
                        BlockTransmitter.BlockTransmitterCompletion callback,
                        boolean realTime,
                        BlockTransmitter.BlockTimeCallback blockTimes)

Method Detail

scheduleTimeoutAfterBlockSends

public void scheduleTimeoutAfterBlockSends()

maybeAllSent

public boolean maybeAllSent()

LOCKING: Must be called with _senderThread held.

Returns:

True if everything has been sent and we are now just waiting for an acknowledgement or timeout from the other side.

maybeComplete

public boolean maybeComplete()

Complete? maybeAllSent() must have already returned true. This method checks _sendCompleted and then uses _completed to complete only once. LOCKING: Must be called with _senderThread held. Caller must call the callback then call cleanup() outside the lock if this returns true.

maybeFail

public freenet.io.xfer.BlockTransmitter.Future maybeFail(int reason,
                                                         java.lang.String description)

Only fail once. Called on a drastic failure e.g. disconnection. Unless we are sure that we don't need to (e.g. on disconnection), the caller must call prepareSendAborted afterwards, and if that returns true, send the sendAborted via innerSendAborted. LOCKING: Must be called inside the _senderThread lock.

Returns:

A Future which the caller must execute() outside the lock.

abortSend

public void abortSend(int reason,
                      java.lang.String desc)
               throws NotConnectedException

Abort the send, and then send the sendAborted message. Don't do anything if the send has already been aborted.

Throws:

NotConnectedException

innerSendAborted

public void innerSendAborted(int reason,
                             java.lang.String desc)
                      throws NotConnectedException

Throws:

NotConnectedException

sendAsync

public void sendAsync()

Send the data, off-thread.

callCallback

public void callCallback(boolean success)

getDestination

public PeerContext getDestination()

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

getRunningSends

public static int getRunningSends()