Home
last modified time | relevance | path

Searched refs:timestamp (Results 1 – 25 of 33) sorted by relevance

12

/xiu/protocol/rtmp/src/session/
H A Dcommon.rs114 timestamp, in send_audio()
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()
198 timestamp: &u32, in on_audio_data()
201 timestamp: *timestamp, in on_audio_data()
225 timestamp: &u32, in on_meta_data()
228 timestamp: *timestamp, in on_meta_data()
[all …]
H A Dclient_session.rs195 let timestamp = chunk_info.message_header.timestamp; in run() localVariable
196 self.process_messages(&mut msg, &timestamp).await?; in run()
234 timestamp: &u32, in process_messages()
267 self.common.on_audio_data(data, timestamp).await? in process_messages()
270 self.common.on_video_data(data, timestamp).await? in process_messages()
273 self.common.on_meta_data(raw_data, timestamp).await?; in process_messages()
H A Dserver_session.rs187 let timestamp = chunk_info.message_header.timestamp; in read_parse_chunks() localVariable
191 self.process_messages(&mut msg, &msg_stream_id, &timestamp) in read_parse_chunks()
245 timestamp: &u32, in process_messages()
267 self.common.on_audio_data(data, timestamp).await?; in process_messages()
270 self.common.on_video_data(data, timestamp).await?; in process_messages()
273 self.common.on_meta_data(raw_data, timestamp).await?; in process_messages()
/xiu/protocol/rtmp/src/chunk/
H A Dpacketizer.rs49 if cur_msg_header.timestamp < pre_msg_header.timestamp { in zip_chunk_header()
53 cur_msg_header.timestamp, in zip_chunk_header()
54 pre_msg_header.timestamp in zip_chunk_header()
59 cur_msg_header.timestamp - pre_msg_header.timestamp; in zip_chunk_header()
108 if message_header.timestamp >= 0xFFFFFF { in write_message_header()
110 (Some(message_header.timestamp), 0xFFFFFF) in write_message_header()
112 (None, message_header.timestamp) in write_message_header()
163 fn write_extened_timestamp(&mut self, timestamp: u32) -> Result<(), PackError> { in write_extened_timestamp()
164 self.writer.write_u32::<BigEndian>(timestamp)?; in write_extened_timestamp()
174 chunk_info.message_header.timestamp, in write_chunk()
H A Dmod.rs42 pub timestamp: u32, field
59 pub fn new(timestamp: u32, msg_length: u32, msg_type_id: u8, msg_stream_id: u32) -> Self { in new()
61 timestamp, in new()
133 timestamp: u32, in new()
142 timestamp, in new()
H A Dunpacketizer.rs372 self.current_chunk_info.message_header.timestamp, in print_current_message_header()
413 self.current_message_header().timestamp = in read_message_header()
445 if self.current_message_header().timestamp >= 0xFFFFFF { in read_message_header()
540 self.current_message_header().timestamp = self.reader.read_u32::<BigEndian>()?; in read_extended_timestamp()
556 let timestamp = self.current_message_header().timestamp; in read_extended_timestamp() localVariable
559 let (cur_abs_timestamp, is_overflow) = timestamp.overflowing_add(timestamp_delta); in read_extended_timestamp()
569 self.current_message_header().timestamp = cur_abs_timestamp; in read_extended_timestamp()
/xiu/protocol/rtmp/src/cache/
H A Dmod.rs64 pub fn save_metadata(&mut self, chunk_body: &BytesMut, timestamp: u32) { in save_metadata()
66 self.metadata_timestamp = timestamp; in save_metadata()
73 timestamp: self.metadata_timestamp, in get_metadata()
84 timestamp: u32, in save_audio_data()
87 timestamp, in save_audio_data()
99 self.audio_timestamp = timestamp; in save_audio_data()
120 timestamp: self.audio_timestamp, in get_audio_seq()
130 timestamp: self.video_timestamp, in get_video_seq()
140 timestamp: u32, in save_video_data()
143 timestamp, in save_video_data()
[all …]
/xiu/library/container/flv/src/
H A Ddemuxer.rs127 timestamp: u32, in demux()
146 pts: timestamp as i64 + tag_header.composition_time as i64, in demux()
147 dts: timestamp as i64, in demux()
176 timestamp: u32, in demux()
197 pts: timestamp as i64, in demux()
198 dts: timestamp as i64, in demux()
238 let timestamp = self.bytes_reader.read_u24::<BigEndian>()?; in read_flv_tag() localVariable
244 let dts: u32 = (timestamp & 0xffffff) | ((timestamp_ext as u32) << 24); in read_flv_tag()
252 timestamp: dts, in read_flv_tag()
258 timestamp: dts, in read_flv_tag()
H A Dmuxer.rs41 timestamp: u32, in write_flv_tag_header()
48 self.writer.write_u24::<BigEndian>(timestamp & 0xffffff)?; in write_flv_tag_header()
50 let timestamp_ext = (timestamp >> 24 & 0xff) as u8; in write_flv_tag_header()
H A Ddefine.rs161 Video { timestamp: u32, data: BytesMut },
162 Audio { timestamp: u32, data: BytesMut },
163 MetaData { timestamp: u32, data: BytesMut },
/xiu/protocol/rtsp/src/rtp/
H A Drtp_h264.rs124 async fn pack(&mut self, nalus: &mut BytesMut, timestamp: u32) -> Result<(), PackerError> { in pack()
125 … self.header.timestamp = timestamp; // ((timestamp as u64 * self.clock_rate as u64) / 1000) as u32; in pack()
156 timestamp: u32, field
170 self.timestamp = rtp_packet.header.timestamp; in unpack()
217 timestamp: self.timestamp, in unpack_single()
292 timestamp: self.timestamp, in unpack_fu()
367 timestamp: self.timestamp, in unpack_stap()
461 timestamp: self.timestamp, in unpack_mtap()
H A Drtp_h265.rs143 async fn pack(&mut self, nalus: &mut BytesMut, timestamp: u32) -> Result<(), PackerError> { in pack()
144 self.header.timestamp = timestamp; in pack()
174 timestamp: u32, field
189 self.timestamp = rtp_packet.header.timestamp; in unpack()
228 timestamp: self.timestamp, in unpack_single()
280 timestamp: self.timestamp, in unpack_ap()
349 timestamp: self.timestamp, in unpack_fu()
H A Drtp_aac.rs56 async fn pack(&mut self, data: &mut BytesMut, timestamp: u32) -> Result<(), PackerError> { in pack()
57 self.header.timestamp = timestamp; in pack()
149 timestamp: rtp_packet.header.timestamp + i as u32 * 1024, in unpack()
H A Drtp_header.rs20 pub timestamp: u32, field
42 rtp_header.timestamp = reader.read_u32::<BigEndian>()?; in unmarshal()
79 writer.write_u32::<BigEndian>(self.timestamp)?; in marshal()
/xiu/protocol/httpflv/src/
H A Dhttpflv.rs104 FrameData::Audio { timestamp, data } => (data, timestamp, tag_type::AUDIO), in write_flv_tag()
105 FrameData::Video { timestamp, data } => (data, timestamp, tag_type::VIDEO), in write_flv_tag()
106 FrameData::MetaData { timestamp, data } => { in write_flv_tag()
111 (data, timestamp, tag_type::SCRIPT_DATA_AMF) in write_flv_tag()
/xiu/protocol/rtmp/src/user_control_messages/
H A Dwriter.rs95 pub async fn write_ping_request(&mut self, timestamp: u32) -> Result<(), EventMessagesError> { in write_ping_request()
99 self.writer.write_u32::<BigEndian>(timestamp)?; in write_ping_request()
106 pub async fn write_ping_response(&mut self, timestamp: u32) -> Result<(), EventMessagesError> { in write_ping_response()
110 self.writer.write_u32::<BigEndian>(timestamp)?; in write_ping_response()
/xiu/protocol/rtmp/src/remuxer/
H A Drtsp2rtmp.rs181 timestamp, in receive_rtsp_data()
183 } => self.on_rtsp_audio(&mut data, timestamp).await?, in receive_rtsp_data()
185 timestamp, in receive_rtsp_data()
188 self.on_rtsp_video(&mut data, timestamp).await?; in receive_rtsp_data()
226 timestamp: u32, in on_rtsp_audio()
229 self.base_audio_timestamp = timestamp; in on_rtsp_audio()
250 (timestamp - self.base_audio_timestamp) / (self.audio_clock_rate / 1000); in on_rtsp_audio()
261 timestamp: u32, in on_rtsp_video()
264 self.base_video_timestamp = timestamp; in on_rtsp_video()
333 (timestamp - self.base_video_timestamp) / (self.video_clock_rate / 1000); in on_rtsp_video()
/xiu/protocol/hls/src/
H A Dflv_data_receiver.rs68 FrameData::Audio { timestamp, data } => FlvData::Audio { timestamp, data }, in receive_flv_data()
69 FrameData::Video { timestamp, data } => FlvData::Video { timestamp, data }, in receive_flv_data()
H A Dflv2hls.rs69 FlvData::Audio { timestamp, data } => { in process_flv_data()
70 let audio_data = self.audio_demuxer.demux(timestamp, data)?; in process_flv_data()
73 FlvData::Video { timestamp, data } => { in process_flv_data()
74 if let Some(video_data) = self.video_demuxer.demux(timestamp, data)? { in process_flv_data()
H A Dtest_flv2hls.rs31 FlvData::Audio { timestamp, data } => { in print_flv_data()
38 FlvData::Video { timestamp, data } => { in print_flv_data()
/xiu/library/logger/src/
H A Dtarget.rs44 let timestamp = "1524820690".parse::<i64>().unwrap(); in test_chrono() localVariable
46 let naive = NaiveDateTime::from_timestamp(timestamp, 0); in test_chrono()
/xiu/protocol/webrtc/src/
H A Dwhip.rs127 timestamp: rtp_packet.header.timestamp, in handle_whip()
137 timestamp: rtp_packet.header.timestamp, in handle_whip()
/xiu/library/streamhub/src/
H A Ddefine.rs122 Video { timestamp: u32, data: BytesMut },
123 Audio { timestamp: u32, data: BytesMut },
124 MetaData { timestamp: u32, data: BytesMut },
131 Video { timestamp: u32, data: BytesMut },
132 Audio { timestamp: u32, data: BytesMut },
H A Dlib.rs69 timestamp: _, in receive_frame_data_loop()
72 FrameData::Audio { timestamp, data } => { in receive_frame_data_loop()
74 timestamp, in receive_frame_data_loop()
86 FrameData::Video { timestamp, data } => { in receive_frame_data_loop()
88 timestamp, in receive_frame_data_loop()
123 PacketData::Audio { timestamp, data } => { in receive_packet_data_loop()
125 timestamp, in receive_packet_data_loop()
137 PacketData::Video { timestamp, data } => { in receive_packet_data_loop()
139 timestamp, in receive_packet_data_loop()
/xiu/protocol/rtsp/src/rtp/rtcp/
H A Drtcp_context.rs218 self.last_rtp_timestamp = pkt.header.timestamp; in send_rtp()
239 - (pkt.header.timestamp - self.last_rtp_timestamp) as i64; in received_rtp()
248 self.last_rtp_timestamp = pkt.header.timestamp; in received_rtp()

12