fixed dht kbucket race

closes #836

fixed dht kbucket race
closes #836
5f313283 · Juan Batiz-Benet · 7f2386b9 · 5f313283
Commit 5f313283 authored Mar 04, 2015 by Juan Batiz-Benet
Show whitespace changes
Inline Side-by-side

Showing with 2 additions and 0 deletions

kbucket/table.go kbucket/table.go +2 -0

No files found.
--- a/kbucket/table.go
+++ b/kbucket/table.go
@@ -185,9 +185,11 @@ func (rt *RoutingTable) NearestPeers(id ID, count int) []peer.ID {
 // Size returns the total number of peers in the routing table
 func (rt *RoutingTable) Size() int {
 	var tot int
+	rt.tabLock.RLock()
 	for _, buck := range rt.Buckets {
 		tot += buck.Len()
 	}
+	rt.tabLock.RUnlock()
 	return tot
 }