| /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()
|
| /webrtc/turn/src/proto/ |
| H A D | channum.rs | 26 pub struct ChannelNumber(pub u16); struct
28 impl fmt::Display for ChannelNumber { implementation
34 impl Setter for ChannelNumber { implementation
45 impl Getter for ChannelNumber { implementation
59 impl ChannelNumber { impl
|
| H A D | chandata.rs | 27 pub number: ChannelNumber,
64 self.number = ChannelNumber(num); in decode()
108 let num = ChannelNumber(u16::from_be_bytes([buf[0], buf[1]])); in is_channel_data()
|
| /webrtc/turn/src/proto/channum/ |
| H A D | channnum_test.rs | 5 let n = ChannelNumber(112); in test_channel_number_string()
40 let n = ChannelNumber(6); in test_channel_number_add_to()
49 let mut num_decoded = ChannelNumber::default(); in test_channel_number_add_to()
56 let mut n_handle = ChannelNumber::default(); in test_channel_number_add_to()
|
| /webrtc/turn/src/allocation/channel_bind/ |
| H A D | channel_bind_test.rs | 24 let c = ChannelBind::new(ChannelNumber(MIN_CHANNEL_NUMBER), addr); in create_channel_bind()
35 let result = a.get_channel_addr(&ChannelNumber(MIN_CHANNEL_NUMBER)).await; in test_channel_bind()
50 .get_channel_addr(&ChannelNumber(MIN_CHANNEL_NUMBER)) in test_channel_bind_start()
63 if let Some(c) = channel_bindings.get(&ChannelNumber(MIN_CHANNEL_NUMBER)) { in test_channel_bind_reset()
70 .get_channel_addr(&ChannelNumber(MIN_CHANNEL_NUMBER)) in test_channel_bind_reset()
|
| /webrtc/turn/benches/ |
| H A D | bench.rs | 6 use turn::proto::channum::{ChannelNumber, MIN_CHANNEL_NUMBER};
23 number: ChannelNumber(MIN_CHANNEL_NUMBER + 1), in benchmark_chan_data()
37 number: ChannelNumber(MIN_CHANNEL_NUMBER + 1), in benchmark_chan_data()
58 let n = ChannelNumber(12); in benchmark_chan()
67 let expected = ChannelNumber(12); in benchmark_chan()
69 let mut n = ChannelNumber::default(); in benchmark_chan()
|
| /webrtc/turn/src/allocation/ |
| H A D | allocation_test.rs | 118 let c = ChannelBind::new(ChannelNumber(MIN_CHANNEL_NUMBER), addr); in test_add_channel_bind()
122 let c2 = ChannelBind::new(ChannelNumber(MIN_CHANNEL_NUMBER + 1), addr); in test_add_channel_bind()
130 let c3 = ChannelBind::new(ChannelNumber(MIN_CHANNEL_NUMBER), addr2); in test_add_channel_bind()
152 let c = ChannelBind::new(ChannelNumber(MIN_CHANNEL_NUMBER), addr); in test_get_channel_by_number()
157 .get_channel_addr(&ChannelNumber(MIN_CHANNEL_NUMBER)) in test_get_channel_by_number()
163 .get_channel_addr(&ChannelNumber(MIN_CHANNEL_NUMBER + 1)) in test_get_channel_by_number()
189 let c = ChannelBind::new(ChannelNumber(MIN_CHANNEL_NUMBER), addr); in test_get_channel_by_addr()
194 assert_eq!(ChannelNumber(MIN_CHANNEL_NUMBER), exist_channel_number); in test_get_channel_by_addr()
220 let number = ChannelNumber(MIN_CHANNEL_NUMBER); in test_remove_channel_bind()
283 let number = ChannelNumber(MIN_CHANNEL_NUMBER); in test_allocation_close()
|
| H A D | channel_bind.rs | 16 pub(crate) number: ChannelNumber,
17 pub(crate) channel_bindings: Option<Arc<Mutex<HashMap<ChannelNumber, ChannelBind>>>>,
24 pub fn new(number: ChannelNumber, peer: SocketAddr) -> Self { in new() argument
|
| H A D | mod.rs | 79 channel_bindings: Arc<Mutex<HashMap<ChannelNumber, ChannelBind>>>,
202 pub async fn remove_channel_bind(&self, number: ChannelNumber) -> bool { in remove_channel_bind()
208 pub async fn get_channel_addr(&self, number: &ChannelNumber) -> Option<SocketAddr> { in get_channel_addr()
214 pub async fn get_channel_number(&self, addr: &SocketAddr) -> Option<ChannelNumber> { in get_channel_number() argument
|
| /webrtc/turn/src/client/ |
| H A D | relay_conn.rs | 381 number: proto::channum::ChannelNumber(ch_num), in send_channel_data()
549 Box::new(proto::channum::ChannelNumber(bind_number)), in bind()
|
| /webrtc/turn/src/server/ |
| H A D | request.rs | 11 use crate::proto::channum::ChannelNumber;
732 let mut channel = ChannelNumber::default(); in handle_channel_bind_request()
|
| /webrtc/turn/src/allocation/allocation_manager/ |
| H A D | allocation_manager_test.rs | 87 ChannelNumber(MIN_CHANNEL_NUMBER), in test_packet_handler()
|