Home
last modified time | relevance | path

Searched refs:offset (Results 1 – 25 of 26) sorted by relevance

12

/webrtc/srtp/src/
H A Dconfig.rs55 let mut offset = 0; in extract_session_keys_from_dtls() localVariable
56 let client_write_key = keying_material[offset..offset + key_len].to_vec(); in extract_session_keys_from_dtls()
57 offset += key_len; in extract_session_keys_from_dtls()
59 let server_write_key = keying_material[offset..offset + key_len].to_vec(); in extract_session_keys_from_dtls()
60 offset += key_len; in extract_session_keys_from_dtls()
62 let client_write_salt = keying_material[offset..offset + salt_len].to_vec(); in extract_session_keys_from_dtls()
63 offset += salt_len; in extract_session_keys_from_dtls()
65 let server_write_salt = keying_material[offset..offset + salt_len].to_vec(); in extract_session_keys_from_dtls()
/webrtc/dtls/src/handshake/
H A Dhandshake_message_server_key_exchange.rs91 let mut offset = 4 + public_key_length; in unmarshal() localVariable
92 if data.len() < offset { in unmarshal()
96 if data.len() <= offset { in unmarshal()
100 let hash_algorithm = data[offset].into(); in unmarshal()
101 offset += 1; in unmarshal()
102 if data.len() <= offset { in unmarshal()
107 offset += 1; in unmarshal()
108 if data.len() < offset + 2 { in unmarshal()
112 let signature_length = (((data[offset] as u16) << 8) | data[offset + 1] as u16) as usize; in unmarshal()
113 offset += 2; in unmarshal()
[all …]
H A Dhandshake_message_server_hello.rs122 let mut offset = 0; in unmarshal() localVariable
123 while offset < extension_buffer_len { in unmarshal()
124 let mut extension_reader = BufReader::new(&extension_buffer[offset..]); in unmarshal()
130 extension_buffer[offset], in unmarshal()
131 extension_buffer[offset + 1] in unmarshal()
136 u16::from_be_bytes([extension_buffer[offset + 2], extension_buffer[offset + 3]]) in unmarshal()
138 offset += 4 + extension_len; in unmarshal()
H A Dhandshake_message_client_hello.rs166 let mut offset = 0; in unmarshal() localVariable
167 while offset < extension_buffer_len { in unmarshal()
168 let mut extension_reader = BufReader::new(&extension_buffer[offset..]); in unmarshal()
174 extension_buffer[offset], in unmarshal()
175 extension_buffer[offset + 1] in unmarshal()
180 u16::from_be_bytes([extension_buffer[offset + 2], extension_buffer[offset + 3]]) in unmarshal()
182 offset += 4 + extension_len; in unmarshal()
H A Dhandshake_message_certificate.rs55 let mut offset = 0; in unmarshal() localVariable
56 while offset < payload_size { in unmarshal()
58 offset += HANDSHAKE_MESSAGE_CERTIFICATE_LENGTH_FIELD_SIZE; in unmarshal()
62 offset += certificate_len; in unmarshal()
/webrtc/sctp/src/
H A Dpacket.rs107 let mut offset = PACKET_HEADER_SIZE; in unmarshal() localVariable
110 if offset == raw.len() { in unmarshal()
112 } else if offset + CHUNK_HEADER_SIZE > raw.len() { in unmarshal()
116 let ct = ChunkType(raw[offset]); in unmarshal()
118 CT_INIT => Box::new(ChunkInit::unmarshal(&raw.slice(offset..))?), in unmarshal()
119 CT_INIT_ACK => Box::new(ChunkInit::unmarshal(&raw.slice(offset..))?), in unmarshal()
120 CT_ABORT => Box::new(ChunkAbort::unmarshal(&raw.slice(offset..))?), in unmarshal()
128 CT_ERROR => Box::new(ChunkError::unmarshal(&raw.slice(offset..))?), in unmarshal()
132 Box::new(ChunkShutdownComplete::unmarshal(&raw.slice(offset..))?) in unmarshal()
134 _ => Box::new(ChunkUnknown::unmarshal(&raw.slice(offset..))?), in unmarshal()
[all …]
/webrtc/dtls/src/record_layer/
H A Dmod.rs88 let mut offset = 0; in unpack_datagram() localVariable
89 while buf.len() != offset { in unpack_datagram()
90 if buf.len() - offset <= RECORD_LAYER_HEADER_SIZE { in unpack_datagram()
95 + (((buf[offset + RECORD_LAYER_HEADER_SIZE - 2] as usize) << 8) in unpack_datagram()
96 | buf[offset + RECORD_LAYER_HEADER_SIZE - 1] as usize); in unpack_datagram()
97 if offset + pkt_len > buf.len() { in unpack_datagram()
101 out.push(buf[offset..offset + pkt_len].to_vec()); in unpack_datagram()
102 offset += pkt_len in unpack_datagram()
/webrtc/ice/src/udp_mux/
H A Dudp_mux_conn.rs72 let mut offset = 0; in write_packet() localVariable
84 offset += 2; in write_packet()
86 buffer[offset..offset + data.len()].copy_from_slice(data); in write_packet()
90 buffer[offset..offset + 2].copy_from_slice(&(len as u16).to_le_bytes()[..]); in write_packet()
91 offset += 2 + len; in write_packet()
155 let mut offset = 0; in recv_from() localVariable
172 offset += 2; in recv_from()
179 buf[..data_len].copy_from_slice(&buffer[offset..offset + data_len]); in recv_from()
182 let address_len: usize = buffer[offset..offset + 2] in recv_from()
187 offset += 2; in recv_from()
[all …]
/webrtc/sctp/src/chunk/
H A Dchunk_error.rs63 let mut offset = CHUNK_HEADER_SIZE; in unmarshal() localVariable
64 while offset + 4 <= raw.len() { in unmarshal()
66 &raw.slice(offset..CHUNK_HEADER_SIZE + header.value_length()), in unmarshal()
68 offset += e.length(); in unmarshal()
H A Dchunk_abort.rs61 let mut offset = CHUNK_HEADER_SIZE; in unmarshal() localVariable
62 while offset + 4 <= raw.len() { in unmarshal()
64 &raw.slice(offset..CHUNK_HEADER_SIZE + header.value_length()), in unmarshal()
66 offset += e.length(); in unmarshal()
H A Dchunk_forward_tsn.rs66 let mut offset = CHUNK_HEADER_SIZE + NEW_CUMULATIVE_TSN_LENGTH; in unmarshal() localVariable
67 if buf.len() < offset { in unmarshal()
75 let mut remaining = buf.len() - offset; in unmarshal()
78 &buf.slice(offset..CHUNK_HEADER_SIZE + header.value_length()), in unmarshal()
80 offset += s.value_length(); in unmarshal()
H A Dchunk_init.rs170 let mut offset = CHUNK_HEADER_SIZE + INIT_CHUNK_MIN_LENGTH; in unmarshal() localVariable
171 let mut remaining = raw.len() as isize - offset as isize; in unmarshal()
173 let p = build_param(&raw.slice(offset..CHUNK_HEADER_SIZE + header.value_length()))?; in unmarshal()
177 offset += len_plus_padding; in unmarshal()
H A Dchunk_reconfig.rs73 let offset = CHUNK_HEADER_SIZE + PARAM_HEADER_LENGTH + param_a.value_length() + padding; in unmarshal() localVariable
74 let param_b = if CHUNK_HEADER_SIZE + header.value_length() > offset { in unmarshal()
76 &raw.slice(offset..CHUNK_HEADER_SIZE + header.value_length()), in unmarshal()
/webrtc/webrtc/src/rtp_transceiver/
H A Dsrtp_writer_future.rs26 offset: u16, field
37 offset: 0, in new()
86 let offset = guard in seq_number() localVariable
90 let offset = guard.last_sq.overflowing_sub(raw_sn.overflowing_sub(1).0).0; in seq_number() localVariable
91 guard.offset = offset; in seq_number()
92 offset in seq_number()
94 .unwrap_or(guard.offset); in seq_number()
95 let next = raw_sn.overflowing_add(offset).0; in seq_number()
/webrtc/rtcp/src/source_description/
H A Dmod.rs151 let mut offset = SDES_SOURCE_LEN; in unmarshal() localVariable
153 while offset < raw_packet_len { in unmarshal()
157 let padding_len = get_padding_size(offset + 1); in unmarshal()
165 offset += item.marshal_size(); in unmarshal()
416 let mut offset = HEADER_LENGTH; in unmarshal() localVariable
418 while offset < raw_packet_len { in unmarshal()
420 offset += chunk.marshal_size(); in unmarshal()
/webrtc/sctp/src/param/
H A Dparam_requested_hmac_algorithm.rs76 let mut offset = 0; in unmarshal() localVariable
77 while offset + 1 < header.value_length() { in unmarshal()
85 offset += 2; in unmarshal()
/webrtc/rtcp/src/extended_report/
H A Ddlrr.rs135 let mut offset = 0; in unmarshal() localVariable
137 while offset < block_length { in unmarshal()
146 offset += DLRR_REPORT_LENGTH; in unmarshal()
H A Dmod.rs265 let mut offset = HEADER_LENGTH + SSRC_LENGTH; in unmarshal() localVariable
268 if offset + XR_HEADER_LENGTH > raw_packet_len { in unmarshal()
292 offset += report.marshal_size(); in unmarshal()
/webrtc/rtcp/src/receiver_report/
H A Dmod.rs202 let mut offset = RR_REPORT_OFFSET; in unmarshal() localVariable
205 if offset + RECEPTION_REPORT_LENGTH > raw_packet_len { in unmarshal()
210 offset += RECEPTION_REPORT_LENGTH; in unmarshal()
/webrtc/rtcp/src/sender_report/
H A Dmod.rs267 let mut offset = SR_REPORT_OFFSET; in unmarshal() localVariable
270 if offset + RECEPTION_REPORT_LENGTH > raw_packet_len { in unmarshal()
275 offset += RECEPTION_REPORT_LENGTH; in unmarshal()
/webrtc/util/src/conn/
H A Dconn_bridge.rs162 pub async fn drop_offset(&self, id: usize, offset: usize, n: usize) { in drop_offset()
164 queue.drain(offset..offset + n); in drop_offset()
/webrtc/stun/src/
H A Dmessage.rs305 let mut offset = 0; in decode() localVariable
308 while offset < size { in decode()
327 offset += ATTRIBUTE_HEADER_SIZE; in decode()
338 offset += a_buff_l; in decode()
/webrtc/sdp/src/description/
H A Ddescription_test.rs107 offset: -3600, in test_marshal()
111 offset: 0, in test_marshal()
H A Dsession.rs103 pub offset: i64, field
108 write!(f, "{} {}", self.adjustment_time, self.offset) in fmt()
1124 let offset = parse_time_units(field)?; in unmarshal_repeat_times() localVariable
1125 offsets.push(offset); in unmarshal_repeat_times()
1154 let offset = parse_time_units(fields[i + 1])?; in unmarshal_time_zones() localVariable
1158 offset, in unmarshal_time_zones()
/webrtc/util/src/vnet/
H A Dnet.rs261 let offset = rand::random::<u16>() % space; in assign_port() localVariable
263 let port = ((offset + i) % space) + start; in assign_port()

12