fix afterClosed call more than once

inlivedev · Jun 14, 2024 · 787cb1e · 787cb1e
1 parent 635db69
commit 787cb1e
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/client.go b/client.go
@@ -1034,10 +1034,14 @@ func (c *Client) processPendingTracks() {
 
 // make sure to call this when client's done to clean everything
 func (c *Client) afterClosed() {
+	c.mu.Lock()
 	state := c.state.Load()
-	if state != ClientStateEnded {
-		c.state.Store(ClientStateEnded)
+	if state == ClientStateEnded {
+		return
 	}
+	c.mu.Unlock()
+
+	c.state.Store(ClientStateEnded)
 
 	c.internalDataChannel.Close()