Class PEPeerControlHashHandlerImpl

java.lang.Object

com.biglybt.core.peer.impl.control.PEPeerControlHashHandlerImpl

All Implemented Interfaces:

PEPeerControlHashHandler, TOTorrentFileHashTree.PieceTreeProvider

public class PEPeerControlHashHandlerImpl
extends Object
implements PEPeerControlHashHandler, TOTorrentFileHashTree.PieceTreeProvider

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static class	PEPeerControlHashHandlerImpl.HashesReceiverImpl
private static class	PEPeerControlHashHandlerImpl.PeerHashRequest
private class	PEPeerControlHashHandlerImpl.PeerStats
private class	PEPeerControlHashHandlerImpl.PieceTreeRequest

Nested classes/interfaces inherited from interface PEPeerControlHashHandler

PEPeerControlHashHandler.HashesReceiver

Field Summary

Fields

Modifier and Type	Field	Description
private Set<PEPeerControlHashHandlerImpl.PeerHashRequest>	active_requests
private final DiskManager	disk_manager
private final ByteArrayHashMap<TOTorrentFileHashTree>	file_map
private final Map<TOTorrentFileHashTree, PEPeerControlHashHandlerImpl.PeerHashRequest>	incomplete_tree_reqs
private final Set<TOTorrentFileHashTree>	incomplete_trees
private static final Object	KEY_PEER_STATS
private long	last_piece_tree_request
private long	last_update
private final PEPeerControlImpl	peer_manager
private Map<PEPeerTransport, List<PEPeerControlHashHandlerImpl.PeerHashRequest>>	peer_requests
private AtomicInteger	piece_hashes_received
private final int	piece_length
private PEPeerControlHashHandlerImpl.PeerHashRequest[][]	piece_requests
private final Map<Integer,byte[][]>	piece_tree_cache
private final int	PIECE_TREE_CACHE_MAX
private final Map<Integer, PEPeerControlHashHandlerImpl.PieceTreeRequest>	piece_tree_requests
private boolean	save_done_on_complete
private final TOTorrent	torrent

Constructor Summary

Constructors

Constructor	Description
PEPeerControlHashHandlerImpl(PEPeerControlImpl _peer_manager, TOTorrent _torrent, DiskManager _disk_manager)

Method Summary

Modifier and Type	Method	Description
void	getPieceTree(TOTorrentFileHashTree.PieceTreeReceiver receiver, TOTorrentFileHashTree tree, int piece_offset)
boolean	hashRequest(int piece_number, DiskManagerCheckRequestListener.HashListener listener)
private PEPeerControlHashHandlerImpl.PeerHashRequest	hashRequestSupport(int piece_number, DiskManagerCheckRequestListener.HashListener listener)
void	receivedHashes(PEPeerTransport peer, byte[] root_hash, int base_layer, int index, int length, int proof_layers, byte[][] hashes)
void	receivedHashRequest(PEPeerTransport peer, PEPeerControlHashHandler.HashesReceiver receiver, byte[] root_hash, int base_layer, int index, int length, int proof_layers)
private void	receivedOrRejectedHashes(PEPeerTransport peer, byte[] root_hash, int base_layer, int index, int length, int proof_layers, byte[][] hashes)
void	rejectedHashes(PEPeerTransport peer, byte[] root_hash, int base_layer, int index, int length, int proof_layers)
private void	removeFromPieceRequests(PEPeerControlHashHandlerImpl.PeerHashRequest peer_request)
private PEPeerControlHashHandlerImpl.PeerHashRequest	request(PEPeerTransport peer, int piece_number, DiskManagerCheckRequestListener.HashListener listener_maybe_null)
void	sendingRequest(PEPeerTransport peer, DiskManagerReadRequest request)
void	stop()
void	update()

Methods inherited from class Object

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

Field Details

KEY_PEER_STATS

private static final Object KEY_PEER_STATS

peer_manager

private final PEPeerControlImpl peer_manager

torrent

private final TOTorrent torrent

disk_manager

private final DiskManager disk_manager

piece_length

private final int piece_length

file_map

private final ByteArrayHashMap<TOTorrentFileHashTree> file_map

last_update

private long last_update

active_requests

private Set<PEPeerControlHashHandlerImpl.PeerHashRequest> active_requests

peer_requests

private Map<PEPeerTransport, List<PEPeerControlHashHandlerImpl.PeerHashRequest>> peer_requests

piece_requests

private PEPeerControlHashHandlerImpl.PeerHashRequest[][] piece_requests

piece_hashes_received

private AtomicInteger piece_hashes_received

save_done_on_complete

private boolean save_done_on_complete

incomplete_trees

private final Set<TOTorrentFileHashTree> incomplete_trees

incomplete_tree_reqs

private final Map<TOTorrentFileHashTree, PEPeerControlHashHandlerImpl.PeerHashRequest> incomplete_tree_reqs

PIECE_TREE_CACHE_MAX

private final int PIECE_TREE_CACHE_MAX

See Also:

• Constant Field Values

piece_tree_cache

private final Map<Integer,byte[][]> piece_tree_cache

last_piece_tree_request

private volatile long last_piece_tree_request

piece_tree_requests

private final Map<Integer, PEPeerControlHashHandlerImpl.PieceTreeRequest> piece_tree_requests

Constructor Details

PEPeerControlHashHandlerImpl

public PEPeerControlHashHandlerImpl(PEPeerControlImpl _peer_manager,
 TOTorrent _torrent,
 DiskManager _disk_manager)

Method Details

stop

public void stop()

Specified by:

stop in interface PEPeerControlHashHandler

update

public void update()

Specified by:

update in interface PEPeerControlHashHandler

request

private PEPeerControlHashHandlerImpl.PeerHashRequest request(PEPeerTransport peer,
 int piece_number,
 DiskManagerCheckRequestListener.HashListener listener_maybe_null)

hashRequest

public boolean hashRequest(int piece_number,
 DiskManagerCheckRequestListener.HashListener listener)

Specified by:

hashRequest in interface PEPeerControlHashHandler

hashRequestSupport

private PEPeerControlHashHandlerImpl.PeerHashRequest hashRequestSupport(int piece_number,
 DiskManagerCheckRequestListener.HashListener listener)

sendingRequest

public void sendingRequest(PEPeerTransport peer,
 DiskManagerReadRequest request)

Specified by:

sendingRequest in interface PEPeerControlHashHandler

receivedHashes

public void receivedHashes(PEPeerTransport peer,
 byte[] root_hash,
 int base_layer,
 int index,
 int length,
 int proof_layers,
 byte[][] hashes)

Specified by:

receivedHashes in interface PEPeerControlHashHandler

receivedOrRejectedHashes

private void receivedOrRejectedHashes(PEPeerTransport peer,
 byte[] root_hash,
 int base_layer,
 int index,
 int length,
 int proof_layers,
 byte[][] hashes)

removeFromPieceRequests

private void removeFromPieceRequests(PEPeerControlHashHandlerImpl.PeerHashRequest peer_request)

rejectedHashes

public void rejectedHashes(PEPeerTransport peer,
 byte[] root_hash,
 int base_layer,
 int index,
 int length,
 int proof_layers)

Specified by:

rejectedHashes in interface PEPeerControlHashHandler

receivedHashRequest

public void receivedHashRequest(PEPeerTransport peer,
 PEPeerControlHashHandler.HashesReceiver receiver,
 byte[] root_hash,
 int base_layer,
 int index,
 int length,
 int proof_layers)

Specified by:

receivedHashRequest in interface PEPeerControlHashHandler

getPieceTree

public void getPieceTree(TOTorrentFileHashTree.PieceTreeReceiver receiver,
 TOTorrentFileHashTree tree,
 int piece_offset)

Specified by:

getPieceTree in interface TOTorrentFileHashTree.PieceTreeProvider