| /dports/accessibility/wl-gammarelay-rs/wl-gammarelay-rs-0.2.1/cargo-crates/async-task-4.1.0/tests/ |
| H A D | waker_ready.rs | 110 assert_eq!(POLL.load(Ordering::SeqCst), 1); in wake()
118 assert_eq!(POLL.load(Ordering::SeqCst), 1); in wake()
125 assert_eq!(POLL.load(Ordering::SeqCst), 2); in wake()
132 assert_eq!(POLL.load(Ordering::SeqCst), 2); in wake()
149 assert_eq!(POLL.load(Ordering::SeqCst), 1); in wake_by_ref()
157 assert_eq!(POLL.load(Ordering::SeqCst), 1); in wake_by_ref()
164 assert_eq!(POLL.load(Ordering::SeqCst), 2); in wake_by_ref()
171 assert_eq!(POLL.load(Ordering::SeqCst), 2); in wake_by_ref()
186 assert_eq!(POLL.load(Ordering::SeqCst), 1); in clone()
199 assert_eq!(POLL.load(Ordering::SeqCst), 2); in clone()
[all …]
|
| /dports/accessibility/wl-gammarelay-rs/wl-gammarelay-rs-0.2.1/cargo-crates/async-trait-0.1.52/tests/ |
| H A D | test.rs | 605 let current_depth = self.inner.current_depth.load(Ordering::Acquire); in event()
611 if old_depth + 1 > self.inner.max_depth.load(Ordering::Acquire) { in enter()
629 assert_eq!(subscriber.inner.max_depth.load(Ordering::Acquire), 2); in tracing()
631 assert_eq!(subscriber.inner.current_depth.load(Ordering::Acquire), 0); in tracing()
633 assert_eq!(subscriber.inner.max_span_id.load(Ordering::Acquire) - 1, 2); in tracing()
1066 async fn load(&self, key: &str); in load() method
1075 async fn load(&self, _key: &str) {} in load() method
1214 assert!(!flag.load(Ordering::Acquire)); in test_drop_order()
1217 assert!(!flag.load(Ordering::Acquire)); in test_drop_order()
1220 assert!(!flag.load(Ordering::Acquire)); in test_drop_order()
|
| /dports/accessibility/wl-gammarelay-rs/wl-gammarelay-rs-0.2.1/cargo-crates/cc-1.0.72/src/ |
| H A D | lib.rs | 1135 if error.load(SeqCst) { in compile_objects()
|
| /dports/accessibility/wl-gammarelay-rs/wl-gammarelay-rs-0.2.1/cargo-crates/concurrent-queue-1.2.2/src/ |
| H A D | bounded.rs | 84 let mut tail = self.tail.load(Ordering::Relaxed); in push()
141 tail = self.tail.load(Ordering::Relaxed); in push()
145 tail = self.tail.load(Ordering::Relaxed); in push()
152 let mut head = self.head.load(Ordering::Relaxed); in pop()
207 head = self.head.load(Ordering::Relaxed); in pop()
220 let tail = self.tail.load(Ordering::SeqCst); in len()
221 let head = self.head.load(Ordering::SeqCst); in len()
243 let head = self.head.load(Ordering::SeqCst); in is_empty()
244 let tail = self.tail.load(Ordering::SeqCst); in is_empty()
255 let tail = self.tail.load(Ordering::SeqCst); in is_full()
[all …]
|
| H A D | single.rs | 81 if self.state.load(Ordering::SeqCst) & PUSHED == 0 { in len()
108 self.state.load(Ordering::SeqCst) & CLOSED != 0 in is_closed()
|
| H A D | unbounded.rs | 47 while self.state.load(Ordering::Acquire) & WRITE == 0 { in wait_write()
76 let next = self.next.load(Ordering::Acquire); in wait_next()
92 if slot.state.load(Ordering::Acquire) & READ == 0 in destroy()
140 let mut tail = self.tail.index.load(Ordering::Acquire); in push()
141 let mut block = self.tail.block.load(Ordering::Acquire); in push()
156 tail = self.tail.index.load(Ordering::Acquire); in push()
157 block = self.tail.block.load(Ordering::Acquire); in push()
222 let mut head = self.head.index.load(Ordering::Acquire); in pop()
232 head = self.head.index.load(Ordering::Acquire); in pop()
348 let head = self.head.index.load(Ordering::SeqCst); in is_empty()
[all …]
|
| /dports/accessibility/wl-gammarelay-rs/wl-gammarelay-rs-0.2.1/cargo-crates/concurrent-queue-1.2.2/tests/ |
| H A D | bounded.rs | 184 assert_eq!(c.load(Ordering::SeqCst), THREADS); in mpmc()
229 assert_eq!(DROPS.load(Ordering::SeqCst), steps); in drops()
231 assert_eq!(DROPS.load(Ordering::SeqCst), steps + additional); in drops()
|
| H A D | single.rs | 114 assert_eq!(c.load(Ordering::SeqCst), THREADS); in mpmc()
159 assert_eq!(DROPS.load(Ordering::SeqCst), steps); in drops()
161 assert_eq!(DROPS.load(Ordering::SeqCst), steps + additional); in drops()
|
| H A D | unbounded.rs | 123 assert_eq!(c.load(Ordering::SeqCst), THREADS); in mpmc()
164 assert_eq!(DROPS.load(Ordering::SeqCst), steps); in drops()
166 assert_eq!(DROPS.load(Ordering::SeqCst), steps + additional); in drops()
|
| /dports/accessibility/wl-gammarelay-rs/wl-gammarelay-rs-0.2.1/cargo-crates/derivative-2.2.0/tests/ |
| H A D | rustc-deriving-copyclone.rs | 55 assert!(!CLONED.load(Ordering::SeqCst), "TheirTheir"); in main()
58 assert!(!CLONED.load(Ordering::SeqCst), "OurOur1"); in main()
60 assert!(!CLONED.load(Ordering::SeqCst), "OurOur2"); in main()
|
| /dports/accessibility/wl-gammarelay-rs/wl-gammarelay-rs-0.2.1/cargo-crates/dlib-0.5.0/ |
| H A D | README.md | 52 and a method `open`, which tries to load the library from the name or path given as an argument.
81 code. As such, you need to ensure that the specific library you want to load is safe to load in the…
82 you want to load it.
|
| /dports/accessibility/wl-gammarelay-rs/wl-gammarelay-rs-0.2.1/cargo-crates/event-listener-2.5.2/ |
| H A D | CHANGELOG.md | 61 - Change a `Relaxed` load to `Acquire` load.
|
| H A D | README.md | 56 if flag.load(Ordering::SeqCst) {
64 if flag.load(Ordering::SeqCst) {
|
| /dports/accessibility/wl-gammarelay-rs/wl-gammarelay-rs-0.2.1/cargo-crates/event-listener-2.5.2/src/ |
| H A D | lib.rs | 223 if inner.notified.load(Ordering::Acquire) < n { in notify()
267 if inner.notified.load(Ordering::Acquire) < n { in notify_relaxed()
310 if inner.notified.load(Ordering::Acquire) < usize::MAX { in notify_additional()
355 if inner.notified.load(Ordering::Acquire) < usize::MAX { in notify_additional_relaxed()
364 let inner = self.inner.load(Ordering::Acquire); in try_inner()
373 let mut inner = self.inner.load(Ordering::Acquire); in inner()
575 ptr::eq::<Inner>(&*self.inner, event.inner.load(Ordering::Acquire)) in listens_to()
|
| /dports/accessibility/wl-gammarelay-rs/wl-gammarelay-rs-0.2.1/cargo-crates/futures-0.3.21/tests/ |
| H A D | stream_futures_unordered.rs | 168 if self.cancel.load(Ordering::Relaxed) { in iter_cancel()
|
| H A D | task_atomic_waker.rs | 25 if woken_copy.load(Ordering::Relaxed) == 1 { in basic()
40 while returned_pending.load(Ordering::Relaxed) == 0 {} in basic()
|
| /dports/accessibility/wl-gammarelay-rs/wl-gammarelay-rs-0.2.1/cargo-crates/futures-channel-0.3.21/src/mpsc/ |
| H A D | mod.rs | 416 let state = decode_state(self.inner.state.load(SeqCst)); in poll_ready_nb()
436 let mut curr = self.inner.state.load(SeqCst); in inc_num_messages()
484 !decode_state(self.inner.state.load(SeqCst)).is_open in is_closed()
567 let mut curr = self.inner.state.load(SeqCst); in inc_num_messages()
609 let state = decode_state(self.inner.state.load(SeqCst)); in park()
626 let state = decode_state(self.inner.state.load(SeqCst)); in poll_ready()
653 !decode_state(self.inner.state.load(SeqCst)).is_open in is_closed()
873 let mut curr = self.inner.num_senders.load(SeqCst); in clone()
901 let mut curr = self.inner.num_senders.load(SeqCst); in clone()
1251 let curr = self.state.load(SeqCst); in set_closed()
[all …]
|
| H A D | queue.rs | 119 let next = (*tail).next.load(Ordering::Acquire); in pop()
130 if self.head.load(Ordering::Acquire) == tail { in pop()
170 let next = (*cur).next.load(Ordering::Relaxed); in drop()
|
| /dports/accessibility/wl-gammarelay-rs/wl-gammarelay-rs-0.2.1/cargo-crates/futures-channel-0.3.21/src/ |
| H A D | oneshot.rs | 122 if self.complete.load(SeqCst) { in send()
138 if self.complete.load(SeqCst) { in send()
159 if self.complete.load(SeqCst) { in poll_canceled()
181 if self.complete.load(SeqCst) { in poll_canceled()
189 self.complete.load(SeqCst) in is_canceled()
244 if self.complete.load(SeqCst) { in try_recv()
264 let done = if self.complete.load(SeqCst) { in recv()
285 if done || self.complete.load(SeqCst) { in recv()
465 if self.inner.complete.load(SeqCst) { in is_terminated()
|
| /dports/accessibility/wl-gammarelay-rs/wl-gammarelay-rs-0.2.1/cargo-crates/futures-channel-0.3.21/tests/ |
| H A D | channel.rs | 61 assert_eq!(DROPS.load(Ordering::SeqCst), 0); in drop_order()
63 assert_eq!(DROPS.load(Ordering::SeqCst), 1); in drop_order()
65 assert_eq!(DROPS.load(Ordering::SeqCst), 2); in drop_order()
|
| H A D | mpsc.rs | 332 assert_eq!(AMT, n.load(Ordering::Relaxed)); in stress_receiver_multi_task_bounded_hard()
|
| /dports/accessibility/wl-gammarelay-rs/wl-gammarelay-rs-0.2.1/cargo-crates/futures-executor-0.3.21/src/ |
| H A D | unpark_mutex.rs | 57 let mut status = self.status.load(SeqCst); in notify()
|
| /dports/accessibility/wl-gammarelay-rs/wl-gammarelay-rs-0.2.1/cargo-crates/futures-executor-0.3.21/tests/ |
| H A D | local_pool.rs | 427 while !latch.load(Ordering::Relaxed) { in park_unpark_independence()
|
| /dports/accessibility/wl-gammarelay-rs/wl-gammarelay-rs-0.2.1/cargo-crates/futures-util-0.3.21/src/ |
| H A D | abortable.rs | 69 self.inner.aborted.load(Ordering::Relaxed) in is_aborted()
|
| /dports/accessibility/wl-gammarelay-rs/wl-gammarelay-rs-0.2.1/cargo-crates/futures-util-0.3.21/src/future/future/ |
| H A D | remote_handle.rs | 99 && !this.keep_running.load(Ordering::SeqCst) in poll()
|