Searched refs:new_state (Results 1 – 6 of 6) sorted by relevance
| /webrtc/sctp/src/association/ |
| H A D | mod.rs | 602 fn set_state(&self, new_state: AssociationState) { in set_state()
603 let old_state = AssociationState::from(self.state.swap(new_state as u8, Ordering::SeqCst)); in set_state()
604 if new_state != old_state { in set_state()
609 new_state, in set_state()
|
| H A D | association_internal.rs | 589 pub(crate) fn set_state(&self, new_state: AssociationState) { in set_state()
590 let old_state = AssociationState::from(self.state.swap(new_state as u8, Ordering::SeqCst)); in set_state()
591 if new_state != old_state { in set_state()
596 new_state, in set_state()
|
| /webrtc/ice/src/agent/ |
| H A D | agent_internal.rs | 303 pub(crate) async fn update_connection_state(&self, new_state: ConnectionState) { in update_connection_state()
304 if self.connection_state.load(Ordering::SeqCst) != new_state as u8 { in update_connection_state()
306 if new_state == ConnectionState::Failed { in update_connection_state()
313 new_state in update_connection_state()
316 .store(new_state as u8, Ordering::SeqCst); in update_connection_state()
323 let _ = tx.send(new_state).await; in update_connection_state()
|
| H A D | agent_gather.rs | 180 new_state: GatheringState, in set_gathering_state()
182 if GatheringState::from(gathering_state.load(Ordering::SeqCst)) != new_state in set_gathering_state()
183 && new_state == GatheringState::Complete in set_gathering_state()
191 gathering_state.store(new_state as u8, Ordering::SeqCst); in set_gathering_state()
|
| /webrtc/webrtc/src/rtp_transceiver/rtp_receiver/ |
| H A D | mod.rs | 289 let new_state = *state_watch_rx.borrow(); in read_rtp() localVariable
291 if new_state == State::Stopped { in read_rtp()
294 current_state = new_state; in read_rtp()
|
| /webrtc/webrtc/src/peer_connection/ |
| H A D | mod.rs | 296 async fn do_signaling_state_change(&self, new_state: RTCSignalingState) { in do_signaling_state_change()
297 log::info!("signaling state changed to {}", new_state); in do_signaling_state_change()
300 f(new_state).await; in do_signaling_state_change()
|