Searched refs:nack (Results 1 – 8 of 8) sorted by relevance
12 use crate::nack::stream_support_nack;60 nack: TransportLayerNack, in resend_packets()64 if let Some(stream) = m.get(&nack.media_ssrc) { in resend_packets()71 for n in &nack.nacks { in resend_packets()111 if let Some(nack) = p.as_any().downcast_ref::<TransportLayerNack>() { in read()112 let nack = nack.clone(); in read() localVariable115 ResponderInternal::resend_packets(streams, nack).await; in read()
2 use crate::nack::UINT16SIZE_HALF;
118 for nack in &self.nacks { in fmt()119 out += format!("\t{}\t{:b}\n", nack.packet_id, nack.lost_packets).as_str(); in fmt()
12 use crate::nack::stream_support_nack;150 for nack in nacks{ in run()151 if let Err(err) = rtcp_writer.write(&[Box::new(nack)], &a).await{ in run()
3 use crate::nack::UINT16SIZE_HALF;
476 } else if let Some(nack) = p.as_any().downcast_ref::<TransportLayerNack>() { in read()477 let count = nack.nacks.iter().flat_map(|p| p.into_iter()).count() as u64; in read()479 let e = acc.entry(nack.media_ssrc).or_default(); in read()643 } else if let Some(nack) = p.as_any().downcast_ref::<TransportLayerNack>() { in write()644 let count = nack.nacks.iter().flat_map(|p| p.into_iter()).count() as u64; in write()646 let e = acc.entry(nack.media_ssrc).or_default(); in write()
9 use interceptor::nack::{generator::Generator, responder::Responder};
16 pub mod nack; module