Home
last modified time | relevance | path

Searched refs:AssociationState (Results 1 – 6 of 6) sorted by relevance

/webrtc/sctp/src/association/
H A Dmod.rs67 pub(crate) enum AssociationState { enum
78 impl From<u8> for AssociationState { implementation
79 fn from(v: u8) -> AssociationState { in from() argument
81 1 => AssociationState::CookieWait, in from()
82 2 => AssociationState::CookieEchoed, in from()
83 3 => AssociationState::Established, in from()
87 7 => AssociationState::ShutdownSent, in from()
88 _ => AssociationState::Closed, in from()
93 impl fmt::Display for AssociationState { implementation
96 AssociationState::Closed => "Closed", in fmt()
[all …]
H A Dassociation_internal.rs563 AssociationState::Established => { in gather_outbound()
573 AssociationState::ShutdownPending in gather_outbound()
574 | AssociationState::ShutdownSent in gather_outbound()
581 AssociationState::ShutdownAckSent => { in gather_outbound()
602 fn get_state(&self) -> AssociationState { in get_state() argument
617 if state != AssociationState::Closed in handle_init()
715 if state != AssociationState::CookieWait { in handle_init_ack()
833 AssociationState::Closed in handle_cookie_echo()
834 | AssociationState::CookieWait in handle_cookie_echo()
1484 state: AssociationState, in postprocess_sack() argument
[all …]
H A Dassociation_test.rs2082 assert_eq!(a0.get_state(), AssociationState::Established); in test_assoc_abort()
2083 assert_eq!(a1.get_state(), AssociationState::Established); in test_assoc_abort()
2094 assert_eq!(a0.get_state(), AssociationState::Established); in test_assoc_abort()
2095 assert_eq!(a1.get_state(), AssociationState::Closed); in test_assoc_abort()
/webrtc/sctp/src/association/association_internal/
H A Dassociation_internal_test.rs361 async fn handle_init_test(name: &str, initial_state: AssociationState, expect_err: bool) { in handle_init_test() argument
410 handle_init_test("normal", AssociationState::Closed, false).await; in test_assoc_handle_init()
414 AssociationState::Established, in test_assoc_handle_init()
421 AssociationState::ShutdownAckSent, in test_assoc_handle_init()
428 AssociationState::ShutdownPending, in test_assoc_handle_init()
435 AssociationState::ShutdownReceived, in test_assoc_handle_init()
442 AssociationState::ShutdownSent, in test_assoc_handle_init()
/webrtc/sctp/src/stream/
H A Dmod.rs4 use crate::association::AssociationState;
296 let state: AssociationState = self.state.load(Ordering::SeqCst).into(); in prepare_write()
298 AssociationState::ShutdownSent in prepare_write()
299 | AssociationState::ShutdownAckSent in prepare_write()
300 | AssociationState::ShutdownPending in prepare_write()
301 | AssociationState::ShutdownReceived => return Err(Error::ErrStreamClosed), in prepare_write()
479 fn get_state(&self) -> AssociationState { in get_state() argument
492 if state != AssociationState::Established { in send_payload_data()
505 if state != AssociationState::Established { in send_reset_request()
H A Dstream_test.rs81 Arc::new(AtomicU8::new(AssociationState::Established as u8)), in test_stream()
155 Arc::new(AtomicU8::new(AssociationState::Established as u8)), in test_poll_stream()