Home
last modified time | relevance | path

Searched refs:chunk (Results 1 – 25 of 36) sorted by relevance

12

/webrtc/sctp/src/
H A Dpacket.rs1 use crate::chunk::Chunk;
3 use crate::chunk::chunk_abort::ChunkAbort;
4 use crate::chunk::chunk_cookie_ack::ChunkCookieAck;
6 use crate::chunk::chunk_error::ChunkError;
8 use crate::chunk::chunk_header::*;
10 use crate::chunk::chunk_init::ChunkInit;
12 use crate::chunk::chunk_reconfig::ChunkReconfig;
14 use crate::chunk::chunk_shutdown::ChunkShutdown;
17 use crate::chunk::chunk_type::*;
21 use crate::chunk::chunk_unknown::ChunkUnknown;
[all …]
H A Dlib.rs5 pub mod chunk; module
/webrtc/sctp/src/queue/
H A Dreassembly_queue.rs49 if c.tsn == chunk.tsn { in push()
55 self.chunks.push(chunk); in push()
137 if chunk.stream_identifier != self.si { in push()
141 if chunk.unordered { in push()
144 self.n_bytes += chunk.user_data.len(); in push()
145 self.unordered_chunks.push(chunk); in push()
162 self.n_bytes += chunk.user_data.len(); in push()
167 return s.push(chunk); in push()
172 let mut cset = ChunkSet::new(chunk.stream_sequence_number, chunk.payload_type); in push()
173 let unordered = chunk.unordered; in push()
[all …]
H A Dqueue_test.rs456 let chunk = ChunkPayloadData { in test_reassembly_queue_ordered_fragments() localVariable
465 let complete = rq.push(chunk); in test_reassembly_queue_ordered_fragments()
469 let chunk = ChunkPayloadData { in test_reassembly_queue_ordered_fragments() localVariable
478 let complete = rq.push(chunk); in test_reassembly_queue_ordered_fragments()
499 let chunk = ChunkPayloadData { in test_reassembly_queue_unordered_fragments() localVariable
509 let complete = rq.push(chunk); in test_reassembly_queue_unordered_fragments()
513 let chunk = ChunkPayloadData { in test_reassembly_queue_unordered_fragments() localVariable
522 let complete = rq.push(chunk); in test_reassembly_queue_unordered_fragments()
526 let chunk = ChunkPayloadData { in test_reassembly_queue_unordered_fragments() localVariable
536 let complete = rq.push(chunk); in test_reassembly_queue_unordered_fragments()
[all …]
H A Dpending_queue.rs9 use crate::chunk::chunk_payload_data::ChunkPayloadData;
120 for chunk in chunks.into_iter() { in append_large()
121 let user_data_len = chunk.user_data.len(); in append_large()
126 if chunk.unordered { in append_large()
128 unordered_queue.push_back(chunk); in append_large()
131 ordered_queue.push_back(chunk); in append_large()
H A Dpayload_queue.rs1 use crate::chunk::chunk_payload_data::ChunkPayloadData;
2 use crate::chunk::chunk_selective_ack::GapAckBlock;
/webrtc/util/src/fixed_big_int/
H A Dmod.rs82 let chunk = i / 64; in bit() localVariable
84 usize::from(self.bits[chunk] & (1 << pos) != 0) in bit()
92 let chunk = i / 64; in set_bit() localVariable
94 self.bits[chunk] |= 1 << pos; in set_bit()
/webrtc/util/src/vnet/
H A Dconn.rs7 use crate::vnet::chunk::{Chunk, ChunkUdp};
84 while let Some(chunk) = read_ch.recv().await { in recv_from()
85 let user_data = chunk.user_data(); in recv_from()
88 let addr = chunk.source_addr(); in recv_from()
124 let mut chunk = ChunkUdp::new(src_addr, target); in send_to() localVariable
125 chunk.user_data = buf.to_vec(); in send_to()
127 let c: Box<dyn Chunk + Send + Sync> = Box::new(chunk); in send_to()
H A Dchunk_queue.rs4 use super::chunk::*;
41 chunks.front().map(|chunk| chunk.clone_to()) in peek()
H A Dmod.rs1 pub mod chunk; module
/webrtc/sctp/src/association/
H A Dmod.rs7 use crate::chunk::chunk_abort::ChunkAbort;
8 use crate::chunk::chunk_cookie_ack::ChunkCookieAck;
9 use crate::chunk::chunk_cookie_echo::ChunkCookieEcho;
10 use crate::chunk::chunk_error::ChunkError;
12 use crate::chunk::chunk_heartbeat::ChunkHeartbeat;
14 use crate::chunk::chunk_init::ChunkInit;
16 use crate::chunk::chunk_reconfig::ChunkReconfig;
18 use crate::chunk::chunk_shutdown::ChunkShutdown;
19 use crate::chunk::chunk_shutdown_ack::ChunkShutdownAck;
21 use crate::chunk::chunk_type::*;
[all …]
H A Dassociation_internal.rs1888 if let Some(chunk) = self in pop_pending_data_chunks_to_send()
1892 chunks.push(chunk); in pop_pending_data_chunks_to_send()
1902 if let Some(chunk) = self in pop_pending_data_chunks_to_send()
1906 chunks.push(chunk); in pop_pending_data_chunks_to_send()
2099 chunk: &Box<dyn Chunk + Send + Sync>, in handle_chunk()
2101 chunk.check()?; in handle_chunk()
2102 let chunk_any = chunk.as_any(); in handle_chunk()
2150 let handle_code = chunk.header().typ.0 >> 6; in handle_chunk()
2161 raw: chunk.marshal()?, in handle_chunk()
2183 raw: chunk.marshal()?, in handle_chunk()
/webrtc/sctp/src/chunk/
H A Dchunk_unknown.rs1 use crate::chunk::chunk_header::{ChunkHeader, CHUNK_HEADER_SIZE};
2 use crate::chunk::Chunk;
H A Dchunk_test.rs464 use crate::chunk::chunk_init::*;
465 use crate::chunk::chunk_payload_data::*;
466 use crate::chunk::chunk_selective_ack::ChunkSelectiveAck;
/webrtc/media/src/audio/
H A Dbuffer.rs195 let samples: Vec<_> = chunks.iter().map(|chunk| B::read_i16(&chunk[..])).collect(); in from_bytes()
228 layout::interleaved_by(chunks, samples, channels, |chunk| { in from_bytes()
229 MaybeUninit::new(B::read_i16(&chunk[..])) in from_bytes()
255 let samples: Vec<_> = chunks.iter().map(|chunk| B::read_i16(&chunk[..])).collect(); in from_bytes()
288 layout::deinterleaved_by(chunks, samples, channels, |chunk| { in from_bytes()
289 MaybeUninit::new(B::read_i16(&chunk[..])) in from_bytes()
/webrtc/rtcp/src/transport_feedbacks/transport_layer_cc/
H A Dtransport_layer_cc_test.rs62 for (name, chunk, want) in tests { in test_transport_layer_cc_run_length_chunk_marshal()
63 let got = chunk.marshal()?; in test_transport_layer_cc_run_length_chunk_marshal()
174 for (name, chunk, want) in tests { in test_transport_layer_cc_status_vector_chunk_marshal()
175 let got = chunk.marshal()?; in test_transport_layer_cc_status_vector_chunk_marshal()
254 for (name, chunk, want) in tests { in test_transport_layer_cc_recv_delta_marshal()
255 let got = chunk.marshal()?; in test_transport_layer_cc_recv_delta_marshal()
920 for (name, chunk, want) in tests { in test_transport_layer_cc_marshal()
921 let got = chunk.marshal()?; in test_transport_layer_cc_marshal()
/webrtc/util/src/vnet/conn/
H A Dconn_test.rs15 let mut chunk = ChunkUdp::new(c.destination_addr(), c.source_addr()); in write() localVariable
16 chunk.user_data = c.user_data(); in write()
20 tx.send(Box::new(chunk)) in write()
/webrtc/rtcp/src/extended_report/
H A Drle.rs196 for chunk in &self.chunks { in marshal_to()
197 buf.put_u16(chunk.0); in marshal_to()
/webrtc/rtcp/src/source_description/
H A Dmod.rs419 let chunk = SourceDescriptionChunk::unmarshal(raw_packet)?; in unmarshal() localVariable
420 offset += chunk.marshal_size(); in unmarshal()
421 chunks.push(chunk); in unmarshal()
/webrtc/sctp/src/param/
H A Dparam_supported_extensions.rs2 use crate::chunk::chunk_type::*;
H A Dparam_chunk_list.rs2 use crate::chunk::chunk_type::*;
/webrtc/sctp/examples/
H A Dping.rs2 use webrtc_sctp::chunk::chunk_payload_data::PayloadProtocolIdentifier;
H A Dthroughput.rs7 use webrtc_sctp::chunk::chunk_payload_data::PayloadProtocolIdentifier;
/webrtc/sctp/
H A DCHANGELOG.md33 * [#245 Fix incorrect chunk type Display for CWR](https://github.com/webrtc-rs/webrtc/pull/245) by …
/webrtc/sctp/src/stream/
H A Dmod.rs5 use crate::chunk::chunk_payload_data::{ChunkPayloadData, PayloadProtocolIdentifier};
329 let chunk = ChunkPayloadData { in packetize() localVariable
343 chunks.push(chunk); in packetize()

12