Home
last modified time | relevance | path

Searched defs:Sync (Results 1 – 25 of 140) sorted by relevance

123456

/webrtc/ice/src/agent/
H A Dagent_selector.rs21 local: &Arc<dyn Candidate + Send + Sync>, in ping_candidate()
22 remote: &Arc<dyn Candidate + Send + Sync>, in ping_candidate()
27 local: &Arc<dyn Candidate + Send + Sync>, in handle_success_response()
28 remote: &Arc<dyn Candidate + Send + Sync>, in handle_success_response()
34 local: &Arc<dyn Candidate + Send + Sync>, in handle_binding_request()
35 remote: &Arc<dyn Candidate + Send + Sync>, in handle_binding_request()
45 local: &Arc<dyn Candidate + Send + Sync>, in ping_candidate()
46 remote: &Arc<dyn Candidate + Send + Sync>, in ping_candidate()
51 local: &Arc<dyn Candidate + Send + Sync>, in handle_success_response()
52 remote: &Arc<dyn Candidate + Send + Sync>, in handle_success_response()
[all …]
H A Dagent_internal.rs410 local: Arc<dyn Candidate + Send + Sync>, in add_pair()
411 remote: Arc<dyn Candidate + Send + Sync>, in add_pair()
424 local: &Arc<dyn Candidate + Send + Sync>, in find_pair()
425 remote: &Arc<dyn Candidate + Send + Sync>, in find_pair()
555 c: &Arc<dyn Candidate + Send + Sync>, in add_candidate()
710 local: &Arc<dyn Candidate + Send + Sync>, in send_binding_request()
738 local: &Arc<dyn Candidate + Send + Sync>, in send_binding_success()
826 local: &Arc<dyn Candidate + Send + Sync>, in handle_inbound()
980 local: &Arc<dyn Candidate + Send + Sync>, in validate_non_stun_traffic()
1119 conn: Arc<dyn util::Conn + Send + Sync>, in recv_loop()
[all …]
/webrtc/interceptor/src/
H A Dchain.rs19 pub fn add(&mut self, icpr: Arc<dyn Interceptor + Send + Sync>) { in add()
30 mut reader: Arc<dyn RTCPReader + Send + Sync>, in bind_rtcp_reader()
31 ) -> Arc<dyn RTCPReader + Send + Sync> { in bind_rtcp_reader()
42 mut writer: Arc<dyn RTCPWriter + Send + Sync>, in bind_rtcp_writer()
43 ) -> Arc<dyn RTCPWriter + Send + Sync> { in bind_rtcp_writer()
55 mut writer: Arc<dyn RTPWriter + Send + Sync>, in bind_local_stream()
56 ) -> Arc<dyn RTPWriter + Send + Sync> { in bind_local_stream()
75 mut reader: Arc<dyn RTPReader + Send + Sync>, in bind_remote_stream()
76 ) -> Arc<dyn RTPReader + Send + Sync> { in bind_remote_stream()
H A Dnoop.rs15 reader: Arc<dyn RTCPReader + Send + Sync>, in bind_rtcp_reader()
16 ) -> Arc<dyn RTCPReader + Send + Sync> { in bind_rtcp_reader()
24 writer: Arc<dyn RTCPWriter + Send + Sync>, in bind_rtcp_writer()
25 ) -> Arc<dyn RTCPWriter + Send + Sync> { in bind_rtcp_writer()
34 writer: Arc<dyn RTPWriter + Send + Sync>, in bind_local_stream()
35 ) -> Arc<dyn RTPWriter + Send + Sync> { in bind_local_stream()
47 reader: Arc<dyn RTPReader + Send + Sync>, in bind_remote_stream()
48 ) -> Arc<dyn RTPReader + Send + Sync> { in bind_remote_stream()
H A Dlib.rs32 fn build(&self, id: &str) -> Result<Arc<dyn Interceptor + Send + Sync>>; in build()
43 reader: Arc<dyn RTCPReader + Send + Sync>, in bind_rtcp_reader()
44 ) -> Arc<dyn RTCPReader + Send + Sync>; in bind_rtcp_reader()
50 writer: Arc<dyn RTCPWriter + Send + Sync>, in bind_rtcp_writer()
51 ) -> Arc<dyn RTCPWriter + Send + Sync>; in bind_rtcp_writer()
58 writer: Arc<dyn RTPWriter + Send + Sync>, in bind_local_stream()
59 ) -> Arc<dyn RTPWriter + Send + Sync>; in bind_local_stream()
69 reader: Arc<dyn RTPReader + Send + Sync>, in bind_remote_stream()
70 ) -> Arc<dyn RTPReader + Send + Sync>; in bind_remote_stream()
134 pkts: &[Box<dyn rtcp::packet::Packet + Send + Sync>], in write()
[all …]
H A Dregistry.rs20 pub fn add(&mut self, builder: Box<dyn InterceptorBuilder + Send + Sync>) { in add()
25 pub fn build(&self, id: &str) -> Result<Arc<dyn Interceptor + Send + Sync>> { in build()
/webrtc/interceptor/src/twcc/sender/
H A Dmod.rs34 fn build(&self, _id: &str) -> Result<Arc<dyn Interceptor + Send + Sync>> { in build()
61 reader: Arc<dyn RTCPReader + Send + Sync>, in bind_rtcp_reader()
62 ) -> Arc<dyn RTCPReader + Send + Sync> { in bind_rtcp_reader()
70 writer: Arc<dyn RTCPWriter + Send + Sync>, in bind_rtcp_writer()
71 ) -> Arc<dyn RTCPWriter + Send + Sync> { in bind_rtcp_writer()
80 writer: Arc<dyn RTPWriter + Send + Sync>, in bind_local_stream()
81 ) -> Arc<dyn RTPWriter + Send + Sync> { in bind_local_stream()
119 reader: Arc<dyn RTPReader + Send + Sync>, in bind_remote_stream()
120 ) -> Arc<dyn RTPReader + Send + Sync> { in bind_remote_stream()
/webrtc/interceptor/src/mock/
H A Dmock_interceptor.rs64 reader: Arc<dyn RTCPReader + Send + Sync>, in bind_rtcp_reader()
65 ) -> Arc<dyn RTCPReader + Send + Sync> { in bind_rtcp_reader()
77 writer: Arc<dyn RTCPWriter + Send + Sync>, in bind_rtcp_writer()
78 ) -> Arc<dyn RTCPWriter + Send + Sync> { in bind_rtcp_writer()
91 writer: Arc<dyn RTPWriter + Send + Sync>, in bind_local_stream()
92 ) -> Arc<dyn RTPWriter + Send + Sync> { in bind_local_stream()
112 reader: Arc<dyn RTPReader + Send + Sync>, in bind_remote_stream()
113 ) -> Arc<dyn RTPReader + Send + Sync> { in bind_remote_stream()
/webrtc/interceptor/src/report/sender/
H A Dmod.rs45 rtcp_writer: Arc<dyn RTCPWriter + Send + Sync>, in run()
94 reader: Arc<dyn RTCPReader + Send + Sync>, in bind_rtcp_reader()
95 ) -> Arc<dyn RTCPReader + Send + Sync> { in bind_rtcp_reader()
103 writer: Arc<dyn RTCPWriter + Send + Sync>, in bind_rtcp_writer()
104 ) -> Arc<dyn RTCPWriter + Send + Sync> { in bind_rtcp_writer()
130 writer: Arc<dyn RTPWriter + Send + Sync>, in bind_local_stream()
131 ) -> Arc<dyn RTPWriter + Send + Sync> { in bind_local_stream()
157 reader: Arc<dyn RTPReader + Send + Sync>, in bind_remote_stream()
158 ) -> Arc<dyn RTPReader + Send + Sync> { in bind_remote_stream()
/webrtc/dtls/examples/hub/src/
H A Dlib.rs31 pub async fn register(&self, conn: Arc<dyn Conn + Send + Sync>) { in register()
46 conns: Arc<Mutex<HashMap<String, Arc<dyn Conn + Send + Sync>>>>, in read_loop()
47 conn: Arc<dyn Conn + Send + Sync>, in read_loop()
60 conns: Arc<Mutex<HashMap<String, Arc<dyn Conn + Send + Sync>>>>, in unregister()
61 conn: Arc<dyn Conn + Send + Sync>, in unregister()
/webrtc/interceptor/src/nack/responder/
H A Dmod.rs38 fn build(&self, _id: &str) -> Result<Arc<dyn Interceptor + Send + Sync>> { in build()
142 reader: Arc<dyn RTCPReader + Send + Sync>, in bind_rtcp_reader()
143 ) -> Arc<dyn RTCPReader + Send + Sync> { in bind_rtcp_reader()
154 writer: Arc<dyn RTCPWriter + Send + Sync>, in bind_rtcp_writer()
155 ) -> Arc<dyn RTCPWriter + Send + Sync> { in bind_rtcp_writer()
164 writer: Arc<dyn RTPWriter + Send + Sync>, in bind_local_stream()
165 ) -> Arc<dyn RTPWriter + Send + Sync> { in bind_local_stream()
190 reader: Arc<dyn RTPReader + Send + Sync>, in bind_remote_stream()
191 ) -> Arc<dyn RTPReader + Send + Sync> { in bind_remote_stream()
/webrtc/interceptor/src/nack/generator/
H A Dmod.rs55 fn build(&self, _id: &str) -> Result<Arc<dyn Interceptor + Send + Sync>> { in build()
114 rtcp_writer: Arc<dyn RTCPWriter + Send + Sync>, in run()
170 reader: Arc<dyn RTCPReader + Send + Sync>, in bind_rtcp_reader()
171 ) -> Arc<dyn RTCPReader + Send + Sync> { in bind_rtcp_reader()
179 writer: Arc<dyn RTCPWriter + Send + Sync>, in bind_rtcp_writer()
180 ) -> Arc<dyn RTCPWriter + Send + Sync> { in bind_rtcp_writer()
206 writer: Arc<dyn RTPWriter + Send + Sync>, in bind_local_stream()
207 ) -> Arc<dyn RTPWriter + Send + Sync> { in bind_local_stream()
219 reader: Arc<dyn RTPReader + Send + Sync>, in bind_remote_stream()
220 ) -> Arc<dyn RTPReader + Send + Sync> { in bind_remote_stream()
/webrtc/interceptor/src/report/receiver/
H A Dmod.rs83 rtcp_writer: Arc<dyn RTCPWriter + Send + Sync>, in run()
133 reader: Arc<dyn RTCPReader + Send + Sync>, in bind_rtcp_reader()
134 ) -> Arc<dyn RTCPReader + Send + Sync> { in bind_rtcp_reader()
145 writer: Arc<dyn RTCPWriter + Send + Sync>, in bind_rtcp_writer()
146 ) -> Arc<dyn RTCPWriter + Send + Sync> { in bind_rtcp_writer()
172 writer: Arc<dyn RTPWriter + Send + Sync>, in bind_local_stream()
173 ) -> Arc<dyn RTPWriter + Send + Sync> { in bind_local_stream()
185 reader: Arc<dyn RTPReader + Send + Sync>, in bind_remote_stream()
186 ) -> Arc<dyn RTPReader + Send + Sync> { in bind_remote_stream()
/webrtc/interceptor/src/twcc/receiver/
H A Dmod.rs32 fn build(&self, _id: &str) -> Result<Arc<dyn Interceptor + Send + Sync>> { in build()
95 rtcp_writer: Arc<dyn RTCPWriter + Send + Sync>, in run()
155 reader: Arc<dyn RTCPReader + Send + Sync>, in bind_rtcp_reader()
156 ) -> Arc<dyn RTCPReader + Send + Sync> { in bind_rtcp_reader()
164 writer: Arc<dyn RTCPWriter + Send + Sync>, in bind_rtcp_writer()
165 ) -> Arc<dyn RTCPWriter + Send + Sync> { in bind_rtcp_writer()
196 writer: Arc<dyn RTPWriter + Send + Sync>, in bind_local_stream()
197 ) -> Arc<dyn RTPWriter + Send + Sync> { in bind_local_stream()
209 reader: Arc<dyn RTPReader + Send + Sync>, in bind_remote_stream()
210 ) -> Arc<dyn RTPReader + Send + Sync> { in bind_remote_stream()
/webrtc/sctp/src/param/
H A Dmod.rs41 fn clone_to(&self) -> Box<dyn Param + Send + Sync>; in clone_to()
42 fn as_any(&self) -> &(dyn Any + Send + Sync); in as_any()
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()
H A Dparam_forward_tsn_supported.rs44 fn clone_to(&self) -> Box<dyn Param + Send + Sync> { in clone_to()
48 fn as_any(&self) -> &(dyn Any + Send + Sync) { in as_any()
H A Dparam_random.rs41 fn clone_to(&self) -> Box<dyn Param + Send + Sync> { in clone_to()
45 fn as_any(&self) -> &(dyn Any + Send + Sync) { in as_any()
H A Dparam_heartbeat_info.rs43 fn clone_to(&self) -> Box<dyn Param + Send + Sync> { in clone_to()
47 fn as_any(&self) -> &(dyn Any + Send + Sync) { in as_any()
H A Dparam_supported_extensions.rs60 fn clone_to(&self) -> Box<dyn Param + Send + Sync> { in clone_to()
64 fn as_any(&self) -> &(dyn Any + Send + Sync) { in as_any()
H A Dparam_chunk_list.rs64 fn clone_to(&self) -> Box<dyn Param + Send + Sync> { in clone_to()
68 fn as_any(&self) -> &(dyn Any + Send + Sync) { in as_any()
H A Dparam_unknown.rs35 fn as_any(&self) -> &(dyn Any + Send + Sync) { in as_any()
61 fn clone_to(&self) -> Box<dyn Param + Send + Sync> { in clone_to()
/webrtc/rtp/src/packetizer/
H A Dmod.rs16 fn clone_to(&self) -> Box<dyn Payloader + Send + Sync>; in clone_to()
20 fn clone(&self) -> Box<dyn Payloader + Send + Sync> { in clone()
30 fn clone_to(&self) -> Box<dyn Packetizer + Send + Sync>; in clone_to()
34 fn clone(&self) -> Box<dyn Packetizer + Send + Sync> { in clone()
88 payloader: Box<dyn Payloader + Send + Sync>, in new_packetizer()
89 sequencer: Box<dyn Sequencer + Send + Sync>, in new_packetizer()
158 fn clone_to(&self) -> Box<dyn Packetizer + Send + Sync> { in clone_to()
/webrtc/rtp/src/
H A Dsequence.rs9 fn clone_to(&self) -> Box<dyn Sequencer + Send + Sync>; in clone_to()
13 fn clone(&self) -> Box<dyn Sequencer + Send + Sync> { in clone()
69 fn clone_to(&self) -> Box<dyn Sequencer + Send + Sync> { in clone_to()
/webrtc/rtcp/src/
H A Dpacket.rs24 fn as_any(&self) -> &(dyn Any + Send + Sync); in as_any()
26 fn cloned(&self) -> Box<dyn Packet + Send + Sync>; in cloned()
29 impl PartialEq for dyn Packet + Send + Sync { implementation
36 fn clone(&self) -> Box<dyn Packet + Send + Sync> { in clone()
/webrtc/util/src/vnet/
H A Dchunk_queue.rs34 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()

123456