Package com.biglybt.plugin.tracker.dht
Class DHTTrackerPluginAlt.GetPeersTask
- java.lang.Object
-
- com.biglybt.plugin.tracker.dht.DHTTrackerPluginAlt.GetPeersTask
-
- Enclosing class:
- DHTTrackerPluginAlt
private class DHTTrackerPluginAlt.GetPeersTask extends java.lang.Object
-
-
Field Summary
Fields Modifier and Type Field Description private ByteArrayHashMap<java.net.InetSocketAddress>
active_queries
(package private) java.util.Comparator<byte[]>
comparator
private boolean
completed
private boolean
failed
private long
found_peer_time
private java.util.Set<java.net.InetSocketAddress>
found_peers
private java.util.TreeMap<byte[],java.net.InetSocketAddress>
heard_from
private java.util.List<DHTTransportAlternativeContact>
initial_contacts
private DHTTrackerPluginAlt.LookupListener
listener
private boolean
no_seeds
private java.util.Set<java.net.InetSocketAddress>
queried_nodes
private int
query_count
private int
reply_count
private java.net.DatagramSocket
server
private long
start_time
private int
timeout_count
private java.util.TreeMap<byte[],java.net.InetSocketAddress>
to_query
private byte[]
torrent_hash
-
Constructor Summary
Constructors Modifier Constructor Description private
GetPeersTask(java.net.DatagramSocket _server, java.util.List<DHTTransportAlternativeContact> _contacts, byte[] _torrent_hash, boolean _no_seeds, DHTTrackerPluginAlt.LookupListener _listener)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description private void
handleReply(java.net.InetSocketAddress from, byte[] tid, java.util.Map<java.lang.String,java.lang.Object> map)
private void
handleTimeout(byte[] tid)
private void
log()
private void
search(java.net.InetSocketAddress address)
private void
setCompleted()
private void
setFailed()
private void
tryQuery()
-
-
-
Field Detail
-
start_time
private long start_time
-
server
private java.net.DatagramSocket server
-
torrent_hash
private byte[] torrent_hash
-
no_seeds
private boolean no_seeds
-
listener
private DHTTrackerPluginAlt.LookupListener listener
-
initial_contacts
private java.util.List<DHTTransportAlternativeContact> initial_contacts
-
active_queries
private ByteArrayHashMap<java.net.InetSocketAddress> active_queries
-
queried_nodes
private java.util.Set<java.net.InetSocketAddress> queried_nodes
-
comparator
java.util.Comparator<byte[]> comparator
-
to_query
private java.util.TreeMap<byte[],java.net.InetSocketAddress> to_query
-
heard_from
private java.util.TreeMap<byte[],java.net.InetSocketAddress> heard_from
-
found_peer_time
private long found_peer_time
-
found_peers
private java.util.Set<java.net.InetSocketAddress> 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 Detail
-
GetPeersTask
private GetPeersTask(java.net.DatagramSocket _server, java.util.List<DHTTransportAlternativeContact> _contacts, byte[] _torrent_hash, boolean _no_seeds, DHTTrackerPluginAlt.LookupListener _listener)
-
-
Method Detail
-
search
private void search(java.net.InetSocketAddress address) throws java.io.IOException
- Throws:
java.io.IOException
-
tryQuery
private void tryQuery()
-
handleTimeout
private void handleTimeout(byte[] tid)
-
handleReply
private void handleReply(java.net.InetSocketAddress from, byte[] tid, java.util.Map<java.lang.String,java.lang.Object> map) throws java.io.IOException
- Throws:
java.io.IOException
-
setCompleted
private void setCompleted()
-
setFailed
private void setFailed()
-
log
private void log()
-
-