| /dports/net-p2p/libtorrent/libtorrent-0.13.8/test/torrent/ |
| H A D | tracker_controller_features.cc | 85 CPPUNIT_ASSERT(!tracker_controller.task_timeout()->is_queued()); in test_requesting_timeout()
101 CPPUNIT_ASSERT(!tracker_controller.task_timeout()->is_queued()); in test_promiscious_timeout()
109 CPPUNIT_ASSERT(!tracker_controller.task_timeout()->is_queued()); in test_promiscious_timeout()
129 CPPUNIT_ASSERT(tracker_controller.task_timeout()->is_queued()); in test_promiscious_failed()
146 CPPUNIT_ASSERT(tracker_controller.task_timeout()->is_queued()); in test_promiscious_failed()
156 CPPUNIT_ASSERT(!tracker_controller.task_scrape()->is_queued()); in test_scrape_basic()
165 CPPUNIT_ASSERT(tracker_controller.task_scrape()->is_queued()); in test_scrape_basic()
174 CPPUNIT_ASSERT(!tracker_controller.task_scrape()->is_queued()); in test_scrape_basic()
184 CPPUNIT_ASSERT(!tracker_controller.task_scrape()->is_queued()); in test_scrape_basic()
212 CPPUNIT_ASSERT(tracker_controller.task_timeout()->is_queued()); in test_scrape_priority()
[all …]
|
| H A D | tracker_controller_test.cc | 107 CPPUNIT_ASSERT(!tracker_controller.task_timeout()->is_queued()); in test_timeout()
172 CPPUNIT_ASSERT(!tracker_controller.task_timeout()->is_queued()); in test_send_start()
195 CPPUNIT_ASSERT(tracker_controller.task_timeout()->is_queued()); in test_send_stop_normal()
222 CPPUNIT_ASSERT(tracker_controller.task_timeout()->is_queued()); in test_send_completed_normal()
249 CPPUNIT_ASSERT(tracker_controller.task_timeout()->is_queued()); in test_send_update_normal()
275 CPPUNIT_ASSERT(tracker_controller.task_timeout()->is_queued()); in test_send_task_timeout()
496 CPPUNIT_ASSERT(tracker_controller.task_timeout()->is_queued()); in test_timeout_lacking_usable()
501 CPPUNIT_ASSERT(!tracker_controller.task_timeout()->is_queued()); in test_timeout_lacking_usable()
505 CPPUNIT_ASSERT(tracker_controller.task_timeout()->is_queued()); in test_timeout_lacking_usable()
525 CPPUNIT_ASSERT(tracker_controller.task_timeout()->is_queued()); in test_disable_tracker()
[all …]
|
| /dports/net-im/py-matrix-synapse/synapse-1.50.2/tests/util/ |
| H A D | test_linearizer.py | 55 self.assertFalse(linearizer.is_queued(key))
61 self.assertTrue(linearizer.is_queued(key))
67 self.assertTrue(linearizer.is_queued(key))
70 self.assertFalse(linearizer.is_queued(key))
73 self.assertFalse(linearizer.is_queued(key))
75 self.assertFalse(linearizer.is_queued(key))
|
| /dports/multimedia/librespot/librespot-0.1.3/cargo-crates/tokio-threadpool-0.1.18/src/task/ |
| H A D | blocking_state.rs | 28 pub fn is_queued(&self) -> bool { in is_queued() method
55 } else if state.is_queued() { in consume_allocation()
65 debug_assert!(prev.is_queued()); in notify_blocking()
85 .field("is_queued", &self.is_queued()) in fmt()
|
| /dports/net-mgmt/nfs-exporter/freebsd-nfs-exporter-0.3.0/cargo-crates/tokio-threadpool-0.1.18/src/task/ |
| H A D | blocking_state.rs | 28 pub fn is_queued(&self) -> bool { in is_queued() method
55 } else if state.is_queued() { in consume_allocation()
65 debug_assert!(prev.is_queued()); in notify_blocking()
85 .field("is_queued", &self.is_queued()) in fmt()
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/tokio-threadpool-0.1.17/src/task/ |
| H A D | blocking_state.rs | 28 pub fn is_queued(&self) -> bool { in is_queued() method
55 } else if state.is_queued() { in consume_allocation()
65 debug_assert!(prev.is_queued()); in notify_blocking()
85 .field("is_queued", &self.is_queued()) in fmt()
|
| /dports/www/geckodriver/mozilla-central-e9783a644016aa9b317887076618425586730d73/testing/geckodriver/cargo-crates/tokio-threadpool-0.1.14/src/task/ |
| H A D | blocking_state.rs | 28 pub fn is_queued(&self) -> bool { in is_queued() method
55 } else if state.is_queued() { in consume_allocation()
65 debug_assert!(prev.is_queued()); in notify_blocking()
85 .field("is_queued", &self.is_queued()) in fmt()
|
| /dports/editors/xi-term/xi-term-d264767/cargo-crates/tokio-threadpool-0.1.14/src/task/ |
| H A D | blocking_state.rs | 28 pub fn is_queued(&self) -> bool { in is_queued() method
55 } else if state.is_queued() { in consume_allocation()
65 debug_assert!(prev.is_queued()); in notify_blocking()
85 .field("is_queued", &self.is_queued()) in fmt()
|
| /dports/www/firefox/firefox-99.0/third_party/rust/tokio-threadpool/src/task/ |
| H A D | blocking_state.rs | 28 pub fn is_queued(&self) -> bool { in is_queued() method
55 } else if state.is_queued() { in consume_allocation()
65 debug_assert!(prev.is_queued()); in notify_blocking()
85 .field("is_queued", &self.is_queued()) in fmt()
|
| /dports/mail/thunderbird/thunderbird-91.8.0/third_party/rust/tokio-threadpool/src/task/ |
| H A D | blocking_state.rs | 28 pub fn is_queued(&self) -> bool { in is_queued() method
55 } else if state.is_queued() { in consume_allocation()
65 debug_assert!(prev.is_queued()); in notify_blocking()
85 .field("is_queued", &self.is_queued()) in fmt()
|
| /dports/security/sequoia/sequoia-383133f6be990237044900a4df676488bf8dd71e/cargo-crates/tokio-threadpool-0.1.18/src/task/ |
| H A D | blocking_state.rs | 28 pub fn is_queued(&self) -> bool { in is_queued() method
55 } else if state.is_queued() { in consume_allocation()
65 debug_assert!(prev.is_queued()); in notify_blocking()
85 .field("is_queued", &self.is_queued()) in fmt()
|
| /dports/www/websocat/websocat-1.9.0/cargo-crates/tokio-threadpool-0.1.18/src/task/ |
| H A D | blocking_state.rs | 28 pub fn is_queued(&self) -> bool { in is_queued() method
55 } else if state.is_queued() { in consume_allocation()
65 debug_assert!(prev.is_queued()); in notify_blocking()
85 .field("is_queued", &self.is_queued()) in fmt()
|
| /dports/sysutils/rsfetch/rsfetch-2.0.0/cargo-crates/tokio-threadpool-0.1.18/src/task/ |
| H A D | blocking_state.rs | 28 pub fn is_queued(&self) -> bool { in is_queued() method
55 } else if state.is_queued() { in consume_allocation()
65 debug_assert!(prev.is_queued()); in notify_blocking()
85 .field("is_queued", &self.is_queued()) in fmt()
|
| /dports/www/firefox-esr/firefox-91.8.0/third_party/rust/tokio-threadpool/src/task/ |
| H A D | blocking_state.rs | 28 pub fn is_queued(&self) -> bool { in is_queued() method
55 } else if state.is_queued() { in consume_allocation()
65 debug_assert!(prev.is_queued()); in notify_blocking()
85 .field("is_queued", &self.is_queued()) in fmt()
|
| /dports/lang/spidermonkey78/firefox-78.9.0/third_party/rust/tokio-threadpool/src/task/ |
| H A D | blocking_state.rs | 28 pub fn is_queued(&self) -> bool { in is_queued() method
55 } else if state.is_queued() { in consume_allocation()
65 debug_assert!(prev.is_queued()); in notify_blocking()
85 .field("is_queued", &self.is_queued()) in fmt()
|
| /dports/audio/spotifyd/spotifyd-0.3.0/cargo-crates/tokio-threadpool-0.1.17/src/task/ |
| H A D | blocking_state.rs | 28 pub fn is_queued(&self) -> bool { in is_queued() method
55 } else if state.is_queued() { in consume_allocation()
65 debug_assert!(prev.is_queued()); in notify_blocking()
85 .field("is_queued", &self.is_queued()) in fmt()
|
| /dports/devel/sccache/sccache-0.2.15/cargo-crates/tokio-threadpool-0.1.18/src/task/ |
| H A D | blocking_state.rs | 28 pub fn is_queued(&self) -> bool { in is_queued() method
55 } else if state.is_queued() { in consume_allocation()
65 debug_assert!(prev.is_queued()); in notify_blocking()
85 .field("is_queued", &self.is_queued()) in fmt()
|
| /dports/net-p2p/libtorrent/libtorrent-0.13.8/rak/ |
| H A D | priority_queue_default.h | 55 if (is_queued()) in X()
63 bool is_queued() const { return m_time != timer(); } in X()
110 if (item->is_queued()) in X()
122 if (!item->is_queued()) in X()
|
| /dports/net-p2p/rtorrent/rtorrent-0.9.8/rak/ |
| H A D | priority_queue_default.h | 55 if (is_queued()) in ~priority_item()
63 bool is_queued() const { return m_time != timer(); } in is_queued() function
110 if (item->is_queued()) in priority_queue_insert()
122 if (!item->is_queued()) in priority_queue_erase()
|
| /dports/devel/sccache/sccache-0.2.15/cargo-crates/wasm-bindgen-futures-0.4.19/src/task/ |
| H A D | singlethread.rs | 21 is_queued: Cell<bool>, field
28 is_queued: Cell::new(false), in spawn()
42 if this.is_queued.replace(true) { in wake_by_ref()
96 self.is_queued.set(false); in run()
|
| /dports/net/routinator/routinator-0.10.2/cargo-crates/wasm-bindgen-futures-0.4.24/src/task/ |
| H A D | singlethread.rs | 21 is_queued: Cell<bool>, field
28 is_queued: Cell::new(false), in spawn()
42 if this.is_queued.replace(true) { in wake_by_ref()
96 self.is_queued.set(false); in run()
|
| /dports/security/vaultwarden/vaultwarden-1.23.1/cargo-crates/wasm-bindgen-futures-0.4.28/src/task/ |
| H A D | singlethread.rs | 21 is_queued: Cell<bool>, field
28 is_queued: Cell::new(false), in spawn()
42 if this.is_queued.replace(true) { in wake_by_ref()
96 self.is_queued.set(false); in run()
|
| /dports/games/genact/genact-0.10.0/cargo-crates/wasm-bindgen-futures-0.4.17/src/task/ |
| H A D | singlethread.rs | 21 is_queued: Cell<bool>, field
28 is_queued: Cell::new(false), in spawn()
42 if this.is_queued.replace(true) { in wake_by_ref()
96 self.is_queued.set(false); in run()
|
| /dports/lang/gleam/gleam-0.18.2/cargo-crates/wasm-bindgen-futures-0.4.28/src/task/ |
| H A D | singlethread.rs | 21 is_queued: Cell<bool>, field
28 is_queued: Cell::new(false), in spawn()
42 if this.is_queued.replace(true) { in wake_by_ref()
96 self.is_queued.set(false); in run()
|
| /dports/net-im/fractal/fractal-4.4.0/vendor/wasm-bindgen-futures/src/task/ |
| H A D | singlethread.rs | 21 is_queued: Cell<bool>, field
28 is_queued: Cell::new(false), in spawn()
42 if this.is_queued.replace(true) { in wake_by_ref()
96 self.is_queued.set(false); in run()
|