mirrors/uquic
1
0
Fork 0
mirror of https://github.com/refraction-networking/uquic.git synced 2025-04-04 12:47:36 +03:00
Code Issues Projects Releases Packages Wiki Activity

use a uint64 in the AllowConnectionWindowIncrease callback

Browse source
This commit is contained in:
Marten Seemann 2022-01-18 09:23:56 +04:00
parent bfd685faf2
commit cb6db58fc1
3 changed files with 3 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

2
config_test.go
View file

@ -103,7 +103,7 @@ var _ = Describe("Config", func() {
var calledAcceptToken, calledAllowConnectionWindowIncrease bool var calledAcceptToken, calledAllowConnectionWindowIncrease bool
c1 := &Config{ c1 := &Config{
AcceptToken: func(_ net.Addr, _ *Token) bool { calledAcceptToken = true; return true }, AcceptToken: func(_ net.Addr, _ *Token) bool { calledAcceptToken = true; return true },
AllowConnectionWindowIncrease: func(Session, int) bool { calledAllowConnectionWindowIncrease = true; return true }, AllowConnectionWindowIncrease: func(Session, uint64) bool { calledAllowConnectionWindowIncrease = true; return true },
} }
c2 := c1.Clone() c2 := c1.Clone()
c2.AcceptToken(&net.UDPAddr{}, &Token{}) c2.AcceptToken(&net.UDPAddr{}, &Token{})

2
interface.go
View file

@ -270,7 +270,7 @@ type Config struct {
// to increase the connection flow control window. // to increase the connection flow control window.
// If set, the caller can prevent an increase of the window. Typically, it would do so to // If set, the caller can prevent an increase of the window. Typically, it would do so to
// limit the memory usage. // limit the memory usage.
AllowConnectionWindowIncrease func(sess Session, delta int) bool AllowConnectionWindowIncrease func(sess Session, delta uint64) bool
// MaxIncomingStreams is the maximum number of concurrent bidirectional streams that a peer is allowed to open. // MaxIncomingStreams is the maximum number of concurrent bidirectional streams that a peer is allowed to open.
// Values above 2^60 are invalid. // Values above 2^60 are invalid.
// If not set, it will default to 100. // If not set, it will default to 100.

2
session.go
View file

@ -510,7 +510,7 @@ func (s *session) preSetup() {
if s.config.AllowConnectionWindowIncrease == nil { if s.config.AllowConnectionWindowIncrease == nil {
return true return true
} }
return s.config.AllowConnectionWindowIncrease(s, int(size)) return s.config.AllowConnectionWindowIncrease(s, uint64(size))
}, },
s.rttStats, s.rttStats,
s.logger, s.logger,