Schedule PeerConnection dispose to avoid race conditions (#316)

@@ -36,7 +36,10 @@ import io.livekit.android.webrtc.getRtps
 import io.livekit.android.webrtc.isConnected
 import io.livekit.android.webrtc.isConnected
 import kotlinx.coroutines.CoroutineDispatcher
 import kotlinx.coroutines.CoroutineDispatcher
 import kotlinx.coroutines.CoroutineScope
 import kotlinx.coroutines.CoroutineScope
+import kotlinx.coroutines.GlobalScope
 import kotlinx.coroutines.SupervisorJob
 import kotlinx.coroutines.SupervisorJob
+import kotlinx.coroutines.delay
+import kotlinx.coroutines.launch
 import kotlinx.coroutines.runBlocking
 import kotlinx.coroutines.runBlocking
 import kotlinx.coroutines.sync.Mutex
 import kotlinx.coroutines.sync.Mutex
 import org.webrtc.*
 import org.webrtc.*
@@ -263,9 +266,16 @@ constructor(
     suspend fun close() {
     suspend fun close() {
         withNotClosedLock {
         withNotClosedLock {
             isClosed.set(true)
             isClosed.set(true)
+            peerConnection.close()
+
+            // Really ugly stop gap measure to avoid race conditions
+            // TODO: Properly lock any PeerConnection resources to prevent usage.
+            GlobalScope.launch {
+                delay(10L * 1000)
                 peerConnection.dispose()
                 peerConnection.dispose()
             }
             }
         }
         }
+    }
 
 
     fun updateRTCConfig(config: RTCConfiguration) {
     fun updateRTCConfig(config: RTCConfiguration) {
         runBlocking {
         runBlocking {

@@ -363,6 +363,7 @@ internal constructor(
 
 
             val reconnectStartTime = SystemClock.elapsedRealtime()
             val reconnectStartTime = SystemClock.elapsedRealtime()
             for (retries in 0 until MAX_RECONNECT_RETRIES) {
             for (retries in 0 until MAX_RECONNECT_RETRIES) {
+                ensureActive()
                 if (retries != 0) {
                 if (retries != 0) {
                     yield()
                     yield()
                 }
                 }
@@ -427,6 +428,7 @@ internal constructor(
                     }
                     }
                 }
                 }
 
 
+                ensureActive()
                 if (isClosed) {
                 if (isClosed) {
                     LKLog.v { "RTCEngine closed, aborting reconnection" }
                     LKLog.v { "RTCEngine closed, aborting reconnection" }
                     break
                     break
@@ -444,6 +446,7 @@ internal constructor(
                     }
                     }
                 }
                 }
 
 
+                ensureActive()
                 if (isClosed) {
                 if (isClosed) {
                     LKLog.v { "RTCEngine closed, aborting reconnection" }
                     LKLog.v { "RTCEngine closed, aborting reconnection" }
                     break
                     break
@@ -458,6 +461,7 @@ internal constructor(
                     delay(100)
                     delay(100)
                 }
                 }
 
 
+                ensureActive()
                 if (isClosed) {
                 if (isClosed) {
                     LKLog.v { "RTCEngine closed, aborting reconnection" }
                     LKLog.v { "RTCEngine closed, aborting reconnection" }
                     break
                     break