Lines Matching refs:timestamp
83 FrameData::Audio { timestamp, data } => { in send_channel_data()
84 self.send_audio(data, timestamp).await?; in send_channel_data()
86 FrameData::Video { timestamp, data } => { in send_channel_data()
87 self.send_video(data, timestamp).await?; in send_channel_data()
89 FrameData::MetaData { timestamp, data } => { in send_channel_data()
90 self.send_metadata(data, timestamp).await?; in send_channel_data()
110 pub async fn send_audio(&mut self, data: BytesMut, timestamp: u32) -> Result<(), SessionError> { in send_audio()
114 timestamp, in send_audio()
128 pub async fn send_video(&mut self, data: BytesMut, timestamp: u32) -> Result<(), SessionError> { in send_video()
132 timestamp, in send_video()
149 timestamp: u32, in send_metadata()
154 timestamp, in send_metadata()
171 timestamp: &u32, in on_video_data()
174 timestamp: *timestamp, in on_video_data()
189 .save_video_data(data, *timestamp) in on_video_data()
198 timestamp: &u32, in on_audio_data()
201 timestamp: *timestamp, in on_audio_data()
216 .save_audio_data(data, *timestamp) in on_audio_data()
225 timestamp: &u32, in on_meta_data()
228 timestamp: *timestamp, in on_meta_data()
241 self.stream_handler.save_metadata(data, *timestamp).await; in on_meta_data()
456 timestamp: u32, in save_video_data()
459 cache.save_video_data(chunk_body, timestamp).await?; in save_video_data()
467 timestamp: u32, in save_audio_data()
470 cache.save_audio_data(chunk_body, timestamp).await?; in save_audio_data()
475 pub async fn save_metadata(&self, chunk_body: &BytesMut, timestamp: u32) { in save_metadata()
477 cache.save_metadata(chunk_body, timestamp); in save_metadata()