gr1ffon/quic-go
1
0
Fork 0
forked from quic-go/quic-go
Code Pull Requests Activity

implement a buffer for received StreamFrames

Browse Source 
fixes #116, ref #115
This commit is contained in:
Marten Seemann
2016-06-01 14:33:12 +07:00
parent 2f49a9525a
commit 9476ae499c
8 changed files with 718 additions and 49 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
stream.go
View File

@@ -44,7 +44,7 @@ type stream struct {
// closed is set when we are finished writing
closed int32 // really a bool
frameQueue streamFrameSorter
frameQueue *streamFrameSorter
newFrameOrErrCond sync.Cond
flowController flowcontrol.FlowController
@@ -62,6 +62,7 @@ func newStream(session streamHandler, connectionParameterManager *handshake.Conn
connectionFlowController: connectionFlowController,
contributesToConnectionFlowControl: true,
flowController: flowcontrol.NewFlowController(StreamID, connectionParameterManager),
frameQueue: newStreamFrameSorter(),
}
// crypto and header stream don't contribute to connection level flow control