toDial[picked.IP.String()] = picked
}
- var wg *sync.WaitGroup
+ var wg sync.WaitGroup
for _, item := range toDial {
wg.Add(1)
go r.dialPeerWorker(item, wg)
}
}
-func (r *PEXReactor) dialPeerWorker(a *NetAddress, wg *sync.WaitGroup) {
+func (r *PEXReactor) dialPeerWorker(a *NetAddress, wg sync.WaitGroup) {
if _, err := r.Switch.DialPeerWithAddress(a, false); err != nil {
r.book.MarkAttempt(a)
} else {