/dports/devel/sccache/sccache-0.2.15/cargo-crates/concurrent-queue-1.2.2/src/ |
H A D | single.rs | 9 const PUSHED: usize = 1 << 1; const 32 .compare_and_swap(0, LOCKED | PUSHED, Ordering::SeqCst); in push() 48 let mut state = PUSHED; in pop() 53 .compare_and_swap(state, (state | LOCKED) & !PUSHED, Ordering::SeqCst); in pop() 62 if prev & PUSHED == 0 { in pop() 81 if self.state.load(Ordering::SeqCst) & PUSHED == 0 { in len() 115 if *self.state.get_mut() & PUSHED != 0 { in drop()
|
/dports/games/genact/genact-0.10.0/cargo-crates/concurrent-queue-1.2.2/src/ |
H A D | single.rs | 9 const PUSHED: usize = 1 << 1; const 32 .compare_and_swap(0, LOCKED | PUSHED, Ordering::SeqCst); in push() 48 let mut state = PUSHED; in pop() 53 .compare_and_swap(state, (state | LOCKED) & !PUSHED, Ordering::SeqCst); in pop() 62 if prev & PUSHED == 0 { in pop() 81 if self.state.load(Ordering::SeqCst) & PUSHED == 0 { in len() 115 if *self.state.get_mut() & PUSHED != 0 { in drop()
|
/dports/accessibility/wl-gammarelay-rs/wl-gammarelay-rs-0.2.1/cargo-crates/concurrent-queue-1.2.2/src/ |
H A D | single.rs | 9 const PUSHED: usize = 1 << 1; const 32 .compare_and_swap(0, LOCKED | PUSHED, Ordering::SeqCst); in push() 48 let mut state = PUSHED; in pop() 53 .compare_and_swap(state, (state | LOCKED) & !PUSHED, Ordering::SeqCst); in pop() 62 if prev & PUSHED == 0 { in pop() 81 if self.state.load(Ordering::SeqCst) & PUSHED == 0 { in len() 115 if *self.state.get_mut() & PUSHED != 0 { in drop()
|
/dports/security/rustscan/RustScan-2.0.1/cargo-crates/concurrent-queue-1.2.2/src/ |
H A D | single.rs | 9 const PUSHED: usize = 1 << 1; const 32 .compare_and_swap(0, LOCKED | PUSHED, Ordering::SeqCst); in push() 48 let mut state = PUSHED; in pop() 53 .compare_and_swap(state, (state | LOCKED) & !PUSHED, Ordering::SeqCst); in pop() 62 if prev & PUSHED == 0 { in pop() 81 if self.state.load(Ordering::SeqCst) & PUSHED == 0 { in len() 115 if *self.state.get_mut() & PUSHED != 0 { in drop()
|
/dports/security/arti/arti-9d0ede26801cdb182daa85c3eb5f0058dc178eb6/cargo-crates/concurrent-queue-1.2.2/src/ |
H A D | single.rs | 9 const PUSHED: usize = 1 << 1; 32 .compare_and_swap(0, LOCKED | PUSHED, Ordering::SeqCst); 48 let mut state = PUSHED; 53 .compare_and_swap(state, (state | LOCKED) & !PUSHED, Ordering::SeqCst); 62 if prev & PUSHED == 0 { 81 if self.state.load(Ordering::SeqCst) & PUSHED == 0 { 115 if *self.state.get_mut() & PUSHED != 0 {
|
/dports/textproc/jql/jql-3.0.6/cargo-crates/concurrent-queue-1.2.2/src/ |
H A D | single.rs | 9 const PUSHED: usize = 1 << 1; const 32 .compare_and_swap(0, LOCKED | PUSHED, Ordering::SeqCst); in push() 48 let mut state = PUSHED; in pop() 53 .compare_and_swap(state, (state | LOCKED) & !PUSHED, Ordering::SeqCst); in pop() 62 if prev & PUSHED == 0 { in pop() 81 if self.state.load(Ordering::SeqCst) & PUSHED == 0 { in len() 115 if *self.state.get_mut() & PUSHED != 0 { in drop()
|
/dports/audio/ncspot/ncspot-0.9.3/cargo-crates/concurrent-queue-1.2.2/src/ |
H A D | single.rs | 9 const PUSHED: usize = 1 << 1; const 32 .compare_and_swap(0, LOCKED | PUSHED, Ordering::SeqCst); in push() 48 let mut state = PUSHED; in pop() 53 .compare_and_swap(state, (state | LOCKED) & !PUSHED, Ordering::SeqCst); in pop() 62 if prev & PUSHED == 0 { in pop() 81 if self.state.load(Ordering::SeqCst) & PUSHED == 0 { in len() 115 if *self.state.get_mut() & PUSHED != 0 { in drop()
|
/dports/multimedia/librespot/librespot-0.1.3/cargo-crates/tokio-threadpool-0.1.18/src/pool/ |
H A D | backup.rs | 70 pub const PUSHED: usize = 0b001; const 143 let prev: State = self.state.fetch_xor(TERMINATED | PUSHED, AcqRel).into(); in signal_stop() 217 let prev: State = self.state.fetch_or(PUSHED, ordering).into(); in set_pushed() 244 self.0 & PUSHED == PUSHED in is_pushed() 248 self.0 &= !PUSHED; in unset_pushed()
|
/dports/devel/sccache/sccache-0.2.15/cargo-crates/tokio-threadpool-0.1.18/src/pool/ |
H A D | backup.rs | 70 pub const PUSHED: usize = 0b001; const 143 let prev: State = self.state.fetch_xor(TERMINATED | PUSHED, AcqRel).into(); in signal_stop() 217 let prev: State = self.state.fetch_or(PUSHED, ordering).into(); in set_pushed() 244 self.0 & PUSHED == PUSHED in is_pushed() 248 self.0 &= !PUSHED; in unset_pushed()
|
/dports/net-mgmt/nfs-exporter/freebsd-nfs-exporter-0.3.0/cargo-crates/tokio-threadpool-0.1.18/src/pool/ |
H A D | backup.rs | 70 pub const PUSHED: usize = 0b001; const 143 let prev: State = self.state.fetch_xor(TERMINATED | PUSHED, AcqRel).into(); in signal_stop() 217 let prev: State = self.state.fetch_or(PUSHED, ordering).into(); in set_pushed() 244 self.0 & PUSHED == PUSHED in is_pushed() 248 self.0 &= !PUSHED; in unset_pushed()
|
/dports/sysutils/vector/vector-0.10.0/cargo-crates/tokio-threadpool-0.1.17/src/pool/ |
H A D | backup.rs | 70 pub const PUSHED: usize = 0b001; const 143 let prev: State = self.state.fetch_xor(TERMINATED | PUSHED, AcqRel).into(); in signal_stop() 217 let prev: State = self.state.fetch_or(PUSHED, ordering).into(); in set_pushed() 244 self.0 & PUSHED == PUSHED in is_pushed() 248 self.0 &= !PUSHED; in unset_pushed()
|
/dports/www/geckodriver/mozilla-central-e9783a644016aa9b317887076618425586730d73/testing/geckodriver/cargo-crates/tokio-threadpool-0.1.14/src/pool/ |
H A D | backup.rs | 70 pub const PUSHED: usize = 0b001; const 143 let prev: State = self.state.fetch_xor(TERMINATED | PUSHED, AcqRel).into(); in signal_stop() 217 let prev: State = self.state.fetch_or(PUSHED, ordering).into(); in set_pushed() 244 self.0 & PUSHED == PUSHED in is_pushed() 248 self.0 &= !PUSHED; in unset_pushed()
|
/dports/editors/xi-term/xi-term-d264767/cargo-crates/tokio-threadpool-0.1.14/src/pool/ |
H A D | backup.rs | 70 pub const PUSHED: usize = 0b001; const 143 let prev: State = self.state.fetch_xor(TERMINATED | PUSHED, AcqRel).into(); in signal_stop() 217 let prev: State = self.state.fetch_or(PUSHED, ordering).into(); in set_pushed() 244 self.0 & PUSHED == PUSHED in is_pushed() 248 self.0 &= !PUSHED; in unset_pushed()
|
/dports/www/firefox/firefox-99.0/third_party/rust/tokio-threadpool/src/pool/ |
H A D | backup.rs | 70 pub const PUSHED: usize = 0b001; const 143 let prev: State = self.state.fetch_xor(TERMINATED | PUSHED, AcqRel).into(); in signal_stop() 217 let prev: State = self.state.fetch_or(PUSHED, ordering).into(); in set_pushed() 244 self.0 & PUSHED == PUSHED in is_pushed() 248 self.0 &= !PUSHED; in unset_pushed()
|
/dports/mail/thunderbird/thunderbird-91.8.0/third_party/rust/tokio-threadpool/src/pool/ |
H A D | backup.rs | 70 pub const PUSHED: usize = 0b001; const 143 let prev: State = self.state.fetch_xor(TERMINATED | PUSHED, AcqRel).into(); in signal_stop() 217 let prev: State = self.state.fetch_or(PUSHED, ordering).into(); in set_pushed() 244 self.0 & PUSHED == PUSHED in is_pushed() 248 self.0 &= !PUSHED; in unset_pushed()
|
/dports/security/sequoia/sequoia-383133f6be990237044900a4df676488bf8dd71e/cargo-crates/tokio-threadpool-0.1.18/src/pool/ |
H A D | backup.rs | 70 pub const PUSHED: usize = 0b001; const 143 let prev: State = self.state.fetch_xor(TERMINATED | PUSHED, AcqRel).into(); in signal_stop() 217 let prev: State = self.state.fetch_or(PUSHED, ordering).into(); in set_pushed() 244 self.0 & PUSHED == PUSHED in is_pushed() 248 self.0 &= !PUSHED; in unset_pushed()
|
/dports/www/websocat/websocat-1.9.0/cargo-crates/tokio-threadpool-0.1.18/src/pool/ |
H A D | backup.rs | 70 pub const PUSHED: usize = 0b001; const 143 let prev: State = self.state.fetch_xor(TERMINATED | PUSHED, AcqRel).into(); in signal_stop() 217 let prev: State = self.state.fetch_or(PUSHED, ordering).into(); in set_pushed() 244 self.0 & PUSHED == PUSHED in is_pushed() 248 self.0 &= !PUSHED; in unset_pushed()
|
/dports/sysutils/rsfetch/rsfetch-2.0.0/cargo-crates/tokio-threadpool-0.1.18/src/pool/ |
H A D | backup.rs | 70 pub const PUSHED: usize = 0b001; const 143 let prev: State = self.state.fetch_xor(TERMINATED | PUSHED, AcqRel).into(); in signal_stop() 217 let prev: State = self.state.fetch_or(PUSHED, ordering).into(); in set_pushed() 244 self.0 & PUSHED == PUSHED in is_pushed() 248 self.0 &= !PUSHED; in unset_pushed()
|
/dports/www/firefox-esr/firefox-91.8.0/third_party/rust/tokio-threadpool/src/pool/ |
H A D | backup.rs | 70 pub const PUSHED: usize = 0b001; const 143 let prev: State = self.state.fetch_xor(TERMINATED | PUSHED, AcqRel).into(); in signal_stop() 217 let prev: State = self.state.fetch_or(PUSHED, ordering).into(); in set_pushed() 244 self.0 & PUSHED == PUSHED in is_pushed() 248 self.0 &= !PUSHED; in unset_pushed()
|
/dports/lang/spidermonkey78/firefox-78.9.0/third_party/rust/tokio-threadpool/src/pool/ |
H A D | backup.rs | 70 pub const PUSHED: usize = 0b001; const 143 let prev: State = self.state.fetch_xor(TERMINATED | PUSHED, AcqRel).into(); in signal_stop() 217 let prev: State = self.state.fetch_or(PUSHED, ordering).into(); in set_pushed() 244 self.0 & PUSHED == PUSHED in is_pushed() 248 self.0 &= !PUSHED; in unset_pushed()
|
/dports/audio/spotifyd/spotifyd-0.3.0/cargo-crates/tokio-threadpool-0.1.17/src/pool/ |
H A D | backup.rs | 70 pub const PUSHED: usize = 0b001; const 143 let prev: State = self.state.fetch_xor(TERMINATED | PUSHED, AcqRel).into(); in signal_stop() 217 let prev: State = self.state.fetch_or(PUSHED, ordering).into(); in set_pushed() 244 self.0 & PUSHED == PUSHED in is_pushed() 248 self.0 &= !PUSHED; in unset_pushed()
|
/dports/lang/perl5-devel/perl5-5.35.4-102-ge43d289c7c/ext/PerlIO-via/t/ |
H A D | via.t | 76 sub Foo::PUSHED { $obj = shift; -1; } 77 sub PerlIO::via::Bar::PUSHED { $obj = shift; -1; } 106 sub PUSHED { 119 sub PUSHED {
|
/dports/lang/perl5.34/perl-5.34.0/ext/PerlIO-via/t/ |
H A D | via.t | 80 sub Foo::PUSHED { $obj = shift; -1; } 81 sub PerlIO::via::Bar::PUSHED { $obj = shift; -1; } 110 sub PUSHED { 123 sub PUSHED {
|
/dports/lang/perl5.30/perl-5.30.3/ext/PerlIO-via/t/ |
H A D | via.t | 80 sub Foo::PUSHED { $obj = shift; -1; } 81 sub PerlIO::via::Bar::PUSHED { $obj = shift; -1; } 110 sub PUSHED { 123 sub PUSHED {
|
/dports/lang/perl5.32/perl-5.32.1/ext/PerlIO-via/t/ |
H A D | via.t | 80 sub Foo::PUSHED { $obj = shift; -1; } 81 sub PerlIO::via::Bar::PUSHED { $obj = shift; -1; } 110 sub PUSHED { 123 sub PUSHED {
|