| /xiu/library/container/mpegts/src/ |
| H A D | crc32.rs | 39 let mut result: u32 = crc; in gen_crc32() localVariable
42 let a = result ^ i as u32; in gen_crc32()
44 let c = result >> 8; in gen_crc32()
45 result = b ^ c; in gen_crc32()
47 result in gen_crc32()
66 let result = gen_crc32(0xffffffff, payload); in test_gen_crc32() localVariable
68 let aa0 = result & 0xFF; in test_gen_crc32()
70 let bb0 = (result >> 8) & 0xFF; in test_gen_crc32()
72 let cc0 = (result >> 16) & 0xFF; in test_gen_crc32()
74 let dd0 = (result >> 24) & 0xFF; in test_gen_crc32()
|
| /xiu/protocol/rtmp/src/handshake/ |
| H A D | utils.rs | 7 Ok(result) => result.as_nanos() as u32, in current_time()
|
| H A D | digest.rs | 41 let result = [left_part, computed_digest, right_part].concat(); in generate_and_fill_digest() localVariable
43 Ok(result) in generate_and_fill_digest()
113 let result = mac.finalize().into_bytes(); in make_digest() localVariable
115 if result.len() != define::RTMP_DIGEST_LENGTH { in make_digest()
122 rv.extend_from_slice(result.as_slice()); in make_digest()
|
| H A D | handshake_server.rs | 314 let result = self.complex_handshaker.handshake().await; in handshake() localVariable
315 match result { in handshake()
|
| /xiu/protocol/rtsp/src/ |
| H A D | rtsp_range.rs | 59 let mut result = (hour * 3600 + minute * 60 + second) * 1000; in unmarshal() localVariable
61 result += m; in unmarshal()
63 result in unmarshal()
|
| /xiu/library/bytesio/src/ |
| H A D | bits_reader.rs | 55 let mut result: u64 = 0; in read_n_bits() localVariable
57 result <<= 1; in read_n_bits()
59 result |= cur_bit as u64; in read_n_bits()
61 Ok(result) in read_n_bits()
|
| /xiu/protocol/rtmp/src/cache/ |
| H A D | metadata.rs | 45 let result = Amf0Reader::new(reader).read_all(); in is_metadata() localVariable
49 match result { in is_metadata()
|
| /xiu/protocol/webrtc/src/ |
| H A D | whip.rs | 24 pub type Result<T> = std::result::Result<T, WebRTCError>;
91 let mut result = Result::<usize>::Ok(0); in handle_whip() localVariable
92 while result.is_ok() { in handle_whip()
99 result = pc.write_rtcp(&[Box::new(PictureLossIndication{ in handle_whip()
|
| H A D | whep.rs | 25 pub type Result<T> = std::result::Result<T, WebRTCError>;
|
| /xiu/library/streamhub/src/ |
| H A D | utils.rs | 57 Ok(result) => result.as_secs(), in new()
|
| H A D | lib.rs | 384 let result = match self in event_loop() localVariable
403 if result_sender.send(result).is_err() { in event_loop()
|
| /xiu/protocol/rtmp/src/messages/ |
| H A D | parser.rs | 166 let result = unpacker.read_chunk(); in test_message_parse() localVariable
168 let rv = match result { in test_message_parse()
|
| /xiu/protocol/rtsp/src/rtp/ |
| H A D | utils.rs | 115 Ok(result) => (result.as_nanos() / 1000) as u64, in current_time()
|
| /xiu/protocol/rtmp/src/amf0/ |
| H A D | amf0_reader.rs | 21 let result = self.read_any()?; in read_all() localVariable
22 match result { in read_all()
27 results.push(result); in read_all()
|
| /xiu/protocol/httpflv/src/ |
| H A D | server.rs | 14 type Result<T> = std::result::Result<T, GenericError>;
|
| /xiu/protocol/hls/src/ |
| H A D | server.rs | 11 type Result<T> = std::result::Result<T, GenericError>;
|
| /xiu/protocol/rtmp/src/chunk/ |
| H A D | unpacketizer.rs | 192 let mut result: UnpackResult = UnpackResult::Empty; in read_chunk() localVariable
204 result = match self.chunk_read_state { in read_chunk()
222 Ok(result) in read_chunk()
|
| /xiu/protocol/rtmp/src/session/ |
| H A D | common.rs | 385 let result = event_result_receiver.await??; in publish_to_channels() localVariable
386 self.data_sender = result.0.unwrap(); in publish_to_channels()
|