| /webrtc/turn/src/allocation/ |
| H A D | permission.rs | 30 pub(crate) async fn start(&mut self, lifetime: Duration) { in start()
39 let timer = tokio::time::sleep(lifetime); in start()
72 pub(crate) async fn refresh(&self, lifetime: Duration) { in refresh()
74 let _ = tx.send(lifetime).await; in refresh()
|
| H A D | channel_bind.rs | 34 pub(crate) async fn start(&mut self, lifetime: Duration) { in start()
43 let timer = tokio::time::sleep(lifetime); in start()
78 pub(crate) async fn refresh(&self, lifetime: Duration) { in refresh()
80 let _ = tx.send(lifetime).await; in refresh()
|
| H A D | mod.rs | 157 pub async fn add_channel_bind(&self, mut c: ChannelBind, lifetime: Duration) -> Result<()> { in add_channel_bind()
175 cb.refresh(lifetime).await; in add_channel_bind()
188 c.start(lifetime).await; in add_channel_bind()
266 pub async fn start(&self, lifetime: Duration) { in start()
275 let timer = tokio::time::sleep(lifetime); in start()
310 pub async fn refresh(&self, lifetime: Duration) { in refresh()
313 let _ = tx.send(lifetime).await; in refresh()
|
| H A D | allocation_manager.rs | 87 lifetime: Duration, in create_allocation()
90 if lifetime == Duration::from_secs(0) { in create_allocation()
113 a.start(lifetime).await; in create_allocation()
|
| H A D | allocation_test.rs | 3 use crate::proto::lifetime::DEFAULT_LIFETIME;
|
| /webrtc/turn/src/server/request/ |
| H A D | request_test.rs | 15 let lifetime = Lifetime(Duration::from_secs(5)); in test_allocation_lifetime_parsing() localVariable
25 lifetime.add_to(&mut m)?; in test_allocation_lifetime_parsing()
29 lifetime_duration, lifetime.0, in test_allocation_lifetime_parsing()
38 let lifetime = Lifetime(MAXIMUM_ALLOCATION_LIFETIME * 2); in test_allocation_lifetime_overflow() localVariable
41 lifetime.add_to(&mut m2)?; in test_allocation_lifetime_overflow()
|
| /webrtc/turn/src/client/ |
| H A D | relay_conn.rs | 58 pub(crate) lifetime: Duration, field
70 lifetime: Duration, field
85 log::debug!("initial lifetime: {} seconds", config.lifetime.as_secs()); in new()
203 lifetime: config.lifetime, in new()
461 lifetime: Duration, in refresh_allocation()
471 Box::new(proto::lifetime::Lifetime(lifetime)), in refresh_allocation()
509 let mut updated_lifetime = proto::lifetime::Lifetime::default(); in refresh_allocation()
512 self.lifetime = updated_lifetime.0; in refresh_allocation()
513 log::debug!("updated lifetime: {} seconds", self.lifetime.as_secs()); in refresh_allocation()
589 let lifetime = self.lifetime; in on_timeout() localVariable
[all …]
|
| H A D | mod.rs | 12 chandata::*, data::*, lifetime::*, peeraddr::*, relayaddr::*, reqtrans::*, PROTO_UDP,
555 let mut lifetime = Lifetime::default(); in allocate() localVariable
556 lifetime.get_from(&res)?; in allocate()
569 lifetime: lifetime.0, in allocate()
|
| /webrtc/turn/src/allocation/channel_bind/ |
| H A D | channel_bind_test.rs | 10 async fn create_channel_bind(lifetime: Duration) -> Result<Allocation> { in create_channel_bind()
26 a.add_channel_bind(c, lifetime).await?; in create_channel_bind()
|
| /webrtc/turn/src/proto/ |
| H A D | mod.rs | 10 pub mod lifetime; module
|
| /webrtc/turn/src/allocation/allocation_manager/ |
| H A D | allocation_manager_test.rs | 7 proto::lifetime::DEFAULT_LIFETIME,
248 let lifetime = Duration::from_millis(100); in test_allocation_timeout() localVariable
258 lifetime, in test_allocation_timeout()
275 tokio::time::sleep(lifetime + Duration::from_millis(100)).await; in test_allocation_timeout()
|
| /webrtc/turn/src/client/relay_conn/ |
| H A D | relay_conn_test.rs | 54 lifetime: Duration::from_secs(0), in test_relay_conn()
|
| /webrtc/turn/src/server/ |
| H A D | request.rs | 14 use crate::proto::lifetime::*;
881 let mut lifetime = Lifetime::default(); in allocation_lifetime() localVariable
882 if lifetime.get_from(m).is_ok() && lifetime.0 < MAXIMUM_ALLOCATION_LIFETIME { in allocation_lifetime()
883 lifetime_duration = lifetime.0; in allocation_lifetime()
|
| H A D | mod.rs | 11 proto::lifetime::DEFAULT_LIFETIME,
|
| /webrtc/turn/benches/ |
| H A D | bench.rs | 8 use turn::proto::lifetime::Lifetime;
|