Home
last modified time | relevance | path

Searched refs:tail (Results 1 – 25 of 84) sorted by relevance

1234

/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/mpsc/unbounded/
H A Dqueue.rs101 tail: Tail<T>, field
118 tail: Tail { in new()
151 let mut tail = self.tail.index.load(Acquire); in send() localVariable
155 if tail & CLOSED == CLOSED { in send()
160 tail = self.tail.index.load(Acquire); in send()
169 .tail in send()
171 .compare_exchange(tail, tail + (1 << INDEX_SHIFT), AcqRel, Acquire) in send()
178 tail = self.tail.index.load(Acquire); in send()
248 let mut tail = self.tail.index.load(Acquire) >> INDEX_SHIFT; in len() localVariable
249 if tail % (CAPACITY + 1) == CAPACITY { in len()
[all …]
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/mpsc/bounded/
H A Darray.rs41 tail: AtomicUsize, field
68 tail: AtomicUsize::new(0), in new()
77 let mut tail = self.tail.load(Acquire); in prepare_send() localVariable
79 if tail & CLOSED == CLOSED { in prepare_send()
91 tail, in prepare_send()
159 let tail = self.tail.load(Acquire); in try_recv() localVariable
160 if tail & CLOSED == CLOSED { in try_recv()
202 let tail = self.tail.load(Acquire) >> INDEX_SHIFT; in len() localVariable
203 tail - head in len()
242 let tail = self.array.tail.load(Acquire); in poll() localVariable
[all …]
/ohos5.0/foundation/communication/bluetooth_service/services/bluetooth/stack/platform/src/
H A Dpacket.c35 Payload *tail; member
95 refPacket->tail = PayloadNewRef(pkt->tail->buf); in PacketRefMalloc()
187 return pkt->tail->buf; in PacketTail()
239 while (node != pkt->tail) { in PacketPayloadSize()
341 Payload *end = pkt->tail; in PacketPayloadRead()
358 Payload *end = pkt->tail; in PacketPayloadWrite()
442 last->next = pkt->tail; in PacketExtractTail()
443 pkt->tail->prev = last; in PacketExtractTail()
484 uplayer->tail = NULL; in PacketFragment()
519 refPacket->tail = NULL; in PacketAssemble()
[all …]
/ohos5.0/commonlibrary/rust/ylong_json/src/
H A Dlinked_list.rs24 tail: *const Node<T>, field
34 tail: null(), in new()
57 node.prev = self.tail; in push_back()
67 self.tail = node; in push_back()
74 if self.tail.is_null() { in pop_back()
98 tail: self.tail, in iter()
109 tail: self.tail, in iter_mut()
141 current: self.tail, in cursor_back()
152 current: self.tail, in cursor_back_mut()
325 tail: *const Node<T>, field
[all …]
/ohos5.0/foundation/arkui/ace_engine/frameworks/core/pipeline/base/
H A Dcomponent.cpp59 auto tail = std::find_if(components.rbegin(), components.rend(), IsRenderComponent<Component>); in MergeRSNode() local
60 if (head == components.end() || tail == components.rend()) { in MergeRSNode()
64 (*tail)->isTailComponent_ = true; in MergeRSNode()
74 … auto tail = std::find_if(components.rbegin(), components.rend(), IsRenderComponent<SingleChild>); in MergeRSNode() local
75 if (head == components.end() || tail == components.rend()) { in MergeRSNode()
79 AceType::DynamicCast<Component>(*tail)->isTailComponent_ = true; in MergeRSNode()
86 if (components.empty() || head == components.end() || tail == components.rend()) { in MergeRSNode()
94 AceType::DynamicCast<Component>(*tail)->isTailComponent_ = true; in MergeRSNode()
98 void Component::MergeRSNode(const RefPtr<Component>& head, const RefPtr<Component>& tail) in MergeRSNode() argument
100 if (!head || !tail) { in MergeRSNode()
[all …]
/ohos5.0/foundation/communication/dsoftbus/core/common/include/
H A Dsoftbus_queue.h83 producerTail = queue->producer.tail; in QueueIsEmpty()
84 consumerTail = queue->consumer.tail; in QueueIsEmpty()
109 consumerTail = queue->consumer.tail; in QueueSingleProducerEnqueue()
138 queue->producer.tail = producerNext; in QueueSingleProducerEnqueue()
165 consumerTail = queue->consumer.tail; in QueueMultiProducerEnqueue()
198 while (queue->producer.tail != producerHead) { in QueueMultiProducerEnqueue()
202 queue->producer.tail += 1; in QueueMultiProducerEnqueue()
225 producerTail = queue->producer.tail; in QueueSingleConsumerDequeue()
255 queue->consumer.tail = consumerNext; in QueueSingleConsumerDequeue()
284 producerTail = queue->producer.tail; in QueueMultiConsumerDequeue()
[all …]
/ohos5.0/foundation/communication/dsoftbus/components/nstackx/fillp/src/public/src/
H A Dskiplist.c68 list->tail = FILLP_NULL_PTR; in SkiplistInit()
96 list->tail = FILLP_NULL_PTR; in SkiplistDestroy()
139 list->tail = FILLP_NULL_PTR; in SkipListPopValue()
159 struct SkipListNode *tail = FILLP_NULL_PTR; in SkipListPopTail() local
167 tail = list->tail; in SkipListPopTail()
170 tnode = tail->pre[index]; in SkipListPopTail()
181 list->tail = tail->pre[0]; in SkipListPopTail()
182 if (list->tail == FILLP_NULL_PTR) { in SkipListPopTail()
187 return tail->item; in SkipListPopTail()
245 list->tail = node; in SkipListInsertFirstNode()
[all …]
H A Dlf_ring.c78 ring->cons.tail = 0; in FillpLfRingInit()
81 ring->prod.tail = 0; in FillpLfRingInit()
106 consTail = ring->cons.tail; in FillpLfRingMpEnqueueWait()
160 while (unlikely(ring->prod.tail != prodHead)) { in FillpLfRingMpEnqueue()
174 ring->prod.tail = prodNext; in FillpLfRingMpEnqueue()
190 prodTail = ring->prod.tail; in FillpLfRingMcDequeueWait()
257 ring->cons.tail = consNext; in FillpLfRingMcDequeue()
266 FILLP_ULONG prodTail = r->prod.tail; in FillpRingEmpty()
267 FILLP_ULONG consTail = r->cons.tail; in FillpRingEmpty()
284 consTail = r->cons.tail; in FillpRingFreeEntries()
[all …]
/ohos5.0/foundation/resourceschedule/ffrt/src/util/
H A Dspmc_queue.cpp63 unsigned int tail = tail_.load(); in PopHead() local
64 if (tail == head) { in PopHead()
82 unsigned int tail = tail_.load(); in PushTail() local
83 if ((tail - head) < capacity_) { in PushTail()
84 buf_[tail % capacity_] = object; in PushTail()
85 tail_.store(tail + 1); in PushTail()
/ohos5.0/commonlibrary/ets_utils/js_util_module/container/linkedlist/
H A Djs_linkedlist.ts123 private tail?: NodeObj<T>;
129 this.tail = undefined;
165 this.head = this.tail = node;
171 this.tail = current.next = node;
180 this.head = this.tail = node;
197 let result: T = this.tail.element;
204 this.tail = undefined;
258 this.tail = current;
322 if (this.tail !== undefined) {
323 return this.tail.element;
[all …]
/ohos5.0/drivers/hdf_core/adapter/khdf/linux/network/src/
H A Dnetbuf_adapter.c234 int32_t NetBufResizeRoom(NetBuf *nb, uint32_t head, uint32_t tail) in NetBufResizeRoom() argument
236 return pskb_expand_head(nb, head, tail, GFP_ATOMIC); in NetBufResizeRoom()
270 nb->tail += len; in NetBufPush()
274 if (unlikely(len > nb->len) || unlikely(len > nb->tail)) { in NetBufPush()
278 nb->tail -= len; in NetBufPush()
330 nb->tail += len; in NetBufPop()
/ohos5.0/foundation/communication/bluetooth_service/services/bluetooth/stack/src/rfcomm/
H A Drfcomm_frames.c139 uint8_t tail = RfcommCalculateFcs(RFCOMM_NOT_UIH_FSC_LEN, header); in RfcommSendSabm() local
165 uint8_t tail = RfcommCalculateFcs(RFCOMM_NOT_UIH_FSC_LEN, header); in RfcommSendDisc() local
191 uint8_t tail = RfcommCalculateFcs(RFCOMM_NOT_UIH_FSC_LEN, header); in RfcommSendUa() local
218 uint8_t tail = RfcommCalculateFcs(RFCOMM_NOT_UIH_FSC_LEN, header); in RfcommSendDm() local
267 uint8_t tail = RfcommCalculateFcs(RFCOMM_IS_UIH_FSC_LEN, header); in RfcommSendUihPn() local
311 uint8_t tail = RfcommCalculateFcs(RFCOMM_IS_UIH_FSC_LEN, header); in RfcommSendUihMsc() local
348 uint8_t tail = RfcommCalculateFcs(RFCOMM_IS_UIH_FSC_LEN, header); in RfcommSendUihRls() local
400 uint8_t tail = RfcommCalculateFcs(RFCOMM_IS_UIH_FSC_LEN, header); in RfcommSendUihRpn() local
431 uint8_t tail = RfcommCalculateFcs(RFCOMM_IS_UIH_FSC_LEN, header); in RfcommSendUihFcon() local
519 return RfcommSendData(session->l2capId, header, len, tail, pkt); in RfcommSendUihTest()
[all …]
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/util/
H A Dslots.rs54 tail: usize, field
86 let tail = self.tail; in push_back() localVariable
94 self.entries.push(Entry::new(val, tail, NULL)); in push_back()
99 self.entries[key].prev = tail; in push_back()
104 match self.entries.get_mut(tail) { in push_back()
112 self.tail = key; in push_back()
139 self.tail = NULL; in pop_front()
188 self.tail = prev; in remove()
230 tail: NULL, in with_capacity()
279 self.tail, in fmt()
/ohos5.0/foundation/graphic/graphic_2d/rosen/modules/render_service_base/src/common/
H A Drs_occlusion_region_helper.cpp96 inline RectType Looper::GetEdgeRelation(int &head, int &tail, in GetEdgeRelation() argument
106 tail = lhsEnd_; in GetEdgeRelation()
110 tail = rhsStart_; in GetEdgeRelation()
116 tail = rhsEnd_; in GetEdgeRelation()
120 tail = lhsStart_; in GetEdgeRelation()
126 tail = rhsStart_ = lhsEnd_; in GetEdgeRelation()
130 tail = lhsStart_ = rhsEnd_; in GetEdgeRelation()
/ohos5.0/foundation/communication/bluetooth_service/services/bluetooth/stack/src/sdp/
H A Dsdp_connect.c1240 uint8_t *tail = NULL; in SdpBuildSearchFragmentResponse() local
1249 tail[0] = 0x00; in SdpBuildSearchFragmentResponse()
1255 tail[0] = 0x01; in SdpBuildSearchFragmentResponse()
1262 tail[0] = 0x02; in SdpBuildSearchFragmentResponse()
1401 tail[0] = 0; in SdpSendSearchResponse()
1429 tail[0] = 0x00; in SdpBuildAttributeFragmentResponse()
1435 tail[0] = 0x01; in SdpBuildAttributeFragmentResponse()
1442 tail[0] = 0x02; in SdpBuildAttributeFragmentResponse()
1563 tail[0] = 0; in SdpSendAttributeResponse()
1585 tail[0] = 0x00; in SdpSendRequest()
[all …]
/ohos5.0/foundation/communication/dsoftbus/core/common/queue/
H A Dsoftbus_queue.c52 queue->producer.tail = 0; in QueueInit()
53 queue->consumer.tail = 0; in QueueInit()
87 producerTail = queue->producer.tail; in QueueCountGet()
88 consumerTail = queue->consumer.tail; in QueueCountGet()
/ohos5.0/foundation/communication/dsoftbus/components/nstackx/fillp/src/public/include/
H A Dskiplist.h42 struct SkipListNode *tail; member
84 … return ((list == FILLP_NULL_PTR) || (list->tail == FILLP_NULL_PTR)) ? FILLP_NULL_PTR : list->tail; in SkipListGetTail()
H A Dlf_ring.h40 volatile FILLP_ULONG tail; member
45 volatile FILLP_ULONG tail; member
/ohos5.0/foundation/arkui/ace_engine/frameworks/core/components/indexer/
H A Dindexer_item_component.cpp32 RefPtr<Component> tail = box_; in BuildItem() local
38 tail = image_; in BuildItem()
46 tail = text_; in BuildItem()
62 Component::MergeRSNode(rotate, tail); in BuildItem()
65 Component::MergeRSNode(box_, tail); in BuildItem()
/ohos5.0/foundation/multimedia/player_framework/services/utils/
H A Dxml_parse.cpp74 std::string tail = str.substr(pos + 1); in TransStrAsRange() local
79 ret = StrToInt(tail, range.maxVal); in TransStrAsRange()
81 "call StrToInt func false, input tail is: %{public}s", tail.c_str()); in TransStrAsRange()
/ohos5.0/foundation/ability/ability_runtime/frameworks/native/ability/native/child_process_manager/
H A Dnative_args_child_process.cpp86 NativeChildProcess_Fd *tail = nullptr; in ParseToNativeArgs() local
111 tail->next = node; in ParseToNativeArgs()
113 tail = node; in ParseToNativeArgs()
/ohos5.0/base/global/resource_management/frameworks/resmgr/src/utils/
H A Dutils.cpp451 bool Utils::endWithTail(const std::string& path, const std::string& tail) in endWithTail() argument
453 if (path.size() < tail.size()) { in endWithTail()
457 return path.compare(path.size() - tail.size(), tail.size(), tail) == 0; in endWithTail()
468 for (auto tail : tailSet) { in ContainsTail() local
469 if (Utils::endWithTail(hapPath, tail)) { in ContainsTail()
/ohos5.0/docs/en/device-dev/kernel/
H A Dkernel-small-basic-trans-queue.md46 UINT16 queueTail; /**< Node tail */
66 …tail node of a queue. To write data to the tail node, locate the start idle message node based on …
68 …Head** and read the message from the node. If **Head** is pointing to the tail of the queue, the r…
76 The preceding figure illustrates how to write data to the tail node only. Writing data to the head …
87 …_QueueWrite**: writes the value of **bufferAddr** (buffer address) to the tail node of a queue.<br…
88 …>- **LOS_QueueWriteCopy**: writes the data saved in **bufferAddr** to the tail node of a queue.<br…
89 …tion, including the queue ID, queue length, message node size, head node, tail node, number of rea…
H A Dkernel-mini-basic-ipc-queue.md43 …UINT16 queueTail; /* Position of the message tail node (array subscri…
65 …tail node of a queue. To write data to the tail node, locate the start idle message node based on …
67 …Head** and read the message from the node. If **Head** is pointing to the tail of the queue, the r…
75 The preceding figure illustrates how to write data to the tail node only. Writing data to the head …
83 …<br>**LOS_QueueWrite**: writes the **bufferAddr** (buffer address) to the tail node of the specifi…
84 …*LOS_QueueWriteCopy**: writes the data saved in the **bufferAddr** to the tail node of the specifi…
85 …tion, including the queue ID, queue length, message node size, head node, tail node, number of rea…
/ohos5.0/base/security/code_signature/services/key_enable/src/
H A Dfile_utils.rs52 pub fn fmt_store_path(prefix: &str, tail: &str) -> String { in fmt_store_path()
53 format!("{}/{}", prefix, tail) in fmt_store_path()

1234