GitHub/olcrtc
1
0
Fork 0
mirror of https://github.com/openlibrecommunity/olcrtc.git synced 2026-06-05 11:59:45 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix(client): Move WaitForData call into loop and reduce timeout

Browse Source
This commit is contained in:
zarazaex69
2026-04-09 18:38:25 +03:00
parent da00d6158f
commit 503b0549e6
1 changed files with 10 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
internal/client/client.go
View File

@@ -269,10 +269,11 @@ func (c *Client) handleSOCKS5(conn net.Conn) {
go func() {
defer close(streamClosed)
dataReady := c.mux.WaitForData(sid)
defer c.mux.CleanupDataChannel(sid)
for {
dataReady := c.mux.WaitForData(sid)
select {
case <-done:
return
@@ -290,7 +291,14 @@ func (c *Client) handleSOCKS5(conn net.Conn) {
if c.mux.StreamClosed(sid) {
return
}
case <-time.After(100 * time.Millisecond):
case <-time.After(10 * time.Millisecond):
data := c.mux.ReadStream(sid)
if len(data) > 0 {
if _, err := conn.Write(data); err != nil {
return
}
}
if c.mux.StreamClosed(sid) {
return
}