packer/rpc: fix data race in MuxConn

2026-09-21 15:31:41 -04:00 · 2013-12-10 17:09:17 -08:00
parent 10c90e6513
commit dd50e9d535
1 changed files with 2 additions and 0 deletions
@@ -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()
 		}
 	}()