Searched refs:timer (Results 1 – 14 of 14) sorted by relevance
39 let timer = tokio::time::sleep(lifetime); in start() localVariable40 tokio::pin!(timer); in start()45 _ = &mut timer => { in start()54 timer.as_mut().reset(Instant::now() + d); in start()
43 let timer = tokio::time::sleep(lifetime); in start() localVariable44 tokio::pin!(timer); in start()49 _ = &mut timer => { in start()60 timer.as_mut().reset(Instant::now() + d); in start()
275 let timer = tokio::time::sleep(lifetime); in start() localVariable276 tokio::pin!(timer); in start()281 _ = &mut timer => { in start()292 timer.as_mut().reset(Instant::now() + d); in start()
44 let timer = tokio::time::sleep(interval); in start() localVariable45 tokio::pin!(timer); in start()48 _ = timer.as_mut() => { in start()
159 let timer = tokio::time::sleep(Duration::from_millis(interval)); in start() localVariable160 tokio::pin!(timer); in start()163 _ = timer.as_mut() => { in start()
61 let timer = tokio::time::sleep(interval); in start() localVariable62 tokio::pin!(timer); in start()65 _ = timer.as_mut() => { in start()
176 let timer = tokio::time::sleep(Duration::from_millis( in start_rtx_timer() localVariable179 tokio::pin!(timer); in start_rtx_timer()182 _ = timer.as_mut() => { in start_rtx_timer()
12 pub(crate) mod timer; module
136 let timer = tokio::time::sleep(Duration::from_millis(10)); in test_listener_accept_filter() localVariable137 tokio::pin!(timer); in test_listener_accept_filter()142 _ = timer.as_mut() => { in test_listener_accept_filter()
74 let timer = tokio::time::sleep(Duration::from_millis(10)); in create_new_association_pair() localVariable75 tokio::pin!(timer); in create_new_association_pair()78 _ = timer.as_mut() =>{}, in create_new_association_pair()138 let timer = tokio::time::sleep(Duration::from_millis(10)); in close_association_pair() localVariable139 tokio::pin!(timer); in close_association_pair()142 _ = timer.as_mut() =>{}, in close_association_pair()
71 let timer = tokio::time::sleep(Duration::from_millis(10)); in create_new_association_pair() localVariable72 tokio::pin!(timer); in create_new_association_pair()75 _ = timer.as_mut() =>{}, in create_new_association_pair()142 tokio::pin!(timer); in close_association_pair()145 _ = timer.as_mut() =>{}, in close_association_pair()1869 tokio::pin!(timer); in test_assoc_reset_close_one_way()1872 _ = timer.as_mut() =>{}, in test_assoc_reset_close_one_way()1971 tokio::pin!(timer); in test_assoc_reset_close_both_ways()1974 _ = timer.as_mut() =>{}, in test_assoc_reset_close_both_ways()2018 tokio::pin!(timer); in test_assoc_reset_close_both_ways()[all …]
36 use crate::timer::ack_timer::*;37 use crate::timer::rtx_timer::*;
398 let timer = tokio::time::sleep(d); in read() localVariable399 tokio::pin!(timer); in read()403 _ = timer.as_mut() => return Err(Error::ErrDeadlineExceeded), in read()448 let timer = tokio::time::sleep(d); in write() localVariable449 tokio::pin!(timer); in write()455 _ = timer.as_mut() => return Err(Error::ErrDeadlineExceeded), in write()
1894 let timer = tokio::time::sleep(Duration::from_millis(10)); in test_server_timeout() localVariable1895 tokio::pin!(timer); in test_server_timeout()1898 _ = timer.as_mut() => { in test_server_timeout()