| /webrtc/rtcp/src/extended_report/ |
| H A D | extended_report_test.rs | 14 chunks: vec![Chunk(0x4006), Chunk(0x0006), Chunk(0x8765), Chunk(0x0000)], in decoded_packet()
23 chunks: vec![Chunk(0x4123), Chunk(0x3FFF), Chunk(0xFFFF), Chunk(0x0000)], in decoded_packet()
|
| H A D | rle.rs | 40 pub struct Chunk(pub u16); struct
42 impl fmt::Display for Chunk { implementation
54 impl Chunk { impl
115 pub chunks: Vec<Chunk>,
234 chunks.push(Chunk(raw_packet.get_u16())); in unmarshal()
|
| /webrtc/util/src/vnet/ |
| H A D | chunk_queue.rs | 11 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()
39 pub(crate) async fn peek(&self) -> Option<Box<dyn Chunk + Send + Sync>> { in peek()
|
| H A D | conn.rs | 7 use crate::vnet::chunk::{Chunk, ChunkUdp};
21 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>>>,
127 let c: Box<dyn Chunk + Send + Sync> = Box::new(chunk); in send_to()
|
| H A D | chunk.rs | 93 pub trait Chunk: fmt::Display + fmt::Debug { interface
106 fn clone_to(&self) -> Box<dyn Chunk + Send + Sync>; in clone_to()
161 impl Chunk for ChunkUdp {
194 fn clone_to(&self) -> Box<dyn Chunk + Send + Sync> { in clone_to()
268 impl Chunk for ChunkTcp {
301 fn clone_to(&self) -> Box<dyn Chunk + Send + Sync> { in clone_to()
|
| H A D | nat.rs | 5 use crate::vnet::chunk::Chunk;
158 from: &(dyn Chunk + Send + Sync), in translate_outbound()
159 ) -> Result<Option<Box<dyn Chunk + Send + Sync>>> { in translate_outbound()
289 from: &(dyn Chunk + Send + Sync), in translate_inbound()
290 ) -> Result<Option<Box<dyn Chunk + Send + Sync>>> { in translate_inbound()
|
| H A D | router.rs | 67 async fn on_inbound_chunk(&self, c: Box<dyn Chunk + Send + Sync>); in on_inbound_chunk()
74 pub type ChunkFilterFn = Box<dyn (Fn(&(dyn Chunk + Send + Sync)) -> bool) + Send + Sync>;
129 async fn on_inbound_chunk(&self, c: Box<dyn Chunk + Send + Sync>) { in on_inbound_chunk()
130 let from_parent: Box<dyn Chunk + Send + Sync> = { in on_inbound_chunk()
410 pub(crate) async fn push(&self, mut c: Box<dyn Chunk + Send + Sync>) { in push()
|
| /webrtc/sctp/src/chunk/ |
| H A D | chunk_unknown.rs | 2 use crate::chunk::Chunk;
19 impl Chunk for ChunkUnknown {
|
| H A D | chunk_forward_tsn.rs | 50 impl Chunk for ChunkForwardTsn {
140 impl Chunk for ChunkForwardTsnStream {
|
| H A D | chunk_cookie_ack.rs | 23 impl Chunk for ChunkCookieAck {
|
| H A D | chunk_shutdown_complete.rs | 23 impl Chunk for ChunkShutdownComplete {
|
| H A D | chunk_shutdown_ack.rs | 23 impl Chunk for ChunkShutdownAck {
|
| H A D | mod.rs | 29 pub(crate) trait Chunk: fmt::Display + fmt::Debug { interface
|
| H A D | chunk_cookie_echo.rs | 28 impl Chunk for ChunkCookieEcho {
|
| H A D | chunk_shutdown.rs | 29 impl Chunk for ChunkShutdown {
|
| H A D | chunk_error.rs | 46 impl Chunk for ChunkError {
|
| H A D | chunk_heartbeat.rs | 45 impl Chunk for ChunkHeartbeat {
|
| H A D | chunk_abort.rs | 44 impl Chunk for ChunkAbort {
|
| H A D | chunk_header.rs | 37 impl Chunk for ChunkHeader {
|
| H A D | chunk_heartbeat_ack.rs | 47 impl Chunk for ChunkHeartbeatAck {
|
| /webrtc/sctp/src/ |
| H A D | packet.rs | 1 use crate::chunk::Chunk;
60 pub(crate) chunks: Vec<Box<dyn Chunk + Send + Sync>>,
117 let c: Box<dyn Chunk + Send + Sync> = match ct { in unmarshal()
|
| /webrtc/interceptor/src/twcc/ |
| H A D | mod.rs | 102 last_chunk: Chunk,
188 struct Chunk { struct
194 impl Chunk { argument
|
| H A D | twcc_test.rs | 10 let mut c = Chunk::default(); in test_chunk_add()
35 let mut c = Chunk::default(); in test_chunk_add()
64 let mut c = Chunk::default(); in test_chunk_add()
94 let mut c = Chunk::default(); in test_chunk_add()
126 let mut c = Chunk::default(); in test_chunk_add()
|
| /webrtc/util/src/vnet/chunk_queue/ |
| H A D | chunk_queue_test.rs | 12 let c: Box<dyn Chunk> = Box::new(ChunkUdp::new( in test_chunk_queue()
|
| /webrtc/util/src/vnet/conn/ |
| H A D | conn_test.rs | 9 read_ch_tx: Arc<Mutex<Option<mpsc::Sender<Box<dyn Chunk + Send + Sync>>>>>,
14 async fn write(&self, c: Box<dyn Chunk + Send + Sync>) -> Result<()> { in write()
|