Home
last modified time | relevance | path

Searched refs:Attributes (Results 1 – 25 of 29) sorted by relevance

12

/webrtc/interceptor/src/
H A Dlib.rs28 pub type Attributes = HashMap<usize, usize>; typedef
88 &Attributes,
107 async fn read(&self, buf: &mut [u8], attributes: &Attributes) -> Result<(usize, Attributes)>; in read() argument
113 &Attributes,
123 async fn read(&self, buf: &mut [u8], attributes: &Attributes) -> Result<(usize, Attributes)> { in read() argument
135 attributes: &Attributes, in write() argument
142 &Attributes,
156 attributes: &Attributes, in write() argument
166 async fn read(&self, buf: &mut [u8], attributes: &Attributes) -> Result<(usize, Attributes)>; in read() argument
172 &Attributes,
[all …]
H A Dstream_reader.rs2 use crate::{Attributes, RTCPReader, RTPReader};
9 async fn read(&self, buf: &mut [u8], a: &Attributes) -> Result<(usize, Attributes)> { in read() argument
16 async fn read(&self, buf: &mut [u8], a: &Attributes) -> Result<(usize, Attributes)> { in read() argument
H A Dnoop.rs63 async fn read(&self, _buf: &mut [u8], a: &Attributes) -> Result<(usize, Attributes)> { in read() argument
70 async fn read(&self, _buf: &mut [u8], a: &Attributes) -> Result<(usize, Attributes)> { in read() argument
H A Dstream_info.rs1 use crate::Attributes;
14 pub attributes: Attributes,
/webrtc/interceptor/src/mock/
H A Dmock_stream.rs3 use crate::{Attributes, Interceptor, RTCPReader, RTCPWriter, RTPReader, RTPWriter};
89 let a = Attributes::new(); in new()
122 let a = Attributes::new(); in new()
155 let a = Attributes::new(); in write_rtcp()
166 let a = Attributes::new(); in write_rtp()
252 _attributes: &Attributes, in write() argument
262 async fn read(&self, buf: &mut [u8], a: &Attributes) -> Result<(usize, Attributes)> { in read() argument
281 async fn write(&self, pkt: &rtp::packet::Packet, _a: &Attributes) -> Result<usize> { in write()
289 async fn read(&self, buf: &mut [u8], a: &Attributes) -> Result<(usize, Attributes)> { in read() argument
/webrtc/webrtc/src/rtp_transceiver/rtp_receiver/
H A Dmod.rs21 use interceptor::{Attributes, Interceptor};
164 async fn read(&self, b: &mut [u8]) -> Result<(usize, Attributes)> { in read() argument
173 let a = Attributes::new(); in read()
204 let a = Attributes::new(); in read_simulcast()
229 ) -> Result<(Vec<Box<dyn rtcp::packet::Packet + Send + Sync>>, Attributes)> { in read_rtcp() argument
244 ) -> Result<(Vec<Box<dyn rtcp::packet::Packet + Send + Sync>>, Attributes)> { in read_simulcast_rtcp() argument
280 let a = Attributes::new(); in read_rtp()
616 pub async fn read(&self, b: &mut [u8]) -> Result<(usize, Attributes)> { in read() argument
629 ) -> Result<(Vec<Box<dyn rtcp::packet::Packet + Send + Sync>>, Attributes)> { in read_rtcp() argument
637 ) -> Result<(Vec<Box<dyn rtcp::packet::Packet + Send + Sync>>, Attributes)> { in read_simulcast_rtcp() argument
[all …]
/webrtc/interceptor/src/twcc/receiver/
H A Dreceiver_stream.rs33 async fn read(&self, buf: &mut [u8], attributes: &Attributes) -> Result<(usize, Attributes)> { in read() argument
/webrtc/stun/src/message/
H A Dmessage_test.rs216 let message_attributes = Attributes(vec![message_attribute]); in test_message_attr_length_less_than_header()
246 let message_attributes = Attributes(vec![message_attribute]); in test_message_attr_size_less_than_length()
401 let attrs = Attributes(vec![attr]); in test_message_equal()
444 let t_attrs = Attributes(vec![RawAttribute { in test_message_equal()
459 let t_attrs = Attributes(vec![RawAttribute { in test_message_equal()
488 b.attributes = Attributes::default(); in test_message_equal()
505 attributes: Attributes(vec![attr.clone()]), in test_message_equal()
510 attributes: Attributes(vec![attr, attr1]), in test_message_equal()
530 attributes: Attributes(vec![attr.clone(), attr.clone()]), in test_message_equal()
535 attributes: Attributes(vec![attr, attr1]), in test_message_equal()
/webrtc/interceptor/src/nack/responder/
H A Dmod.rs7 Attributes, Interceptor, InterceptorBuilder, RTCPReader, RTCPWriter, RTPReader, RTPWriter,
80 let a = Attributes::new(); in resend_packets()
105 async fn read(&self, buf: &mut [u8], a: &Attributes) -> Result<(usize, Attributes)> { in read() argument
H A Dresponder_stream.rs3 use crate::{Attributes, RTPWriter};
92 async fn write(&self, pkt: &rtp::packet::Packet, a: &Attributes) -> Result<usize> { in write()
/webrtc/webrtc/src/track/track_remote/
H A Dmod.rs11 use interceptor::{Attributes, Interceptor};
37 peeked: VecDeque<(Bytes, Attributes)>,
219 pub async fn read(&self, b: &mut [u8]) -> Result<(usize, Attributes)> { in read() argument
281 pub async fn read_rtp(&self) -> Result<(rtp::packet::Packet, Attributes)> { in read_rtp() argument
291 pub(crate) async fn peek(&self, b: &mut [u8]) -> Result<(usize, Attributes)> { in peek() argument
311 pub(crate) async fn prepopulate_peeked_data(&self, data: VecDeque<(Bytes, Attributes)>) { in prepopulate_peeked_data() argument
/webrtc/webrtc/src/rtp_transceiver/
H A Dsrtp_writer_future.rs11 use interceptor::{Attributes, RTCPReader, RTPWriter};
263 async fn read(&self, buf: &mut [u8], a: &Attributes) -> IResult<(usize, Attributes)> { in read() argument
270 async fn write(&self, pkt: &rtp::packet::Packet, _a: &Attributes) -> IResult<usize> { in write()
/webrtc/interceptor/src/report/receiver/
H A Dmod.rs29 async fn read(&self, buf: &mut [u8], a: &Attributes) -> Result<(usize, Attributes)> { in read() argument
113 let a = Attributes::new(); in run()
H A Dreceiver_stream.rs2 use crate::{Attributes, RTPReader};
211 async fn read(&self, buf: &mut [u8], a: &Attributes) -> Result<(usize, Attributes)> { in read() argument
/webrtc/interceptor/src/report/sender/
H A Dsender_stream.rs2 use crate::{Attributes, RTPWriter};
94 async fn write(&self, pkt: &rtp::packet::Packet, a: &Attributes) -> Result<usize> { in write()
H A Dmod.rs74 let a = Attributes::new(); in run()
/webrtc/webrtc/src/track/track_local/
H A Dmod.rs12 use interceptor::{Attributes, RTPWriter};
151 let a = Attributes::new(); in write_rtp()
/webrtc/webrtc/src/rtp_transceiver/rtp_sender/
H A Dmod.rs20 use interceptor::{Attributes, Interceptor, RTCPReader, RTPWriter};
37 async fn read(&self, b: &mut [u8]) -> Result<(usize, Attributes)> { in read() argument
47 let a = Attributes::new(); in read()
70 ) -> Result<(Vec<Box<dyn rtcp::packet::Packet + Send + Sync>>, Attributes)> { in read_rtcp() argument
472 pub async fn read(&self, b: &mut [u8]) -> Result<(usize, Attributes)> { in read() argument
479 ) -> Result<(Vec<Box<dyn rtcp::packet::Packet + Send + Sync>>, Attributes)> { in read_rtcp() argument
/webrtc/interceptor/src/twcc/sender/
H A Dsender_stream.rs27 async fn write(&self, pkt: &rtp::packet::Packet, a: &Attributes) -> Result<usize> { in write()
H A Dmod.rs6 use crate::{Attributes, RTPWriter};
/webrtc/stun/src/
H A Dattributes.rs11 pub struct Attributes(pub Vec<RawAttribute>); struct
13 impl Attributes { impl
H A Dmessage.rs61 pub attributes: Attributes,
248 self.attributes = Attributes(attributes); in write_attributes()
/webrtc/interceptor/src/nack/generator/
H A Dmod.rs9 use crate::{Attributes, Interceptor, RTCPReader, RTPReader, RTPWriter};
149 let a = Attributes::new(); in run()
H A Dgenerator_stream.rs155 async fn read(&self, buf: &mut [u8], a: &Attributes) -> Result<(usize, Attributes)> { in read() argument
/webrtc/interceptor/src/stats/
H A Dinterceptor.rs23 use crate::{Attributes, Interceptor, RTCPReader, RTCPWriter, RTPReader, RTPWriter};
395 async fn read(&self, buf: &mut [u8], attributes: &Attributes) -> Result<(usize, Attributes)> { in read() argument
623 attributes: &Attributes, in write() argument
724 async fn read(&self, buf: &mut [u8], attributes: &Attributes) -> Result<(usize, Attributes)> { in read() argument
768 async fn write(&self, pkt: &rtp::packet::Packet, attributes: &Attributes) -> Result<usize> { in write()

12