| /xiu/protocol/hls/src/ |
| H A D | m3u8.rs | 66 let m3u8_folder = format!("./{app_name}/{stream_name}"); in new() 69 let live_m3u8_name = format!("{stream_name}.m3u8"); in new() 71 format!("vod_{stream_name}.m3u8") in new() 129 let vod_m3u8_path = format!("{}/{}", self.m3u8_folder, self.vod_m3u8_name); in clear() 140 let live_m3u8_path = format!("{}/{}", self.m3u8_folder, self.live_m3u8_name); in clear() 148 m3u8_header += format!("#EXT-X-VERSION:{}\n", self.version).as_str(); in generate_m3u8_header() 149 m3u8_header += format!("#EXT-X-TARGETDURATION:{}\n", (self.duration + 999) / 1000).as_str(); in generate_m3u8_header() 156 m3u8_header += format!("#EXT-X-MEDIA-SEQUENCE:{}\n", self.sequence_no).as_str(); in generate_m3u8_header() 169 m3u8_content += format!( in refresh_playlist() 182 let m3u8_path = format!("{}/{}", self.m3u8_folder, self.live_m3u8_name); in refresh_playlist() [all …]
|
| H A D | ts.rs | 14 let live_path = format!("./{app_name}/{stream_name}"); in new() 23 let ts_file_name = format!("{}.ts", self.ts_number); in write() 24 let ts_file_path = format!("{}/{}", self.live_path, ts_file_name); in write()
|
| H A D | server.rs | 30 file_path = format!("./{app_name}/{stream_name}/{stream_name}.m3u8"); in handle_connection() 45 file_path = format!("./{app_name}/{stream_name}/{ts_name}.ts"); in handle_connection() 73 let listen_address = format!("0.0.0.0:{port}"); in run()
|
| /xiu/protocol/rtmp/src/chunk/ |
| H A D | packetizer.rs | 40 chunk_info.basic_header.format = 0; in zip_chunk_header() 57 chunk_info.basic_header.format = 1; in zip_chunk_header() 64 chunk_info.basic_header.format = 2; in zip_chunk_header() 66 chunk_info.basic_header.format = 3; in zip_chunk_header() 106 (self.extended_timestamp, message_header_timestamp) = match basic_header.format { in write_message_header() 121 basic_header.format, in write_message_header() 136 match basic_header.format { in write_message_header() 180 chunk_info.basic_header.format, in write_chunk()
|
| H A D | mod.rs | 14 pub format: u8, field 21 format: fmt, in new() 111 .map(|chunk| format!("0x{}{}", chunk[0] as char, chunk[1] as char)) in fmt() 132 format: u8, in new() 140 basic_header: ChunkBasicHeader::new(format, csid), in new()
|
| H A D | unpacketizer.rs | 231 self.current_chunk_info.basic_header.format in print_current_basic_header() 354 self.current_chunk_info.basic_header.format = format_id; in read_basic_header() 391 if self.current_chunk_info.basic_header.format != 3 { in read_message_header() 395 match self.current_chunk_info.basic_header.format { in read_message_header() 551 let cur_format_id = self.current_chunk_info.basic_header.format; in read_extended_timestamp()
|
| /xiu/protocol/rtsp/src/ |
| H A D | rtsp_transport.rs | 119 format!("client_port={}-{};", client_ports[0], client_ports[1]) in marshal() 125 format!("server_port={}-{};", server_ports[0], server_ports[1]) in marshal() 131 format!("interleaved={}-{};", interleaveds[0], interleaveds[1]) in marshal() 137 format!("ssrc={ssrc};") in marshal() 143 format!("mode={mode}") in marshal() 148 format!("{protocol_type};{cast_type};{client_port}{server_port}{interleaved}{ssrc}{mode}") in marshal()
|
| /xiu/protocol/rtsp/src/sdp/ |
| H A D | mod.rs | 38 format!("{}:{}\r\n", self.b_type, self.bandwidth) in marshal() 153 format!("b={}", bandwidth.marshal()) in marshal() 158 let mut sdp_media_info = format!( in marshal() 169 sdp_media_info = format!("{}a=fmtp:{}", sdp_media_info, fmtp.marshal()); in marshal() 173 sdp_media_info = format!("{sdp_media_info}a={k}:{v}\r\n"); in marshal() 305 let mut sdp_str = format!( in marshal() 311 sdp_str = format!("{sdp_str}a={k}:{v}\r\n"); in marshal() 315 sdp_str = format!("{}{}", sdp_str, media_info.marshal()); in marshal()
|
| H A D | rtpmap.rs | 49 let mut rtpmap = format!( in marshal() 54 rtpmap = format!("{}/{}", rtpmap, self.encoding_param); in marshal() 57 format!("{rtpmap}\r\n") in marshal()
|
| H A D | fmtp.rs | 125 let h264_fmtp = format!( in marshal() 130 format!("{h264_fmtp}\r\n") in marshal() 183 let h265_fmtp = format!( in marshal() 188 format!("{h265_fmtp}\r\n") in marshal() 255 let mpeg4_fmtp = format!( in marshal() 260 format!("{mpeg4_fmtp}\r\n") in marshal()
|
| /xiu/protocol/rtsp/src/http/ |
| H A D | mod.rs | 88 let mut request_str = format!("{} {} {}\r\n", self.method, self.url, self.version); in marshal() 91 request_str += &format!("{header_name}: {header_value}\r\n"); in marshal() 95 request_str += &format!("Content-Length: {}\r\n", body.len()); in marshal() 160 let mut response_str = format!( in marshal() 166 response_str += &format!("{header_name}: {header_value}\r\n"); in marshal() 170 response_str += &format!("Content-Length: {}\r\n", body.len()); in marshal()
|
| /xiu/protocol/webrtc/src/http/ |
| H A D | mod.rs | 130 format!("{}?{}", self.path, parameters) in marshal() 134 let mut request_str = format!("{} {} {}\r\n", self.method, full_path, self.version); in marshal() 138 request_str += &format!("Content-Length: {}\r\n", body.len()); in marshal() 141 request_str += &format!("{header_name}: {header_value}\r\n"); in marshal() 208 let mut response_str = format!( in marshal() 215 response_str += &format!("{header_name}: {header_value}\r\n"); in marshal() 220 response_str += &format!("Content-Length: {}\r\n", body.len()); in marshal()
|
| /xiu/library/logger/src/ |
| H A D | logger.rs | 44 format!( in get_log_file_name() 52 format!( in get_log_file_name() 61 format!( in get_log_file_name() 75 let full_path = format!("{path}/{file_name}.log"); in gen_log_file() 105 let cur_number = format!( in gen_log_file_thread_run()
|
| H A D | target.rs | 50 let newdate = datetime.format("%Y-%m-%d %H:%M:%S"); in test_chrono() 53 let cur_number = format!( in test_chrono()
|
| /xiu/application/xiu/src/ |
| H A D | service.rs | 101 let address = format!( in start_rtmp() 124 let address = format!( in start_rtmp() 147 let address = format!("0.0.0.0:{listen_port}"); in start_rtmp() 206 let address = format!("0.0.0.0:{listen_port}"); in start_rtsp() 230 let address = format!("0.0.0.0:{listen_port}"); in start_webrtc()
|
| /xiu/library/container/mpegts/ |
| H A D | README.md | 3 Support mux H264/AAC data to ts format.
|
| /xiu/protocol/rtmp/ |
| H A D | README.md | 26 let address = format!("0.0.0.0:{port}", port = listen_port); 63 let address = format!("{ip}:{port}", ip = "192.168.0.2", port = 1935); 78 let address = format!("{ip}:{port}", ip = "192.168.0.3", port = "1935"); 95 let address = format!("0.0.0.0:{port}", port = listen_port);
|
| /xiu/library/bytesio/src/ |
| H A D | bytesio.rs | 36 let remote_address = format!("{remote_domain}:{remote_port}"); in new() 38 let local_address = format!("0.0.0.0:{local_port}"); in new()
|
| /xiu/protocol/httpflv/src/ |
| H A D | server.rs | 64 let listen_address = format!("0.0.0.0:{port}"); in run()
|
| /xiu/protocol/rtmp/src/utils/ |
| H A D | mod.rs | 88 self.raw_domain_name = format!("{}:{}", self.raw_domain_name, port); in append_port()
|
| /xiu/protocol/rtmp/src/session/ |
| H A D | server_session.rs | 527 format!("{tc_url}/{raw_stream_name}") in get_request_url() 529 format!("{}/{}", self.app_name.clone(), raw_stream_name) in get_request_url()
|
| H A D | client_session.rs | 345 let url = format!( in send_connect()
|
| /xiu/protocol/webrtc/src/session/ |
| H A D | mod.rs | 150 let path = format!( in run()
|