mirror of
https://github.com/ethereum/go-ethereum.git
synced 2026-08-20 10:52:25 +00:00
swarm/network: reduce the scope of mutex lock in newBzzBaseTesterWithAddrs
This commit is contained in:
parent
22ca0b5c82
commit
4fc2a1ab92
1 changed files with 1 additions and 1 deletions
|
|
@ -102,8 +102,8 @@ func newBzzBaseTesterWithAddrs(prvkey *ecdsa.PrivateKey, addrs [][]byte, spec *p
|
||||||
nodeToAddr := make(map[enode.ID][]byte)
|
nodeToAddr := make(map[enode.ID][]byte)
|
||||||
protocol := func(p *p2p.Peer, rw p2p.MsgReadWriter) error {
|
protocol := func(p *p2p.Peer, rw p2p.MsgReadWriter) error {
|
||||||
mu.Lock()
|
mu.Lock()
|
||||||
defer mu.Unlock()
|
|
||||||
nodeToAddr[p.ID()] = addrs[0]
|
nodeToAddr[p.ID()] = addrs[0]
|
||||||
|
mu.Unlock()
|
||||||
bzzAddr := &BzzAddr{addrs[0], []byte(p.Node().String())}
|
bzzAddr := &BzzAddr{addrs[0], []byte(p.Node().String())}
|
||||||
addrs = addrs[1:]
|
addrs = addrs[1:]
|
||||||
return srv(&BzzPeer{Peer: protocols.NewPeer(p, rw, spec), BzzAddr: bzzAddr})
|
return srv(&BzzPeer{Peer: protocols.NewPeer(p, rw, spec), BzzAddr: bzzAddr})
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue