Package com.biglybt.plugin.tracker.dht
Class DHTTrackerPluginAlt.GetPeersTask
java.lang.Object
com.biglybt.plugin.tracker.dht.DHTTrackerPluginAlt.GetPeersTask
- Enclosing class:
DHTTrackerPluginAlt
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate ByteArrayHashMap
<InetSocketAddress> (package private) Comparator
<byte[]> private boolean
private boolean
private long
private Set
<InetSocketAddress> private TreeMap
<byte[], InetSocketAddress> private List
<DHTTransportAlternativeContact> private boolean
private Set
<InetSocketAddress> private int
private int
private DatagramSocket
private long
private int
private TreeMap
<byte[], InetSocketAddress> private byte[]
-
Constructor Summary
ConstructorsModifierConstructorDescriptionprivate
GetPeersTask
(DatagramSocket _server, List<DHTTransportAlternativeContact> _contacts, byte[] _torrent_hash, boolean _no_seeds, DHTTrackerPluginAlt.LookupListener _listener) -
Method Summary
Modifier and TypeMethodDescriptionprivate void
handleReply
(InetSocketAddress from, byte[] tid, Map<String, Object> map) private void
handleTimeout
(byte[] tid) private void
log()
private void
search
(InetSocketAddress address) private void
private void
private void
tryQuery()
-
Field Details
-
start_time
private long start_time -
server
-
torrent_hash
private byte[] torrent_hash -
no_seeds
private boolean no_seeds -
listener
-
initial_contacts
-
active_queries
-
queried_nodes
-
comparator
Comparator<byte[]> comparator -
to_query
-
heard_from
-
found_peer_time
private long found_peer_time -
found_peers
-
query_count
private int query_count -
timeout_count
private int timeout_count -
reply_count
private int reply_count -
completed
private boolean completed -
failed
private boolean failed
-
-
Constructor Details
-
GetPeersTask
private GetPeersTask(DatagramSocket _server, List<DHTTransportAlternativeContact> _contacts, byte[] _torrent_hash, boolean _no_seeds, DHTTrackerPluginAlt.LookupListener _listener)
-
-
Method Details
-
search
- Throws:
IOException
-
tryQuery
private void tryQuery() -
handleTimeout
private void handleTimeout(byte[] tid) -
handleReply
private void handleReply(InetSocketAddress from, byte[] tid, Map<String, Object> map) throws IOException- Throws:
IOException
-
setCompleted
private void setCompleted() -
setFailed
private void setFailed() -
log
private void log()
-