diff --git a/internal/client/client.go b/internal/client/client.go
index 79be2fe..a738b27 100644
--- a/internal/client/client.go
+++ b/internal/client/client.go
@@ -65,7 +65,7 @@ func Run(roomURL, keyHex string, socksPort int) error {
 	c.peer = peer
 
 	peer.SetReconnectCallback(func(dc *webrtc.DataChannel) {
-		log.Println("Updating DataChannel after reconnect")
+		log.Println("Client reconnected - resetting multiplexer state")
 		c.mux.Reset()
 		c.mux.UpdateSendFunc(func(frame []byte) error {
 			encrypted, err := c.cipher.Encrypt(frame)
@@ -74,6 +74,7 @@ func Run(roomURL, keyHex string, socksPort int) error {
 			}
 			return dc.Send(encrypted)
 		})
+		log.Println("Client multiplexer reset complete")
 	})
 
 	log.Println("Connecting to Telemost...")
diff --git a/internal/server/server.go b/internal/server/server.go
index a99d4d8..8c3aca4 100644
--- a/internal/server/server.go
+++ b/internal/server/server.go
@@ -72,7 +72,7 @@ func Run(roomURL, keyHex string) error {
 	s.peer = peer
 
 	peer.SetReconnectCallback(func(dc *webrtc.DataChannel) {
-		log.Println("Updating DataChannel after reconnect")
+		log.Println("Server reconnected - resetting multiplexer state")
 		s.mux.Reset()
 		s.mux.UpdateSendFunc(func(frame []byte) error {
 			encrypted, err := s.cipher.Encrypt(frame)
@@ -81,6 +81,7 @@ func Run(roomURL, keyHex string) error {
 			}
 			return dc.Send(encrypted)
 		})
+		log.Println("Server multiplexer reset complete")
 	})
 
 	log.Println("Connecting to Telemost...")