packer/rpc: fix data race in MuxConn

This commit is contained in:
Mitchell Hashimoto 2013-12-10 17:09:17 -08:00
parent f79daa0b1b
commit 8a24c9b177
1 changed files with 2 additions and 0 deletions

View File

@ -241,7 +241,9 @@ func (m *MuxConn) loop() {
m.mu.Lock()
defer m.mu.Unlock()
for _, w := range m.streams {
w.mu.Lock()
w.remoteClose()
w.mu.Unlock()
}
}()