packer/rpc: need a real lock for closing

This commit is contained in:
Mitchell Hashimoto 2013-12-10 16:23:47 -08:00
parent 7372c32b6b
commit 5dffab7439
1 changed files with 2 additions and 2 deletions

View File

@ -48,8 +48,8 @@ func NewMuxConn(rwc io.ReadWriteCloser) *MuxConn {
// Close closes the underlying io.ReadWriteCloser. This will also close
// all streams that are open.
func (m *MuxConn) Close() error {
m.mu.RLock()
defer m.mu.RUnlock()
m.mu.Lock()
defer m.mu.Unlock()
// Close all the streams
for _, w := range m.streams {