Home
last modified time | relevance | path

Searched refs:String (Results 1 – 25 of 51) sorted by relevance

123

/xiu/protocol/rtmp/src/netconnection/
H A Dwriter.rs26 pub pub_type: Option<String>,
30 pub fn new(app_name: String) -> Self { in new()
125 String::from("flashVer"), in write_connect()
201 String::from("fmsVer"), in write_connect_response()
214 String::from("level"), in write_connect_response()
218 String::from("code"), in write_connect_response()
222 String::from("description"), in write_connect_response()
263 stream_name: &String, in write_get_stream_length() argument
288 String::from("level"), in error()
292 String::from("code"), in error()
[all …]
/xiu/library/streamhub/src/notify/
H A Dmod.rs4 on_publish_url: Option<String>,
5 on_unpublish_url: Option<String>,
6 on_play_url: Option<String>,
7 on_stop_url: Option<String>,
12 on_publish_url: Option<String>, in new() argument
13 on_unpublish_url: Option<String>, in new() argument
14 on_play_url: Option<String>, in new() argument
15 on_stop_url: Option<String>, in new() argument
25 pub async fn on_publish_notify(&self, body: String) { in on_publish_notify() argument
63 pub async fn on_play_notify(&self, body: String) { in on_play_notify() argument
[all …]
/xiu/protocol/rtmp/src/utils/
H A Dmod.rs9 pub raw_url: String,
11 pub raw_domain_name: String,
12 pub domain_name: String,
13 pub port: String,
14 pub app_name: String,
16 pub raw_stream_name: String,
17 pub stream_name: String,
18 pub parameters: String,
22 pub fn new(url: String) -> Self { in new()
77 pub fn parse_raw_stream_name(&mut self) -> (String, String) { in parse_raw_stream_name() argument
[all …]
/xiu/protocol/rtsp/src/http/
H A Dmod.rs8 pub method: String,
9 pub url: String,
11 pub address: String,
13 pub path: String,
14 pub version: String,
15 pub headers: IndexMap<String, String>,
16 pub body: Option<String>,
20 pub fn get_header(&self, header_name: &String) -> Option<&String> { in get_header() argument
107 pub version: String,
110 pub headers: IndexMap<String, String>,
[all …]
/xiu/protocol/webrtc/src/http/
H A Dmod.rs23 pub method: String,
24 pub address: String,
26 pub path: String,
29 pub path_parameters_map: IndexMap<String, String>,
30 pub version: String,
31 pub headers: IndexMap<String, String>,
32 pub body: Option<String>,
36 pub fn get_header(&self, header_name: &String) -> Option<&String> { in get_header() argument
76 let (k, v) = scanf!(ele, '=', String, String); in unmarshal()
155 pub version: String,
[all …]
/xiu/protocol/hls/src/
H A Dts.rs9 live_path: String,
13 pub fn new(app_name: String, stream_name: String) -> Self { in new() argument
22 pub fn write(&mut self, data: BytesMut) -> Result<(String, String), MediaError> { in write() argument
32 pub fn delete(&mut self, ts_file_name: String) { in delete() argument
H A Dm3u8.rs12 pub name: String,
13 path: String,
21 name: String, in new() argument
22 path: String, in new() argument
48 m3u8_folder: String,
49 live_m3u8_name: String,
54 vod_m3u8_content: String,
55 vod_m3u8_name: String,
62 app_name: String, in new() argument
63 stream_name: String, in new() argument
[all …]
H A Dflv_data_receiver.rs25 app_name: String,
26 stream_name: String,
35 app_name: String, in new() argument
36 stream_name: String, in new() argument
97 app_name: String, in subscribe_from_rtmp_channels() argument
98 stream_name: String, in subscribe_from_rtmp_channels() argument
106 request_url: String::from(""), in subscribe_from_rtmp_channels()
107 remote_addr: String::from(""), in subscribe_from_rtmp_channels()
147 request_url: String::from(""), in unsubscribe_from_rtmp_channels()
148 remote_addr: String::from(""), in unsubscribe_from_rtmp_channels()
H A Dserver.rs17 let mut file_path: String = String::from(""); in handle_connection()
27 let app_name = String::from(rv[1]); in handle_connection()
28 let stream_name = String::from(rv[2]); in handle_connection()
41 let app_name = String::from(rv[1]); in handle_connection()
42 let stream_name = String::from(rv[2]); in handle_connection()
43 let ts_name = String::from(rv[3]); in handle_connection()
/xiu/protocol/rtmp/src/amf0/
H A Damf0_reader.rs87 let val = String::from_utf8(bytes.to_vec())?; in read_raw_string()
154 let val = String::from_utf8(buff.to_vec())?; in read_long_string()
207 Amf0ValueType::UTF8String(String::from("connect")) in test_amf_reader()
216 String::from("app"), in test_amf_reader()
220 String::from("type"), in test_amf_reader()
224 String::from("flashVer"), in test_amf_reader()
228 String::from("swfUrl"), in test_amf_reader()
232 String::from("tcUrl"), in test_amf_reader()
353 String::from("tcUrl"), in test_player_connect_reader()
358 String::from("app"), in test_player_connect_reader()
[all …]
H A Ddefine.rs7 UTF8String(String),
8 Object(IndexMap<String, Amf0ValueType>),
10 EcmaArray(IndexMap<String, Amf0ValueType>),
11 LongUTF8String(String),
/xiu/protocol/rtmp/src/netstream/
H A Dwriter.rs45 stream_name: &String, in write_play() argument
66 .write_string(&String::from("deleteStream"))?; in write_delete_stream()
80 .write_string(&String::from("closeStream"))?; in write_close_stream()
91 stream_name: &String, in write_release_stream() argument
105 stream_name: &String, in write_fcpublish() argument
122 .write_string(&String::from("receiveAudio"))?; in write_receive_audio()
146 stream_name: &String, in write_publish() argument
147 stream_type: &String, in write_publish() argument
210 String::from("level"), in write_on_status()
214 String::from("code"), in write_on_status()
[all …]
/xiu/protocol/rtsp/src/sdp/
H A Dmod.rs12 b_type: String,
61 pub media_type: String,
63 protocol: String,
68 pub attributes: HashMap<String, String>,
88 pub raw_string: String,
90 origin: String,
91 session: String,
92 connection: String,
93 timing: String,
95 attributes: HashMap<String, String>,
[all …]
H A Dfmtp.rs27 mode: String,
62 pub fn marshal(&self) -> String { in marshal() argument
120 fn marshal(&self) -> String { in marshal() argument
123 let profile_level_id_str = String::from_utf8(self.profile_level_id.to_vec()).unwrap(); in marshal()
178 fn marshal(&self) -> String { in marshal() argument
179 let sps_str = String::from_utf8(self.sps.to_vec()).unwrap(); in marshal()
180 let pps_str = String::from_utf8(self.pps.to_vec()).unwrap(); in marshal()
181 let vps_str = String::from_utf8(self.vps.to_vec()).unwrap(); in marshal()
251 fn marshal(&self) -> String { in marshal() argument
252 let profile_level_id_str = String::from_utf8(self.profile_level_id.to_vec()).unwrap(); in marshal()
[all …]
/xiu/library/streamhub/src/
H A Dstream.rs9 app_name: String,
10 stream_name: String,
13 stream_path: String,
16 app_name: String,
17 stream_name: String,
/xiu/application/xiu/src/
H A Dapi.rs19 id: String,
28 async fn root(&self) -> String { in root() argument
29 String::from( in root()
36 async fn get_stream_status(&self) -> Result<String> { in get_stream_status() argument
50 return Ok(String::from("no stream data")); in get_stream_status()
70 Ok(String::from("")) in get_stream_status()
73 async fn kick_off_client(&self, id: KickOffClient) -> Result<String> { in kick_off_client() argument
84 Ok(String::from("ok")) in kick_off_client()
H A Dmain.rs27 .value_parser(value_parser!(String)) in main()
101 let args: Vec<String> = env::args().collect(); in main()
109 let config = if let Some(path) = matches.get_one::<String>("config_file_path") { in main()
151 let log_level = match matches.get_one::<String>("log") { in main()
153 None => String::from("info"), in main()
182 Logger::new(&String::from("info"), None, None)? in main()
/xiu/application/xiu/src/config/
H A Dmod.rs27 log_level: String, in new() argument
102 pub address: String,
108 pub address: String,
148 pub level: String,
155 pub rotate: String,
156 pub path: String,
167 pub on_publish: Option<String>,
168 pub on_unpublish: Option<String>,
169 pub on_play: Option<String>,
170 pub on_stop: Option<String>,
[all …]
/xiu/application/http-server/src/
H A Dmain.rs33 async fn on_publish(body: String) { in on_publish() argument
37 async fn on_unpublish(body: String) { in on_unpublish() argument
41 async fn on_play(body: String) { in on_play() argument
45 async fn on_stop(body: String) { in on_stop() argument
/xiu/protocol/rtmp/src/remuxer/
H A Drtsp2rtmp.rs37 app_name: String,
38 stream_name: String,
43 stream_path: String,
66 (String::from("rtsp"), String::from(eles[0])) in new()
68 (String::from(eles[0]), String::from(eles[1])) in new()
126 request_url: String::from(""), in subscribe_rtsp()
127 remote_addr: String::from(""), in subscribe_rtsp()
156 request_url: String::from(""), in unsubscribe_rtsp()
157 remote_addr: String::from(""), in unsubscribe_rtsp()
344 amf_writer.write_string(&String::from("@setDataFrame"))?; in gen_rtmp_meta_data()
[all …]
/xiu/application/pprtmp/src/
H A Dmain.rs31 .value_parser(value_parser!(String)) in main()
40 .value_parser(value_parser!(String)) in main()
44 let args: Vec<String> = env::args().collect(); in main()
50 let pull_rtmp_url = matches.get_one::<String>("pullrtmp").unwrap().clone(); in main()
51 let push_rtmp_url = matches.get_one::<String>("pushrtmp").unwrap().clone(); in main()
61 pull_parser.append_port(String::from("1935")); in main()
84 push_parser.append_port(String::from("1935")); in main()
/xiu/protocol/rtsp/src/
H A Drtsp_transport.rs24 pub transport_mod: Option<String>,
107 fn marshal(&self) -> String { in marshal() argument
121 String::from("") in marshal()
127 String::from("") in marshal()
133 String::from("") in marshal()
139 String::from("") in marshal()
145 String::from("") in marshal()
/xiu/protocol/rtmp/src/session/
H A Dclient_session.rs76 raw_domain_name: String,
77 app_name: String,
79 raw_stream_name: String,
80 stream_name: String,
97 raw_domain_name: String, in new() argument
98 app_name: String, in new() argument
99 raw_stream_name: String, in new() argument
400 stream_name: &String, in send_publish() argument
401 stream_type: &String, in send_publish() argument
414 stream_name: &String, in send_play() argument
[all …]
/xiu/library/logger/src/
H A Dlogger.rs40 fn get_log_file_name(rotate: Rotate) -> String { in get_log_file_name() argument
73 pub fn gen_log_file(rotate: Rotate, path: String) -> Result<File> { in gen_log_file()
90 path: String, in gen_log_file_thread_run() argument
140 pub fn new(level: &String, rotate: Option<Rotate>, path: Option<String>) -> Result<Logger> { in new() argument
196 &String::from("info"), in test_log()
198 Some(String::from("./logs")), in test_log()
/xiu/protocol/httpflv/src/
H A Dhttpflv.rs26 app_name: String,
27 stream_name: String,
35 request_url: String,
41 app_name: String, in new() argument
42 stream_name: String, in new() argument
45 request_url: String, in new() argument

123