Searched refs:packet (Results 1 – 6 of 6) sorted by relevance
60 let mut packet = RtpPacket::new(self.header.clone()); in pack() localVariable61 packet.payload.put_u16(16); in pack()62 packet.payload.put_u8((data_len >> 5) as u8); in pack()63 packet.payload.put_u8(((data_len & 0x1F) << 3) as u8); in pack()64 packet.payload.put(data); in pack()67 f(packet.clone()); in pack()71 f(self.io.clone(), packet).await?; in pack()
100 let mut packet = RtpPacket::new(self.header.clone()); in pack_fu() localVariable101 packet.payload.put_u16(payload_hdr); in pack_fu()102 packet.payload.put_u8(fu_header); in pack_fu()103 packet.payload.put(fu_payload); in pack_fu()111 f(packet.clone()); in pack_fu()115 f(self.io.clone(), packet).await?; in pack_fu()124 let mut packet = RtpPacket::new(self.header.clone()); in pack_single() localVariable125 packet.header.marker = 1; in pack_single()126 packet.payload.put(nalu); in pack_single()131 f(packet.clone()); in pack_single()[all …]
75 let mut packet = RtpPacket::new(self.header.clone()); in pack_fu_a() localVariable76 packet.payload.put_u8(fu_indicator); in pack_fu_a()77 packet.payload.put_u8(fu_header); in pack_fu_a()83 packet.payload.put(fu_payload); in pack_fu_a()87 f(packet.clone()); in pack_fu_a()92 f(self.io.clone(), packet).await?; in pack_fu_a()102 let mut packet = RtpPacket::new(self.header.clone()); in pack_single() localVariable103 packet.header.marker = 1; in pack_single()104 packet.payload.put(nalu); in pack_single()110 f(packet.clone()); in pack_single()[all …]
7 Support transferring rtp packet.
189 pub fn on_packet(&mut self, packet: RtpPacket) { in on_packet()190 self.recv_ctx.received_rtp(packet); in on_packet()
311 rtp_channel_guard.on_packet_for_rtcp_handler(Box::new(move |packet: RtpPacket| { in handle_announce()314 rtcp_channel_in.lock().await.on_packet(packet); in handle_announce()428 move |io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>, packet: RtpPacket| { in handle_play()430 let msg = packet.marshal()?; in handle_play()444 move |io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>, packet: RtpPacket| { in handle_play()448 let msg = packet.marshal()?; in handle_play()