Skip to content

Commit e77dd9b

Browse files
committed
fixup! drpcmanager: replace streamBuffer with streamRegistry
1 parent 0129d8f commit e77dd9b

1 file changed

Lines changed: 1 addition & 8 deletions

File tree

drpcmanager/manager.go

Lines changed: 1 addition & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -276,14 +276,7 @@ func (m *Manager) manageReader() {
276276
}
277277

278278
default:
279-
// A non-invoke frame arrived for a stream that doesn't exist yet
280-
// (curr is nil or incomingFrame.ID.Stream > curr.ID). The first
281-
// frame of a new stream must be KindInvoke or KindInvokeMetadata.
282-
m.terminate(managerClosed.Wrap(drpc.ProtocolError.New(
283-
"first frame of a new stream must be Invoke, got %v (ID:%v)",
284-
incomingFrame.Kind,
285-
incomingFrame.ID)))
286-
return
279+
m.log("DROP", incomingFrame.String)
287280
}
288281
}
289282
}

0 commit comments

Comments
 (0)