| /xiu/protocol/hls/src/ |
| H A D | flv_data_receiver.rs | 25 app_name: String, field
35 app_name: String, in new()
45 app_name: app_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()
97 app_name: String, in subscribe_from_rtmp_channels()
112 app_name, in subscribe_from_rtmp_channels()
153 app_name: self.app_name.clone(), in unsubscribe_from_rtmp_channels()
|
| H A D | remuxer.rs | 34 app_name, in run()
39 app_name, in run()
|
| H A D | server.rs | 27 let app_name = String::from(rv[1]); in handle_connection() localVariable
41 let app_name = String::from(rv[1]); 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 | 62 app_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/library/streamhub/src/ |
| H A D | stream.rs | 9 app_name: String,
16 app_name: String,
24 app_name, in fmt()
35 app_name, in fmt()
|
| /xiu/protocol/rtmp/src/session/ |
| H A D | server_session.rs | 50 pub app_name: String, field
335 self.app_name, in on_amf0_command_message()
354 self.app_name, in on_set_chunk_size()
451 self.app_name = match app_name { in on_connect()
485 self.app_name, in on_create_stream()
517 self.app_name, in on_delete_stream()
591 self.app_name, in on_play()
643 self.app_name, in on_play()
704 self.app_name, in on_publish()
711 self.app_name, in on_publish()
[all …]
|
| H A D | common.rs | 297 app_name: String, in subscribe_from_channels()
303 app_name, in subscribe_from_channels()
309 app_name, in subscribe_from_channels()
336 app_name: String, in unsubscribe_from_channels()
341 app_name, in unsubscribe_from_channels()
359 app_name: String, in publish_to_channels()
371 app_name, in publish_to_channels()
392 app_name: String, in unpublish_to_channels()
398 app_name, in unpublish_to_channels()
403 app_name: app_name.clone(), in unpublish_to_channels()
[all …]
|
| H A D | client_session.rs | 77 app_name: String, field
98 app_name: String, in new()
133 app_name, in new()
348 app_name = self.app_name in send_connect()
350 properties.app = Some(self.app_name.clone()); in send_connect()
529 if let (Some(app_name), Some(stream_name)) = in on_status()
534 app_name.clone(), in on_status()
542 self.app_name.clone(), in on_status()
554 self.app_name.clone(), in on_status()
568 pub fn subscribe(&mut self, app_name: String, stream_name: String) { in subscribe()
[all …]
|
| /xiu/protocol/httpflv/src/ |
| H A D | httpflv.rs | 26 app_name: String, field
41 app_name: String, in new()
52 app_name, in new()
151 app_name: self.app_name.clone(), in unsubscribe_from_rtmp_channels()
178 app_name: self.app_name.clone(), in subscribe_from_rtmp_channels()
|
| H A D | server.rs | 29 let app_name = String::from(rv[1]); in handle_connection() localVariable
35 app_name, in handle_connection()
|
| /xiu/protocol/rtmp/src/relay/ |
| H A D | pull_client.rs | 37 app_name, in run()
44 app_name, in run()
53 app_name.clone(), in run()
|
| H A D | push_client.rs | 40 app_name, in run()
46 app_name.clone(), in run()
56 app_name.clone(), in run()
|
| /xiu/protocol/rtmp/src/utils/ |
| H A D | mod.rs | 14 pub app_name: String, field
54 self.app_name = url_parts[1].to_string(); in parse_url()
109 println!(" app_name: {}", parser.app_name); in test_rtmp_url_parser()
124 println!(" app_name: {}", parser.app_name); in test_rtmp_url_parser2()
|
| /xiu/protocol/webrtc/src/session/ |
| H A D | mod.rs | 134 let app_name = pars_map.get("app").unwrap().clone(); in run() localVariable
209 app_name, in run()
248 app_name: String, in publish_whip()
257 app_name, in publish_whip()
299 app_name: String, in unpublish_whip()
306 app_name, in unpublish_whip()
323 app_name: String, in subscribe_whep()
334 app_name: app_name.clone(), in subscribe_whep()
355 let app_name_out = app_name.clone(); in subscribe_whep()
412 app_name: String, in unsubscribe_whep()
[all …]
|
| /xiu/application/pprtmp/src/ |
| H A D | main.rs | 67 pull_parser.app_name.clone(), in main()
91 push_parser.app_name, in main()
97 push_client_session.subscribe(pull_parser.app_name, pull_parser.stream_name); in main()
|
| /xiu/protocol/rtmp/src/remuxer/ |
| H A D | rtsp2rtmp.rs | 37 app_name: String, field
61 let (app_name, stream_name) = if eles.len() < 2 { in new()
73 app_name, in new()
98 self.app_name.clone(), in publish_rtmp()
110 self.app_name.clone(), in unpublish_rtmp()
|
| /xiu/protocol/rtmp/src/ |
| H A D | rtmp.rs | 42 session.app_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()
46 app_name, in new()
|
| /xiu/protocol/rtmp/src/netconnection/ |
| H A D | writer.rs | 30 pub fn new(app_name: String) -> Self { in new()
32 app: Some(app_name), in new()
|