diff --git a/amethyst/src/main/java/com/vitorpamplona/amethyst/service/call/CallController.kt b/amethyst/src/main/java/com/vitorpamplona/amethyst/service/call/CallController.kt index be655c05f..5d90caf49 100644 --- a/amethyst/src/main/java/com/vitorpamplona/amethyst/service/call/CallController.kt +++ b/amethyst/src/main/java/com/vitorpamplona/amethyst/service/call/CallController.kt @@ -729,12 +729,17 @@ class CallController( private fun onPeerDisconnected(peerPubKey: HexKey) { Log.d(TAG) { "Peer ${peerPubKey.take(8)} disconnected (ICE FAILED)" } - // If all peers disconnected, hang up - val sessionStates = peerSessions.map { (key, ps) -> "${key.take(8)}=${ps.session.getSignalingState()}" } + // If all peers disconnected, hang up. + // A session counts as "not active" if it is the one that just failed, + // if it was already closed, or if it never received a remote description + // (e.g. the peer rejected before answering). + val sessionStates = peerSessions.map { (key, ps) -> "${key.take(8)}=${ps.session.getSignalingState()},remoteSet=${ps.remoteDescriptionSet.get()}" } Log.d(TAG) { "onPeerDisconnected: checking remaining sessions: $sessionStates" } val allDisconnected = peerSessions.keys.all { key -> - key == peerPubKey || peerSessions[key]?.session?.getSignalingState() == PeerConnection.SignalingState.CLOSED + key == peerPubKey || + peerSessions[key]?.session?.getSignalingState() == PeerConnection.SignalingState.CLOSED || + peerSessions[key]?.remoteDescriptionSet?.get() != true } if (allDisconnected) { Log.d(TAG) { "onPeerDisconnected: all peers disconnected, hanging up" } diff --git a/commons/src/commonMain/kotlin/com/vitorpamplona/amethyst/commons/call/CallManager.kt b/commons/src/commonMain/kotlin/com/vitorpamplona/amethyst/commons/call/CallManager.kt index d7bde9a2b..055f664e9 100644 --- a/commons/src/commonMain/kotlin/com/vitorpamplona/amethyst/commons/call/CallManager.kt +++ b/commons/src/commonMain/kotlin/com/vitorpamplona/amethyst/commons/call/CallManager.kt @@ -349,6 +349,7 @@ class CallManager( transitionToEnded(current.callId, current.peerPubKeys, EndReason.PEER_REJECTED) } else { _state.value = current.copy(peerPubKeys = remaining) + onPeerLeft?.invoke(rejectingPeer) } } @@ -356,12 +357,14 @@ class CallManager( if (callId != current.callId) return _state.value = current.copy(pendingPeerPubKeys = current.pendingPeerPubKeys - rejectingPeer) + onPeerLeft?.invoke(rejectingPeer) } is CallState.Connected -> { if (callId != current.callId) return _state.value = current.copy(pendingPeerPubKeys = current.pendingPeerPubKeys - rejectingPeer) + onPeerLeft?.invoke(rejectingPeer) } is CallState.IncomingCall -> {