diff --git a/packer/rpc/muxconn.go b/packer/rpc/muxconn.go index 206208033..434ebdea8 100644 --- a/packer/rpc/muxconn.go +++ b/packer/rpc/muxconn.go @@ -315,6 +315,13 @@ func (m *MuxConn) loop() { panic(fmt.Sprintf("Unknown stream direction: %d", from)) } + if stream == nil && packetType != muxPacketSyn { + log.Printf( + "[WARN] %p: Non-existent stream %d (%s) received packer %d", + m, id, from, packetType) + continue + } + //log.Printf("[TRACE] %p: Stream %d (%s) received packet %d", m, id, from, packetType) switch packetType { case muxPacketSyn: