| /webrtc/util/src/vnet/chunk_queue/ |
| H A D | chunk_queue_test.rs | 22 let ok = q.push(c.clone_to()).await; in test_chunk_queue() localVariable
23 assert!(ok, "should succeed"); in test_chunk_queue()
35 let ok = q.push(c.clone_to()).await; in test_chunk_queue() localVariable
36 assert!(ok, "should succeed"); in test_chunk_queue()
38 let ok = q.push(c.clone_to()).await; in test_chunk_queue() localVariable
39 assert!(!ok, "should fail"); in test_chunk_queue()
|
| /webrtc/sctp/src/timer/ |
| H A D | timer_test.rs | 43 let ok = rt.start(); in test_ack_timer_start_and_stop() localVariable
44 assert!(ok, "start() should succeed"); in test_ack_timer_start_and_stop()
62 let ok = rt.start(); in test_ack_timer_start_and_stop() localVariable
237 let ok = rt.start(30).await; in test_rtx_timer_callback_interval() localVariable
238 assert!(ok, "should be true"); in test_rtx_timer_callback_interval()
262 let ok = rt.start(interval).await; in test_rtx_timer_last_start_wins() localVariable
263 assert!(ok, "should be accepted"); in test_rtx_timer_last_start_wins()
265 assert!(!ok, "should be ignored"); in test_rtx_timer_last_start_wins()
344 let ok = rt.start(30).await; in test_rtx_timer_start_and_stop_in_atight_loop() localVariable
475 let ok = rt.start(20).await; in test_rtx_timer_stop_timer_that_is_not_running_is_noop() localVariable
[all …]
|
| /webrtc/turn/src/client/periodic_timer/ |
| H A D | periodic_timer_test.rs | 22 let ok = rt.start(dummy1).await; in test_periodic_timer() localVariable
23 assert!(ok, "should be true"); in test_periodic_timer()
28 let ok = rt.start(dummy2).await; in test_periodic_timer() localVariable
29 assert!(!ok, "start again is noop"); in test_periodic_timer()
|
| /webrtc/turn/src/client/binding/ |
| H A D | binding_test.rs | 77 let ok = m.delete_by_addr(&addr); in test_binding_manager_failure() localVariable
78 assert!(!ok, "should fail"); in test_binding_manager_failure()
79 let ok = m.delete_by_number(5555); in test_binding_manager_failure() localVariable
80 assert!(!ok, "should fail"); in test_binding_manager_failure()
|
| /webrtc/sctp/src/ |
| H A D | fuzz_artifact_test.rs | 25 crate::param::build_param(&Bytes::from(artifact)).ok(); in param_crash_artifacts()
41 crate::packet::Packet::unmarshal(&Bytes::from(artifact)).ok(); in packet_crash_artifacts()
|
| /webrtc/stun/src/textattrs/ |
| H A D | textattrs_test.rs | 24 let (s_attr, ok) = m.attributes.get(ATTR_SOFTWARE); in test_software_get_from()
25 assert!(ok, "sowfware attribute should be found"); in test_software_get_from()
179 let (r_attr, ok) = m.attributes.get(ATTR_REALM); in test_realm_get_from()
180 assert!(ok, "realm attribute should be found"); in test_realm_get_from()
252 let (r_attr, ok) = m.attributes.get(ATTR_NONCE); in test_nonce_get_from()
253 assert!(ok, "realm attribute should be found"); in test_nonce_get_from()
|
| /webrtc/util/src/replay_detector/ |
| H A D | replay_detector_test.rs | 268 let ok = det.check(*seq); in test_replay_detector() localVariable
269 if ok && valid[i] { in test_replay_detector()
|
| /webrtc/sctp/src/queue/ |
| H A D | payload_queue.rs | 64 let ok = self.chunk_map.contains_key(&p.tsn); in push() localVariable
65 if ok || sna32lte(p.tsn, cumulative_tsn) { in push()
|
| H A D | queue_test.rs | 114 let ok = pq.get_last_tsn_received(); in test_payload_queue_get_last_tsn_received() localVariable
115 assert!(ok.is_none(), "should be none"); in test_payload_queue_get_last_tsn_received()
117 let ok = pq.push(make_payload(20, 0), 0); in test_payload_queue_get_last_tsn_received() localVariable
118 assert!(ok, "should be true"); in test_payload_queue_get_last_tsn_received()
124 let ok = pq.push(make_payload(21, 0), 0); in test_payload_queue_get_last_tsn_received() localVariable
125 assert!(ok, "should be true"); in test_payload_queue_get_last_tsn_received()
131 let ok = pq.push(make_payload(19, 0), 0); in test_payload_queue_get_last_tsn_received() localVariable
132 assert!(ok, "should be true"); in test_payload_queue_get_last_tsn_received()
|
| H A D | reassembly_queue.rs | 174 let ok = cset.push(chunk); in push() localVariable
180 ok in push()
|
| /webrtc/rtcp/src/transport_feedbacks/rapid_resynchronization_request/ |
| H A D | rapid_resynchronization_request_test.rs | 105 let mut data = got.ok().unwrap(); in test_rapid_resynchronization_request_roundtrip()
|
| /webrtc/rtcp/src/payload_feedbacks/slice_loss_indication/ |
| H A D | slice_loss_indication_test.rs | 124 let mut data = got.ok().unwrap(); in test_slice_loss_indication_roundtrip()
|
| /webrtc/rtcp/src/payload_feedbacks/picture_loss_indication/ |
| H A D | picture_loss_indication_test.rs | 118 let mut data = got.ok().unwrap(); in test_picture_loss_indication_roundtrip()
|
| /webrtc/util/src/conn/ |
| H A D | conn_bridge.rs | 133 let ok = inverse(&mut stack); in push() localVariable
134 if ok { in push()
|
| /webrtc/rtcp/src/payload_feedbacks/full_intra_request/ |
| H A D | full_intra_request_test.rs | 164 let mut data = got.ok().unwrap(); in test_full_intra_request_round_trip()
|
| /webrtc/dtls/src/crypto/ |
| H A D | padding.rs | 116 assert_eq!(DtlsPadding::unpad(&block).ok(), Some(&[][..])); in one_of_the_padding_bytes_with_value_different_than_padding_length_is_unpadding_error()
|
| /webrtc/rtcp/src/sender_report/ |
| H A D | sender_report_test.rs | 242 let mut data = got.ok().unwrap(); in test_sender_report_roundtrip()
|
| /webrtc/rtcp/src/receiver_report/ |
| H A D | receiver_report_test.rs | 232 let mut data = got.ok().unwrap(); in test_receiver_report_roundtrip()
|
| /webrtc/rtcp/src/goodbye/ |
| H A D | goodbye_test.rs | 215 let mut data = got.ok().unwrap(); in test_goodbye_round_trip()
|
| /webrtc/rtcp/src/transport_feedbacks/transport_layer_nack/ |
| H A D | transport_layer_nack_test.rs | 123 let mut data = got.ok().unwrap(); in test_transport_layer_nack_roundtrip()
|
| /webrtc/rtcp/src/source_description/ |
| H A D | source_description_test.rs | 349 let mut data = got.ok().unwrap(); in test_source_description_roundtrip()
|
| /webrtc/stun/src/ |
| H A D | message.rs | 398 let (v, ok) = self.attributes.get(t); in get()
399 if ok { in get()
|
| /webrtc/rtcp/src/ |
| H A D | header.rs | 303 let data = got.ok().unwrap(); in test_header_roundtrip()
|
| /webrtc/dtls/src/conn/ |
| H A D | mod.rs | 931 let ok = ctx.replay_detector[h.epoch as usize].check(h.sequence_number); in handle_incoming_packet() localVariable
932 if !ok { in handle_incoming_packet()
|
| /webrtc/sctp/src/association/ |
| H A D | association_internal.rs | 513 let mut ok = true; in gather_outbound_shutdown_packets() localVariable
541 ok = false; in gather_outbound_shutdown_packets()
547 (raw_packets, ok) in gather_outbound_shutdown_packets()
|