fluencelabs/go-libp2p-kad-dht
1
0
Fork 0
mirror of https://github.com/fluencelabs/go-libp2p-kad-dht synced 2025-06-24 10:11:43 +00:00
Code Issues Projects Releases Wiki Activity

dht/bootstrap: logging

Browse Source
This commit is contained in:
Juan Batiz-Benet
2015-01-18 00:58:34 -08:00
parent d15f03cb6a
commit 4bb443e4c7
1 changed files with 11 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
dht_bootstrap.go
View File

@ -42,6 +42,10 @@ const DefaultBootstrapQueries = 1
// queries // queries
const DefaultBootstrapPeriod = time.Duration(10 * time.Second) const DefaultBootstrapPeriod = time.Duration(10 * time.Second)
// DefaultBootstrapTimeout specifies how long to wait for a bootstrap query
// to run.
const DefaultBootstrapTimeout = time.Duration(10 * time.Second)
// Bootstrap runs bootstrapping once, then calls SignalBootstrap with default // Bootstrap runs bootstrapping once, then calls SignalBootstrap with default
// parameters: DefaultBootstrapQueries and DefaultBootstrapPeriod. This allows // parameters: DefaultBootstrapQueries and DefaultBootstrapPeriod. This allows
// the user to catch an error off the bat if the connections are faulty. It also // the user to catch an error off the bat if the connections are faulty. It also
@ -76,10 +80,10 @@ func (dht *IpfsDHT) BootstrapOnSignal(queries int, signal <-chan time.Time) (gop
} }
proc := goprocess.Go(func(worker goprocess.Process) { proc := goprocess.Go(func(worker goprocess.Process) {
defer log.Debug("dht bootstrapper shutting down")
for { for {
select { select {
case <-worker.Closing(): case <-worker.Closing():
log.Debug("dht bootstrapper shutting down")
return return
case <-signal: case <-signal:
@ -118,6 +122,12 @@ func (dht *IpfsDHT) BootstrapOnSignal(queries int, signal <-chan time.Time) (gop
// runBootstrap builds up list of peers by requesting random peer IDs // runBootstrap builds up list of peers by requesting random peer IDs
func (dht *IpfsDHT) runBootstrap(ctx context.Context, queries int) error { func (dht *IpfsDHT) runBootstrap(ctx context.Context, queries int) error {
bslog := func(msg string) {
log.Debugf("DHT %s dhtRunBootstrap %s -- routing table size: %d", dht.self, msg, dht.routingTable.Size())
}
bslog("start")
defer bslog("end")
defer log.EventBegin(ctx, "dhtRunBootstrap").Done()
var merr u.MultiErr var merr u.MultiErr