Switch to write lock

Resolves #74
pion · Jul 15, 2019 · f95fbce · f95fbce
1 parent 2c92c03
commit f95fbce
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/client.go b/client.go
@@ -492,6 +492,8 @@ func (c *Client) handleChannelData(data []byte) error {
 		return fmt.Errorf("binding with channel %d not found", int(chData.Number))
 	}
 
+	c.log.Tracef("channel data received from %s (ch=%d)", addr.String(), int(chData.Number))
+
 	relayedConn.HandleInbound(chData.Data, addr)
 	return nil
 }

diff --git a/internal/client/transaction.go b/internal/client/transaction.go
@@ -67,8 +67,8 @@ func (t *Transaction) StartRtxTimer(onTimeout func(trKey string, nRtx int32)) {
 
 // StopRtxTimer stop the transaction timer
 func (t *Transaction) StopRtxTimer() {
-	t.mutex.RLock()
-	defer t.mutex.RUnlock()
+	t.mutex.Lock()
+	defer t.mutex.Unlock()
 
 	if t != nil {
 		t.timer.Stop()