Home
last modified time | relevance | path

Searched refs:Sync (Results 1 – 25 of 208) sorted by relevance

123456789

/webrtc/interceptor/src/mock/
H A Dmock_interceptor.rs10 -> Pin<Box<dyn Future<Output = Arc<dyn RTCPReader + Send + Sync>> + Send + Sync>>)
12 + Sync,
19 -> Pin<Box<dyn Future<Output = Arc<dyn RTCPWriter + Send + Sync>> + Send + Sync>>)
21 + Sync,
27 ) -> Pin<Box<dyn Future<Output = Arc<dyn RTPWriter + Send + Sync>> + Send + Sync>>)
29 + Sync,
32 Box<dyn (Fn(&StreamInfo) -> Pin<Box<dyn Future<Output = ()> + Send + Sync>>) + Send + Sync>;
37 ) -> Pin<Box<dyn Future<Output = Arc<dyn RTPReader + Send + Sync>> + Send + Sync>>)
39 + Sync,
42 Box<dyn (Fn(&StreamInfo) -> Pin<Box<dyn Future<Output = ()> + Send + Sync>>) + Send + Sync>;
[all …]
H A Dmock_builder.rs5 pub type MockBuilderResult = Result<Arc<dyn Interceptor + Send + Sync>>;
9 pub build: Box<dyn (Fn(&str) -> MockBuilderResult) + Send + Sync + 'static>,
13 pub fn new<F: (Fn(&str) -> MockBuilderResult) + Send + Sync + 'static>(f: F) -> Self { in new()
H A Dmock_stream.rs10 type RTCPPackets = Vec<Box<dyn rtcp::packet::Packet + Send + Sync>>;
14 interceptor: Arc<dyn Interceptor + Send + Sync>,
16 rtcp_writer: Mutex<Option<Arc<dyn RTCPWriter + Send + Sync>>>,
17 rtp_writer: Mutex<Option<Arc<dyn RTPWriter + Send + Sync>>>,
37 interceptor: Arc<dyn Interceptor + Send + Sync>, in new() argument
76 Arc::clone(&stream) as Arc<dyn RTPWriter + Send + Sync>, in new()
117 Arc::clone(&stream) as Arc<dyn RTPReader + Send + Sync>, in new()
153 pkt: &[Box<dyn rtcp::packet::Packet + Send + Sync>], in write_rtcp() argument
202 ) -> Option<Vec<Box<dyn rtcp::packet::Packet + Send + Sync>>> { in last_written_rtcp() argument
222 ) -> Option<Result<Vec<Box<dyn rtcp::packet::Packet + Send + Sync>>>> { in read_rtcp() argument
[all …]
/webrtc/interceptor/src/
H A Dlib.rs43 reader: Arc<dyn RTCPReader + Send + Sync>, in bind_rtcp_reader() argument
44 ) -> Arc<dyn RTCPReader + Send + Sync>; in bind_rtcp_reader() argument
50 writer: Arc<dyn RTCPWriter + Send + Sync>, in bind_rtcp_writer() argument
51 ) -> Arc<dyn RTCPWriter + Send + Sync>; in bind_rtcp_writer() argument
58 writer: Arc<dyn RTPWriter + Send + Sync>, in bind_local_stream() argument
59 ) -> Arc<dyn RTPWriter + Send + Sync>; in bind_local_stream() argument
70 ) -> Arc<dyn RTPReader + Send + Sync>; in bind_remote_stream() argument
91 + Sync,
116 + Sync,
145 + Sync,
[all …]
H A Dchain.rs10 interceptors: Vec<Arc<dyn Interceptor + Send + Sync>>,
15 pub fn new(interceptors: Vec<Arc<dyn Interceptor + Send + Sync>>) -> Self { in new()
19 pub fn add(&mut self, icpr: Arc<dyn Interceptor + Send + Sync>) { in add() argument
30 mut reader: Arc<dyn RTCPReader + Send + Sync>, in bind_rtcp_reader() argument
31 ) -> Arc<dyn RTCPReader + Send + Sync> { in bind_rtcp_reader() argument
42 mut writer: Arc<dyn RTCPWriter + Send + Sync>, in bind_rtcp_writer() argument
43 ) -> Arc<dyn RTCPWriter + Send + Sync> { in bind_rtcp_writer() argument
55 mut writer: Arc<dyn RTPWriter + Send + Sync>, in bind_local_stream() argument
56 ) -> Arc<dyn RTPWriter + Send + Sync> { in bind_local_stream() argument
75 mut reader: Arc<dyn RTPReader + Send + Sync>, in bind_remote_stream() argument
[all …]
H A Dnoop.rs15 reader: Arc<dyn RTCPReader + Send + Sync>, in bind_rtcp_reader() argument
16 ) -> Arc<dyn RTCPReader + Send + Sync> { in bind_rtcp_reader() argument
24 writer: Arc<dyn RTCPWriter + Send + Sync>, in bind_rtcp_writer() argument
25 ) -> Arc<dyn RTCPWriter + Send + Sync> { in bind_rtcp_writer() argument
34 writer: Arc<dyn RTPWriter + Send + Sync>, in bind_local_stream() argument
35 ) -> Arc<dyn RTPWriter + Send + Sync> { in bind_local_stream() argument
47 reader: Arc<dyn RTPReader + Send + Sync>, in bind_remote_stream() argument
48 ) -> Arc<dyn RTPReader + Send + Sync> { in bind_remote_stream() argument
H A Dregistry.rs11 builders: Vec<Box<dyn InterceptorBuilder + Send + Sync>>,
20 pub fn add(&mut self, builder: Box<dyn InterceptorBuilder + Send + Sync>) { in add() argument
25 pub fn build(&self, id: &str) -> Result<Arc<dyn Interceptor + Send + Sync>> { in build() argument
31 .map(|c| Arc::new(c) as 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() argument
61 reader: Arc<dyn RTCPReader + Send + Sync>, in bind_rtcp_reader() argument
62 ) -> Arc<dyn RTCPReader + Send + Sync> { in bind_rtcp_reader() argument
70 writer: Arc<dyn RTCPWriter + Send + Sync>, in bind_rtcp_writer() argument
71 ) -> Arc<dyn RTCPWriter + Send + Sync> { in bind_rtcp_writer() argument
80 writer: Arc<dyn RTPWriter + Send + Sync>, in bind_local_stream() argument
81 ) -> Arc<dyn RTPWriter + Send + Sync> { in bind_local_stream() argument
119 reader: Arc<dyn RTPReader + Send + Sync>, in bind_remote_stream() argument
120 ) -> Arc<dyn RTPReader + Send + Sync> { in bind_remote_stream() argument
/webrtc/rtp/src/packetizer/
H A Dmod.rs16 fn clone_to(&self) -> Box<dyn Payloader + Send + Sync>; in clone_to() argument
19 impl Clone for Box<dyn Payloader + Send + Sync> {
20 fn clone(&self) -> Box<dyn Payloader + Send + Sync> { in clone() argument
30 fn clone_to(&self) -> Box<dyn Packetizer + Send + Sync>; in clone_to() argument
33 impl Clone for Box<dyn Packetizer + Send + Sync> {
34 fn clone(&self) -> Box<dyn Packetizer + Send + Sync> { in clone() argument
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() argument
89 sequencer: Box<dyn Sequencer + Send + Sync>, in new_packetizer() argument
[all …]
/webrtc/ice/src/agent/
H A Dagent_selector.rs21 local: &Arc<dyn Candidate + Send + Sync>, in ping_candidate() argument
22 remote: &Arc<dyn Candidate + Send + Sync>, in ping_candidate() argument
27 local: &Arc<dyn Candidate + Send + Sync>, in handle_success_response() argument
28 remote: &Arc<dyn Candidate + Send + Sync>, in handle_success_response() argument
34 local: &Arc<dyn Candidate + Send + Sync>, in handle_binding_request() argument
35 remote: &Arc<dyn Candidate + Send + Sync>, in handle_binding_request() argument
45 local: &Arc<dyn Candidate + Send + Sync>, in ping_candidate() argument
46 remote: &Arc<dyn Candidate + Send + Sync>, in ping_candidate() argument
51 local: &Arc<dyn Candidate + Send + Sync>, in handle_success_response() argument
52 remote: &Arc<dyn Candidate + Send + Sync>, in handle_success_response() argument
[all …]
/webrtc/interceptor/src/nack/responder/
H A Dmod.rs38 fn build(&self, _id: &str) -> Result<Arc<dyn Interceptor + Send + Sync>> { in build() argument
99 parent_rtcp_reader: Arc<dyn RTCPReader + Send + Sync>,
142 reader: Arc<dyn RTCPReader + Send + Sync>, in bind_rtcp_reader() argument
143 ) -> Arc<dyn RTCPReader + Send + Sync> { in bind_rtcp_reader() argument
147 }) as Arc<dyn RTCPReader + Send + Sync> in bind_rtcp_reader()
154 writer: Arc<dyn RTCPWriter + Send + Sync>, in bind_rtcp_writer() argument
155 ) -> Arc<dyn RTCPWriter + Send + Sync> { in bind_rtcp_writer() argument
164 writer: Arc<dyn RTPWriter + Send + Sync>, in bind_local_stream() argument
165 ) -> Arc<dyn RTPWriter + Send + Sync> { in bind_local_stream() argument
190 reader: Arc<dyn RTPReader + Send + Sync>, in bind_remote_stream() argument
[all …]
/webrtc/interceptor/src/report/sender/
H A Dmod.rs45 rtcp_writer: Arc<dyn RTCPWriter + Send + Sync>, in run() argument
94 reader: Arc<dyn RTCPReader + Send + Sync>, in bind_rtcp_reader() argument
95 ) -> Arc<dyn RTCPReader + Send + Sync> { in bind_rtcp_reader() argument
103 writer: Arc<dyn RTCPWriter + Send + Sync>, in bind_rtcp_writer() argument
104 ) -> Arc<dyn RTCPWriter + Send + Sync> { in bind_rtcp_writer() argument
130 writer: Arc<dyn RTPWriter + Send + Sync>, in bind_local_stream() argument
131 ) -> Arc<dyn RTPWriter + Send + Sync> { in bind_local_stream() argument
157 reader: Arc<dyn RTPReader + Send + Sync>, in bind_remote_stream() argument
158 ) -> Arc<dyn RTPReader + Send + Sync> { in bind_remote_stream() argument
/webrtc/rtcp/src/
H A Dpacket.rs24 fn as_any(&self) -> &(dyn Any + Send + Sync); in as_any() argument
25 fn equal(&self, other: &(dyn Packet + Send + Sync)) -> bool; in equal()
26 fn cloned(&self) -> Box<dyn Packet + Send + Sync>; in cloned() argument
29 impl PartialEq for dyn Packet + Send + Sync { implementation
35 impl Clone for Box<dyn Packet + Send + Sync> {
36 fn clone(&self) -> Box<dyn Packet + Send + Sync> { in clone() argument
42 pub fn marshal(packets: &[Box<dyn Packet + Send + Sync>]) -> Result<Bytes> { in marshal()
57 pub fn unmarshal<B>(raw_data: &mut B) -> Result<Vec<Box<dyn Packet + Send + Sync>>> in unmarshal()
79 pub(crate) fn unmarshaller<B>(raw_data: &mut B) -> Result<Box<dyn Packet + Send + Sync>> in unmarshaller()
92 let p: Box<dyn Packet + Send + Sync> = match h.packet_type { in unmarshaller()
[all …]
/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() argument
39 pub(crate) async fn peek(&self) -> Option<Box<dyn Chunk + Send + Sync>> { in peek() argument
H A Dconn.rs21 async fn write(&self, c: Box<dyn Chunk + Send + Sync>) -> Result<()>; in write()
26 pub(crate) type ChunkChTx = mpsc::Sender<Box<dyn Chunk + Send + Sync>>;
34 read_ch_rx: Mutex<mpsc::Receiver<Box<dyn Chunk + Send + Sync>>>,
36 obs: Arc<Mutex<dyn ConnObserver + Send + Sync>>,
43 obs: Arc<Mutex<dyn ConnObserver + Send + Sync>>, in new() argument
127 let c: Box<dyn Chunk + Send + Sync> = Box::new(chunk); in send_to()
/webrtc/interceptor/src/report/receiver/
H A Dmod.rs24 pub(crate) parent_rtcp_reader: Arc<dyn RTCPReader + Send + Sync>,
83 rtcp_writer: Arc<dyn RTCPWriter + Send + Sync>, in run() argument
133 reader: Arc<dyn RTCPReader + Send + Sync>, in bind_rtcp_reader() argument
134 ) -> Arc<dyn RTCPReader + Send + Sync> { in bind_rtcp_reader() argument
145 writer: Arc<dyn RTCPWriter + Send + Sync>, in bind_rtcp_writer() argument
146 ) -> Arc<dyn RTCPWriter + Send + Sync> { in bind_rtcp_writer() argument
172 writer: Arc<dyn RTPWriter + Send + Sync>, in bind_local_stream() argument
173 ) -> Arc<dyn RTPWriter + Send + Sync> { in bind_local_stream() argument
185 reader: Arc<dyn RTPReader + Send + Sync>, in bind_remote_stream() argument
186 ) -> Arc<dyn RTPReader + Send + Sync> { in bind_remote_stream() argument
/webrtc/dtls/examples/hub/src/
H A Dlib.rs19 conns: Arc<Mutex<HashMap<String, Arc<dyn Conn + Send + Sync>>>>,
31 pub async fn register(&self, conn: Arc<dyn Conn + Send + Sync>) { in register() argument
46 conns: Arc<Mutex<HashMap<String, Arc<dyn Conn + Send + Sync>>>>, in read_loop() argument
47 conn: Arc<dyn Conn + Send + Sync>, in read_loop() argument
60 conns: Arc<Mutex<HashMap<String, Arc<dyn Conn + Send + Sync>>>>, in unregister() argument
61 conn: Arc<dyn Conn + Send + Sync>, in unregister() argument
/webrtc/interceptor/src/nack/generator/
H A Dmod.rs55 fn build(&self, _id: &str) -> Result<Arc<dyn Interceptor + Send + Sync>> { in build() argument
114 rtcp_writer: Arc<dyn RTCPWriter + Send + Sync>, in run() argument
170 reader: Arc<dyn RTCPReader + Send + Sync>, in bind_rtcp_reader() argument
171 ) -> Arc<dyn RTCPReader + Send + Sync> { in bind_rtcp_reader() argument
179 writer: Arc<dyn RTCPWriter + Send + Sync>, in bind_rtcp_writer() argument
180 ) -> Arc<dyn RTCPWriter + Send + Sync> { in bind_rtcp_writer() argument
206 writer: Arc<dyn RTPWriter + Send + Sync>, in bind_local_stream() argument
207 ) -> Arc<dyn RTPWriter + Send + Sync> { in bind_local_stream() argument
219 reader: Arc<dyn RTPReader + Send + Sync>, in bind_remote_stream() argument
220 ) -> Arc<dyn RTPReader + Send + Sync> { in bind_remote_stream() argument
/webrtc/interceptor/src/twcc/receiver/
H A Dmod.rs32 fn build(&self, _id: &str) -> Result<Arc<dyn Interceptor + Send + Sync>> { in build() argument
95 rtcp_writer: Arc<dyn RTCPWriter + Send + Sync>, in run() argument
155 reader: Arc<dyn RTCPReader + Send + Sync>, in bind_rtcp_reader() argument
156 ) -> Arc<dyn RTCPReader + Send + Sync> { in bind_rtcp_reader() argument
164 writer: Arc<dyn RTCPWriter + Send + Sync>, in bind_rtcp_writer() argument
165 ) -> Arc<dyn RTCPWriter + Send + Sync> { in bind_rtcp_writer() argument
196 writer: Arc<dyn RTPWriter + Send + Sync>, in bind_local_stream() argument
197 ) -> Arc<dyn RTPWriter + Send + Sync> { in bind_local_stream() argument
209 reader: Arc<dyn RTPReader + Send + Sync>, in bind_remote_stream() argument
210 ) -> Arc<dyn RTPReader + Send + Sync> { in bind_remote_stream() argument
/webrtc/sctp/src/param/
H A Dparam_unrecognized.rs13 param: Box<dyn Param + Send + Sync>,
17 pub(crate) fn wrap(param: Box<dyn Param + Send + Sync>) -> Self { in wrap()
37 fn as_any(&self) -> &(dyn Any + Send + Sync) { in as_any() argument
61 fn clone_to(&self) -> Box<dyn Param + Send + Sync> { in clone_to() argument
H A Dmod.rs41 fn clone_to(&self) -> Box<dyn Param + Send + Sync>; in clone_to() argument
42 fn as_any(&self) -> &(dyn Any + Send + Sync); in as_any() argument
52 impl Clone for Box<dyn Param + Send + Sync> {
53 fn clone(&self) -> Box<dyn Param + Send + Sync> { in clone() argument
58 pub(crate) fn build_param(raw_param: &Bytes) -> Result<Box<dyn Param + Send + Sync>> { in build_param() argument
/webrtc/turn/src/server/
H A Dconfig.rs14 pub conn: Arc<dyn Conn + Send + Sync>,
18 pub relay_addr_generator: Box<dyn RelayAddressGenerator + Send + Sync>,
37 pub auth_handler: Arc<dyn AuthHandler + Send + Sync>,
/webrtc/rtp/src/
H A Dsequence.rs9 fn clone_to(&self) -> Box<dyn Sequencer + Send + Sync>; in clone_to() argument
12 impl Clone for Box<dyn Sequencer + Send + Sync> {
13 fn clone(&self) -> Box<dyn Sequencer + Send + Sync> { in clone() argument
69 fn clone_to(&self) -> Box<dyn Sequencer + Send + Sync> { in clone_to() argument
/webrtc/dtls/src/cipher_suite/
H A Dmod.rs11 use std::marker::{Send, Sync};
141 pub fn cipher_suite_for_id(id: CipherSuiteId) -> Result<Box<dyn CipherSuite + Send + Sync>> { in cipher_suite_for_id() argument
175 pub(crate) fn default_cipher_suites() -> Vec<Box<dyn CipherSuite + Send + Sync>> { in default_cipher_suites()
184 fn all_cipher_suites() -> Vec<Box<dyn CipherSuite + Send + Sync>> { in all_cipher_suites()
198 fn cipher_suites_for_ids(ids: &[CipherSuiteId]) -> Result<Vec<Box<dyn CipherSuite + Send + Sync>>> { in cipher_suites_for_ids() argument
210 ) -> Result<Vec<Box<dyn CipherSuite + Send + Sync>>> { in parse_cipher_suites() argument
217 let filtered_cipher_suites: Vec<Box<dyn CipherSuite + Send + Sync>> = cipher_suites in parse_cipher_suites()
/webrtc/util/src/vnet/conn_map/
H A Dconn_map_test.rs14 async fn write(&self, _c: Box<dyn Chunk + Send + Sync>) -> Result<()> { in write()
29 let obs: Arc<Mutex<dyn ConnObserver + Send + Sync>> = in test_udp_conn_map_insert_remove()
68 let obs: Arc<Mutex<dyn ConnObserver + Send + Sync>> = in test_udp_conn_map_insert_0_remove()
107 let obs: Arc<Mutex<dyn ConnObserver + Send + Sync>> = in test_udp_conn_map_find_0()
136 let obs: Arc<Mutex<dyn ConnObserver + Send + Sync>> = in test_udp_conn_map_insert_many_ips_with_same_port()
183 let obs: Arc<Mutex<dyn ConnObserver + Send + Sync>> = in test_udp_conn_map_already_inuse_when_insert_0()
208 let obs: Arc<Mutex<dyn ConnObserver + Send + Sync>> = in test_udp_conn_map_already_inuse_when_insert_a_specified_ip()
233 let obs: Arc<Mutex<dyn ConnObserver + Send + Sync>> = in test_udp_conn_map_already_inuse_when_insert_same_specified_ip()
258 let obs: Arc<Mutex<dyn ConnObserver + Send + Sync>> = in test_udp_conn_map_find_failure_1()
280 let obs: Arc<Mutex<dyn ConnObserver + Send + Sync>> = in test_udp_conn_map_find_failure_2()
[all …]

123456789