| /webrtc/turn/src/client/ |
| H A D | binding.rs | 26 pub(crate) number: u16, field
80 number: self.assign_channel_number(), in create()
86 self.chan_map.insert(b.number, b.addr.to_string()); in create()
99 pub(crate) fn find_by_number(&self, number: u16) -> Option<&Binding> { in find_by_number()
100 if let Some(s) = self.chan_map.get(&number) { in find_by_number()
107 pub(crate) fn get_by_number(&mut self, number: u16) -> Option<&mut Binding> { in get_by_number()
108 if let Some(s) = self.chan_map.get(&number) { in get_by_number()
117 self.chan_map.remove(&b.number); in delete_by_addr()
124 pub(crate) fn delete_by_number(&mut self, number: u16) -> bool { in delete_by_number()
125 if let Some(s) = self.chan_map.remove(&number) { in delete_by_number()
|
| H A D | relay_conn.rs | 233 let number = { in send_to() localVariable
243 (b.state(), b.refreshed_at(), b.number, b.addr) in send_to()
356 self.send_channel_data(p, number).await in send_to()
381 number: proto::channum::ChannelNumber(ch_num), in send_channel_data()
|
| H A D | mod.rs | 384 let addr = ClientInternal::find_addr_by_channel_number(binding_mgr, ch_data.number.0) in handle_channel_data()
391 ch_data.number.0 in handle_channel_data()
|
| /webrtc/turn/src/proto/chandata/ |
| H A D | chandata_test.rs | 7 number: ChannelNumber(MIN_CHANNEL_NUMBER + 1), in test_channel_data_encode()
32 number: ChannelNumber(MIN_CHANNEL_NUMBER), in test_channel_data_equal()
37 number: ChannelNumber(MIN_CHANNEL_NUMBER), in test_channel_data_equal()
46 number: ChannelNumber(MIN_CHANNEL_NUMBER + 1), in test_channel_data_equal()
51 number: ChannelNumber(MIN_CHANNEL_NUMBER), in test_channel_data_equal()
60 number: ChannelNumber(MIN_CHANNEL_NUMBER), in test_channel_data_equal()
65 number: ChannelNumber(MIN_CHANNEL_NUMBER), in test_channel_data_equal()
74 number: ChannelNumber(MIN_CHANNEL_NUMBER), in test_channel_data_equal()
79 number: ChannelNumber(MIN_CHANNEL_NUMBER), in test_channel_data_equal()
135 number: ChannelNumber(MIN_CHANNEL_NUMBER + 1), in test_channel_data_reset()
[all …]
|
| /webrtc/turn/src/allocation/ |
| H A D | channel_bind.rs | 16 pub(crate) number: ChannelNumber, field
24 pub fn new(number: ChannelNumber, peer: SocketAddr) -> Self { in new()
26 number, in new()
39 let number = self.number; in start() localVariable
52 if cb.remove(&number).is_none() { in start()
53 log::error!("Failed to remove ChannelBind for {}", number); in start()
|
| H A D | mod.rs | 159 if let Some(addr) = self.get_channel_addr(&c.number).await { in add_channel_bind()
165 if let Some(number) = self.get_channel_number(&c.peer).await { in add_channel_bind()
166 if number != c.number { in add_channel_bind()
174 if let Some(cb) = channel_bindings.get(&c.number) { in add_channel_bind()
192 channel_bindings.insert(c.number, c); in add_channel_bind()
204 channel_bindings.remove(&number).is_some() in remove_channel_bind()
210 channel_bindings.get(number).map(|cb| cb.peer) in get_channel_addr()
218 return Some(cb.number); in get_channel_number()
384 cb_number = Some(cb.number); in packet_handler()
391 if let Some(number) = cb_number { in packet_handler()
[all …]
|
| H A D | allocation_test.rs | 220 let number = ChannelNumber(MIN_CHANNEL_NUMBER); in test_remove_channel_bind() localVariable
221 let c = ChannelBind::new(number, addr); in test_remove_channel_bind()
225 a.remove_channel_bind(number).await; in test_remove_channel_bind()
227 let not_exist_channel = a.get_channel_addr(&number).await; in test_remove_channel_bind()
283 let number = ChannelNumber(MIN_CHANNEL_NUMBER); in test_allocation_close() localVariable
284 let c = ChannelBind::new(number, addr); in test_allocation_close()
|
| /webrtc/turn/src/proto/ |
| H A D | chandata.rs | 27 pub number: ChannelNumber, field
33 self.data == other.data && self.number == other.number in eq()
64 self.number = ChannelNumber(num); in decode()
65 if !self.number.valid() { in decode()
88 self.raw[..CHANNEL_DATA_NUMBER_SIZE].copy_from_slice(&self.number.0.to_be_bytes()); in write_header()
|
| /webrtc/rtcp/src/payload_feedbacks/slice_loss_indication/ |
| H A D | slice_loss_indication_test.rs | 20 number: 0, in test_slice_loss_indication_unmarshal()
95 number: 0xAA, in test_slice_loss_indication_roundtrip()
100 number: 0x05, in test_slice_loss_indication_roundtrip()
|
| H A D | mod.rs | 23 pub number: u16, field
112 | ((s.number as u32 & 0x1FFF) << 6) in marshal_to()
157 number: ((sli >> 6) & 0x1FFF) as u16, in unmarshal()
|
| /webrtc/stun/src/ |
| H A D | error_code.rs | 47 let number = (self.code.0 % ERROR_CODE_MODULO) as u8; // error code modulo 100 in add_to() localVariable
51 value.push(number); //[ERROR_CODE_NUMBER_BYTE] = in add_to()
70 let number = v[ERROR_CODE_NUMBER_BYTE] as u16; in get_from() localVariable
71 let code = class * ERROR_CODE_MODULO + number; in get_from()
|
| /webrtc/turn/benches/ |
| H A D | bench.rs | 23 number: ChannelNumber(MIN_CHANNEL_NUMBER + 1), in benchmark_chan_data()
37 number: ChannelNumber(MIN_CHANNEL_NUMBER + 1), in benchmark_chan_data()
|
| /webrtc/media/ |
| H A D | CHANGELOG.md | 13 * Introduced a new field in `Sample`, `prev_padding_packets`, that reflects the number of observed …
|
| /webrtc/turn/src/client/binding/ |
| H A D | binding_test.rs | 40 let b2 = m.find_by_number(b0.number); in test_binding_manager_method()
|
| /webrtc/turn/src/client/relay_conn/ |
| H A D | relay_conn_test.rs | 67 (b.addr, b.number) in test_relay_conn()
|
| /webrtc/.github/workflows/ |
| H A D | grcov.yml | 76 --service-number ${{ github.run_id }}
|
| /webrtc/turn/src/allocation/allocation_manager/ |
| H A D | allocation_manager_test.rs | 152 channel_bind.number, channel_data.number, in test_packet_handler()
|
| /webrtc/turn/src/server/ |
| H A D | request.rs | 785 let channel = a.get_channel_addr(&c.number).await; in handle_channel_data()
|