GitHub/olcrtc
1
0
Fork 0
mirror of https://github.com/openlibrecommunity/olcrtc.git synced 2026-06-03 02:49:47 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix(peer): Improve WebSocket closure and reconnection handling

Browse Source
This commit is contained in:
zarazaex69
2026-04-09 19:25:48 +03:00
parent 7172b0756e
commit 02da40f0d2
1 changed files with 7 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
internal/telemost/peer.go
View File

@@ -487,7 +487,6 @@ func (p *Peer) sendLeave() {
log.Printf("Failed to send leave: %v", err)
} else {
log.Println("Sent leave message to server")
time.Sleep(500 * time.Millisecond)
}
}
@@ -499,6 +498,8 @@ func (p *Peer) Close() error {
log.Println("Sending leave message...")
p.sendLeave()
time.Sleep(1 * time.Second)
log.Println("Closing channels...")
if p.closeCh != nil {
select {
@@ -540,6 +541,7 @@ func (p *Peer) Close() error {
if p.ws != nil {
log.Println("Closing WebSocket...")
p.wsMu.Lock()
p.ws.WriteControl(websocket.CloseMessage, websocket.FormatCloseMessage(websocket.CloseNormalClosure, ""), time.Now().Add(time.Second))
p.ws.Close()
p.wsMu.Unlock()
}
@@ -600,6 +602,7 @@ func (p *Peer) reconnect(ctx context.Context) error {
log.Println("Reconnecting...")
p.sendLeave()
time.Sleep(500 * time.Millisecond)
close(p.keepAliveCh)
@@ -616,7 +619,10 @@ func (p *Peer) reconnect(ctx context.Context) error {
}
if p.ws != nil {
p.wsMu.Lock()
p.ws.WriteControl(websocket.CloseMessage, websocket.FormatCloseMessage(websocket.CloseNormalClosure, ""), time.Now().Add(time.Second))
p.ws.Close()
p.wsMu.Unlock()
}
time.Sleep(3 * time.Second)