| /webrtc/sctp/src/ |
| H A D | packet.rs | 56 pub(crate) struct Packet { struct
64 impl fmt::Display for Packet { argument
83 impl Packet { implementation
191 impl Packet { impl
|
| /webrtc/rtp/src/packet/ |
| H A D | mod.rs | 13 pub struct Packet { struct
18 impl fmt::Display for Packet { argument
34 impl Unmarshal for Packet { implementation
64 impl MarshalSize for Packet { implementation
82 impl Marshal for Packet { implementation
|
| /webrtc/dtls/src/flight/ |
| H A D | mod.rs | 54 pub(crate) struct Packet { struct
55 pub(crate) record: RecordLayer,
56 pub(crate) should_encrypt: bool,
57 pub(crate) reset_local_sequence_number: bool,
85 ) -> Result<Vec<Packet>, (Option<Alert>, Option<Error>)>; in generate()
|
| H A D | flight0.rs | 187 ) -> Result<Vec<Packet>, (Option<Alert>, Option<Error>)> { in generate()
|
| H A D | flight2.rs | 113 ) -> Result<Vec<Packet>, (Option<Alert>, Option<Error>)> { in generate()
|
| H A D | flight1.rs | 123 ) -> Result<Vec<Packet>, (Option<Alert>, Option<Error>)> { in generate()
|
| H A D | flight6.rs | 75 ) -> Result<Vec<Packet>, (Option<Alert>, Option<Error>)> { in generate()
|
| H A D | flight3.rs | 351 ) -> Result<Vec<Packet>, (Option<Alert>, Option<Error>)> { in generate()
|
| H A D | flight5.rs | 180 ) -> Result<Vec<Packet>, (Option<Alert>, Option<Error>)> { in generate()
|
| H A D | flight4.rs | 502 ) -> Result<Vec<Packet>, (Option<Alert>, Option<Error>)> { in generate()
|
| /webrtc/sctp/src/association/ |
| H A D | association_internal.rs | 346 mut raw_packets: Vec<Packet>, in gather_outbound_data_and_reconfig_packets()
347 ) -> Vec<Packet> { in gather_outbound_data_and_reconfig_packets()
414 mut raw_packets: Vec<Packet>, in gather_outbound_fast_retransmission_packets()
415 ) -> Vec<Packet> { in gather_outbound_fast_retransmission_packets()
511 mut raw_packets: Vec<Packet>, in gather_outbound_shutdown_packets()
512 ) -> (Vec<Packet>, bool) { in gather_outbound_shutdown_packets()
606 async fn handle_init(&mut self, p: &Packet, i: &ChunkInit) -> Result<Vec<Packet>> { in handle_init()
712 async fn handle_init_ack(&mut self, p: &Packet, i: &ChunkInit) -> Result<Vec<Packet>> { in handle_init_ack()
952 ) -> Result<Vec<Packet>> { in handle_peer_last_tsn_and_acknowledgement()
1746 ) -> Result<Option<Packet>> { in handle_reconfig_param()
[all …]
|
| /webrtc/interceptor/src/nack/responder/ |
| H A D | responder_stream.rs | 26 fn add(&mut self, packet: &rtp::packet::Packet) { in add()
50 fn get(&self, seq: u16) -> Option<&rtp::packet::Packet> { in get()
77 async fn add(&self, pkt: &rtp::packet::Packet) { in add()
82 pub(super) async fn get(&self, seq: u16) -> Option<rtp::packet::Packet> { in get()
92 async fn write(&self, pkt: &rtp::packet::Packet, a: &Attributes) -> Result<usize> { in write()
|
| /webrtc/interceptor/src/twcc/receiver/ |
| H A D | mod.rs | 55 struct Packet { struct
65 packet_chan_rx: Mutex<Option<mpsc::Receiver<Packet>>>, argument
|
| H A D | receiver_stream.rs | 17 packet_chan_tx: mpsc::Sender<Packet>, in new()
|
| /webrtc/interceptor/src/report/sender/ |
| H A D | sender_stream.rs | 22 fn process_rtp(&mut self, now: SystemTime, pkt: &rtp::packet::Packet) { in process_rtp()
76 async fn process_rtp(&self, now: SystemTime, pkt: &rtp::packet::Packet) { in process_rtp()
94 async fn write(&self, pkt: &rtp::packet::Packet, a: &Attributes) -> Result<usize> { in write()
|
| /webrtc/rtcp/src/ |
| H A D | packet.rs | 20 pub trait Packet: Marshal + Unmarshal + fmt::Display + fmt::Debug { trait
|
| /webrtc/util/src/ifaces/ |
| H A D | mod.rs | 12 Packet, enumerator
|
| /webrtc/interceptor/src/mock/ |
| H A D | mock_stream.rs | 184 pub async fn receive_rtp(&self, pkt: rtp::packet::Packet) { in receive_rtp()
214 pub async fn written_rtp(&self) -> Option<rtp::packet::Packet> { in written_rtp()
228 pub async fn read_rtp(&self) -> Option<Result<rtp::packet::Packet>> { in read_rtp()
281 async fn write(&self, pkt: &rtp::packet::Packet, _a: &Attributes) -> Result<usize> { in write()
|
| /webrtc/interceptor/src/twcc/sender/ |
| H A D | sender_stream.rs | 27 async fn write(&self, pkt: &rtp::packet::Packet, a: &Attributes) -> Result<usize> { in write()
|
| /webrtc/interceptor/src/report/receiver/ |
| H A D | receiver_stream.rs | 43 fn process_rtp(&mut self, now: SystemTime, pkt: &rtp::packet::Packet) { in process_rtp()
187 pub(crate) fn process_rtp(&self, now: SystemTime, pkt: &rtp::packet::Packet) { in process_rtp()
|
| /webrtc/rtp/src/packetizer/ |
| H A D | mod.rs | 28 fn packetize(&mut self, payload: &Bytes, samples: u32) -> Result<Vec<Packet>>; in packetize()
110 fn packetize(&mut self, payload: &Bytes, samples: u32) -> Result<Vec<Packet>> { in packetize()
|
| /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()
|
| /webrtc/webrtc/src/track/track_local/ |
| H A D | track_local_static_rtp.rs | 64 p: &rtp::packet::Packet, in write_rtp_with_extensions()
|
| /webrtc/dtls/src/conn/ |
| H A D | mod.rs | 525 mut pkts: Vec<Packet>, in handle_outgoing_packets()
594 p: &mut Packet, in process_packet()
636 p: &Packet, in process_handshake_packet()
|
| /webrtc/webrtc/src/rtp_transceiver/ |
| H A D | srtp_writer_future.rs | 270 async fn write(&self, pkt: &rtp::packet::Packet, _a: &Attributes) -> IResult<usize> { in write()
|