Lines Matching refs:track
160 for track in self.tracks.values_mut() { in on_rtp_over_rtsp_message()
161 if let Some(interleaveds) = track.transport.interleaved { in on_rtp_over_rtsp_message()
166 track.on_rtp(&mut cur_reader).await?; in on_rtp_over_rtsp_message()
168 track.on_rtcp(&mut cur_reader, self.io.clone()).await; in on_rtp_over_rtsp_message()
297 for track in self.tracks.values_mut() { in handle_announce()
299 let mut rtp_channel_guard = track.rtp_channel.lock().await; in handle_announce()
310 let rtcp_channel = Arc::clone(&track.rtcp_channel); in handle_announce()
330 for track in self.tracks.values_mut() { in handle_setup()
331 if !rtsp_request.url.contains(&track.media_control) { in handle_setup()
348 track.create_packer(self.io.clone()).await; in handle_setup()
366 track.create_packer(Arc::new(Mutex::new(box_udp_io))).await; in handle_setup()
368 track.rtp_receive_loop(box_udp_io).await; in handle_setup()
379 track.rtcp_receive_loop(box_rtcp_io).await; in handle_setup()
402 track.set_transport(trans).await; in handle_setup()
414 for track in self.tracks.values_mut() { in handle_play()
415 let protocol_type = track.transport.protocol_type.clone(); in handle_play()
419 let channel_identifer = if let Some(interleaveds) = track.transport.interleaved in handle_play()
427 track.rtp_channel.lock().await.on_packet_handler(Box::new( in handle_play()
443 track.rtp_channel.lock().await.on_packet_handler(Box::new( in handle_play()
615 let track = RtspTrack::new(TrackType::Audio, codec_info, media_control); in new_tracks() localVariable
616 self.tracks.insert(TrackType::Audio, track); in new_tracks()
629 let track = RtspTrack::new(TrackType::Video, codec_info, media_control); in new_tracks() localVariable
630 self.tracks.insert(TrackType::Video, track); in new_tracks()