iSharkFly-Docs/Packer-Cn
2
0
Fork 0
mirror of https://github.com/hashicorp/packer.git synced 2026-10-05 22:23:18 -04:00
Code Issues Packages Projects Releases Wiki Activity

packer/rpc: use a pointer for maps to avoid race

Browse Source
This commit is contained in:
Mitchell Hashimoto
2013-12-20 10:02:47 -08:00
parent 3b2871a2ea
commit b11cfb9fb0
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
packer/rpc/muxconn.go
+5 -5
View File
@@ -200,11 +200,11 @@ func (m *MuxConn) NextId() uint32 {
func (m *MuxConn) cleaner() {
checks := []struct {
Map map[uint32]*Stream
Map *map[uint32]*Stream
Lock *sync.RWMutex
}{
{m.streamsAccept, &m.muAccept},
{m.streamsDial, &m.muDial},
{&m.streamsAccept, &m.muAccept},
{&m.streamsDial, &m.muDial},
}
for {
@@ -217,7 +217,7 @@ func (m *MuxConn) cleaner() {
for _, check := range checks {
check.Lock.Lock()
for id, s := range check.Map {
for id, s := range *check.Map {
s.mu.Lock()
if done && s.state != streamStateClosed {
@@ -229,7 +229,7 @@ func (m *MuxConn) cleaner() {
// for a certain amount of time.
since := time.Now().UTC().Sub(s.stateUpdated)
if since > 2*time.Second {
delete(check.Map, id)
delete(*check.Map, id)
}
}