GitHub/olcrtc
1
0
Fork 0
mirror of https://github.com/openlibrecommunity/olcrtc.git synced 2026-06-08 13:24:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix(peer): Improve error handling and logging in sendLeave and Close

Browse Source
This commit is contained in:
zarazaex69
2026-04-09 19:23:39 +03:00
parent 43b50518dd
commit 7172b0756e
1 changed files with 15 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
internal/telemost/peer.go
View File

@@ -474,6 +474,7 @@ func (p *Peer) sendLeave() {
defer p.wsMu.Unlock()
if p.ws == nil {
log.Println("WebSocket already closed, cannot send leave")
return
}
@@ -481,9 +482,12 @@ func (p *Peer) sendLeave() {
"uid": uuid.New().String(),
"leave": map[string]interface{}{},
}
if err := p.ws.WriteJSON(leave); err == nil {
if err := p.ws.WriteJSON(leave); err != nil {
log.Printf("Failed to send leave: %v", err)
} else {
log.Println("Sent leave message to server")
time.Sleep(200 * time.Millisecond)
time.Sleep(500 * time.Millisecond)
}
}
@@ -492,8 +496,10 @@ func (p *Peer) Close() error {
p.sendQueueClosed.Store(true)
log.Println("Sending leave message...")
p.sendLeave()
log.Println("Closing channels...")
if p.closeCh != nil {
select {
case <-p.closeCh:
@@ -502,13 +508,6 @@ func (p *Peer) Close() error {
}
}
if p.ws != nil {
log.Println("Closing WebSocket...")
p.wsMu.Lock()
p.ws.Close()
p.wsMu.Unlock()
}
log.Println("Waiting for goroutines...")
done := make(chan struct{})
go func() {
@@ -538,6 +537,13 @@ func (p *Peer) Close() error {
p.pcSub.Close()
}
if p.ws != nil {
log.Println("Closing WebSocket...")
p.wsMu.Lock()
p.ws.Close()
p.wsMu.Unlock()
}
log.Println("Peer closed")
return nil
}