Home
last modified time | relevance | path

Searched refs:define (Results 1 – 25 of 65) sorted by relevance

123

/xiu/protocol/rtsp/src/rtp/
H A Drtp_h264.rs1 use super::define;
21 use streamhub::define::FrameData;
178 define::STAP_A | define::STAP_B => { in unpack()
181 define::MTAP_16 | define::MTAP_24 => { in unpack()
184 define::FU_A | define::FU_B => { in unpack()
209 _t: define::RtpNalType, in unpack_single()
267 t: define::RtpNalType, in unpack_fu()
273 if t == define::FU_B { in unpack_fu()
347 t: define::RtpNalType, in unpack_stap()
353 if t == define::STAP_B { in unpack_stap()
[all …]
H A Drtp_h265.rs1 use super::define;
21 use streamhub::define::FrameData;
92 fu_header = (nalu_header_1st_byte & 0x1F) | define::FU_END; in pack_fu()
106 if fu_header & define::FU_START > 0 { in pack_fu()
162 if nalu.len() + define::RTP_FIXED_HEADER_LEN <= self.mtu { in pack_nalu()
194 define::FU => { in unpack()
197 define::AP => { in unpack()
200 define::PACI => return Ok(()), in unpack()
223 annexb_payload.extend_from_slice(&define::ANNEXB_NALU_START_CODE); in unpack_single()
275 payload.extend_from_slice(&define::ANNEXB_NALU_START_CODE); in unpack_ap()
[all …]
H A Dutils.rs1 use super::define;
13 use streamhub::define::FrameData;
69 fu_header & define::FU_START > 0 in is_fu_start()
73 fu_header & define::FU_END > 0 in is_fu_end()
/xiu/protocol/rtmp/src/user_control_messages/
H A Dwriter.rs2 super::{define, errors::EventMessagesError},
3 crate::messages::define::msg_type_id,
36 .write_u16::<BigEndian>(define::RTMP_EVENT_STREAM_BEGIN)?; in write_stream_begin()
46 .write_u16::<BigEndian>(define::RTMP_EVENT_STREAM_EOF)?; in write_stream_eof()
57 .write_u16::<BigEndian>(define::RTMP_EVENT_STREAM_DRY)?; in write_stream_dry()
72 .write_u16::<BigEndian>(define::RTMP_EVENT_SET_BUFFER_LENGTH)?; in write_set_buffer_length()
87 .write_u16::<BigEndian>(define::RTMP_EVENT_STREAM_IS_RECORDED)?; in write_stream_is_record()
98 .write_u16::<BigEndian>(define::RTMP_EVENT_PING)?; in write_ping_request()
109 .write_u16::<BigEndian>(define::RTMP_EVENT_PONG)?; in write_ping_response()
H A Dreader.rs2 super::{define, errors},
3 crate::messages::define as message_define,
22 define::RTMP_EVENT_SET_BUFFER_LENGTH => { in parse_event()
26 define::RTMP_EVENT_STREAM_BEGIN => { in parse_event()
30 define::RTMP_EVENT_STREAM_IS_RECORDED => { in parse_event()
H A Dmod.rs3 pub mod define; module
/xiu/protocol/rtmp/src/handshake/
H A Dhandshake_server.rs3 define, define::ServerHandshakeState, digest::DigestProcessor, errors::HandshakeError,
147 let c1_bytes = self.reader.read_bytes(define::RTMP_HANDSHAKE_SIZE)?; in read_c1()
157 self.reader.read_bytes(define::RTMP_HANDSHAKE_SIZE)?; in read_c2()
162 self.writer.write_u8(define::RTMP_VERSION as u8)?; in write_s0()
173 .write_random_bytes(define::RTMP_HANDSHAKE_SIZE as u32 - 8)?; in write_s1()
209 self.reader.read_bytes(define::RTMP_HANDSHAKE_SIZE)?; in read_c2()
214 self.writer.write_u8(define::RTMP_VERSION as u8)?; in write_s0()
223 writer.write(&define::RTMP_SERVER_VERSION)?; in write_s1()
224 writer.write_random_bytes(define::RTMP_HANDSHAKE_SIZE as u32 - 8)?; in write_s1()
244 writer.write_random_bytes(define::RTMP_HANDSHAKE_SIZE as u32 - 8)?; in write_s2()
[all …]
H A Dhandshake_client.rs3 define, define::ClientHandshakeState, errors::HandshakeError,
78 self.writer.write_u8(define::RTMP_VERSION as u8)?; in write_c0()
86 .write_random_bytes((define::RTMP_HANDSHAKE_SIZE - 8) as u32)?; in write_c1()
99 self.s1_bytes = self.reader.read_bytes(define::RTMP_HANDSHAKE_SIZE)?; in read_s1()
103 let _ = self.reader.read_bytes(define::RTMP_HANDSHAKE_SIZE)?; in read_s2()
H A Ddigest.rs3 define,
4 define::SchemaVersion,
105 let digest_data = new_reader.read_bytes(define::RTMP_DIGEST_LENGTH)?; in cook_raw_message()
115 if result.len() != define::RTMP_DIGEST_LENGTH { in make_digest()
H A Dmod.rs1 pub mod define; module
/xiu/library/container/flv/src/
H A Dflv_tag_header.rs5 define,
96 if tag_header.sound_format == define::SoundFormat::AAC as u8 { in unmarshal()
112 if self.sound_format == define::SoundFormat::AAC as u8 { in marshal()
172 if tag_header.codec_id == define::AvcCodecId::H264 as u8 in unmarshal()
173 || tag_header.codec_id == define::AvcCodecId::HEVC as u8 in unmarshal()
204 if self.codec_id == define::AvcCodecId::H264 as u8 in marshal()
205 || self.codec_id == define::AvcCodecId::HEVC as u8 in marshal()
H A Ddemuxer_tag.rs2 super::{define, errors::FlvDemuxerError},
97 if self.tag.sound_format == define::SoundFormat::AAC as u8 { in parse_tag_header()
168 if self.tag.codec_id == define::AvcCodecId::H264 as u8 in parse_tag_header()
169 || self.tag.codec_id == define::AvcCodecId::HEVC as u8 in parse_tag_header()
/xiu/library/container/mpegts/src/
H A Dts.rs3 define,
4 define::{epat_pid, epes_stream_id, ts},
85 || (define::epes_stream_id::PES_SID_VIDEO in write()
86 == (cur_stream.stream_id & define::epes_stream_id::PES_SID_VIDEO) in write()
100 if (flags & define::MPEG_FLAG_IDR_FRAME) > 0 { in write()
240 ts_header.or_u8_at(1, define::TS_PAYLOAD_UNIT_START_INDICATOR)?; in write_ts_header_for_pes()
244 && define::PTS_NO_VALUE != stream_data.pts) in write_ts_header_for_pes()
257 ts_header.or_u8_at(5, define::AF_FLAG_PCR)?; in write_ts_header_for_pes()
259 let pcr = if define::PTS_NO_VALUE == stream_data.dts { in write_ts_header_for_pes()
272 && define::PTS_NO_VALUE != stream_data.pts in write_ts_header_for_pes()
[all …]
H A Dpes.rs2 super::{define, errors::MpegTsError},
108 if define::PTS_NO_VALUE != stream_data.pts { in write_pes_header()
113 if define::PTS_NO_VALUE != stream_data.dts && stream_data.dts != stream_data.pts { in write_pes_header()
161 if define::epsi_stream_type::PSI_STREAM_H264 == stream_data.codec_id && !h264_h265_with_aud in write_pes_header()
168 self.bytes_writer.len() - define::PES_HEADER_LEN as usize + payload_data_length; in write_pes_header()
/xiu/protocol/rtmp/src/amf0/
H A Dmod.rs3 pub mod define; module
10 pub use self::define::Amf0ValueType;
/xiu/protocol/rtmp/src/cache/
H A Dmod.rs12 streamhub::define::FrameData,
16 define,
95 if tag_header.sound_format == define::SoundFormat::AAC as u8 in save_audio_data()
96 && tag_header.aac_packet_type == define::aac_packet_type::AAC_SEQHDR in save_audio_data()
150 let is_key_frame = tag_header.frame_type == define::frame_type::KEY_FRAME; in save_video_data()
153 if is_key_frame && tag_header.avc_packet_type == define::avc_packet_type::AVC_SEQHDR { in save_video_data()
/xiu/library/streamhub/src/statistics/
H A Davstatistics.rs15 define,
16 define::{aac_packet_type, AvcCodecId, SoundFormat},
50 audio_info.profile = define::u8_2_aac_profile(codec_info.profile); in notify_audio_codec_info()
59 video_info.profile = define::u8_2_avc_profile(codec_info.profile); in notify_video_codec_info()
60 video_info.level = define::u8_2_avc_level(codec_info.level); in notify_video_codec_info()
/xiu/application/xiu/src/
H A Dapi.rs9 streamhub::{define, define::StreamHubEventSender, utils::Uuid},
39 let hub_event = define::StreamHubEvent::ApiStatistic { in get_stream_status()
77 let hub_event = define::StreamHubEvent::ApiKickClient { id }; in kick_off_client()
/xiu/protocol/rtmp/src/session/
H A Dserver_session.rs6 define,
7 define::SessionType,
13 define::CHUNK_SIZE,
18 messages::{define::RtmpMessageData, parser::MessageParser},
33 define::StreamHubEventSender,
439 define::PEER_BANDWIDTH, in on_connect()
440 define::peer_bandwidth_limit_type::DYNAMIC, in on_connect()
447 _ => &define::OBJENCODING_AMF0, in on_connect()
465 define::FMSVER, in on_connect()
466 &define::CAPABILITIES, in on_connect()
[all …]
H A Dclient_session.rs6 define,
7 define::SessionType,
13 define::CHUNK_SIZE,
17 handshake::{define::ClientHandshakeState, handshake_client::SimpleHandshakeClient},
18 messages::{define::RtmpMessageData, parser::MessageParser},
32 streamhub::define::StreamHubEventSender,
155 self.send_connect(&(define::TRANSACTION_ID_CONNECT as f64)) in run()
161 self.send_create_stream(&(define::TRANSACTION_ID_CREATE_STREAM as f64)) in run()
219 while bytes_len < handshake::define::RTMP_HANDSHAKE_SIZE * 2 { in handshake()
309 define::TRANSACTION_ID_CONNECT => { in on_amf0_command_message()
[all …]
H A Dmod.rs2 pub mod define; module
/xiu/protocol/rtmp/src/messages/
H A Dmod.rs3 pub mod define; module
/xiu/protocol/hls/src/
H A Dflv_data_receiver.rs11 define::{
19 xflv::define::FlvData,
104 sub_data_type: streamhub::define::SubDataType::Frame, in subscribe_from_rtmp_channels()
145 sub_data_type: streamhub::define::SubDataType::Frame, in unsubscribe_from_rtmp_channels()
/xiu/protocol/rtmp/src/protocol_control_messages/
H A Dmod.rs4 pub mod define; module
/xiu/protocol/httpflv/src/
H A Dlib.rs4 pub mod define; module

123