| /xiu/protocol/rtmp/src/relay/ |
| H A D | push_client.rs | 12 address: String, field
19 address: String, in new()
24 address, in new()
48 self.address.clone() in run()
50 let stream = TcpStream::connect(self.address.clone()).await?; in run()
55 self.address.clone(), in run()
|
| H A D | pull_client.rs | 11 address: String, field
18 address: String, in new()
23 address, in new()
47 let stream = TcpStream::connect(self.address.clone()).await?; in run()
52 self.address.clone(), in run()
|
| /xiu/protocol/rtsp/src/ |
| H A D | rtsp.rs | 9 address: String, field
14 pub fn new(address: String, event_producer: StreamHubEventSender) -> Self { in new()
16 address, in new()
22 let socket_addr: &SocketAddr = &self.address.parse().unwrap(); in run()
|
| /xiu/protocol/rtmp/src/ |
| H A D | rtmp.rs | 9 address: String, field
15 pub fn new(address: String, event_producer: StreamHubEventSender, gop_num: usize) -> Self { in new()
17 address, in new()
24 let socket_addr: &SocketAddr = &self.address.parse().unwrap(); in run()
|
| /xiu/application/xiu/src/ |
| H A D | service.rs | 101 let address = format!( in start_rtmp() localVariable
103 ip = push_value.address, in start_rtmp()
108 address, in start_rtmp()
124 let address = format!( in start_rtmp() localVariable
126 ip = pull_cfg_value.address, in start_rtmp()
131 address, in start_rtmp()
147 let address = format!("0.0.0.0:{listen_port}"); in start_rtmp() localVariable
206 let address = format!("0.0.0.0:{listen_port}"); in start_rtsp() localVariable
208 let mut rtsp_server = RtspServer::new(address, producer); in start_rtsp()
230 let address = format!("0.0.0.0:{listen_port}"); in start_webrtc() localVariable
[all …]
|
| /xiu/protocol/rtmp/ |
| H A D | README.md | 26 let address = format!("0.0.0.0:{port}", port = listen_port);
28 let mut rtmp_server = RtmpServer::new(address, sender, 1);
63 let address = format!("{ip}:{port}", ip = "192.168.0.2", port = 1935);
66 address,
78 let address = format!("{ip}:{port}", ip = "192.168.0.3", port = "1935");
79 log::info!("start rtmp pull client from address: {}", address);
81 address,
95 let address = format!("0.0.0.0:{port}", port = listen_port);
97 let mut rtmp_server = RtmpServer::new(address, sender.clone(), 1);
|
| /xiu/protocol/webrtc/src/ |
| H A D | webrtc.rs | 15 address: String, field
21 pub fn new(address: String, event_producer: StreamHubEventSender) -> Self { in new()
23 address, in new()
30 let socket_addr: &SocketAddr = &self.address.parse().unwrap(); in run()
|
| /xiu/application/xiu/src/config/ |
| H A D | config.toml | 12 address = "192.168.0.1"
17 address = "localhost"
21 address = "192.168.0.3"
|
| H A D | mod.rs | 102 pub address: String, field
108 pub address: String, field
|
| /xiu/protocol/rtsp/src/http/ |
| H A D | mod.rs | 11 pub address: String, field
49 if let Some(address) = address_val { in unmarshal()
50 rtsp_request.address = address; in unmarshal()
|
| /xiu/protocol/webrtc/src/http/ |
| H A D | mod.rs | 24 pub address: String, field
98 if let Some(address) = address_val { in unmarshal()
99 http_request.address = address; in unmarshal()
|
| /xiu/ |
| H A D | README_CN.md | 140 address = "192.168.0.1"
146 address = "localhost"
150 address = "192.168.0.3"
258 address = "localhost"
297 address = "localhost"
|
| H A D | README.md | 142 address = "192.168.0.1"
148 address = "localhost"
152 address = "192.168.0.3"
254 2. Open the address http://localhost:8900 in the browser.
255 3. Enter the app name and stream name corresponding to the OBS whip publish address.
271 address = "localhost"
311 address = "localhost"
|
| /xiu/application/xiu/ |
| H A D | README.md | 137 address = "192.168.0.1"
143 address = "localhost"
147 address = "192.168.0.3"
249 2. Open the address http://localhost:8900 in the browser.
250 3. Enter the app name and stream name corresponding to the OBS whip publish address.
266 address = "localhost"
306 address = "localhost"
|
| /xiu/protocol/rtsp/src/session/ |
| H A D | mod.rs | 359 let address = rtsp_request.address.clone(); in handle_setup() localVariable
360 if let Some(rtp_io) = UdpIO::new(address.clone(), rtp_port, 0).await { in handle_setup()
373 UdpIO::new(address.clone(), rtcp_port, rtp_server_port.unwrap() + 1) in handle_setup()
|