feat: Expose RTT information

MarcoPolo · web-flow · commit edd16dbfc32b · 2025-07-29T10:22:45.000-07:00
Expose RTT information
diff --git a/session.go b/session.go
@@ -379,7 +379,7 @@ func (s *Session) startMeasureRTT() {
 }
 
 // 0 if we don't yet have a measurement
-func (s *Session) getRTT() time.Duration {
+func (s *Session) RTT() time.Duration {
 	return time.Duration(atomic.LoadInt64(&s.rtt))
 }
 
diff --git a/stream.go b/stream.go
@@ -223,7 +223,7 @@ func (s *Stream) sendWindowUpdate(deadline <-chan struct{}) error {
 	}
 
 	now := time.Now()
-	if rtt := s.session.getRTT(); flags == 0 && rtt > 0 && now.Sub(s.epochStart) < rtt*4 {
+	if rtt := s.session.RTT(); flags == 0 && rtt > 0 && now.Sub(s.epochStart) < rtt*4 {
 		var recvWindow uint32
 		if s.recvWindow > math.MaxUint32/2 {
 			recvWindow = min(math.MaxUint32, s.session.config.MaxStreamWindowSize)

Original file line number	Diff line number	Diff line change
`@@ -379,7 +379,7 @@ func (s *Session) startMeasureRTT() {`
`379`	`379`	`}`
`380`	`380`
`381`	`381`	`// 0 if we don't yet have a measurement`
`382`		`-func (s *Session) getRTT() time.Duration {`
	`382`	`+func (s *Session) RTT() time.Duration {`
`383`	`383`	`return time.Duration(atomic.LoadInt64(&s.rtt))`
`384`	`384`	`}`
`385`	`385`
Original file line number	Diff line number	Diff line change
`@@ -223,7 +223,7 @@ func (s *Stream) sendWindowUpdate(deadline <-chan struct{}) error {`
`223`	`223`	`}`
`224`	`224`
`225`	`225`	`now := time.Now()`
`226`		`- if rtt := s.session.getRTT(); flags == 0 && rtt > 0 && now.Sub(s.epochStart) < rtt*4 {`
	`226`	`+ if rtt := s.session.RTT(); flags == 0 && rtt > 0 && now.Sub(s.epochStart) < rtt*4 {`
`227`	`227`	`var recvWindow uint32`
`228`	`228`	`if s.recvWindow > math.MaxUint32/2 {`
`229`	`229`	`recvWindow = min(math.MaxUint32, s.session.config.MaxStreamWindowSize)`