GuanM/hysteria-dev
1
0
Fork 0
mirror of https://github.com/cmz0228/hysteria-dev.git synced 2025-06-30 08:19:57 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

feat: add RTT to brutal sender debug

Browse Source
This commit is contained in:
Toby 2023-10-06 20:26:51 -07:00
parent 89429598bf
commit 5597b482a9
1 changed files with 6 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
core/internal/congestion/brutal/brutal.go
View File

@ -134,7 +134,8 @@ func (b *BrutalSender) updateAckRate(currentTimestamp int64) {
b.ackRate = 1 b.ackRate = 1
if b.canPrintAckRate(currentTimestamp) { if b.canPrintAckRate(currentTimestamp) {
b.lastAckPrintTimestamp = currentTimestamp b.lastAckPrintTimestamp = currentTimestamp
b.debugPrint("Not enough samples (total=%d, ack=%d, loss=%d)", ackCount+lossCount, ackCount, lossCount) b.debugPrint("Not enough samples (total=%d, ack=%d, loss=%d, rtt=%d)",
ackCount+lossCount, ackCount, lossCount, b.rttStats.SmoothedRTT().Milliseconds())
} }
return return
} }
@ -143,14 +144,16 @@ func (b *BrutalSender) updateAckRate(currentTimestamp int64) {
b.ackRate = minAckRate b.ackRate = minAckRate
if b.canPrintAckRate(currentTimestamp) { if b.canPrintAckRate(currentTimestamp) {
b.lastAckPrintTimestamp = currentTimestamp b.lastAckPrintTimestamp = currentTimestamp
b.debugPrint("ACK rate too low: %.2f, clamped to %.2f (total=%d, ack=%d, loss=%d)", rate, minAckRate, ackCount+lossCount, ackCount, lossCount) b.debugPrint("ACK rate too low: %.2f, clamped to %.2f (total=%d, ack=%d, loss=%d, rtt=%d)",
rate, minAckRate, ackCount+lossCount, ackCount, lossCount, b.rttStats.SmoothedRTT().Milliseconds())
} }
return return
} }
b.ackRate = rate b.ackRate = rate
if b.canPrintAckRate(currentTimestamp) { if b.canPrintAckRate(currentTimestamp) {
b.lastAckPrintTimestamp = currentTimestamp b.lastAckPrintTimestamp = currentTimestamp
b.debugPrint("ACK rate: %.2f (total=%d, ack=%d, loss=%d)", rate, ackCount+lossCount, ackCount, lossCount) b.debugPrint("ACK rate: %.2f (total=%d, ack=%d, loss=%d, rtt=%d)",
rate, ackCount+lossCount, ackCount, lossCount, b.rttStats.SmoothedRTT().Milliseconds())
} }
} }