Searched refs:chunk_body (Results 1 – 3 of 3) sorted by relevance
| /xiu/protocol/rtmp/src/cache/ |
| H A D | mod.rs | 64 pub fn save_metadata(&mut self, chunk_body: &BytesMut, timestamp: u32) { in save_metadata()
65 self.metadata.save(chunk_body); in save_metadata()
83 chunk_body: &BytesMut, in save_audio_data()
88 data: chunk_body.clone(), in save_audio_data()
92 let mut reader = BytesReader::new(chunk_body.clone()); in save_audio_data()
98 self.audio_seq = chunk_body.clone(); in save_audio_data()
139 chunk_body: &BytesMut, in save_video_data()
144 data: chunk_body.clone(), in save_video_data()
147 let mut reader = BytesReader::new(chunk_body.clone()); in save_video_data()
161 self.video_seq = chunk_body.clone(); in save_video_data()
[all …]
|
| H A D | metadata.rs | 9 chunk_body: BytesMut, field
22 chunk_body: BytesMut::new(), in new()
29 self.chunk_body = body.clone(); in save()
38 let (_, right) = self.chunk_body.split_at(amf_writer.len()); in remove_set_data_frame()
95 self.chunk_body.clone() in get_chunk_body()
|
| /xiu/protocol/rtmp/src/session/ |
| H A D | common.rs | 455 chunk_body: &BytesMut, in save_video_data()
459 cache.save_video_data(chunk_body, timestamp).await?; in save_video_data()
466 chunk_body: &BytesMut, 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()
|