RandomChildID returns a random id that has the same prefix with bucket.

Replace removes node, then put bucket.candidates.Back() to the right place of bucket.nodes.

Request pushes the request to the queue.

Response returns a chan of Response.

Run starts the peer wire protocol.

Run starts the dht.

SetChild sets routingTableNode's left or right child. When index is 0, it's the left child, if 1, it's the right child.

SetKBucket sets the bucket.

Split splits current routingTableNode and sets it's two children.

Unset sets the bit at idnex to 0.

check returns whether the token is valid.

delete removes blocked item form the blackList.

fetchMetadata fetchs medata info accroding to infohash from dht.

genTransID generates a transaction id and returns it.

getByIndex returns a transaction by indexed key.

getByTransID returns a transaction by transID.

getLocalIPs returns local ips.

getRemoteIP returns the wlan ip.

getTopK solves the top-k problem with heap. It's time complexity is O(n*log(k)). When n is large, time complexity will be too high, need to be optimiz

getUTMetaSize returns the ut_metadata and metadata_size.

handle handles packets received from udp.

init initializes global varables.

isDone returns whether the wire get all pieces of the metadata info.

len returns how many transactions are requesting now.

listen receives message from udp.

makeQuery returns a query-formed data.

newKBucket returns a new kbucket pointer.

newNodeFromCompactInfo parses compactNodeInfo and returns a node pointer.

newPeerFromCompactIPPortInfo create a peer pointer by compact ip/port info.

newPeersManager returns a new peersManager.

newRoutingTable returns a new routingTable pointer.

newTokenManager returns a new tokenManager.

newTransaction creates a new transaction.

newTransactionManager returns new transactionManager pointer.

onHandshake handles the handshake response.

parseMessage parses the basic data received from udp. It returns a map value.

ping sends ping query to the chan.

query sends the query-formed data to udp and wait for the response. When timeout, it will retry `try - 1` times, which means it will query `try` times

readMessage gets a message from the tcp connection.

run starts to listen and consume the query chan.

sendExtHandshake requests for the ut_metadata and metadata_size.

sendHandshake sends handshake message to conn.

Clear resets the list queue.

Clear resets the deque.

CompactIPPortInfo returns "Compact node info". See http://www.bittorrent.org/beps/bep_0005.html.

DecodeInt decodes int value in the data.

DecodeList decodes a list value.

Deprecated: Use Empty.ProtoReflect.Descriptor instead.

Deprecated: Use BitTorrent.ProtoReflect.Descriptor instead.

Deprecated: Use File.ProtoReflect.Descriptor instead.

Fresh sends findNode to all nodes in the expired nodes.

GetPeers returns size-length peers who announces having infoHash.

Insert adds a peer into peersManager.

Insert adds a node to routing table. It returns whether the node is new in the routingtable.

InsertAfter inserts v after mark.

Iter returns a chan which output all elements.

Len returns the number of nodes in table.

Len returns length of the slist.

New returns a DHT pointer. If config is nil, then config will be set to the default config.

NewCrawlConfig returns a config in crawling mode.

NewWire returns a Wire pointer. - blackListSize: the blacklist size - requestQueueSize: the max requests it can buffers - workerQueueSize: the max gor

PushFront pushs an element to the head of slist.

Removes overwrites list.List.Remove.

Set sets pair {key: val}.