Searched refs:get_mut (Results 1 – 11 of 11) sorted by relevance
93 pub(crate) fn get_mut(&mut self, tsn: u32) -> Option<&mut ChunkPayloadData> { in get_mut() method94 self.chunk_map.get_mut(&tsn) in get_mut()143 let n_bytes_acked = if let Some(c) = self.chunk_map.get_mut(&tsn) { in mark_as_acked()
96 self.addr_map.get_mut(&addr.to_string()) in get_by_addr()109 self.addr_map.get_mut(s) in get_by_number()
259 self.tr_map.get_mut(key) in get()
75 if let Some(x) = self.cache.get_mut(&handshake_header.message_sequence) { in push()94 let (content, epoch) = if let Some(frags) = self.cache.get_mut(&seq_num) { in pop()
169 self.srtp_ssrc_states.get_mut(&ssrc) in get_srtp_ssrc_state()179 self.srtcp_ssrc_states.get_mut(&ssrc) in get_srtcp_ssrc_state()
44 if let Some(conns) = port_map.get_mut(&addr.port()) { in insert()
453 if let Some(addrs) = m.get_mut(&iface.name) { in new()
425 if let Some(c) = self.inflight_queue.get_mut(tsn) { in gather_outbound_fast_retransmission_packets()940 if let Some(s) = self.streams.get_mut(&d.stream_identifier) { in handle_data()1108 if let Some(amount) = bytes_acked_per_stream.get_mut(&c.stream_identifier) { in process_selective_ack()1172 if let Some(amount) = bytes_acked_per_stream.get_mut(&c.stream_identifier) { in process_selective_ack()1317 if let Some(c) = self.inflight_queue.get_mut(tsn) { in process_fast_retransmission()1416 if let Some(s) = self.streams.get_mut(si) { in handle_sack()1702 if let Some(s) = self.streams.get_mut(&forwarded.identifier) { in handle_forward_tsn()2005 if let Some(c) = self.inflight_queue.get_mut(tsn) { in get_data_packets_to_retransmit()
185 if let Some(saved_codec) = codecs.get_mut(&codec.payload_type) { in merge_codecs()
178 if let Some(read_stream) = read_streams.get_mut(ssrc) { in test_session_srtp_multi_ssrc()
531 if let Some(cands) = remote_candidates.get_mut(&network_type) { in add_remote_candidate()583 if let Some(cands) = local_candidates.get_mut(&network_type) { in add_candidate()