| /xiu/protocol/rtmp/src/handshake/ |
| H A D | digest.rs | 59 digest_offset += self.reader.get(772)? as usize; in find_digest_offset()
60 digest_offset += self.reader.get(773)? as usize; in find_digest_offset()
61 digest_offset += self.reader.get(774)? as usize; in find_digest_offset()
62 digest_offset += self.reader.get(775)? as usize; in find_digest_offset()
68 digest_offset += self.reader.get(8)? as usize; in find_digest_offset()
69 digest_offset += self.reader.get(9)? as usize; in find_digest_offset()
70 digest_offset += self.reader.get(10)? as usize; in find_digest_offset()
71 digest_offset += self.reader.get(11)? as usize; in find_digest_offset()
|
| /xiu/protocol/rtsp/src/sdp/ |
| H A D | rtpmap.rs | 26 if let Some(part_1) = parts.get(1) { in unmarshal()
33 if let Some(para_1) = parameters.get(1) { in unmarshal()
38 if let Some(para_2) = parameters.get(2) { in unmarshal()
|
| H A D | mod.rs | 26 if let Some(bandwidth) = parameters.get(1) { in unmarshal()
109 if let Some(para_1) = parameters.get(1) { in unmarshal()
115 if let Some(para_2) = parameters.get(2) { in unmarshal()
121 while let Some(fmt_str) = parameters.get(cur_param_idx) { in unmarshal()
254 let attr_value = if let Some(val) = attribute.get(1) { in unmarshal()
|
| /xiu/application/http-server/src/ |
| H A D | main.rs | 2 routing::{get, post},
14 .route("/", get(root)) in main()
|
| /xiu/application/xiu/src/ |
| H A D | api.rs | 4 routing::{get, post},
113 .route("/", get(root)) in run()
114 .route("/get_stream_status", get(status)) in run()
|
| /xiu/protocol/webrtc/src/clients/ |
| H A D | whep.js | 84 if (!fetched.headers.get("location"))
88 this.resourceURL = new URL(fetched.headers.get("location"), url);
96 const linkHeaders = fetched.headers.get("link").split(/,\s+(?=<)/)
172 const sseUrl = new URL(fetched.headers.get("location"), this.eventsUrl);
|
| /xiu/protocol/webrtc/src/session/ |
| H A D | mod.rs | 122 if eles.len() < 2 || pars_map.get("app").is_none() || pars_map.get("stream").is_none() { in run()
134 let app_name = pars_map.get("app").unwrap().clone(); in run()
135 let stream_name = pars_map.get("stream").unwrap().clone(); in run()
182 if let Some(session_id) = pars_map.get("session_id") { in run()
186 if let Some(session) = uuid_2_sessions_unlock.get(&uuid) { in run()
|
| /xiu/protocol/rtsp/src/rtp/ |
| H A D | mod.rs | 58 let padding_length = reader.get(reader.len() - 1)? as usize; in unmarshal()
|
| /xiu/library/bytesio/src/ |
| H A D | bytes_writer.rs | 67 pub fn get(&mut self, position: usize) -> Option<&u8> { in get() method
68 self.bytes.get(position) in get()
|
| H A D | bytes_reader.rs | 126 pub fn get(&self, index: usize) -> Result<u8, BytesReadError> { in get() method
133 Ok(*self.buffer.get(index).unwrap()) in get()
|
| /xiu/protocol/rtsp/src/session/ |
| H A D | mod.rs | 545 if let Some(range_str) = rtsp_request.headers.get(&String::from("Range")) { in handle_record()
592 let media_control = if let Some(media_control_val) = media.attributes.get("control") { in new_tracks()
603 .get(&media.rtpmap.encoding_name.to_lowercase().as_str()) in new_tracks()
620 .get(&media.rtpmap.encoding_name.to_lowercase().as_str()) in new_tracks()
652 if let Some(cseq) = rtsp_request.headers.get("CSeq") { in gen_response()
|
| /xiu/protocol/rtsp/src/http/ |
| H A D | mod.rs | 21 self.headers.get(header_name) in get_header()
|
| /xiu/library/streamhub/src/ |
| H A D | lib.rs | 561 let info = if let Some(info) = self.streams_info.get(&uid) { in api_kick_off_client()
662 if self.streams.get(&identifier).is_some() { in publish()
|
| /xiu/protocol/rtmp/src/session/ |
| H A D | server_session.rs | 444 let obj_encoding = command_obj.get("objectEncoding"); in on_connect()
450 let app_name = command_obj.get("app"); in on_connect()
|
| H A D | client_session.rs | 524 if let Some(Amf0ValueType::UTF8String(code_info)) = obj.get("code") { in on_status()
|
| /xiu/protocol/webrtc/src/http/ |
| H A D | mod.rs | 37 self.headers.get(header_name) in get_header()
|
| /xiu/library/container/mpegts/src/ |
| H A D | ts.rs | 295 if (ts_header.get(3).unwrap() & 0x20) > 0 { in write_ts_header_for_pes()
|
| /xiu/ |
| H A D | README.md | 75 Start the service with the following command to get help:
|
| /xiu/application/xiu/ |
| H A D | README.md | 70 Start the service with the following command to get help:
|