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(server): Add nil checks and cleanup stale connections

Browse Source
This commit is contained in:
zarazaex69
2026-04-09 16:42:10 +03:00
parent 2b65b8c238
commit d608a8a229
1 changed files with 7 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
internal/server/server.go
View File

@@ -131,7 +131,7 @@ func (s *Server) run() error {
conn, exists := s.connections[sid]
s.connMu.RUnlock()
if exists {
if exists && conn != nil {
if _, err := conn.Write(data); err != nil {
s.mux.CloseStream(sid)
conn.Close()
@@ -142,6 +142,11 @@ func (s *Server) run() error {
} else {
var req ConnectRequest
if err := json.Unmarshal(data, &req); err == nil && req.Cmd == "connect" {
s.connMu.Lock()
if oldConn, exists := s.connections[sid]; exists && oldConn != nil {
oldConn.Close()
}
s.connMu.Unlock()
go s.handleConnect(sid, req)
}
}
@@ -152,7 +157,7 @@ func (s *Server) run() error {
conn, exists := s.connections[sid]
s.connMu.RUnlock()
if exists {
if exists && conn != nil {
conn.Close()
s.connMu.Lock()
delete(s.connections, sid)