bt.torrent.data

Interface DataWorker

All Known Implementing Classes:

DefaultDataWorker

public interface DataWorker

Data worker is responsible for processing blocks and block requests, received from peers.

Since:

1.0

Method Summary

Modifier and Type	Method and Description
CompletableFuture<BlockWrite>	addBlock(TorrentId torrentId, Peer peer, int pieceIndex, int offset, BufferedData buffer) Add a write block request.
CompletableFuture<BlockRead>	addBlockRequest(TorrentId torrentId, Peer peer, int pieceIndex, int offset, int length) Add a read block request.

Method Detail

addBlockRequest

CompletableFuture<BlockRead> addBlockRequest(TorrentId torrentId,
                                             Peer peer,
                                             int pieceIndex,
                                             int offset,
                                             int length)

Add a read block request.

Parameters:

torrentId - Torrent ID

peer - Requestor

pieceIndex - Index of the requested piece (0-based)

offset - Offset in piece to start reading from (0-based)

length - Amount of bytes to read

Returns:

Future; rejected requests are returned immediately (see BlockRead.isRejected())

Since:

1.9

addBlock

CompletableFuture<BlockWrite> addBlock(TorrentId torrentId,
                                       Peer peer,
                                       int pieceIndex,
                                       int offset,
                                       BufferedData buffer)

Add a write block request.

Parameters:

torrentId - Torrent ID

peer - Peer, that the data has been received from

pieceIndex - Index of the piece to write to (0-based)

offset - Offset in piece to start writing to (0-based)

buffer - Data

Returns:

Future; rejected requests are returned immediately (see BlockWrite.isRejected())

Since:

1.9