SagerNet/sing
1
0
Fork 0
mirror of https://github.com/SagerNet/sing.git synced 2025-04-05 12:57:38 +03:00
Code Issues Projects Releases Packages Wiki Activity Actions

Fix calculate headroom

Browse source
This commit is contained in:
世界 2022-09-30 21:02:14 +08:00
parent 9a83e35b71
commit cb9b17d6a4
No known key found for this signature in database
GPG key ID: CD109927C34A63C4
1 changed files with 6 additions and 8 deletions
Download patch file Download diff file Expand all files Collapse all files

14
common/network/thread.go
View file

@ -68,12 +68,11 @@ func CalculateFrontHeadroom(writer any) int {
if headroomWriter, needHeadroom := writer.(FrontHeadroom); needHeadroom {
headroom = headroomWriter.FrontHeadroom()
}
if upstream, hasUpstream := writer.(common.WithUpstream); hasUpstream {
if upstreamWriter, hasUpstreamWriter := writer.(WithUpstreamWriter); hasUpstreamWriter {
headroom += CalculateFrontHeadroom(upstreamWriter.UpstreamWriter())
} else if upstream, hasUpstream := writer.(common.WithUpstream); hasUpstream {
headroom += CalculateFrontHeadroom(upstream.Upstream())
}
if upstream, hasUpstream := writer.(WithUpstreamWriter); hasUpstream {
headroom += CalculateFrontHeadroom(upstream.UpstreamWriter())
}
return headroom
}
@ -82,12 +81,11 @@ func CalculateRearHeadroom(writer any) int {
if headroomWriter, needHeadroom := writer.(RearHeadroom); needHeadroom {
headroom = headroomWriter.RearHeadroom()
}
if upstream, hasUpstream := writer.(common.WithUpstream); hasUpstream {
if upstreamWriter, hasUpstreamWriter := writer.(WithUpstreamWriter); hasUpstreamWriter {
headroom += CalculateRearHeadroom(upstreamWriter.UpstreamWriter())
} else if upstream, hasUpstream := writer.(common.WithUpstream); hasUpstream {
headroom += CalculateRearHeadroom(upstream.Upstream())
}
if upstream, hasUpstream := writer.(WithUpstreamWriter); hasUpstream {
headroom += CalculateRearHeadroom(upstream.UpstreamWriter())
}
return headroom
}