Home
last modified time | relevance | path

Searched refs:Box (Results 1 – 25 of 199) sorted by relevance

12345678

/webrtc/srtp/src/
H A Doption.rs3 pub type ContextOption = Box<dyn (Fn() -> Box<dyn ReplayDetector + Send + 'static>) + Send + Sync>;
10 Box::new(move || -> Box<dyn ReplayDetector + Send> { in srtp_replay_protection()
11 Box::new(WrappedSlidingWindowDetector::new( in srtp_replay_protection()
20 Box::new(move || -> Box<dyn ReplayDetector + Send> { in srtcp_replay_protection()
21 Box::new(WrappedSlidingWindowDetector::new( in srtcp_replay_protection()
30 Box::new(|| -> Box<dyn ReplayDetector + Send> { Box::<NoOpReplayDetector>::default() }) in srtp_no_replay_protection()
35 Box::new(|| -> Box<dyn ReplayDetector + Send> { Box::<NoOpReplayDetector>::default() }) in srtcp_no_replay_protection()
/webrtc/rtcp/src/compound_packet/
H A Dcompound_packet_test.rs128 Box::new(cname.clone()), in test_valid_packet()
136 Box::new(cname.clone()), in test_valid_packet()
144 Box::new(cname.clone()), in test_valid_packet()
153 Box::new(cname), in test_valid_packet()
201 Box::new(cname.clone()), in test_cname()
211 Box::new(cname.clone()), in test_cname()
220 Box::new(cname.clone()), in test_cname()
230 Box::new(cname.clone()), in test_cname()
239 Box::new(cname), in test_cname()
288 Box::new(cname), in test_compound_packet_roundtrip()
[all …]
/webrtc/dtls/src/cipher_suite/
H A Dmod.rs156 Ok(Box::new(CipherSuiteAes256CbcSha::new(true))) in cipher_suite_for_id()
159 Ok(Box::new(CipherSuiteAes256CbcSha::new(false))) in cipher_suite_for_id()
177 Box::new(CipherSuiteAes128GcmSha256::new(false)), in default_cipher_suites()
178 Box::new(CipherSuiteAes256CbcSha::new(false)), in default_cipher_suites()
179 Box::new(CipherSuiteAes128GcmSha256::new(true)), in default_cipher_suites()
180 Box::new(CipherSuiteAes256CbcSha::new(true)), in default_cipher_suites()
188 Box::new(CipherSuiteAes128GcmSha256::new(false)), in all_cipher_suites()
189 Box::new(CipherSuiteAes128GcmSha256::new(true)), in all_cipher_suites()
190 Box::new(CipherSuiteAes256CbcSha::new(false)), in all_cipher_suites()
191 Box::new(CipherSuiteAes256CbcSha::new(true)), in all_cipher_suites()
[all …]
/webrtc/rtcp/src/
H A Dpacket.rs26 fn cloned(&self) -> Box<dyn Packet + Send + Sync>; in cloned()
35 impl Clone for Box<dyn Packet + Send + Sync> { implementation
36 fn clone(&self) -> Box<dyn Packet + Send + Sync> { in clone()
92 let p: Box<dyn Packet + Send + Sync> = match h.packet_type { in unmarshaller()
102 _ => Box::new(RawPacket::unmarshal(&mut in_packet)?), in unmarshaller()
112 _ => Box::new(RawPacket::unmarshal(&mut in_packet)?), in unmarshaller()
198 Box::new(a), in test_packet_unmarshal()
199 Box::new(b), in test_packet_unmarshal()
200 Box::new(c), in test_packet_unmarshal()
201 Box::new(d), in test_packet_unmarshal()
[all …]
/webrtc/sctp/src/param/
H A Dmod.rs41 fn clone_to(&self) -> Box<dyn Param + Send + Sync>; in clone_to()
52 impl Clone for Box<dyn Param + Send + Sync> { implementation
53 fn clone(&self) -> Box<dyn Param + Send + Sync> { in clone()
58 pub(crate) fn build_param(raw_param: &Bytes) -> Result<Box<dyn Param + Send + Sync>> { in build_param()
66 ParamType::SupportedExt => Ok(Box::new(ParamSupportedExtensions::unmarshal(raw_param)?)), in build_param()
67 ParamType::Random => Ok(Box::new(ParamRandom::unmarshal(raw_param)?)), in build_param()
69 ParamType::ChunkList => Ok(Box::new(ParamChunkList::unmarshal(raw_param)?)), in build_param()
70 ParamType::StateCookie => Ok(Box::new(ParamStateCookie::unmarshal(raw_param)?)), in build_param()
71 ParamType::HeartbeatInfo => Ok(Box::new(ParamHeartbeatInfo::unmarshal(raw_param)?)), in build_param()
73 ParamType::ReconfigResp => Ok(Box::new(ParamReconfigResponse::unmarshal(raw_param)?)), in build_param()
[all …]
/webrtc/mdns/src/message/
H A Dmessage_test.rs121 body: Some(Box::new(SoaResource { in large_test_msg()
149 body: Some(Box::new(MxResource { in large_test_msg()
177 body: Some(Box::new(NsResource { in large_test_msg()
466 let want = Box::new(SrvResource { in test_srv_pack_unpack()
765 body: Some(Box::new(TxtResource { in test_very_long_txt()
835 Box::new(|| -> Builder { in test_start_error()
845 Box::new(|| -> Builder { in test_start_error()
970 Box::new(|| -> Builder { in test_builder_resource_error()
980 Box::new(|| -> Builder { in test_builder_resource_error()
990 Box::new(|| -> Builder { in test_builder_resource_error()
[all …]
/webrtc/webrtc/src/data_channel/
H A Ddata_channel_test.rs205 Box::pin(async move { in test_data_channel_send_before_signaling()
225 Box::pin(async move { in test_data_channel_send_before_signaling()
235 Box::pin(async move { in test_data_channel_send_before_signaling()
261 Box::pin(async move { in test_data_channel_send_after_connected()
287 Box::pin(async move { in test_data_channel_send_after_connected()
547 Box::pin(async {}) in test_data_channel_parameters_negotiated_exchange()
555 Box::pin(async {}) in test_data_channel_parameters_negotiated_exchange()
888 dc.on_message(Box::new(|_msg: DataChannelMessage| Box::pin(async {}))); in test_data_channel_buffered_amount_set_before_open()
898 Box::pin(async {}) in test_data_channel_buffered_amount_set_before_open()
989 dc.on_message(Box::new(|_msg: DataChannelMessage| Box::pin(async {}))); in test_data_channel_buffered_amount_set_after_open()
[all …]
/webrtc/interceptor/src/mock/
H A Dmock_interceptor.rs6 pub type BindRtcpReaderFn = Box<
10 -> Pin<Box<dyn Future<Output = Arc<dyn RTCPReader + Send + Sync>> + Send + Sync>>)
15 pub type BindRtcpWriterFn = Box<
19 -> Pin<Box<dyn Future<Output = Arc<dyn RTCPWriter + Send + Sync>> + Send + Sync>>)
23 pub type BindLocalStreamFn = Box<
27 ) -> Pin<Box<dyn Future<Output = Arc<dyn RTPWriter + Send + Sync>> + Send + Sync>>)
32 Box<dyn (Fn(&StreamInfo) -> Pin<Box<dyn Future<Output = ()> + Send + Sync>>) + Send + Sync>;
33 pub type BindRemoteStreamFn = Box<
37 ) -> Pin<Box<dyn Future<Output = Arc<dyn RTPReader + Send + Sync>> + Send + Sync>>)
42 Box<dyn (Fn(&StreamInfo) -> Pin<Box<dyn Future<Output = ()> + Send + Sync>>) + Send + Sync>;
[all …]
/webrtc/examples/examples/data-channels-flow-control/
H A Ddata-channels-flow-control.rs75 dc.on_open(Box::new(|| { in create_requester()
76 Box::pin(async move { in create_requester()
103 Box::pin(async move { in create_requester()
119 Box::pin(async move { in create_responder()
123 dc.on_open(Box::new(move || { in create_responder()
124 Box::pin(async { in create_responder()
153 Box::pin(async move { in create_responder()
174 Box::pin(async move { in main()
191 Box::pin(async move { in main()
208 Box::pin(async move { in main()
[all …]
/webrtc/sctp/src/
H A Dpacket.rs60 pub(crate) chunks: Vec<Box<dyn Chunk + Send + Sync>>,
117 let c: Box<dyn Chunk + Send + Sync> = match ct { in unmarshal()
118 CT_INIT => Box::new(ChunkInit::unmarshal(&raw.slice(offset..))?), in unmarshal()
119 CT_INIT_ACK => Box::new(ChunkInit::unmarshal(&raw.slice(offset..))?), in unmarshal()
120 CT_ABORT => Box::new(ChunkAbort::unmarshal(&raw.slice(offset..))?), in unmarshal()
125 CT_SACK => Box::new(ChunkSelectiveAck::unmarshal(&raw.slice(offset..))?), in unmarshal()
126 CT_RECONFIG => Box::new(ChunkReconfig::unmarshal(&raw.slice(offset..))?), in unmarshal()
128 CT_ERROR => Box::new(ChunkError::unmarshal(&raw.slice(offset..))?), in unmarshal()
129 CT_SHUTDOWN => Box::new(ChunkShutdown::unmarshal(&raw.slice(offset..))?), in unmarshal()
132 Box::new(ChunkShutdownComplete::unmarshal(&raw.slice(offset..))?) in unmarshal()
[all …]
/webrtc/rtp/src/packetizer/
H A Dmod.rs16 fn clone_to(&self) -> Box<dyn Payloader + Send + Sync>; in clone_to()
19 impl Clone for Box<dyn Payloader + Send + Sync> { implementation
20 fn clone(&self) -> Box<dyn Payloader + Send + Sync> { in clone()
30 fn clone_to(&self) -> Box<dyn Packetizer + Send + Sync>; in clone_to()
33 impl Clone for Box<dyn Packetizer + Send + Sync> { implementation
34 fn clone(&self) -> Box<dyn Packetizer + Send + Sync> { in clone()
63 pub(crate) payloader: Box<dyn Payloader + Send + Sync>,
64 pub(crate) sequencer: Box<dyn Sequencer + Send + Sync>,
88 payloader: Box<dyn Payloader + Send + Sync>, in new_packetizer()
89 sequencer: Box<dyn Sequencer + Send + Sync>, in new_packetizer()
[all …]
H A Dpacketizer_test.rs11 let g722 = Box::new(g7xx::G722Payloader {}); in test_packetizer()
12 let seq = Box::new(new_random_sequencer()); in test_packetizer()
36 let g722 = Box::new(g7xx::G722Payloader {}); in test_packetizer_abs_send_time()
37 let sequencer = Box::new(new_fixed_sequencer(1234)); in test_packetizer_abs_send_time()
95 let g722 = Box::new(g7xx::G722Payloader {}); in test_packetizer_timestamp_rollover_does_not_panic()
96 let seq = Box::new(new_random_sequencer()); in test_packetizer_timestamp_rollover_does_not_panic()
/webrtc/rtcp/src/extended_report/
H A Dextended_report_test.rs7 Box::new(LossRLEReportBlock { in decoded_packet()
16 Box::new(DuplicateRLEReportBlock { in decoded_packet()
25 Box::new(PacketReceiptTimesReportBlock { in decoded_packet()
33 Box::new(ReceiverReferenceTimeReportBlock { in decoded_packet()
36 Box::new(DLRRReportBlock { in decoded_packet()
55 Box::new(StatisticsSummaryReportBlock { in decoded_packet()
75 Box::new(VoIPMetricsReportBlock { in decoded_packet()
H A Dmod.rs159 pub reports: Vec<Box<dyn Packet + Send + Sync>>,
207 fn cloned(&self) -> Box<dyn Packet + Send + Sync> { in cloned()
208 Box::new(self.clone()) in cloned()
273 let report: Box<dyn Packet + Send + Sync> = match block_type { in unmarshal()
274 BlockType::LossRLE => Box::new(LossRLEReportBlock::unmarshal(raw_packet)?), in unmarshal()
276 Box::new(DuplicateRLEReportBlock::unmarshal(raw_packet)?) in unmarshal()
279 Box::new(PacketReceiptTimesReportBlock::unmarshal(raw_packet)?) in unmarshal()
282 Box::new(ReceiverReferenceTimeReportBlock::unmarshal(raw_packet)?) in unmarshal()
284 BlockType::DLRR => Box::new(DLRRReportBlock::unmarshal(raw_packet)?), in unmarshal()
286 Box::new(StatisticsSummaryReportBlock::unmarshal(raw_packet)?) in unmarshal()
[all …]
/webrtc/turn/src/client/
H A Drelay_conn.rs299 Box::new(peer_addr), in send_to()
300 Box::new(FINGERPRINT), in send_to()
472 Box::new(obs.username()), in refresh_allocation()
473 Box::new(obs.realm()), in refresh_allocation()
474 Box::new(self.nonce.clone()), in refresh_allocation()
476 Box::new(FINGERPRINT), in refresh_allocation()
550 Box::new(obs.username()), in bind()
551 Box::new(obs.realm()), in bind()
552 Box::new(nonce), in bind()
553 Box::new(integrity), in bind()
[all …]
/webrtc/interceptor/src/
H A Dlib.rs85 pub type RTPWriterBoxFn = Box<
89 ) -> Pin<Box<dyn Future<Output = Result<usize>> + Send + Sync>>)
110 pub type RTPReaderBoxFn = Box<
114 ) -> Pin<Box<dyn Future<Output = Result<(usize, Attributes)>> + Send + Sync>>)
134 pkts: &[Box<dyn rtcp::packet::Packet + Send + Sync>], in write()
139 pub type RTCPWriterBoxFn = Box<
141 &[Box<dyn rtcp::packet::Packet + Send + Sync>],
143 ) -> Pin<Box<dyn Future<Output = Result<usize>> + Send + Sync>>)
155 pkts: &[Box<dyn rtcp::packet::Packet + Send + Sync>], in write()
169 pub type RTCPReaderBoxFn = Box<
[all …]
/webrtc/mdns/src/message/resource/
H A Dmod.rs42 pub body: Option<Box<dyn ResourceBody>>,
255 ) -> Result<(Box<dyn ResourceBody>, usize)> { in unpack_resource_body()
256 let mut rb: Box<dyn ResourceBody> = match typ { in unpack_resource_body()
257 DnsType::A => Box::<AResource>::default(), in unpack_resource_body()
258 DnsType::Ns => Box::<NsResource>::default(), in unpack_resource_body()
260 DnsType::Soa => Box::<SoaResource>::default(), in unpack_resource_body()
261 DnsType::Ptr => Box::<PtrResource>::default(), in unpack_resource_body()
262 DnsType::Mx => Box::<MxResource>::default(), in unpack_resource_body()
263 DnsType::Txt => Box::<TxtResource>::default(), in unpack_resource_body()
265 DnsType::Srv => Box::<SrvResource>::default(), in unpack_resource_body()
[all …]
/webrtc/webrtc/src/rtp_transceiver/fmtp/h264/
H A Dh264_test.rs5 let tests: Vec<(&str, &str, Box<dyn Fmtp>)> = vec![ in test_h264_fmtp_parse()
9 Box::new(H264Fmtp { in test_h264_fmtp_parse()
19 Box::new(H264Fmtp { in test_h264_fmtp_parse()
29 Box::new(H264Fmtp { in test_h264_fmtp_parse()
42 Box::new(H264Fmtp { in test_h264_fmtp_parse()
/webrtc/rtp/src/
H A Dsequence.rs9 fn clone_to(&self) -> Box<dyn Sequencer + Send + Sync>; in clone_to()
12 impl Clone for Box<dyn Sequencer + Send + Sync> { implementation
13 fn clone(&self) -> Box<dyn Sequencer + Send + Sync> { in clone()
69 fn clone_to(&self) -> Box<dyn Sequencer + Send + Sync> { in clone_to()
70 Box::new(self.clone()) in clone_to()
/webrtc/util/src/vnet/
H A Dchunk_queue.rs11 chunks: RwLock<VecDeque<Box<dyn Chunk + Send + Sync>>>,
23 pub(crate) async fn push(&self, c: Box<dyn Chunk + Send + Sync>) -> bool { in push()
34 pub(crate) async fn pop(&self) -> Option<Box<dyn Chunk + Send + Sync>> { in pop()
39 pub(crate) async fn peek(&self) -> Option<Box<dyn Chunk + Send + Sync>> { in peek()
/webrtc/ice/src/control/
H A Dcontrol_test.rs15 m.build(&[Box::new(BINDING_REQUEST), Box::new(c)])?; in test_controlled_get_from()
52 m.build(&[Box::new(BINDING_REQUEST), Box::new(c)])?; in test_controlling_get_from()
105 m.build(&[Box::new(BINDING_REQUEST), Box::new(c)])?; in test_control_get_from()
143 m.build(&[Box::new(BINDING_REQUEST), Box::new(c)])?; in test_control_get_from()
/webrtc/webrtc/src/api/interceptor_registry/
H A Dmod.rs32 let receiver = Box::new(ReceiverReport::builder()); in configure_rtcp_reports()
33 let sender = Box::new(SenderReport::builder()); in configure_rtcp_reports()
56 let generator = Box::new(Generator::builder()); in configure_nack()
57 let responder = Box::new(Responder::builder()); in configure_nack()
96 let sender = Box::new(Sender::builder()); in configure_twcc()
97 let receiver = Box::new(Receiver::builder()); in configure_twcc()
125 let sender = Box::new(Sender::builder()); in configure_twcc_sender_only()
165 let receiver = Box::new(Receiver::builder()); in configure_twcc_receiver_only()
/webrtc/dtls/src/
H A Dlistener.rs22 accept_filter: Some(Box::new( in listen()
23 |packet: &[u8]| -> Pin<Box<dyn Future<Output = bool> + Send + 'static>> { in listen()
27 return Box::pin(async { false }); in listen()
31 Err(_) => return Box::pin(async { false }), in listen()
38 Box::pin(async move { content_type == ContentType::Handshake }) in listen()
40 Err(_) => Box::pin(async { false }), in listen()
/webrtc/webrtc/src/rtp_transceiver/fmtp/generic/
H A Dgeneric_test.rs5 let tests: Vec<(&str, &str, Box<dyn Fmtp>)> = vec![ in test_generic_fmtp_parse()
9 Box::new(GenericFmtp { in test_generic_fmtp_parse()
20 Box::new(GenericFmtp { in test_generic_fmtp_parse()
31 Box::new(GenericFmtp { in test_generic_fmtp_parse()
45 Box::new(GenericFmtp { in test_generic_fmtp_parse()
/webrtc/ice/src/agent/
H A Dagent_selector.rs120 Box::new(BINDING_REQUEST), in nominate_pair()
121 Box::new(TransactionId::new()), in nominate_pair()
123 Box::<UseCandidateAttr>::default(), in nominate_pair()
129 Box::new(FINGERPRINT), in nominate_pair()
281 Box::new(BINDING_REQUEST), in ping_candidate()
282 Box::new(TransactionId::new()), in ping_candidate()
285 Box::new(PriorityAttr(local.priority())), in ping_candidate()
289 Box::new(FINGERPRINT), in ping_candidate()
433 Box::new(BINDING_REQUEST), in ping_candidate()
434 Box::new(TransactionId::new()), in ping_candidate()
[all …]

12345678