Skip to content

Commit 668445c

Browse files
committed
fix on_negotiation never called bug
1 parent f9426a6 commit 668445c

File tree

1 file changed

+7
-6
lines changed

1 file changed

+7
-6
lines changed

src/peer_connection/mod.rs

Lines changed: 7 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -328,14 +328,15 @@ impl RTCPeerConnection {
328328
}
329329

330330
async fn after_negotiation_needed_op(params: NegotiationNeededParams) -> bool {
331-
if params.negotiation_needed_state.load(Ordering::SeqCst)
332-
== NegotiationNeededState::Queue as u8
333-
{
331+
let old_negotiation_needed_state = params.negotiation_needed_state.load(Ordering::SeqCst);
332+
333+
params
334+
.negotiation_needed_state
335+
.store(NegotiationNeededState::Empty as u8, Ordering::SeqCst);
336+
337+
if old_negotiation_needed_state == NegotiationNeededState::Queue as u8 {
334338
RTCPeerConnection::do_negotiation_needed_inner(&params)
335339
} else {
336-
params
337-
.negotiation_needed_state
338-
.store(NegotiationNeededState::Empty as u8, Ordering::SeqCst);
339340
false
340341
}
341342
}

0 commit comments

Comments
 (0)