Traversals should try to complete before tokens received could expire, per BEP 5. This seems like a reasonable default for timeouts anyway.

With bootstrap and when connecting to the torrent, there are about 1000 connections.
Connections are not replaced, but added, if after bootstrap connect to the torrent, there will be about ~2000 connections, etc.
My ISP blocked me access because it thinks it's a virus attack

Over time, connections are disconnected

The address router.silotis.us is broken and throwing errors since its dns is not working

The of this server have mentioned that it is temporary previously here

Please confirm the issue from your side so that i could create a PR to fix.

So,I tried to run go get -u on project which depends on this dht package .

I was greeted with this error.

go get: github.com/willf/[email protected] updating to github.com/willf/[email protected]: parsing go.mod: module declares its path as: github.com/bits-and-blooms/bitset but was required as: github.com/willf/bitset

Please fix this asap or atleast tell me what should I do

Hi,

i was trying to figure out how much of this bep was available in your package.
http://bittorrent.org/beps/bep_0044.html

I found the immutable items part was there, if i dont mistake.

About mutable items, there are few more operation to do when a message is sent / receive.
I was wondering how that would operate with your package.
inside or outside of it ?
if there was some specific ways to implement those extra functions with the lib ?

I was looking for a Put method at Server.go, but i could not find it.
Is it missing as i believe i understand ?

thanks for help!

Hi,

Just a thought, potentially wrong.
Does int160 need to exposed in order to use the Server::FindNode function?

The title really states it all.
My current use case: I want to run a DHT node that remembers as many good nodes as possible.
Allowing the k-buckets to be (infinitely) large results in good nodes not being forgotten once they are stored in the routing table.

Hi.
First of all, thank you for the great work you have done on this project.

I just discovered this repo a few days ago and would like to continue using it for a project.
For that I would need to send find_node queries to target addresses.
Is it possible that the findNode function in server.go is not exposed unlike Ping and Announce?
If so, how can one use the function after having bootstrapped?
I just started using go a few days ago, therefore, this may be an oversight on my part.

Thank you,
Charmaine

occassionally peers disappear and do not return, is there a mechanism to remove them?

from anacrolix/torrent#242

Hey, I've been trying to get this library to work standalone without bootstrapping from the global servers but I seem to not be getting the expected behaviour.

Here's a gist which sets up a server standalone https://gist.github.com/asim/99d9978f76ec46083b6dcf4a65b58cb5 and then the equivalent can be run with ports changed and using the first address in BootstrapNodes list.

When I run this locally or across the public internet I can see udp packets flowing back and forth between the servers but nothing is ever announced and I can't actually tell if anything's working.

If I use the global servers then it all seems to work fine. Any ideas why this won't bootstrap as a standalone dht server?

Is it necessary to print this time out log out?

vendor/github.com/anacrolix/dht/v2.(*Server).pingQuestionableNodesInBucket.func1.1:1376]: error pinging questionable node in bucket 18: after 3 tries: transaction timed out

Hi,

Using this server init, and two working nodes on 9090 / 9091 ports.

func getDhtTable(since int, bootstrap []string, refresh time.Duration) (ret *dht.Server, port int, err error) {
	err = errors.New("No port found.")
	for i := since; i < since+30; i++ {
		conf := &dht.ServerConfig{
			Addr:               fmt.Sprintf("localhost:%v", i),
			NoDefaultBootstrap: !true,
			NoSecurity:         true,
			BootstrapNodes:     bootstrap,
			StoreTimeout:       refresh,
			OnQuery: func(query *krpc.Msg, source net.Addr) (propagate bool) {
				log.Printf("query %v %#v\n", source, query.Q)
				<-time.After(1 * time.Second)
				return true // true or false ? unclear doc.
			},
			OnResponsePeer: func(query krpc.Msg, source dht.Addr) {
				r := ""
				if query.R != nil {
					r = fmt.Sprintf("ret.V=%#v ret.Seq=%#v ret.K=%#v ret.Sign=%#v",
						query.R.V, query.R.Seq, query.R.K, query.R.Sign)
				}
				log.Printf("response %v err=%v %v\n", source, query.Error(), r)
			},
		}

		if srv, netErr := dht.NewServer(conf); netErr == nil {
			ret = srv
			port = i
			err = nil
			break
		}
	}
	return
}

In the OnQuery, i had to add a 1s timeout rate limiter, otherwise the table would generate a loooottttt of traffic.
A quick count with grep/wc yields 2860 5500 query per second here (so if i have two nodes, its like 5k 10k :o).

Is there anything to take care of here, as i suspected, or it s expected to be that fast under best conditions ?

The under best conditions matters, as the phenomena won t happen if any of the node is offline (it creates a sort of 10 sec blocking timeout in the stream).

thanks!

func main() {
	var id krpc.ID
        copy(id[:],[]byte("012345678901234567890"))
        fmt.Printf("%s",bencode.MustMarshal(id))
}

I receive:
li48ei49ei50ei51ei52ei53ei54ei55ei56ei57ei48ei49ei50ei51ei52ei53ei54ei55ei56ei57ee

Shouldn't be:
20:012345678901234567890

Michele

A simple git clone is taking ages:

$ git clone [email protected]:anacrolix/dht.git
Cloning into 'dht'...
remote: Counting objects: 218641, done.
remote: Compressing objects: 100% (6/6), done.
Receiving objects:  13% (30228/218641), 20.12 MiB | 39.00 KiB/s

Same problem when cloning a fork of this repository. I've tried both HTTPS and SSH. Downloading the ZIP works fine and it's tiny.

Do you have any idea what's going on? Any other repo is working fine.

Hey! Is this also licensed under MPLv2.0? I couldn't find any explicit mention of the license and I'd like to make sure. =)

Running r55080c5 I'm regularly getting the following panic. Any ideas, or should I work on a reproduction?

panic: sync: negative WaitGroup counter
goroutine 17787 [running]:
sync.(*WaitGroup).Add(0x13984c10, 0xffffffff) /usr/local/go/src/sync/waitgroup.go:73 +0x150
sync.(*WaitGroup).Done(0x13984c10) /usr/local/go/src/sync/waitgroup.go:98 +0x24
localhost/xxx/vendor/github.com/anacrolix/dht.(*Server).Bootstrap.func1.1(0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, ...)
localhost/xxx/vendor/github.com/anacrolix/dht/server.go:662 +0x13c
localhost/xxx/vendor/github.com/anacrolix/dht.(*Server).findNode.func1(0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, ...)
localhost/xxx/vendor/github.com/anacrolix/dht/server.go:630 +0x80
created by localhost/xxx/vendor/github.com/anacrolix/dht.(*Server).query.func4 localhost/xxx/vendor/github.com/anacrolix/dht/server.go:540 +0x88
`

Since adding a new parameter in the s.config.ConnectionTracking.Wait breaks the backwards compatibility, I can no longer use anacrolix/torrent through with go mod.

I'm getting the following issue when I run go get -u

# github.com/anacrolix/dht
../../../../pkg/mod/github.com/anacrolix/[email protected]/server.go:623:44: not enough arguments in call to s.config.ConnectionTracking.Wait
	have (conntrack.Entry, string, number)
	want (context.Context, conntrack.Entry, string, conntrack.priority)

I think this can be fixed by simply creating a new Github release. Thanks.

$go build testDht.go

github.com/anacrolix/dht/v2

../../../../go/pkg/mod/github.com/anacrolix/dht/[email protected]/server.go:171:26: implicit function instantiation requires go1.18 or later (-lang was set to go1.17; check go.mod)

$ go version
go version go1.18 darwin/amd64

Hello! Thank you for maintaining this project and publishing it as FLOSS. I've been experimenting with using it as part of the ooni project to measure mainline DHT censorship.

However, it is not clear to me precisely what the exposed stats actually mean. For example, running the provided CLI tool returns the following:

$ ./dht get-peers
{
  "Peers": [],
  "DistinctPeerIps": 0,
  "TraversalStats": {
    "NumAddrsTried": 31,
    "NumResponses": 0
  },
  "ServerStats": {
    "GoodNodes": 2,
    "Nodes": 3,
    "OutstandingTransactions": 0,
    "SuccessfulOutboundAnnouncePeerQueries": 0,
    "BadNodes": 0,
    "OutboundQueriesAttempted": 31
  }
}

In this example, we can see NumResponses is zero, but in server stats GoodNodes is 2. This does not match my current mental model.

In a test case i wrote, where i start a local dht.Server without any bootstrap nodes, then try to connect from it from another dht.Server (with only the first one as bootstrap nodes), i get the following results after an Announce: in announce.TraversalStats(): 1 peer tried, 0 responded. And announce.Peers is empty. Yet i can see using tcpdump that the first peer did respond to the query.

Trying with the default set of bootstrap nodes (13 addresses), i get 19 NumResponses (NumAddrsTried 46) and announce.Peers contains 22 entries.

It's not clear to me what NumResponses and the entries in announce.Peers are. Is the first one the number of traversed peers queried about the specific infohash, and the second the number of found peers who announce that infohash? If so, is NumResponses only counting replies from peers announcing that infohash?

To get more comprehensive results, maybe i should call get_peers recursively myself? In the meantime, i feel like it's worth explaining more about what the exposed stats/data actually means.

Thanks for your attention

vgo can't generate a go.mod file in this repo. See golang/go#24103 (comment).

Is there Simeone working on this?
I'm planning an app that uses DHT storage and your packet seems to be really interesting.

Only using DHT to find peers, https://github.com/webtorrent/torrent-discovery (through peerflix) connects to ~20 peers instantly while this package (through confluence) connects to 1 peer in 20 seconds.

I have some packet captures.
packet-capture.zip

Per elgatito/plugin.video.elementum#169 (comment), the server should avoid flooding netfilter connection tracking tables. This should also benefit other implementations (like Windoze) as a side effect.

krpc.CompactIPv4NodeAddrs (or NodeAddr) does not have the essential To4() piece in its marshaller functions, unlike pp.CompactIp which does.
Without this, the use sites need to carry the conversion explicitly.

if I add a log.Printf to annouce.go/beginQuery I get:
20-03-21 21:50:33 announce.go:290: doing dht announce get_peers to [address]

and not a single doing "dht announce announce_peer"

Panic caught by user on windows.

http://paste.ubuntu.com/26059096/

There is a Client config on line 137.

I'm trying to use this as part of my project, and the BT/DHT function is not always needed, it's only some part of my application.

So the dht/v2 as a library start a goroutine in the background running forever is very weird.

I think this goroutine should be started when the BT client is created, not the library is imported, library itself shoule bt side-effect free.

From @vtolstov on December 5, 2016 13:41

I need a dht package for own storage system, and as i see godoc.org says that this package have more stars then other. Does it possible to use this package for own program that does not using torrents?

Copied from original issue: anacrolix/torrent#134

Pardon my naivete of the bittorrent protocol, but is it possible currently to multiplex the connection? I see I can probably provide my own socket and pre-obtain a byte array and pass it along only if it's bencoded. Is this the recommended approach or might it be preferred to have a config option to handle fallthrough packets?

Because it could be first node in dht network

See #4 (comment)

I am trying to build a p2p network and I am just asking can this dht github.com/anacrolix/dht be used for holepunshing and if so how to provide the tcp listening internal port?

Here is my try:
go run ./cmd/dht ping router.bittorrent.com:6881 router.utorrent.com:6881

2022/01/06 14:16:01 main.go:63: public ip: "103.201.26.3"
2022/01/06 14:16:01 main.go:70: dht server on [::]:61082 with id 5d12d5586d35ce2eaf751ef3af0812935955529b
router.utorrent.com:6881: 2.003219305s: after 1 tries: transaction timed out
router.bittorrent.com:6881: 2.004312261s: after 1 tries: transaction timed out

And here is my capture from tcpdump

Actually I also met this question when I using python.
Does my operation right ?
Could you please give me some advice, thank you very much !