| /xiu/library/streamhub/src/ |
| H A D | stream.rs | 10 stream_name: String,
17 stream_name: String,
25 stream_name, in fmt()
30 stream_path: stream_name, in fmt()
36 stream_name, in fmt()
|
| /xiu/protocol/hls/src/ |
| H A D | flv_data_receiver.rs | 26 stream_name: String, field
36 stream_name: String, in new()
46 stream_name: stream_name.clone(), in new()
49 media_processor: Flv2HlsRemuxer::new(duration, app_name, stream_name, need_record), in new()
55 self.subscribe_from_rtmp_channels(self.app_name.clone(), self.stream_name.clone()) in run()
98 stream_name: String, in subscribe_from_rtmp_channels()
113 stream_name, in subscribe_from_rtmp_channels()
154 stream_name: self.stream_name.clone(), in unsubscribe_from_rtmp_channels()
|
| H A D | remuxer.rs | 35 stream_name, in run()
40 stream_name, in run()
|
| H A D | server.rs | 28 let stream_name = String::from(rv[2]); in handle_connection() localVariable
42 let stream_name = String::from(rv[2]); in handle_connection() localVariable
|
| H A D | ts.rs | 13 pub fn new(app_name: String, stream_name: String) -> Self { in new()
|
| H A D | m3u8.rs | 63 stream_name: String, in new()
84 ts_handler: Ts::new(app_name, stream_name), in new()
|
| H A D | flv2hls.rs | 36 pub fn new(duration: i64, app_name: String, stream_name: String, need_record: bool) -> Self { in new()
63 m3u8_handler: M3u8::new(duration, 6, app_name, stream_name, need_record), in new()
|
| /xiu/protocol/rtmp/src/session/ |
| H A D | server_session.rs | 51 pub stream_name: String, field
83 stream_name: String::from(""), in new()
325 self.stream_name in on_amf0_command_message()
336 self.stream_name in on_amf0_command_message()
355 self.stream_name, in on_set_chunk_size()
518 self.stream_name in on_delete_stream()
592 self.stream_name in on_play()
644 self.stream_name, in on_play()
705 self.stream_name, in on_publish()
712 self.stream_name, in on_publish()
[all …]
|
| H A D | common.rs | 298 stream_name: String, in subscribe_from_channels()
304 stream_name, in subscribe_from_channels()
310 stream_name, in subscribe_from_channels()
337 stream_name: String, in unsubscribe_from_channels()
342 stream_name, in unsubscribe_from_channels()
360 stream_name: String, in publish_to_channels()
372 stream_name, in publish_to_channels()
393 stream_name: String, in unpublish_to_channels()
399 stream_name in unpublish_to_channels()
404 stream_name: stream_name.clone(), in unpublish_to_channels()
[all …]
|
| H A D | client_session.rs | 80 stream_name: String, field
123 let (stream_name, _) = RtmpUrlParser::default() in new()
135 stream_name, in new()
400 stream_name: &String, in send_publish()
414 stream_name: &String, in send_play()
426 .write_get_stream_length(transaction_id, stream_name) in send_play()
529 if let (Some(app_name), Some(stream_name)) = in on_status()
535 stream_name.clone(), in on_status()
543 self.stream_name.clone(), in on_status()
555 self.stream_name.clone(), in on_status()
[all …]
|
| /xiu/protocol/rtmp/src/utils/ |
| H A D | mod.rs | 17 pub stream_name: String, field
79 self.stream_name = data[0].to_string(); in parse_raw_stream_name()
83 (self.stream_name.clone(), self.parameters.clone()) in parse_raw_stream_name()
111 println!(" stream_name: {}", parser.stream_name); in test_rtmp_url_parser()
126 println!(" stream_name: {}", parser.stream_name); in test_rtmp_url_parser2()
|
| /xiu/protocol/httpflv/src/ |
| H A D | httpflv.rs | 27 stream_name: String, field
42 stream_name: String, in new()
53 stream_name, in new()
152 stream_name: self.stream_name.clone(), in unsubscribe_from_rtmp_channels()
179 stream_name: self.stream_name.clone(), in subscribe_from_rtmp_channels()
|
| H A D | server.rs | 30 let stream_name = String::from(rv[2]); in handle_connection() localVariable
36 stream_name, in handle_connection()
|
| /xiu/protocol/rtmp/src/relay/ |
| H A D | pull_client.rs | 38 stream_name, in run()
45 stream_name in run()
54 stream_name.clone(), in run()
|
| H A D | push_client.rs | 41 stream_name, in run()
47 stream_name.clone(), in run()
57 stream_name.clone(), in run()
|
| /xiu/protocol/rtmp/src/netstream/ |
| H A D | writer.rs | 45 stream_name: &String, in write_play()
53 self.amf0_writer.write_string(stream_name)?; in write_play()
91 stream_name: &String, in write_release_stream()
97 self.amf0_writer.write_string(stream_name)?; in write_release_stream()
105 stream_name: &String, in write_fcpublish()
110 self.amf0_writer.write_string(stream_name)?; in write_fcpublish()
146 stream_name: &String, in write_publish()
152 self.amf0_writer.write_string(stream_name)?; in write_publish()
|
| /xiu/protocol/webrtc/src/session/ |
| H A D | mod.rs | 137 log::info!("1:{},2:{},3:{}", t, app_name, stream_name); in run()
210 stream_name, in run()
249 stream_name: String, in publish_whip()
258 stream_name, in publish_whip()
300 stream_name: String, in unpublish_whip()
307 stream_name, in unpublish_whip()
324 stream_name: String, in subscribe_whep()
335 stream_name: stream_name.clone(), in subscribe_whep()
356 let stream_name_out = stream_name.clone(); in subscribe_whep()
413 stream_name: String, in unsubscribe_whep()
[all …]
|
| /xiu/protocol/rtmp/src/remuxer/ |
| H A D | rtsp2rtmp.rs | 38 stream_name: String, field
61 let (app_name, stream_name) = if eles.len() < 2 { in new()
74 stream_name, in new()
99 self.stream_name.clone(), in publish_rtmp()
111 self.stream_name.clone(), in unpublish_rtmp()
|
| /xiu/protocol/rtmp/src/ |
| H A D | rtmp.rs | 43 session.stream_name, in run()
|
| /xiu/protocol/rtmp/src/cache/ |
| H A D | mod.rs | 44 pub fn new(app_name: String, stream_name: String, gop_num: usize) -> Self { in new()
47 stream_name, in new()
|
| /xiu/application/pprtmp/src/ |
| H A D | main.rs | 97 push_client_session.subscribe(pull_parser.app_name, pull_parser.stream_name); in main()
|
| /xiu/protocol/rtmp/src/netconnection/ |
| H A D | writer.rs | 263 stream_name: &String, in write_get_stream_length()
269 self.amf0_writer.write_string(stream_name)?; in write_get_stream_length()
|