Skip to content

Commit

Permalink
Merge pull request #1638 from aboch/ovlk
Browse files Browse the repository at this point in the history
Do not hold the peer map lock during the peerDBNetworkWalk
  • Loading branch information
mavenugo authored Feb 7, 2017
2 parents 7fadaec + 760abd0 commit 6d6d4ac
Showing 1 changed file with 9 additions and 5 deletions.
14 changes: 9 additions & 5 deletions drivers/overlay/peerdb.go
Original file line number Diff line number Diff line change
Expand Up @@ -80,25 +80,29 @@ func (d *driver) peerDbWalk(f func(string, *peerKey, *peerEntry) bool) error {
func (d *driver) peerDbNetworkWalk(nid string, f func(*peerKey, *peerEntry) bool) error {
d.peerDb.Lock()
pMap, ok := d.peerDb.mp[nid]
d.peerDb.Unlock()

if !ok {
d.peerDb.Unlock()
return nil
}
d.peerDb.Unlock()

mp := map[string]peerEntry{}

pMap.Lock()
for pKeyStr, pEntry := range pMap.mp {
mp[pKeyStr] = pEntry
}
pMap.Unlock()

for pKeyStr, pEntry := range mp {
var pKey peerKey
if _, err := fmt.Sscan(pKeyStr, &pKey); err != nil {
logrus.Warnf("Peer key scan on network %s failed: %v", nid, err)
}

if f(&pKey, &pEntry) {
pMap.Unlock()
return nil
}
}
pMap.Unlock()

return nil
}
Expand Down

0 comments on commit 6d6d4ac

Please # to comment.