Home
last modified time | relevance | path

Searched refs:str (Results 1 – 25 of 31) sorted by relevance

12

/xiu/protocol/rtsp/src/session/
H A Ddefine.rs4 pub const OPTIONS: &str = "OPTIONS";
5 pub const DESCRIBE: &str = "DESCRIBE";
6 pub const ANNOUNCE: &str = "ANNOUNCE";
7 pub const SETUP: &str = "SETUP";
8 pub const PLAY: &str = "PLAY";
9 pub const PAUSE: &str = "PAUSE";
10 pub const TEARDOWN: &str = "TEARDOWN";
11 pub const GET_PARAMETER: &str = "GET_PARAMETER";
13 pub const REDIRECT: &str = "REDIRECT";
14 pub const RECORD: &str = "RECORD";
[all …]
H A Derrors.rs7 std::str::Utf8Error,
/xiu/protocol/webrtc/src/http/
H A Ddefine.rs2 pub const OPTIONS: &str = "OPTIONS";
3 pub const PATCH: &str = "PATCH";
4 pub const POST: &str = "POST";
5 pub const DELETE: &str = "DELETE";
6 pub const GET: &str = "GET";
H A Dmod.rs12 fn unmarshal(request_data: &str) -> Option<Self> in unmarshal()
41 pub fn parse_content_length(request_data: &str) -> Option<u32> { in parse_content_length()
53 fn unmarshal(request_data: &str) -> Option<Self> { in unmarshal()
68 let path_data: Vec<&str> = path.splitn(2, '?').collect(); in unmarshal()
73 let pars_array: Vec<&str> = pars.split('&').collect(); in unmarshal()
163 fn unmarshal(request_data: &str) -> Option<Self> { in unmarshal()
/xiu/protocol/rtmp/src/session/
H A Ddefine.rs12 pub const FMSVER: &str = "FMS/3,0,1,123";
14 pub const LEVEL: &str = "status";
25 pub const RTMP_LEVEL_WARNING: &str = "warning";
26 pub const RTMP_LEVEL_STATUS: &str = "status";
27 pub const RTMP_LEVEL_ERROR: &str = "error\n";
/xiu/protocol/rtsp/src/sdp/
H A Dfmtp.rs40 pub fn new(codec: &str, raw_data: &str) -> Option<Fmtp> { in new() argument
73 fn unmarshal(raw_data: &str) -> Option<Self> { in unmarshal()
75 let eles: Vec<&str> = raw_data.splitn(2, ' ').collect(); in unmarshal()
85 let parameters: Vec<&str> = eles[1].split(';').collect(); in unmarshal()
99 let spspps: Vec<&str> = kv[1].split(',').collect(); in unmarshal()
136 fn unmarshal(raw_data: &str) -> Option<Self> { in unmarshal()
138 let eles: Vec<&str> = raw_data.splitn(2, ' ').collect(); in unmarshal()
148 let parameters: Vec<&str> = eles[1].split(';').collect(); in unmarshal()
194 fn unmarshal(raw_data: &str) -> Option<Self> { in unmarshal()
196 let eles: Vec<&str> = raw_data.splitn(2, ' ').collect(); in unmarshal()
[all …]
H A Dmod.rs18 fn unmarshal(raw_data: &str) -> Option<Self> { in unmarshal()
21 let parameters: Vec<&str> = raw_data.split(':').collect(); in unmarshal()
101 fn unmarshal(raw_data: &str) -> Option<Self> { in unmarshal()
103 let parameters: Vec<&str> = raw_data.split(' ').collect(); in unmarshal()
181 fn unmarshal(raw_data: &str) -> Option<Self> { in unmarshal()
187 let lines: Vec<&str> = raw_data.split(|c| c == '\r' || c == '\n').collect(); in unmarshal()
192 let kv: Vec<&str> = line.trim().splitn(2, '=').collect(); in unmarshal()
251 let attribute: Vec<&str> = kv[1].splitn(2, ':').collect(); in unmarshal()
H A Drtpmap.rs15 fn unmarshal(raw_data: &str) -> Option<Self> { in unmarshal()
18 let parts: Vec<&str> = raw_data.split(' ').collect(); in unmarshal()
27 let parameters: Vec<&str> = part_1.split('/').collect(); in unmarshal()
/xiu/protocol/rtsp/src/
H A Drtsp_range.rs21 fn unmarshal(raw_data: &str) -> Option<Self> { in unmarshal()
24 let kv: Vec<&str> = raw_data.splitn(2, '=').collect(); in unmarshal()
32 let ranges: Vec<&str> = kv[1].split('-').collect(); in unmarshal()
34 let get_clock_time = |range_time: &str| -> i64 { in unmarshal()
53 let ranges: Vec<&str> = kv[1].split('-').collect(); in unmarshal()
55 let get_npt_time = |range_time: &str| -> i64 { in unmarshal()
H A Drtsp_codec.rs14 pub static ref RTSP_CODEC_ID_2_NAME: HashMap<RtspCodecId, &'static str> = {
22 pub static ref RTSP_CODEC_NAME_2_ID: HashMap<&'static str, RtspCodecId> = {
H A Dglobal_trait.rs2 fn unmarshal(request_data: &str) -> Option<Self> in unmarshal()
H A Drtsp_transport.rs31 fn unmarshal(raw_data: &str) -> Option<Self> { in unmarshal()
34 let param_parts: Vec<&str> = raw_data.split(';').collect(); in unmarshal()
36 let kv: Vec<&str> = part.split('=').collect(); in unmarshal()
H A Drtsp_utils.rs11 pub fn print(title: &str, data: BytesMut) { in print() argument
/xiu/protocol/rtmp/src/handshake/
H A Ddefine.rs28 pub const RTMP_SERVER_KEY_FIRST_HALF: &str = "Genuine Adobe Flash Media Server 001";
29 pub const RTMP_CLIENT_KEY_FIRST_HALF: &str = "Genuine Adobe Flash Player 001";
/xiu/protocol/rtmp/src/cache/
H A Dmetadata.rs64 if let Amf0ValueType::UTF8String(str) = values.remove(0) { in is_metadata()
65 if str == "@setDataFrame" || str == "onMetaData" { in is_metadata()
/xiu/protocol/rtmp/src/netconnection/
H A Dwriter.rs188 fmsver: &str, in write_connect_response() argument
190 code: &str, in write_connect_response() argument
191 level: &str, in write_connect_response() argument
192 description: &str, in write_connect_response() argument
277 code: &str, in error() argument
278 level: &str, in error() argument
279 description: &str, in error() argument
/xiu/protocol/rtmp/src/utils/
H A Dmod.rs46 let url_parts: Vec<&str> = remove_header_left.split('/').collect(); in parse_url()
69 let data: Vec<&str> = self.raw_domain_name.split(':').collect(); in parse_raw_domain_name()
78 let data: Vec<&str> = self.raw_stream_name.split('?').collect(); in parse_raw_stream_name()
H A Dprint.rs16 pub fn print2(title: &str, data: BytesMut) { in print2() argument
/xiu/application/http-server/src/
H A Dmain.rs29 async fn root() -> &'static str { in root()
/xiu/protocol/rtmp/src/netstream/
H A Dwriter.rs199 level: &str, in write_on_status() argument
200 code: &str, in write_on_status() argument
201 description: &str, in write_on_status() argument
/xiu/application/xiu/src/config/
H A Dmod.rs187 let str = fs::read_to_string( in test_toml_parse() localVariable
191 match str { in test_toml_parse()
/xiu/library/logger/src/
H A Dlogger.rs11 str::FromStr,
30 fn from_str(input: &str) -> Result<Rotate, Self::Err> { in from_str()
/xiu/protocol/rtsp/src/http/
H A Dmod.rs26 fn unmarshal(request_data: &str) -> Option<Self> { in unmarshal()
115 fn unmarshal(request_data: &str) -> Option<Self> { in unmarshal()
/xiu/protocol/webrtc/src/session/
H A Dmod.rs86 if let Some(content_length) = parse_content_length(std::str::from_utf8(&remaining_data)?) { in run()
101 if let Some(http_request) = HttpRequest::unmarshal(std::str::from_utf8(&request_data)?) { in run()
103 let eles: Vec<&str> = http_request.path.splitn(2, '/').collect(); in run()
484 fn gen_file_response(file_path: &str) -> HttpResponse { in gen_file_response()
/xiu/protocol/hls/src/
H A Dserver.rs60 async fn simple_file_send(filename: &str) -> Result<Response<Body>> { in simple_file_send()

12