Commit 77d0d63b authored by Mitchell Hashimoto's avatar Mitchell Hashimoto

packer/rpc: ignore non-existent streams in muxconn

parent 437dc12d
...@@ -315,6 +315,13 @@ func (m *MuxConn) loop() { ...@@ -315,6 +315,13 @@ func (m *MuxConn) loop() {
panic(fmt.Sprintf("Unknown stream direction: %d", from)) 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) //log.Printf("[TRACE] %p: Stream %d (%s) received packet %d", m, id, from, packetType)
switch packetType { switch packetType {
case muxPacketSyn: case muxPacketSyn:
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment