| /webrtc/interceptor/src/ |
| H A D | lib.rs | 82 async fn write(&self, pkt: &rtp::packet::Packet, attributes: &Attributes) -> Result<usize>; in write()
98 async fn write(&self, pkt: &rtp::packet::Packet, attributes: &Attributes) -> Result<usize> { in write()
99 self.0(pkt, attributes).await in write()
107 async fn read(&self, buf: &mut [u8], attributes: &Attributes) -> Result<(usize, Attributes)>; in read()
123 async fn read(&self, buf: &mut [u8], attributes: &Attributes) -> Result<(usize, Attributes)> { in read()
124 self.0(buf, attributes).await in read()
135 attributes: &Attributes, in write()
156 attributes: &Attributes, in write()
158 self.0(pkts, attributes).await in write()
166 async fn read(&self, buf: &mut [u8], attributes: &Attributes) -> Result<(usize, Attributes)>; in read()
[all …]
|
| H A D | stream_info.rs | 14 pub attributes: Attributes, field
|
| /webrtc/stun/src/ |
| H A D | message.rs | 5 use crate::attributes::*;
61 pub attributes: Attributes, field
73 self.attributes.0.len(), in fmt()
92 if self.attributes != other.attributes { in eq()
152 self.attributes.0.clear(); in reset()
215 self.attributes.0.push(attr); in add()
244 let attributes: Vec<RawAttribute> = self.attributes.0.drain(..).collect(); in write_attributes() localVariable
245 for a in &attributes { in write_attributes()
248 self.attributes = Attributes(attributes); in write_attributes()
304 self.attributes.0.clear(); in decode()
[all …]
|
| H A D | integrity.rs | 4 use crate::attributes::*;
41 for a in &m.attributes.0 { in add_to()
97 for a in &m.attributes.0 { in check()
|
| H A D | lib.rs | 9 pub mod attributes; module
|
| H A D | checks.rs | 1 use crate::attributes::*;
|
| H A D | uattrs.rs | 4 use crate::attributes::*;
|
| /webrtc/webrtc/src/peer_connection/sdp/ |
| H A D | sdp_test.rs | 19 attributes: vec![Attribute { in test_extract_fingerprint()
63 attributes: vec![Attribute { in test_extract_fingerprint()
152 attributes: vec![ in test_extract_ice_details()
175 attributes: vec![ in test_extract_ice_details()
203 attributes: vec![ in test_extract_ice_details()
233 attributes: vec![ in test_extract_ice_details()
269 attributes: vec![ in test_track_details_from_sdp()
486 attributes: vec![ in test_have_application_media_section()
989 attributes: vec![ in test_get_rids()
1050 attributes: vec![ in test_codecs_from_media_description()
[all …]
|
| H A D | mod.rs | 98 for attr in &media.attributes { in track_details_from_sdp()
242 for attr in &media.attributes { in get_rids()
260 for a in &m.attributes { in add_candidates_to_media_descriptions()
284 for a in &m.attributes { in add_candidates_to_media_descriptions()
329 attributes: vec![], in add_data_media_section()
500 attributes: vec![], in add_transceiver_sdp()
732 for attr in &media.attributes { in get_mid_value()
741 for a in &media.attributes { in get_peer_direction()
803 for a in &m.attributes { in extract_ice_details()
938 for a in &m.attributes { in rtp_extensions_from_media_description()
|
| /webrtc/sdp/src/description/ |
| H A D | media.rs | 58 pub attributes: Vec<Attribute>, field
64 for a in &self.attributes { in attribute()
102 attributes: vec![], in new_jsep_media_description()
108 self.attributes.push(Attribute::new(key, None)); in with_property_attribute()
114 self.attributes.push(Attribute::new(key, Some(value))); in with_value_attribute()
|
| H A D | description_test.rs | 115 attributes: vec![ in test_marshal()
149 attributes: vec![Attribute::new("sendrecv".to_string(), None)], in test_marshal()
165 attributes: vec![Attribute::new( in test_marshal()
|
| /webrtc/stun/src/message/ |
| H A D | message_test.rs | 220 attributes: message_attributes, in test_message_attr_length_less_than_header()
250 attributes: message_attributes, in test_message_attr_size_less_than_length()
403 attributes: attrs.clone(), in test_message_equal()
408 attributes: attrs.clone(), in test_message_equal()
452 attributes: t_attrs, in test_message_equal()
467 attributes: t_attrs, in test_message_equal()
481 attributes: attrs, 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()
[all …]
|
| /webrtc/interceptor/src/twcc/receiver/ |
| H A D | receiver_stream.rs | 33 async fn read(&self, buf: &mut [u8], attributes: &Attributes) -> Result<(usize, Attributes)> { in read()
34 let (n, attr) = self.parent_rtp_reader.read(buf, attributes).await?; in read()
|
| /webrtc/webrtc/src/track/track_remote/ |
| H A D | mod.rs | 223 if let Some((data, attributes)) = internal.peeked.pop_front() { in read()
228 return Ok((n, attributes)); in read()
237 let (n, attributes) = receiver.read_rtp(b, self.tid).await?; in read()
239 Ok((n, attributes)) in read()
283 let (n, attributes) = self.read(&mut b).await?; in read_rtp()
287 Ok((r, attributes)) in read_rtp()
|
| /webrtc/turn/src/proto/ |
| H A D | dontfrag.rs | 4 use stun::attributes::*;
|
| H A D | data.rs | 4 use stun::attributes::*;
|
| H A D | rsrvtoken.rs | 4 use stun::attributes::*;
|
| H A D | reqtrans.rs | 7 use stun::attributes::*;
|
| H A D | evenport.rs | 5 use stun::attributes::*;
|
| H A D | channum.rs | 5 use stun::attributes::*;
|
| H A D | reqfamily.rs | 4 use stun::attributes::*;
|
| /webrtc/ice/src/use_candidate/ |
| H A D | mod.rs | 4 use stun::attributes::ATTR_USE_CANDIDATE;
|
| /webrtc/ice/src/priority/ |
| H A D | mod.rs | 4 use stun::attributes::ATTR_PRIORITY;
|
| /webrtc/interceptor/src/stats/ |
| H A D | interceptor.rs | 395 async fn read(&self, buf: &mut [u8], attributes: &Attributes) -> Result<(usize, Attributes)> { in read()
396 let (n, attributes) = self.rtcp_reader.read(buf, attributes).await?; in read()
605 Ok((n, attributes)) in read()
623 attributes: &Attributes, in write()
701 self.rtcp_writer.write(pkts, attributes).await in write()
724 async fn read(&self, buf: &mut [u8], attributes: &Attributes) -> Result<(usize, Attributes)> { in read()
725 let (bytes_read, attributes) = self.rtp_reader.read(buf, attributes).await?; in read()
744 Ok((bytes_read, attributes)) in read()
768 async fn write(&self, pkt: &rtp::packet::Packet, attributes: &Attributes) -> Result<usize> { in write()
769 let n = self.rtp_writer.write(pkt, attributes).await?; in write()
|
| /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()
179 let (r_attr, ok) = m.attributes.get(ATTR_REALM); in test_realm_get_from()
252 let (r_attr, ok) = m.attributes.get(ATTR_NONCE); in test_nonce_get_from()
|