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

don't apply a limit to the number of outgoing streams

Browse Source
This commit is contained in:
Marten Seemann
2017-10-15 14:56:03 +07:00
parent 480db80da1
commit 925a52f032
3 changed files with 3 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
internal/handshake/params_negotiator_base.go
View File

@@ -51,7 +51,7 @@ func (h *paramsNegotiatorBase) init(params *TransportParameters) {
h.idleTimeout = params.IdleTimeout
// use this as a default value. As soon as the client sends its value, this gets updated
h.maxOutgoingStreams = protocol.MaxOutgoingStreams
h.maxOutgoingStreams = protocol.MaxIncomingStreams
}
// GetSendStreamFlowControlWindow gets the size of the stream-level flow control window for sending data
@@ -74,10 +74,6 @@ func (h *paramsNegotiatorBase) GetMaxOutgoingStreams() uint32 {
return h.maxOutgoingStreams
}
func (h *paramsNegotiatorBase) setMaxOutgoingStreams(clientValue uint32) {
h.maxOutgoingStreams = utils.MinUint32(clientValue, protocol.MaxOutgoingStreams)
}
func (h *paramsNegotiatorBase) setRemoteIdleTimeout(t time.Duration) {
h.remoteIdleTimeout = utils.MaxDuration(protocol.MinRemoteIdleTimeout, t)
}

2
internal/handshake/params_negotiator_gquic.go
View File

@@ -47,7 +47,7 @@ func (h *paramsNegotiatorGQUIC) SetFromMap(params map[Tag][]byte) error {
if err != nil {
return errMalformedTag
}
h.setMaxOutgoingStreams(clientValue)
h.maxOutgoingStreams = clientValue
}
if value, ok := params[TagICSL]; ok {
clientValue, err := utils.LittleEndian.ReadUint32(bytes.NewBuffer(value))