| /dports/multimedia/gstreamer1-plugins-rust/gst-plugins-rs-d0466b3eee114207f851b37cae0015c0e718f021/cargo-crates/tokio-util-0.6.7/tests/ |
| H A D | time_delay_queue.rs | 142 queue.insert_at("foo", now); in insert_in_past_fires_immediately()
287 let key = queue.insert_at("foo", now); in remove_expired_item()
333 queue.insert_at("foo", now + ms(10_000)); in expires_before_last_insert()
339 queue.insert_at("bar", now + ms(600)); in expires_before_last_insert()
397 queue.insert_at("two", now + ms(250)); in expire_first_key_when_reset_to_expire_earlier()
419 queue.insert_at("one", now + ms(200)); in expire_second_key_when_reset_to_expire_earlier()
490 queue.insert_at("1", now + ms(100)); in insert_after_ready_poll()
491 queue.insert_at("2", now + ms(100)); in insert_after_ready_poll()
492 queue.insert_at("3", now + ms(100)); in insert_after_ready_poll()
618 queue.insert_at("foo", now + ms(200)); in insert_in_past_after_poll_fires_immediately()
[all …]
|
| /dports/net/routinator/routinator-0.10.2/cargo-crates/tokio-util-0.6.7/tests/ |
| H A D | time_delay_queue.rs | 142 queue.insert_at("foo", now); in insert_in_past_fires_immediately()
287 let key = queue.insert_at("foo", now); in remove_expired_item()
333 queue.insert_at("foo", now + ms(10_000)); in expires_before_last_insert()
339 queue.insert_at("bar", now + ms(600)); in expires_before_last_insert()
397 queue.insert_at("two", now + ms(250)); in expire_first_key_when_reset_to_expire_earlier()
419 queue.insert_at("one", now + ms(200)); in expire_second_key_when_reset_to_expire_earlier()
490 queue.insert_at("1", now + ms(100)); in insert_after_ready_poll()
491 queue.insert_at("2", now + ms(100)); in insert_after_ready_poll()
492 queue.insert_at("3", now + ms(100)); in insert_after_ready_poll()
618 queue.insert_at("foo", now + ms(200)); in insert_in_past_after_poll_fires_immediately()
[all …]
|
| /dports/dns/doh-proxy/doh-proxy-0.9.2/cargo-crates/tokio-util-0.6.8/tests/ |
| H A D | time_delay_queue.rs | 142 queue.insert_at("foo", now); in insert_in_past_fires_immediately()
287 let key = queue.insert_at("foo", now); in remove_expired_item()
333 queue.insert_at("foo", now + ms(10_000)); in expires_before_last_insert()
339 queue.insert_at("bar", now + ms(600)); in expires_before_last_insert()
397 queue.insert_at("two", now + ms(250)); in expire_first_key_when_reset_to_expire_earlier()
419 queue.insert_at("one", now + ms(200)); in expire_second_key_when_reset_to_expire_earlier()
490 queue.insert_at("1", now + ms(100)); in insert_after_ready_poll()
491 queue.insert_at("2", now + ms(100)); in insert_after_ready_poll()
492 queue.insert_at("3", now + ms(100)); in insert_after_ready_poll()
618 queue.insert_at("foo", now + ms(200)); in insert_in_past_after_poll_fires_immediately()
[all …]
|
| /dports/www/ffsend/ffsend-ccd489ce2e75b91c0f17fbf13dbd91fe84f5ad98/cargo-crates/tokio-util-0.6.8/tests/ |
| H A D | time_delay_queue.rs | 142 queue.insert_at("foo", now); in insert_in_past_fires_immediately()
287 let key = queue.insert_at("foo", now); in remove_expired_item()
333 queue.insert_at("foo", now + ms(10_000)); in expires_before_last_insert()
339 queue.insert_at("bar", now + ms(600)); in expires_before_last_insert()
397 queue.insert_at("two", now + ms(250)); in expire_first_key_when_reset_to_expire_earlier()
419 queue.insert_at("one", now + ms(200)); in expire_second_key_when_reset_to_expire_earlier()
490 queue.insert_at("1", now + ms(100)); in insert_after_ready_poll()
491 queue.insert_at("2", now + ms(100)); in insert_after_ready_poll()
492 queue.insert_at("3", now + ms(100)); in insert_after_ready_poll()
618 queue.insert_at("foo", now + ms(200)); in insert_in_past_after_poll_fires_immediately()
[all …]
|
| /dports/www/rearx/rearx-0.1.4/cargo-crates/tokio-util-0.6.4/tests/ |
| H A D | time_delay_queue.rs | 142 queue.insert_at("foo", now); in insert_in_past_fires_immediately()
287 let key = queue.insert_at("foo", now); in remove_expired_item()
333 queue.insert_at("foo", now + ms(10_000)); in expires_before_last_insert()
339 queue.insert_at("bar", now + ms(600)); in expires_before_last_insert()
397 queue.insert_at("two", now + ms(250)); in expire_first_key_when_reset_to_expire_earlier()
419 queue.insert_at("one", now + ms(200)); in expire_second_key_when_reset_to_expire_earlier()
490 queue.insert_at("1", now + ms(100)); in insert_after_ready_poll()
491 queue.insert_at("2", now + ms(100)); in insert_after_ready_poll()
492 queue.insert_at("3", now + ms(100)); in insert_after_ready_poll()
618 queue.insert_at("foo", now + ms(200)); in insert_in_past_after_poll_fires_immediately()
[all …]
|
| /dports/net/krill/krill-0.9.4/cargo-crates/tokio-util-0.6.8/tests/ |
| H A D | time_delay_queue.rs | 142 queue.insert_at("foo", now); in insert_in_past_fires_immediately()
287 let key = queue.insert_at("foo", now); in remove_expired_item()
333 queue.insert_at("foo", now + ms(10_000)); in expires_before_last_insert()
339 queue.insert_at("bar", now + ms(600)); in expires_before_last_insert()
397 queue.insert_at("two", now + ms(250)); in expire_first_key_when_reset_to_expire_earlier()
419 queue.insert_at("one", now + ms(200)); in expire_second_key_when_reset_to_expire_earlier()
490 queue.insert_at("1", now + ms(100)); in insert_after_ready_poll()
491 queue.insert_at("2", now + ms(100)); in insert_after_ready_poll()
492 queue.insert_at("3", now + ms(100)); in insert_after_ready_poll()
618 queue.insert_at("foo", now + ms(200)); in insert_in_past_after_poll_fires_immediately()
[all …]
|
| /dports/net/oha/oha-0.4.7/cargo-crates/tokio-util-0.6.8/tests/ |
| H A D | time_delay_queue.rs | 142 queue.insert_at("foo", now); in insert_in_past_fires_immediately()
287 let key = queue.insert_at("foo", now); in remove_expired_item()
333 queue.insert_at("foo", now + ms(10_000)); in expires_before_last_insert()
339 queue.insert_at("bar", now + ms(600)); in expires_before_last_insert()
397 queue.insert_at("two", now + ms(250)); in expire_first_key_when_reset_to_expire_earlier()
419 queue.insert_at("one", now + ms(200)); in expire_second_key_when_reset_to_expire_earlier()
490 queue.insert_at("1", now + ms(100)); in insert_after_ready_poll()
491 queue.insert_at("2", now + ms(100)); in insert_after_ready_poll()
492 queue.insert_at("3", now + ms(100)); in insert_after_ready_poll()
618 queue.insert_at("foo", now + ms(200)); in insert_in_past_after_poll_fires_immediately()
[all …]
|
| /dports/www/xh/xh-0.14.1/cargo-crates/tokio-util-0.6.8/tests/ |
| H A D | time_delay_queue.rs | 142 queue.insert_at("foo", now); in insert_in_past_fires_immediately()
287 let key = queue.insert_at("foo", now); in remove_expired_item()
333 queue.insert_at("foo", now + ms(10_000)); in expires_before_last_insert()
339 queue.insert_at("bar", now + ms(600)); in expires_before_last_insert()
397 queue.insert_at("two", now + ms(250)); in expire_first_key_when_reset_to_expire_earlier()
419 queue.insert_at("one", now + ms(200)); in expire_second_key_when_reset_to_expire_earlier()
490 queue.insert_at("1", now + ms(100)); in insert_after_ready_poll()
491 queue.insert_at("2", now + ms(100)); in insert_after_ready_poll()
492 queue.insert_at("3", now + ms(100)); in insert_after_ready_poll()
618 queue.insert_at("foo", now + ms(200)); in insert_in_past_after_poll_fires_immediately()
[all …]
|
| /dports/textproc/mdbook/mdBook-0.4.13/cargo-crates/tokio-util-0.6.7/tests/ |
| H A D | time_delay_queue.rs | 142 queue.insert_at("foo", now); in insert_in_past_fires_immediately()
287 let key = queue.insert_at("foo", now); in remove_expired_item()
333 queue.insert_at("foo", now + ms(10_000)); in expires_before_last_insert()
339 queue.insert_at("bar", now + ms(600)); in expires_before_last_insert()
397 queue.insert_at("two", now + ms(250)); in expire_first_key_when_reset_to_expire_earlier()
419 queue.insert_at("one", now + ms(200)); in expire_second_key_when_reset_to_expire_earlier()
490 queue.insert_at("1", now + ms(100)); in insert_after_ready_poll()
491 queue.insert_at("2", now + ms(100)); in insert_after_ready_poll()
492 queue.insert_at("3", now + ms(100)); in insert_after_ready_poll()
618 queue.insert_at("foo", now + ms(200)); in insert_in_past_after_poll_fires_immediately()
[all …]
|
| /dports/devel/pijul/pijul-1.0.0.a55/cargo-crates/tokio-util-0.6.8/tests/ |
| H A D | time_delay_queue.rs | 142 queue.insert_at("foo", now); in insert_in_past_fires_immediately()
287 let key = queue.insert_at("foo", now); in remove_expired_item()
333 queue.insert_at("foo", now + ms(10_000)); in expires_before_last_insert()
339 queue.insert_at("bar", now + ms(600)); in expires_before_last_insert()
397 queue.insert_at("two", now + ms(250)); in expire_first_key_when_reset_to_expire_earlier()
419 queue.insert_at("one", now + ms(200)); in expire_second_key_when_reset_to_expire_earlier()
490 queue.insert_at("1", now + ms(100)); in insert_after_ready_poll()
491 queue.insert_at("2", now + ms(100)); in insert_after_ready_poll()
492 queue.insert_at("3", now + ms(100)); in insert_after_ready_poll()
618 queue.insert_at("foo", now + ms(200)); in insert_in_past_after_poll_fires_immediately()
[all …]
|
| /dports/www/miniserve/miniserve-0.18.0/cargo-crates/tokio-util-0.6.8/tests/ |
| H A D | time_delay_queue.rs | 142 queue.insert_at("foo", now); in insert_in_past_fires_immediately()
287 let key = queue.insert_at("foo", now); in remove_expired_item()
333 queue.insert_at("foo", now + ms(10_000)); in expires_before_last_insert()
339 queue.insert_at("bar", now + ms(600)); in expires_before_last_insert()
397 queue.insert_at("two", now + ms(250)); in expire_first_key_when_reset_to_expire_earlier()
419 queue.insert_at("one", now + ms(200)); in expire_second_key_when_reset_to_expire_earlier()
490 queue.insert_at("1", now + ms(100)); in insert_after_ready_poll()
491 queue.insert_at("2", now + ms(100)); in insert_after_ready_poll()
492 queue.insert_at("3", now + ms(100)); in insert_after_ready_poll()
618 queue.insert_at("foo", now + ms(200)); in insert_in_past_after_poll_fires_immediately()
[all …]
|
| /dports/lang/rust/rustc-1.58.1-src/vendor/tokio-util/tests/ |
| H A D | time_delay_queue.rs | 142 queue.insert_at("foo", now); in insert_in_past_fires_immediately()
287 let key = queue.insert_at("foo", now); in remove_expired_item()
333 queue.insert_at("foo", now + ms(10_000)); in expires_before_last_insert()
339 queue.insert_at("bar", now + ms(600)); in expires_before_last_insert()
397 queue.insert_at("two", now + ms(250)); in expire_first_key_when_reset_to_expire_earlier()
419 queue.insert_at("one", now + ms(200)); in expire_second_key_when_reset_to_expire_earlier()
490 queue.insert_at("1", now + ms(100)); in insert_after_ready_poll()
491 queue.insert_at("2", now + ms(100)); in insert_after_ready_poll()
492 queue.insert_at("3", now + ms(100)); in insert_after_ready_poll()
618 queue.insert_at("foo", now + ms(200)); in insert_in_past_after_poll_fires_immediately()
[all …]
|
| /dports/www/monolith/monolith-2.6.1/cargo-crates/tokio-util-0.6.7/tests/ |
| H A D | time_delay_queue.rs | 142 queue.insert_at("foo", now); in insert_in_past_fires_immediately()
287 let key = queue.insert_at("foo", now); in remove_expired_item()
333 queue.insert_at("foo", now + ms(10_000)); in expires_before_last_insert()
339 queue.insert_at("bar", now + ms(600)); in expires_before_last_insert()
397 queue.insert_at("two", now + ms(250)); in expire_first_key_when_reset_to_expire_earlier()
419 queue.insert_at("one", now + ms(200)); in expire_second_key_when_reset_to_expire_earlier()
490 queue.insert_at("1", now + ms(100)); in insert_after_ready_poll()
491 queue.insert_at("2", now + ms(100)); in insert_after_ready_poll()
492 queue.insert_at("3", now + ms(100)); in insert_after_ready_poll()
618 queue.insert_at("foo", now + ms(200)); in insert_in_past_after_poll_fires_immediately()
[all …]
|
| /dports/devel/py-maturin/maturin-0.11.3/cargo-crates/tokio-util-0.6.7/tests/ |
| H A D | time_delay_queue.rs | 142 queue.insert_at("foo", now); in insert_in_past_fires_immediately()
287 let key = queue.insert_at("foo", now); in remove_expired_item()
333 queue.insert_at("foo", now + ms(10_000)); in expires_before_last_insert()
339 queue.insert_at("bar", now + ms(600)); in expires_before_last_insert()
397 queue.insert_at("two", now + ms(250)); in expire_first_key_when_reset_to_expire_earlier()
419 queue.insert_at("one", now + ms(200)); in expire_second_key_when_reset_to_expire_earlier()
490 queue.insert_at("1", now + ms(100)); in insert_after_ready_poll()
491 queue.insert_at("2", now + ms(100)); in insert_after_ready_poll()
492 queue.insert_at("3", now + ms(100)); in insert_after_ready_poll()
618 queue.insert_at("foo", now + ms(200)); in insert_in_past_after_poll_fires_immediately()
[all …]
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/tokio-0.2.21/tests/ |
| H A D | time_delay_queue.rs | 134 queue.insert_at("foo", now); in insert_in_past_fires_immediately()
250 let key = queue.insert_at("foo", now); in remove_expired_item()
264 queue.insert_at("foo", now + ms(10_000)); in expires_before_last_insert()
270 queue.insert_at("bar", now + ms(600)); in expires_before_last_insert()
328 queue.insert_at("two", now + ms(250)); in expire_first_key_when_reset_to_expire_earlier()
350 queue.insert_at("one", now + ms(200)); in expire_second_key_when_reset_to_expire_earlier()
421 queue.insert_at("1", now + ms(100)); in insert_after_ready_poll()
422 queue.insert_at("2", now + ms(100)); in insert_after_ready_poll()
423 queue.insert_at("3", now + ms(100)); in insert_after_ready_poll()
528 queue.insert_at("foo", now + ms(200)); in insert_in_past_after_poll_fires_immediately()
[all …]
|
| /dports/games/abstreet/abstreet-0.2.9-49-g74aca40c0/cargo-crates/tokio-0.2.21/tests/ |
| H A D | time_delay_queue.rs | 134 queue.insert_at("foo", now); in insert_in_past_fires_immediately()
250 let key = queue.insert_at("foo", now); in remove_expired_item()
264 queue.insert_at("foo", now + ms(10_000)); in expires_before_last_insert()
270 queue.insert_at("bar", now + ms(600)); in expires_before_last_insert()
328 queue.insert_at("two", now + ms(250)); in expire_first_key_when_reset_to_expire_earlier()
350 queue.insert_at("one", now + ms(200)); in expire_second_key_when_reset_to_expire_earlier()
421 queue.insert_at("1", now + ms(100)); in insert_after_ready_poll()
422 queue.insert_at("2", now + ms(100)); in insert_after_ready_poll()
423 queue.insert_at("3", now + ms(100)); in insert_after_ready_poll()
528 queue.insert_at("foo", now + ms(200)); in insert_in_past_after_poll_fires_immediately()
[all …]
|
| /dports/math/lidia/lidia-2.3.0+latte-patches-2014-10-04/src/base/include/LiDIA/ |
| H A D | base_matrix.cc | 1180 this->DD_base_modul.insert_at(*this, r, c, A, startr, startc, l1, l2); in insert_at()
1183 this->DS_base_modul.insert_at(*this, r, c, A, startr, startc, l1, l2); in insert_at()
1190 this->SD_base_modul.insert_at(*this, r, c, A, startr, startc, l1, l2); in insert_at()
1193 this->SS_base_modul.insert_at(*this, r, c, A, startr, startc, l1, l2); in insert_at()
1347 this->DD_base_modul.insert_at(A, 0, 0, *this, 0, 0, A.rows, A.columns); in split_t()
1349 this->DS_base_modul.insert_at(A, 0, 0, *this, 0, 0, A.rows, A.columns); in split_t()
1372 this->SD_base_modul.insert_at(A, 0, 0, *this, 0, 0, A.rows, A.columns); in split_t()
1374 this->SS_base_modul.insert_at(A, 0, 0, *this, 0, 0, A.rows, A.columns); in split_t()
1431 this->DD_base_modul.insert_at(A, 0, 0, *this, 0, 0, A.rows, A.columns); in split_h()
1433 this->DS_base_modul.insert_at(A, 0, 0, *this, 0, 0, A.rows, A.columns); in split_h()
[all …]
|
| /dports/mail/thunderbird/thunderbird-91.8.0/third_party/rust/tokio/tests/ |
| H A D | time_delay_queue.rs | 44 let _k = queue.insert_at("1", Instant::now()); in multi_immediate_delays()
45 let _k = queue.insert_at("2", Instant::now()); in multi_immediate_delays()
134 queue.insert_at("foo", now); in insert_in_past_fires_immediately()
250 let key = queue.insert_at("foo", now); in remove_expired_item()
264 queue.insert_at("foo", now + ms(10_000)); in expires_before_last_insert()
270 queue.insert_at("bar", now + ms(600)); in expires_before_last_insert()
328 queue.insert_at("two", now + ms(250)); in expire_first_key_when_reset_to_expire_earlier()
350 queue.insert_at("one", now + ms(200)); in expire_second_key_when_reset_to_expire_earlier()
421 queue.insert_at("1", now + ms(100)); in insert_after_ready_poll()
422 queue.insert_at("2", now + ms(100)); in insert_after_ready_poll()
[all …]
|
| /dports/www/firefox-esr/firefox-91.8.0/third_party/rust/tokio/tests/ |
| H A D | time_delay_queue.rs | 44 let _k = queue.insert_at("1", Instant::now()); in multi_immediate_delays()
45 let _k = queue.insert_at("2", Instant::now()); in multi_immediate_delays()
134 queue.insert_at("foo", now); in insert_in_past_fires_immediately()
250 let key = queue.insert_at("foo", now); in remove_expired_item()
264 queue.insert_at("foo", now + ms(10_000)); in expires_before_last_insert()
270 queue.insert_at("bar", now + ms(600)); in expires_before_last_insert()
328 queue.insert_at("two", now + ms(250)); in expire_first_key_when_reset_to_expire_earlier()
350 queue.insert_at("one", now + ms(200)); in expire_second_key_when_reset_to_expire_earlier()
421 queue.insert_at("1", now + ms(100)); in insert_after_ready_poll()
422 queue.insert_at("2", now + ms(100)); in insert_after_ready_poll()
[all …]
|
| /dports/lang/spidermonkey78/firefox-78.9.0/third_party/rust/tokio/tests/ |
| H A D | time_delay_queue.rs | 44 let _k = queue.insert_at("1", Instant::now()); in multi_immediate_delays()
45 let _k = queue.insert_at("2", Instant::now()); in multi_immediate_delays()
134 queue.insert_at("foo", now); in insert_in_past_fires_immediately()
250 let key = queue.insert_at("foo", now); in remove_expired_item()
264 queue.insert_at("foo", now + ms(10_000)); in expires_before_last_insert()
270 queue.insert_at("bar", now + ms(600)); in expires_before_last_insert()
328 queue.insert_at("two", now + ms(250)); in expire_first_key_when_reset_to_expire_earlier()
350 queue.insert_at("one", now + ms(200)); in expire_second_key_when_reset_to_expire_earlier()
421 queue.insert_at("1", now + ms(100)); in insert_after_ready_poll()
422 queue.insert_at("2", now + ms(100)); in insert_after_ready_poll()
[all …]
|
| /dports/net/gemserv/gemserv-v0.4.5/cargo-crates/tokio-0.2.24/tests/ |
| H A D | time_delay_queue.rs | 135 queue.insert_at("foo", now); in insert_in_past_fires_immediately()
251 let key = queue.insert_at("foo", now); in remove_expired_item()
265 queue.insert_at("foo", now + ms(10_000)); in expires_before_last_insert()
271 queue.insert_at("bar", now + ms(600)); in expires_before_last_insert()
329 queue.insert_at("two", now + ms(250)); in expire_first_key_when_reset_to_expire_earlier()
351 queue.insert_at("one", now + ms(200)); in expire_second_key_when_reset_to_expire_earlier()
422 queue.insert_at("1", now + ms(100)); in insert_after_ready_poll()
423 queue.insert_at("2", now + ms(100)); in insert_after_ready_poll()
424 queue.insert_at("3", now + ms(100)); in insert_after_ready_poll()
550 queue.insert_at("foo", now + ms(200)); in insert_in_past_after_poll_fires_immediately()
[all …]
|
| /dports/www/firefox/firefox-99.0/third_party/rust/tokio/tests/ |
| H A D | time_delay_queue.rs | 135 queue.insert_at("foo", now); in insert_in_past_fires_immediately()
251 let key = queue.insert_at("foo", now); in remove_expired_item()
265 queue.insert_at("foo", now + ms(10_000)); in expires_before_last_insert()
271 queue.insert_at("bar", now + ms(600)); in expires_before_last_insert()
329 queue.insert_at("two", now + ms(250)); in expire_first_key_when_reset_to_expire_earlier()
351 queue.insert_at("one", now + ms(200)); in expire_second_key_when_reset_to_expire_earlier()
422 queue.insert_at("1", now + ms(100)); in insert_after_ready_poll()
423 queue.insert_at("2", now + ms(100)); in insert_after_ready_poll()
424 queue.insert_at("3", now + ms(100)); in insert_after_ready_poll()
550 queue.insert_at("foo", now + ms(200)); in insert_in_past_after_poll_fires_immediately()
[all …]
|
| /dports/www/ffsend/ffsend-ccd489ce2e75b91c0f17fbf13dbd91fe84f5ad98/cargo-crates/tokio-0.2.25/tests/ |
| H A D | time_delay_queue.rs | 135 queue.insert_at("foo", now); in insert_in_past_fires_immediately()
251 let key = queue.insert_at("foo", now); in remove_expired_item()
265 queue.insert_at("foo", now + ms(10_000)); in expires_before_last_insert()
271 queue.insert_at("bar", now + ms(600)); in expires_before_last_insert()
329 queue.insert_at("two", now + ms(250)); in expire_first_key_when_reset_to_expire_earlier()
351 queue.insert_at("one", now + ms(200)); in expire_second_key_when_reset_to_expire_earlier()
422 queue.insert_at("1", now + ms(100)); in insert_after_ready_poll()
423 queue.insert_at("2", now + ms(100)); in insert_after_ready_poll()
424 queue.insert_at("3", now + ms(100)); in insert_after_ready_poll()
550 queue.insert_at("foo", now + ms(200)); in insert_in_past_after_poll_fires_immediately()
[all …]
|
| /dports/security/cargo-audit/rustsec-cargo-audit-v0.15.2/cargo-audit/cargo-crates/tokio-0.2.25/tests/ |
| H A D | time_delay_queue.rs | 135 queue.insert_at("foo", now); in insert_in_past_fires_immediately()
251 let key = queue.insert_at("foo", now); in remove_expired_item()
265 queue.insert_at("foo", now + ms(10_000)); in expires_before_last_insert()
271 queue.insert_at("bar", now + ms(600)); in expires_before_last_insert()
329 queue.insert_at("two", now + ms(250)); in expire_first_key_when_reset_to_expire_earlier()
351 queue.insert_at("one", now + ms(200)); in expire_second_key_when_reset_to_expire_earlier()
422 queue.insert_at("1", now + ms(100)); in insert_after_ready_poll()
423 queue.insert_at("2", now + ms(100)); in insert_after_ready_poll()
424 queue.insert_at("3", now + ms(100)); in insert_after_ready_poll()
550 queue.insert_at("foo", now + ms(200)); in insert_in_past_after_poll_fires_immediately()
[all …]
|
| /dports/textproc/angle-grinder/angle-grinder-0.18.0/cargo-crates/tokio-0.2.25/tests/ |
| H A D | time_delay_queue.rs | 135 queue.insert_at("foo", now); in insert_in_past_fires_immediately()
251 let key = queue.insert_at("foo", now); in remove_expired_item()
265 queue.insert_at("foo", now + ms(10_000)); in expires_before_last_insert()
271 queue.insert_at("bar", now + ms(600)); in expires_before_last_insert()
329 queue.insert_at("two", now + ms(250)); in expire_first_key_when_reset_to_expire_earlier()
351 queue.insert_at("one", now + ms(200)); in expire_second_key_when_reset_to_expire_earlier()
422 queue.insert_at("1", now + ms(100)); in insert_after_ready_poll()
423 queue.insert_at("2", now + ms(100)); in insert_after_ready_poll()
424 queue.insert_at("3", now + ms(100)); in insert_after_ready_poll()
550 queue.insert_at("foo", now + ms(200)); in insert_in_past_after_poll_fires_immediately()
[all …]
|