Fix reconnection (#301)

@@ -36,7 +36,6 @@ import io.livekit.android.webrtc.isConnected
 import io.livekit.android.webrtc.isDisconnected
 import io.livekit.android.webrtc.isDisconnected
 import io.livekit.android.webrtc.toProtoSessionDescription
 import io.livekit.android.webrtc.toProtoSessionDescription
 import kotlinx.coroutines.*
 import kotlinx.coroutines.*
-import kotlinx.coroutines.sync.Mutex
 import livekit.LivekitModels
 import livekit.LivekitModels
 import livekit.LivekitRtc
 import livekit.LivekitRtc
 import livekit.LivekitRtc.JoinResponse
 import livekit.LivekitRtc.JoinResponse
@@ -102,7 +101,6 @@ internal constructor(
 
 
     internal var reconnectType: ReconnectType = ReconnectType.DEFAULT
     internal var reconnectType: ReconnectType = ReconnectType.DEFAULT
     private var reconnectingJob: Job? = null
     private var reconnectingJob: Job? = null
-    private val reconnectingLock = Mutex()
     private var fullReconnectOnNext = false
     private var fullReconnectOnNext = false
 
 
     private val pendingTrackResolvers: MutableMap<String, Continuation<LivekitModels.TrackInfo>> =
     private val pendingTrackResolvers: MutableMap<String, Continuation<LivekitModels.TrackInfo>> =
@@ -301,6 +299,7 @@ internal constructor(
         if (isClosed) {
         if (isClosed) {
             return
             return
         }
         }
+        LKLog.v { "Close - $reason" }
         isClosed = true
         isClosed = true
         hasPublished = false
         hasPublished = false
         sessionUrl = null
         sessionUrl = null
@@ -343,12 +342,14 @@ internal constructor(
     /**
     /**
      * reconnect Signal and PeerConnections
      * reconnect Signal and PeerConnections
      */
      */
+    @Synchronized
     internal fun reconnect() {
     internal fun reconnect() {
-        val didLock = reconnectingLock.tryLock()
-        if (!didLock) {
+        if (reconnectingJob?.isActive == true) {
+            LKLog.d { "Reconnection is already in progress" }
             return
             return
         }
         }
         if (this.isClosed) {
         if (this.isClosed) {
+            LKLog.d { "Skip reconnection - engine is closed" }
             return
             return
         }
         }
         val url = sessionUrl
         val url = sessionUrl
@@ -463,7 +464,6 @@ internal constructor(
             if (reconnectingJob == job) {
             if (reconnectingJob == job) {
                 reconnectingJob = null
                 reconnectingJob = null
             }
             }
-            reconnectingLock.unlock()
         }
         }
     }
     }