| /aosp_15_r20/external/okio/okio/src/commonMain/kotlin/okio/internal/ |
| H A D | Buffer.kt | 283 val tail = head!!.prev!! in commonCompleteSegmentByteCount() constant
525 val tail = writableSegment(width) in commonWriteDecimalLong() constant
571 val tail = writableSegment(width) in commonWriteHexadecimalUnsignedLong() constant
596 var tail = head!!.prev in commonWritableSegment() variable
615 val tail = writableSegment(1) in commonWrite() constant
984 val tail = writableSegment(1) in commonWriteUtf8() constant
1007 val tail = writableSegment(2) in commonWriteUtf8() constant
1019 val tail = writableSegment(3) in commonWriteUtf8() constant
1045 val tail = writableSegment(4) in commonWriteUtf8() constant
1071 val tail = writableSegment(2) in commonWriteUtf8CodePoint() constant
[all …]
|
| /aosp_15_r20/prebuilts/rust/linux-x86/1.80.1/lib/rustlib/src/rust/library/std/src/sync/mpmc/ |
| H A D | array.rs | 68 tail: CachePadded<AtomicUsize>, field
101 let tail = 0; in with_capacity() localVariable
127 let mut tail = self.tail.load(Ordering::Relaxed); in start_send() localVariable
261 let tail = self.tail.load(Ordering::Relaxed); in start_recv() localVariable
416 let tail = self.tail.load(Ordering::SeqCst); in len() localVariable
447 let tail = self.tail.fetch_or(self.mark_bit, Ordering::SeqCst); in disconnect_senders() localVariable
466 let tail = self.tail.fetch_or(self.mark_bit, Ordering::SeqCst); in disconnect_receivers() localVariable
497 let tail = tail & !self.mark_bit; in discard_all_messages() localVariable
544 let tail = self.tail.load(Ordering::SeqCst); in is_empty() localVariable
555 let tail = self.tail.load(Ordering::SeqCst); in is_full() localVariable
|
| H A D | list.rs | 149 tail: CachePadded<Position<T>>, field
178 let mut tail = self.tail.index.load(Ordering::Acquire); in start_send() localVariable
299 let tail = self.tail.index.load(Ordering::Relaxed); in start_recv() localVariable
463 let mut tail = self.tail.index.load(Ordering::SeqCst); in len() localVariable
504 let tail = self.tail.index.fetch_or(MARK_BIT, Ordering::SeqCst); in disconnect_senders() localVariable
518 let tail = self.tail.index.fetch_or(MARK_BIT, Ordering::SeqCst); in disconnect_receivers() localVariable
535 let mut tail = self.tail.index.load(Ordering::Acquire); in discard_all_messages() localVariable
607 let tail = self.tail.index.load(Ordering::SeqCst); in is_empty() localVariable
620 let mut tail = self.tail.index.load(Ordering::Relaxed); in drop() localVariable
|
| /aosp_15_r20/prebuilts/rust/linux-x86/1.81.0.u1/lib/rustlib/src/rust/library/std/src/sync/mpmc/ |
| H A D | array.rs | 68 tail: CachePadded<AtomicUsize>, field
101 let tail = 0; in with_capacity() localVariable
127 let mut tail = self.tail.load(Ordering::Relaxed); in start_send() localVariable
262 let tail = self.tail.load(Ordering::Relaxed); in start_recv() localVariable
420 let tail = self.tail.load(Ordering::SeqCst); in len() localVariable
451 let tail = self.tail.fetch_or(self.mark_bit, Ordering::SeqCst); in disconnect_senders() localVariable
470 let tail = self.tail.fetch_or(self.mark_bit, Ordering::SeqCst); in disconnect_receivers() localVariable
501 let tail = tail & !self.mark_bit; in discard_all_messages() localVariable
548 let tail = self.tail.load(Ordering::SeqCst); in is_empty() localVariable
559 let tail = self.tail.load(Ordering::SeqCst); in is_full() localVariable
|
| H A D | list.rs | 149 tail: CachePadded<Position<T>>, field
178 let mut tail = self.tail.index.load(Ordering::Acquire); in start_send() localVariable
301 let tail = self.tail.index.load(Ordering::Relaxed); in start_recv() localVariable
467 let mut tail = self.tail.index.load(Ordering::SeqCst); in len() localVariable
508 let tail = self.tail.index.fetch_or(MARK_BIT, Ordering::SeqCst); in disconnect_senders() localVariable
522 let tail = self.tail.index.fetch_or(MARK_BIT, Ordering::SeqCst); in disconnect_receivers() localVariable
539 let mut tail = self.tail.index.load(Ordering::Acquire); in discard_all_messages() localVariable
611 let tail = self.tail.index.load(Ordering::SeqCst); in is_empty() localVariable
624 let mut tail = self.tail.index.load(Ordering::Relaxed); in drop() localVariable
|
| /aosp_15_r20/prebuilts/rust/linux-musl-x86/1.81.0/lib/rustlib/src/rust/library/std/src/sync/mpmc/ |
| H A D | array.rs | 68 tail: CachePadded<AtomicUsize>, field
101 let tail = 0; in with_capacity() localVariable
127 let mut tail = self.tail.load(Ordering::Relaxed); in start_send() localVariable
262 let tail = self.tail.load(Ordering::Relaxed); in start_recv() localVariable
420 let tail = self.tail.load(Ordering::SeqCst); in len() localVariable
451 let tail = self.tail.fetch_or(self.mark_bit, Ordering::SeqCst); in disconnect_senders() localVariable
470 let tail = self.tail.fetch_or(self.mark_bit, Ordering::SeqCst); in disconnect_receivers() localVariable
501 let tail = tail & !self.mark_bit; in discard_all_messages() localVariable
548 let tail = self.tail.load(Ordering::SeqCst); in is_empty() localVariable
559 let tail = self.tail.load(Ordering::SeqCst); in is_full() localVariable
|
| H A D | list.rs | 149 tail: CachePadded<Position<T>>, field
178 let mut tail = self.tail.index.load(Ordering::Acquire); in start_send() localVariable
301 let tail = self.tail.index.load(Ordering::Relaxed); in start_recv() localVariable
467 let mut tail = self.tail.index.load(Ordering::SeqCst); in len() localVariable
508 let tail = self.tail.index.fetch_or(MARK_BIT, Ordering::SeqCst); in disconnect_senders() localVariable
522 let tail = self.tail.index.fetch_or(MARK_BIT, Ordering::SeqCst); in disconnect_receivers() localVariable
539 let mut tail = self.tail.index.load(Ordering::Acquire); in discard_all_messages() localVariable
611 let tail = self.tail.index.load(Ordering::SeqCst); in is_empty() localVariable
624 let mut tail = self.tail.index.load(Ordering::Relaxed); in drop() localVariable
|
| /aosp_15_r20/prebuilts/rust/linux-musl-x86/1.80.1/lib/rustlib/src/rust/library/std/src/sync/mpmc/ |
| H A D | array.rs | 68 tail: CachePadded<AtomicUsize>, field
101 let tail = 0; in with_capacity() localVariable
127 let mut tail = self.tail.load(Ordering::Relaxed); in start_send() localVariable
261 let tail = self.tail.load(Ordering::Relaxed); in start_recv() localVariable
416 let tail = self.tail.load(Ordering::SeqCst); in len() localVariable
447 let tail = self.tail.fetch_or(self.mark_bit, Ordering::SeqCst); in disconnect_senders() localVariable
466 let tail = self.tail.fetch_or(self.mark_bit, Ordering::SeqCst); in disconnect_receivers() localVariable
497 let tail = tail & !self.mark_bit; in discard_all_messages() localVariable
544 let tail = self.tail.load(Ordering::SeqCst); in is_empty() localVariable
555 let tail = self.tail.load(Ordering::SeqCst); in is_full() localVariable
|
| H A D | list.rs | 149 tail: CachePadded<Position<T>>, field
178 let mut tail = self.tail.index.load(Ordering::Acquire); in start_send() localVariable
299 let tail = self.tail.index.load(Ordering::Relaxed); in start_recv() localVariable
463 let mut tail = self.tail.index.load(Ordering::SeqCst); in len() localVariable
504 let tail = self.tail.index.fetch_or(MARK_BIT, Ordering::SeqCst); in disconnect_senders() localVariable
518 let tail = self.tail.index.fetch_or(MARK_BIT, Ordering::SeqCst); in disconnect_receivers() localVariable
535 let mut tail = self.tail.index.load(Ordering::Acquire); in discard_all_messages() localVariable
607 let tail = self.tail.index.load(Ordering::SeqCst); in is_empty() localVariable
620 let mut tail = self.tail.index.load(Ordering::Relaxed); in drop() localVariable
|
| /aosp_15_r20/prebuilts/rust/linux-x86/1.81.0/lib/rustlib/src/rust/library/std/src/sync/mpmc/ |
| H A D | array.rs | 68 tail: CachePadded<AtomicUsize>, field
101 let tail = 0; in with_capacity() localVariable
127 let mut tail = self.tail.load(Ordering::Relaxed); in start_send() localVariable
262 let tail = self.tail.load(Ordering::Relaxed); in start_recv() localVariable
420 let tail = self.tail.load(Ordering::SeqCst); in len() localVariable
451 let tail = self.tail.fetch_or(self.mark_bit, Ordering::SeqCst); in disconnect_senders() localVariable
470 let tail = self.tail.fetch_or(self.mark_bit, Ordering::SeqCst); in disconnect_receivers() localVariable
501 let tail = tail & !self.mark_bit; in discard_all_messages() localVariable
548 let tail = self.tail.load(Ordering::SeqCst); in is_empty() localVariable
559 let tail = self.tail.load(Ordering::SeqCst); in is_full() localVariable
|
| H A D | list.rs | 149 tail: CachePadded<Position<T>>, field
178 let mut tail = self.tail.index.load(Ordering::Acquire); in start_send() localVariable
301 let tail = self.tail.index.load(Ordering::Relaxed); in start_recv() localVariable
467 let mut tail = self.tail.index.load(Ordering::SeqCst); in len() localVariable
508 let tail = self.tail.index.fetch_or(MARK_BIT, Ordering::SeqCst); in disconnect_senders() localVariable
522 let tail = self.tail.index.fetch_or(MARK_BIT, Ordering::SeqCst); in disconnect_receivers() localVariable
539 let mut tail = self.tail.index.load(Ordering::Acquire); in discard_all_messages() localVariable
611 let tail = self.tail.index.load(Ordering::SeqCst); in is_empty() localVariable
624 let mut tail = self.tail.index.load(Ordering::Relaxed); in drop() localVariable
|
| /aosp_15_r20/prebuilts/go/linux-x86/src/math/big/ |
| D | arith_ppc64x.s | 72 tail: label
161 tail: label
238 tail: label
314 tail: label
557 tail: label
646 tail: label
|
| /aosp_15_r20/external/rust/android-crates-io/crates/crossbeam-queue/src/ |
| D | array_queue.rs | 65 tail: CachePadded<AtomicUsize>, field
103 let tail = 0; in new() localVariable
134 let mut tail = self.tail.load(Ordering::Relaxed); in push_or_else() localVariable
326 let tail = self.tail.load(Ordering::Relaxed); in pop() localVariable
373 let tail = self.tail.load(Ordering::SeqCst); in is_empty() localVariable
397 let tail = self.tail.load(Ordering::SeqCst); in is_full() localVariable
426 let tail = self.tail.load(Ordering::SeqCst); in len() localVariable
453 let tail = *self.tail.get_mut(); in drop() localVariable
|
| D | seg_queue.rs | 143 tail: CachePadded<Position<T>>, field
193 let mut tail = self.tail.index.load(Ordering::Acquire); in push() localVariable
307 let tail = self.tail.index.load(Ordering::Relaxed); in pop() localVariable
388 let tail = self.tail.index.load(Ordering::SeqCst); in is_empty() localVariable
411 let mut tail = self.tail.index.load(Ordering::SeqCst); in len() localVariable
447 let mut tail = *self.tail.index.get_mut(); in drop() localVariable
514 let tail = *value.tail.index.get_mut(); in next() localVariable
|
| /aosp_15_r20/external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/internal/ |
| H A D | LockFreeTaskQueue.kt | 87 val isEmpty: Boolean get() = _state.value.withState { head, tail -> head == tail } in head() method
88 … val size: Int get() = _state.value.withState { head, tail -> (tail - head) and MAX_CAPACITY_MASK } in head() method
103 state.withState { head, tail -> in addLast() method
163 state.withState { head, tail -> in removeFirstOrNull() method
227 state.withState { head, tail -> in allocateNextCopy() method
243 _state.value.withState { head, tail -> in map() method
296 val tail = ((this and TAIL_MASK) shr TAIL_SHIFT).toInt() in isClosed() constant
|
| /aosp_15_r20/external/rust/android-crates-io/crates/crossbeam-channel/src/flavors/ |
| D | array.rs | 72 tail: CachePadded<AtomicUsize>, field
105 let tail = 0; in with_capacity() localVariable
144 let mut tail = self.tail.load(Ordering::Relaxed); in start_send() localVariable
278 let tail = self.tail.load(Ordering::Relaxed); in start_recv() localVariable
451 let tail = self.tail.load(Ordering::SeqCst); in len() localVariable
481 let tail = self.tail.fetch_or(self.mark_bit, Ordering::SeqCst); in disconnect() localVariable
500 let tail = self.tail.load(Ordering::SeqCst); in is_empty() localVariable
511 let tail = self.tail.load(Ordering::SeqCst); in is_full() localVariable
527 let tail = *self.tail.get_mut(); in drop() localVariable
|
| D | list.rs | 162 tail: CachePadded<Position<T>>, field
201 let mut tail = self.tail.index.load(Ordering::Acquire); in start_send() localVariable
322 let tail = self.tail.index.load(Ordering::Relaxed); in start_recv() localVariable
499 let mut tail = self.tail.index.load(Ordering::SeqCst); in len() localVariable
540 let tail = self.tail.index.fetch_or(MARK_BIT, Ordering::SeqCst); in disconnect_senders() localVariable
554 let tail = self.tail.index.fetch_or(MARK_BIT, Ordering::SeqCst); in disconnect_receivers() localVariable
571 let mut tail = self.tail.index.load(Ordering::Acquire); in discard_all_messages() localVariable
641 let tail = self.tail.index.load(Ordering::SeqCst); in is_empty() localVariable
654 let mut tail = *self.tail.index.get_mut(); in drop() localVariable
|
| /aosp_15_r20/external/rust/android-crates-io/crates/grpcio-sys/grpc/third_party/abseil-cpp/absl/strings/internal/ |
| D | cord_rep_ring.cc | 66 void UnrefEntries(const CordRepRing* rep, index_type head, index_type tail) { in UnrefEntries()
252 index_type tail) { in Fill()
271 index_type tail, size_t extra) { in Copy()
377 Position tail = ring->FindTail(head.index, offset + len); in AddRing() local
546 const char* tail = data.data() + data.length() - avail.length(); in Prepend() local
587 index_type tail, in FindBinary()
605 index_type tail = tail_; in FindSlow() local
634 index_type tail = tail_; in FindTailSlow() local
680 Position tail = rep->FindTail(head.index, offset + len); in SubRing() local
749 Position tail = rep->FindTail(rep->length - len); in RemoveSuffix() local
|
| /aosp_15_r20/external/private-join-and-compute/third_party/abseil-cpp-20230125.2/absl/strings/internal/ |
| H A D | cord_rep_ring.cc | 66 void UnrefEntries(const CordRepRing* rep, index_type head, index_type tail) { in UnrefEntries()
252 index_type tail) { in Fill()
271 index_type tail, size_t extra) { in Copy()
377 Position tail = ring->FindTail(head.index, offset + len); in AddRing() local
546 const char* tail = data.data() + data.length() - avail.length(); in Prepend() local
587 index_type tail, in FindBinary()
605 index_type tail = tail_; in FindSlow() local
634 index_type tail = tail_; in FindTailSlow() local
680 Position tail = rep->FindTail(head.index, offset + len); in SubRing() local
749 Position tail = rep->FindTail(rep->length - len); in RemoveSuffix() local
|
| /aosp_15_r20/external/webrtc/third_party/abseil-cpp/absl/strings/internal/ |
| H A D | cord_rep_ring.cc | 66 void UnrefEntries(const CordRepRing* rep, index_type head, index_type tail) { in UnrefEntries()
252 index_type tail) { in Fill()
271 index_type tail, size_t extra) { in Copy()
377 Position tail = ring->FindTail(head.index, offset + len); in AddRing() local
546 const char* tail = data.data() + data.length() - avail.length(); in Prepend() local
587 index_type tail, in FindBinary()
605 index_type tail = tail_; in FindSlow() local
634 index_type tail = tail_; in FindTailSlow() local
680 Position tail = rep->FindTail(head.index, offset + len); in SubRing() local
749 Position tail = rep->FindTail(rep->length - len); in RemoveSuffix() local
|
| /aosp_15_r20/external/libwebsockets/lib/misc/ |
| H A D | lws-ring.c | 100 lws_ring_get_count_waiting_elements(struct lws_ring *ring, uint32_t *tail) in lws_ring_get_count_waiting_elements()
199 lws_ring_consume(struct lws_ring *ring, uint32_t *tail, void *dest, in lws_ring_consume()
255 lws_ring_get_element(struct lws_ring *ring, uint32_t *tail) in lws_ring_get_element()
267 lws_ring_update_oldest_tail(struct lws_ring *ring, uint32_t tail) in lws_ring_update_oldest_tail()
288 lws_ring_dump(struct lws_ring *ring, uint32_t *tail) in lws_ring_dump()
|
| /aosp_15_r20/external/rust/android-crates-io/crates/tokio/src/sync/ |
| D | broadcast.rs | 313 tail: Mutex<Tail>, field
588 let mut tail = self.shared.tail.lock(); in send() localVariable
691 let tail = self.shared.tail.lock(); in len() localVariable
738 let tail = self.shared.tail.lock(); in is_empty() localVariable
781 let tail = self.shared.tail.lock(); in receiver_count() localVariable
809 let mut tail = self.shared.tail.lock(); in close_channel() localVariable
818 let mut tail = shared.tail.lock(); in new_receiver() localVariable
1075 let mut tail = self.shared.tail.lock(); in recv_ref() localVariable
1345 let mut tail = self.shared.tail.lock(); in drop() localVariable
1429 let mut tail = self.receiver.shared.tail.lock(); in drop() localVariable
|
| /aosp_15_r20/external/rust/android-crates-io/crates/tokio/src/runtime/scheduler/multi_thread/ |
| D | queue.rs | 53 tail: AtomicUnsignedShort, field
149 let mut tail = unsafe { self.inner.tail.unsync_load() }; in push_back() localVariable
191 let tail = loop { in push_back_or_overflow() localVariable
196 let tail = unsafe { self.inner.tail.unsync_load() }; in push_back_or_overflow() localVariable
352 let tail = unsafe { self.inner.tail.unsync_load() }; in pop() localVariable
571 let tail = self.tail.load(Acquire); in remaining_slots() localVariable
578 let tail = self.tail.load(Acquire); in len() localVariable
|
| /aosp_15_r20/external/rust/android-crates-io/crates/tokio/src/runtime/scheduler/multi_thread_alt/ |
| D | queue.rs | 54 tail: AtomicUnsignedShort, field
130 let mut tail = unsafe { self.inner.tail.unsync_load() }; in push_back() localVariable
175 let tail = loop { in push_back_or_overflow() localVariable
180 let tail = unsafe { self.inner.tail.unsync_load() }; in push_back_or_overflow() localVariable
344 let tail = unsafe { self.inner.tail.unsync_load() }; in pop() localVariable
566 let tail = self.tail.load(Acquire); in remaining_slots() localVariable
573 let tail = self.tail.load(Acquire); in len() localVariable
|
| /aosp_15_r20/external/libwebsockets/include/libwebsockets/ |
| H A D | lws-ring.h | 262 #define lws_ring_consume_and_update_oldest_tail(\ argument
298 #define lws_ring_consume_single_tail(\ argument
|