Home
last modified time | relevance | path

Searched refs:head (Results 1 – 25 of 112) sorted by relevance

12345

/foundation/communication/dsoftbus/components/nstackx/nstackx_util/interface/
Dnstackx_list.h31 static inline void ListInitHead(List *head) in ListInitHead() argument
33 head->next = head; in ListInitHead()
34 head->prev = head; in ListInitHead()
37 static inline void ListInsertHead(List *head, List *node) in ListInsertHead() argument
39 node->next = head->next; in ListInsertHead()
41 node->prev = head; in ListInsertHead()
42 head->next = node; in ListInsertHead()
45 static inline void ListInsertTail(List *head, List *node) in ListInsertTail() argument
47 node->prev = head->prev; in ListInsertTail()
49 node->next = head; in ListInsertTail()
[all …]
/foundation/communication/dsoftbus/components/nstackx_mini/nstackx_util/interface/
Dnstackx_list.h31 static inline void ListInitHead(List *head) in ListInitHead() argument
33 head->next = head; in ListInitHead()
34 head->prev = head; in ListInitHead()
37 static inline void ListInsertHead(List *head, List *node) in ListInsertHead() argument
39 node->next = head->next; in ListInsertHead()
41 node->prev = head; in ListInsertHead()
42 head->next = node; in ListInsertHead()
45 static inline void ListInsertTail(List *head, List *node) in ListInsertTail() argument
47 node->prev = head->prev; in ListInsertTail()
49 node->next = head; in ListInsertTail()
[all …]
/foundation/communication/dsoftbus/core/authentication/src/
Dauth_socket.c89 static void AuthIpOnDataReceived(int32_t fd, const ConnPktHead *head, char *data, int len) in AuthIpOnDataReceived() argument
91 if (head == NULL || data == NULL) { in AuthIpOnDataReceived()
101 if (!IsAuthTransModule(head->module)) { in AuthIpOnDataReceived()
102 if (auth->authId != head->seq && auth->authId != fd && in AuthIpOnDataReceived()
103 (head->seq != 0 || head->module != MODULE_AUTH_CONNECTION)) { in AuthIpOnDataReceived()
109 SoftBusLog(SOFTBUS_LOG_AUTH, SOFTBUS_LOG_INFO, "auth ip data module is %d", head->module); in AuthIpOnDataReceived()
110 switch (head->module) { in AuthIpOnDataReceived()
112 if (auth->side == SERVER_SIDE_FLAG && head->flag == 0 && auth->authId == fd) { in AuthIpOnDataReceived()
113 auth->authId = head->seq; in AuthIpOnDataReceived()
120 HandleReceiveAuthData(auth, head->module, (uint8_t *)data, head->len); in AuthIpOnDataReceived()
[all …]
Dauth_connection.c30 const AuthDataHead *head, const uint8_t *data, uint32_t len) in AuthSocketSendData() argument
33 (void)head; in AuthSocketSendData()
71 static int32_t SetBufData(char *buf, const AuthManager *auth, const AuthDataHead *head, in SetBufData() argument
76 *(int32_t *)buf = head->dataType; in SetBufData()
78 *(int32_t *)buf = head->module; in SetBufData()
80 *(int64_t *)buf = head->seq; in SetBufData()
82 *(int32_t *)buf = head->flag; in SetBufData()
94 static void HandlePeerSyncDeviceInfo(AuthManager *auth, const AuthDataHead *head) in HandlePeerSyncDeviceInfo() argument
96 if (head->dataType == DATA_TYPE_SYNC) { in HandlePeerSyncDeviceInfo()
99 if (head->dataType == DATA_TYPE_SYNC && auth->encryptDevData != NULL) { in HandlePeerSyncDeviceInfo()
[all …]
Dauth_p2p.c43 AuthDataHead head; in AuthP2pOnKeyGenerated() local
44 head.flag = auth->side; in AuthP2pOnKeyGenerated()
45 head.dataType = DATA_TYPE_SYNC; in AuthP2pOnKeyGenerated()
46 head.module = HICHAIN_SYNC; in AuthP2pOnKeyGenerated()
47 head.authId = authId; in AuthP2pOnKeyGenerated()
48 head.seq = authId; in AuthP2pOnKeyGenerated()
49 if (AuthPostData(&head, buf, bufSize) != SOFTBUS_OK) { in AuthP2pOnKeyGenerated()
/foundation/graphic/ui/frameworks/font/
Dui_font_cache.h50 void ListInit(ListHead* head) in ListInit() argument
52 head->prev = head; in ListInit()
53 head->next = head; in ListInit()
55 void ListAdd(ListHead* node, ListHead* head) in ListAdd() argument
57 head->next->prev = node; in ListAdd()
58 node->next = head->next; in ListAdd()
59 node->prev = head; in ListAdd()
60 head->next = node; in ListAdd()
/foundation/ace/ace_engine/frameworks/core/image/
Dimage_source_info.cpp58 std::string head = uri.substr(0, iter); in ResolveURIType() local
59 …std::transform(head.begin(), head.end(), head.begin(), [](unsigned char c) { return std::tolower(c… in ResolveURIType()
60 if (head == "http" || head == "https") { in ResolveURIType()
62 } else if (head == "file") { in ResolveURIType()
64 } else if (head == "internal") { in ResolveURIType()
66 } else if (head == "data") { in ResolveURIType()
72 } else if (head == "memory") { in ResolveURIType()
74 } else if (head == "resource") { in ResolveURIType()
76 } else if (head == "dataability") { in ResolveURIType()
/foundation/ace/ace_engine/frameworks/core/pipeline/base/
Dcomponent.cpp60 auto head = std::find_if(components.begin(), components.end(), IsRenderComponent<Component>); in MergeRSNode() local
62 if (head == components.end() || tail == components.rend()) { in MergeRSNode()
65 (*head)->isHeadComponent_ = true; in MergeRSNode()
75 auto head = std::find_if(components.begin(), components.end(), IsRenderComponent<SingleChild>); in MergeRSNode() local
77 if (head == components.end() || tail == components.rend()) { in MergeRSNode()
80 AceType::DynamicCast<Component>(*head)->isHeadComponent_ = true; in MergeRSNode()
86 auto head = std::find_if(components.begin(), components.end(), IsRenderComponent<SingleChild>); in MergeRSNode() local
88 if (components.empty() || head == components.end() || tail == components.rend()) { in MergeRSNode()
92 AceType::DynamicCast<Component>(*head)->isHeadComponent_ = true; in MergeRSNode()
100 void Component::MergeRSNode(const RefPtr<Component>& head, const RefPtr<Component>& tail) in MergeRSNode() argument
[all …]
/foundation/multimodalinput/input/frameworks/util/socket/src/
Duds_socket.cpp112 PackHead *head = reinterpret_cast<PackHead *>(buf); in OnReadPackets() local
113 CHKPB(head); in OnReadPackets()
114 if (head->size < 0 || head->size > MAX_PACKET_BUF_SIZE) { in OnReadPackets()
116 " head->size:%{public}d, unreadSize:%{public}d", head->size, unreadSize); in OnReadPackets()
120 if (head->size > dataSize) { in OnReadPackets()
123 NetPacket pkt(head->idMsg); in OnReadPackets()
124 if ((head->size > 0) && (!pkt.Write(&buf[headSize], head->size))) { in OnReadPackets()
126 "size:%{public}d", head->idMsg, head->size); in OnReadPackets()
/foundation/communication/dsoftbus/core/connection/br/src/
Dbr_trans_manager.c35 ConnPktHead *head = (ConnPktHead *)(conn->recvBuf); in ReceivedHeadCheck() local
36 if ((uint32_t)(head->magic) != MAGIC_NUMBER) { in ReceivedHeadCheck()
38 …ftBusLog(SOFTBUS_LOG_CONN, SOFTBUS_LOG_ERROR, "[ReceivedHeadCheck] magic error 0x%x", head->magic); in ReceivedHeadCheck()
42 if ((int32_t)(head->len) < 0 || in ReceivedHeadCheck()
43 conn->recvSize - pktHeadLen < (int32_t)(head->len)) { in ReceivedHeadCheck()
47 head->module, head->seq, head->len); in ReceivedHeadCheck()
59 ConnPktHead *head = (ConnPktHead *)(conn->recvBuf); in BrRecvDataParse() local
60 int32_t packLen = (int32_t)(head->len) + sizeof(ConnPktHead); in BrRecvDataParse()
215 ConnPktHead head; in BrPackRequestOrResponse() local
216 head.magic = MAGIC_NUMBER; in BrPackRequestOrResponse()
[all …]
/foundation/communication/dsoftbus/components/nstackx/fillp/src/public/include/
Dhlist.h30 struct HlistNode head; member
39 (ptr)->head.next = FILLP_NULL_PTR; \
40 (ptr)->head.pprev = &((ptr)->head.next); \
51 #define HLIST_FIRST(_list) ((_list)->head.next)
52 #define HLIST_TAIL(_list) (HLIST_EMPTY(_list) ? FILLP_NULL_PTR : HLIST_PREV(&(_list)->head))
74 list->head.pprev = &toBeAdded->next; in HlistAddAfter()
88 HlistAddAfter(list, HLIST_PREV(&list->head), node); in HlistAddTail()
94 HlistAddAfter(list, &list->head, node); in HlistAddHead()
101 list->head.pprev = n->pprev; in HlistDelete()
/foundation/communication/dsoftbus/tests/core/connection/tcp/
Dtcp_manager_test.cpp309 ConnPktHead head = {0}; variable
310 head.len = strlen(g_data);
319 char *data = (char *)SoftBusCalloc(sizeof(head) + head.len);
323 (void)memcpy_s(data, sizeof(head), (void*)&head, sizeof(head));
324 (void)memcpy_s(data + sizeof(head), (unsigned int)head.len, g_data, (unsigned int)head.len);
325 … EXPECT_EQ(SOFTBUS_OK, TcpPostBytes(g_connectionId, data, sizeof(ConnPktHead) + head.len, 0, 0));
327 EXPECT_EQ(int(sizeof(ConnPktHead) + head.len), g_receivedDatalength);
406 ConnPktHead head = {0}; variable
407 head.len = maxDataLen + 1;
409 char *data = (char *)SoftBusCalloc(sizeof(head) + head.len);
[all …]
/foundation/communication/dsoftbus/components/nstackx/fillp/src/public/src/
Dskiplist.c67 list->head = FILLP_NULL_PTR; in SkiplistInit()
95 list->head = FILLP_NULL_PTR; in SkiplistDestroy()
118 struct SkipListNode *head = FILLP_NULL_PTR; in SkipListPopValue() local
121 if ((list == FILLP_NULL_PTR) || (list->head == FILLP_NULL_PTR)) { in SkipListPopValue()
125 head = list->head; in SkipListPopValue()
127 for (index = head->level - 1; index >= 0; index--) { in SkipListPopValue()
128 list->hnode[index] = head->forward[index]; in SkipListPopValue()
139 list->head = head->forward[0]; in SkipListPopValue()
140 if (list->head == FILLP_NULL_PTR) { in SkipListPopValue()
145 return head->item; in SkipListPopValue()
[all …]
Dlf_ring.c77 ring->cons.head = 0; in FillpLfRingInit()
80 ring->prod.head = 0; in FillpLfRingInit()
106 *prodHead = ring->prod.head; in FillpLfRingMpEnqueueWait()
124 ring->prod.head = *prodNext; in FillpLfRingMpEnqueueWait()
127 } while (unlikely(!CAS(&ring->prod.head, *prodHead, *prodNext))); in FillpLfRingMpEnqueueWait()
190 *consHead = ring->cons.head; in FillpLfRingMcDequeueWait()
207 ring->cons.head = *consNext; in FillpLfRingMcDequeueWait()
210 } while (unlikely(!CAS(&ring->cons.head, *consHead, *consNext))); in FillpLfRingMcDequeueWait()
286 prodHead = r->prod.head; in FillpRingFreeEntries()
308 consHead = r->cons.head; in FillpRingValidOnes()
/foundation/communication/bluetooth/services/bluetooth_standard/stack/platform/src/
Dpacket.c34 Payload *head; member
74 packet->head = PayloadNew(headSize); in PacketMalloc()
78 if ((packet->head != NULL) && (packet->tail != NULL) && (packet->payload != NULL)) { in PacketMalloc()
79 packet->head->next = packet->payload; in PacketMalloc()
80 packet->payload->prev = packet->head; in PacketMalloc()
94 refPacket->head = PayloadNewRef(pkt->head->buf); in PacketRefMalloc()
97 if ((refPacket->head != NULL) && (refPacket->tail != NULL)) { in PacketRefMalloc()
99 Payload *refPayload = refPacket->head; in PacketRefMalloc()
114 refPacket->payload = refPacket->head->next; in PacketRefMalloc()
115 refPacket->payload->prev = refPacket->head; in PacketRefMalloc()
[all …]
/foundation/communication/dsoftbus/core/common/include/
Dsoftbus_queue.h49 volatile uint32_t head; /* producer head */ member
58 volatile uint32_t head; /* consumer head */ member
108 producerHead = queue->producer.head; in QueueSingleProducerEnqueue()
126 queue->producer.head = producerNext; in QueueSingleProducerEnqueue()
159 producerHead = queue->producer.head; in QueueMultiProducerEnqueue()
183 success = SoftBusAtomicCmpAndSwap32(&queue->producer.head, producerHead, producerNext); in QueueMultiProducerEnqueue()
221 consumerHead = queue->consumer.head; in QueueSingleConsumerDequeue()
242 queue->consumer.head = consumerNext; in QueueSingleConsumerDequeue()
276 consumerHead = queue->consumer.head; in QueueMultiConsumerDequeue()
302 success = SoftBusAtomicCmpAndSwap32(&queue->consumer.head, consumerHead, consumerNext); in QueueMultiConsumerDequeue()
/foundation/graphic/utils/interfaces/innerkits/
Dqueue.h49 volatile uint32_t head; /* producer head */ member
58 volatile uint32_t head; /* consumer head */ member
106 producerHead = queue->producer.head; in QueueSingleProducerEnqueue()
124 queue->producer.head = producerNext; in QueueSingleProducerEnqueue()
157 producerHead = queue->producer.head; in QueueMultiProducerEnqueue()
181 success = HalAtomicCmpAndSwap32(&queue->producer.head, producerHead, producerNext); in QueueMultiProducerEnqueue()
219 consumerHead = queue->consumer.head; in QueueSingleConsumerDequeue()
240 queue->consumer.head = consumerNext; in QueueSingleConsumerDequeue()
274 consumerHead = queue->consumer.head; in QueueMultiConsumerDequeue()
300 success = HalAtomicCmpAndSwap32(&queue->consumer.head, consumerHead, consumerNext); in QueueMultiConsumerDequeue()
/foundation/communication/dsoftbus/core/transmission/trans_channel/proxy/src/
Dsoftbus_proxychannel_session.c624 PacketHead *head = (PacketHead*)data; in TransProxyNoSubPacketProc() local
625 if ((uint32_t)head->magicNumber != MAGIC_NUMBER) { in TransProxyNoSubPacketProc()
626 … SoftBusLog(SOFTBUS_LOG_TRAN, SOFTBUS_LOG_ERROR, "invalid magicNumber %x", head->magicNumber); in TransProxyNoSubPacketProc()
629 if (head->dataLen <= 0) { in TransProxyNoSubPacketProc()
630 SoftBusLog(SOFTBUS_LOG_TRAN, SOFTBUS_LOG_ERROR, "invalid dataLen %d", head->dataLen); in TransProxyNoSubPacketProc()
633 …SoftBusLog(SOFTBUS_LOG_TRAN, SOFTBUS_LOG_INFO, "NoSubPacketProc dataLen[%d] inputLen[%d]", head->d… in TransProxyNoSubPacketProc()
634 if (head->dataLen + sizeof(PacketHead) != len) { in TransProxyNoSubPacketProc()
637 int32_t ret = TransProxyProcessSessionData(pkgName, channelId, head, data + sizeof(PacketHead)); in TransProxyNoSubPacketProc()
645 static int32_t TransProxyCheckSliceHead(const SliceHead *head) in TransProxyCheckSliceHead() argument
647 if (head == NULL) { in TransProxyCheckSliceHead()
[all …]
/foundation/distributeddatamgr/distributeddatamgr/services/distributeddataservice/app/src/session_manager/
Droute_head_handler_impl.cpp131 RouteHead *head = reinterpret_cast<RouteHead *>(ptr); in PackDataHead() local
132 head->magic = HostToNet(RouteHead::MAGIC_NUMBER); in PackDataHead()
133 head->version = HostToNet(RouteHead::VERSION); in PackDataHead()
134 head->checkSum = HostToNet(uint64_t(0)); in PackDataHead()
135 head->dataLen = HostToNet(uint32_t(totalLen - sizeof(RouteHead))); in PackDataHead()
208 RouteHead head = { 0 }; in UnPackData() local
209 bool result = UnPackDataHead(data, totalLen, head); in UnPackData()
210 if (result && head.version == RouteHead::VERSION) { in UnPackData()
213 unpackedSize = sizeof(RouteHead) + head.dataLen; in UnPackData()
226 const RouteHead *head = reinterpret_cast<const RouteHead *>(data); in UnPackDataHead() local
[all …]
/foundation/communication/wifi/services/wifi_standard/wifi_hal/
Dwifi_hal_crpc_server.c361 WifiHalEventCallbackMsg *head = g_wifiHalEventCallback->cbmsgs + i; in ReleaseCallbackMsg() local
362 WifiHalEventCallbackMsg *p = head->next; in ReleaseCallbackMsg()
363 while (p != head) { in ReleaseCallbackMsg()
382 WifiHalEventCallbackMsg *head = g_wifiHalEventCallback->cbmsgs + pos; in PushBackCallbackMsg() local
383 if (head->next == head) { /* Empty Queue */ in PushBackCallbackMsg()
384 msg->pre = head; in PushBackCallbackMsg()
385 head->next = msg; in PushBackCallbackMsg()
386 msg->next = head; in PushBackCallbackMsg()
387 head->pre = msg; in PushBackCallbackMsg()
389 msg->pre = head->pre; in PushBackCallbackMsg()
[all …]
/foundation/graphic/standard/rosen/modules/render_service_base/src/common/
Drs_common_def.cpp69 BlockHead* head = reinterpret_cast<BlockHead*>(mem); in Alloc() local
70 head->size = static_cast<int>(size); in Alloc()
71 return head->ptr; in Alloc()
81 BlockHead* head = reinterpret_cast<BlockHead*>(p); in Free() local
82 auto itr = memCaches_.find(head->size); in Free()
/foundation/multimedia/image_standard/plugins/common/libs/image/formatagentplugin/src/
Dwebp_format_agent.cpp56 const char *head = static_cast<const char *>(headerData); in CheckFormat() local
57 …return dataSize >= WEBP_MINIMUM_LENGTH && !memcmp(head, WEBP_HEADER_PRE, WEBP_HEADER_PRE_LENGTH) && in CheckFormat()
58 !memcmp(&head[8], WEBP_HEADER_POST, WEBP_HEADER_POST_LENGTH); in CheckFormat()
/foundation/distributedschedule/dmsfwk_lite/source/
Ddmslite_parser.c177 TlvNode *head = MallocTlvNode(); in TlvBytesToNode() local
178 if (head == NULL) { in TlvBytesToNode()
181 TlvNode *curNode = head; in TlvBytesToNode()
221 TlvFreeNodeList(head); in TlvBytesToNode()
222 head = NULL; in TlvBytesToNode()
224 *tlv = head; in TlvBytesToNode()
229 static int32_t Parse(const uint8_t *payload, uint16_t length, TlvNode **head) in Parse() argument
238 *head = tlvHead; in Parse()
/foundation/communication/dsoftbus/components/nstackx/nstackx_core/dfile/core/
Dnstackx_dfile_send.c34 static int32_t AllocIovList(List *head) in AllocIovList() argument
44 ListInsertTail(head, &ptr[i].entry); in AllocIovList()
68 void DestroyIovList(const List *head, DFileSession *s, uint32_t tid) in DestroyIovList() argument
76 LIST_FOR_EACH_SAFE(p, n, head) { in DestroyIovList()
124 static int32_t SendFileDataFrame(DFileSession *session, PeerInfo *peerInfo, List *head, uint32_t ti… in SendFileDataFrame() argument
138 LIST_FOR_EACH_SAFE(p, n, head) { in SendFileDataFrame()
163 DestroyIovList(head, session, tid); in SendFileDataFrame()
168 static int32_t SendFileDataFrameEx(DFileSession *session, PeerInfo *peerInfo, List *head, uint32_t … in SendFileDataFrameEx() argument
170 return SendFileDataFrame(session, peerInfo, head, tid); in SendFileDataFrameEx()
173 static int32_t CheckUnsentList(List *unsent, List *head, int32_t maxCount) in CheckUnsentList() argument
[all …]
/foundation/ace/ace_engine_lite/frameworks/module_manager/
Dmodule_manager.cpp227 void ModuleManager::InsertCallback(CallbackNode *&head, NativeCallback callback, in InsertCallback() argument
246 if (head == nullptr) { in InsertCallback()
247 head = node; in InsertCallback()
249 node->next = head; in InsertCallback()
250 head = node; in InsertCallback()
254 void ModuleManager::InvokeCallbacks(CallbackNode *&head) const in InvokeCallbacks()
256 CallbackNode *node = head; in InvokeCallbacks()
267 head = node->next; in InvokeCallbacks()
269 node = head; in InvokeCallbacks()
271 head = nullptr; in InvokeCallbacks()

12345