Searched refs:CLOSED (Results 1 - 5 of 5) sorted by relevance
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/mpsc/bounded/ |
| H A D | array.rs | 31 const CLOSED: usize = 0b01; consts
79 if tail & CLOSED == CLOSED { in prepare_send()
160 if tail & CLOSED == CLOSED {
191 self.tail.fetch_or(CLOSED, Release); in close()
197 self.tail.load(Acquire) & CLOSED == CLOSED in is_close()
247 if (tail >> INDEX_SHIFT) == node_index || tail & CLOSED == CLOSED {
[all...] |
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/ |
| H A D | oneshot.rs | 60 const CLOSED: usize = 0b10; consts
181 CLOSED => { in send()
211 self.channel.state.load(Acquire) == CLOSED in is_closed()
333 CLOSED => Err(TryRecvError::Closed), in try_recv()
379 .compare_exchange(INIT, CLOSED, AcqRel, Acquire); in close()
403 CLOSED => Ready(Err(RecvError)), in poll()
433 self.state.store(CLOSED, Release); in take_value_sent()
|
| H A D | semaphore_inner.rs | 30 const CLOSED: usize = 1; consts
120 if curr & CLOSED == CLOSED {
143 self.permits.load(Acquire) & CLOSED == CLOSED
149 self.permits.fetch_or(CLOSED, Release);
186 if curr & CLOSED == CLOSED { in poll_acquire()
194 if curr & CLOSED == CLOSED { in poll_acquire()
[all...] |
| H A D | watch.rs | 31 const CLOSED: usize = 1; consts
527 let is_closed = state & CLOSED == CLOSED; in load()
532 self.0.fetch_or(CLOSED, Release); in close()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/mpsc/unbounded/ |
| H A D | queue.rs | 32 const CLOSED: usize = 0b01; consts
155 if tail & CLOSED == CLOSED {
211 if tail_index & CLOSED == CLOSED {
238 self.tail.index.fetch_or(CLOSED, Release); in close()
243 self.tail.index.load(Acquire) & CLOSED == CLOSED in is_close()
|
Completed in 3 milliseconds