| /foundation/communication/dsoftbus/core/transmission/common/src/ |
| H A D | trans_pending_pkt.c | 136 SoftBusList *pendingList = g_pendingList[type]; in AddPendingPacket() local
137 TRANS_CHECK_AND_RETURN_RET_LOGE(pendingList != NULL, SOFTBUS_TRANS_TDC_PENDINGLIST_NOT_FOUND, TRANS_SVC, in AddPendingPacket()
140 ret = SoftBusMutexLock(&pendingList->lock); in AddPendingPacket()
143 LIST_FOR_EACH_ENTRY(item, &pendingList->list, PendingPktInfo, node) { in AddPendingPacket()
146 (void)SoftBusMutexUnlock(&pendingList->lock); in AddPendingPacket()
153 (void)SoftBusMutexUnlock(&pendingList->lock); in AddPendingPacket()
156 ListAdd(&pendingList->list, &item->node); in AddPendingPacket()
158 pendingList->cnt++; in AddPendingPacket()
159 (void)SoftBusMutexUnlock(&pendingList->lock); in AddPendingPacket()
171 SoftBusList *pendingList in GetPendingPacket() local
200 SoftBusList *pendingList = g_pendingList[type]; DelPendingPacketbyChannelId() local
230 SoftBusList *pendingList = g_pendingList[type]; ProcPendingPacket() local
265 SoftBusList *pendingList = g_pendingList[type]; SetPendingPacket() local
295 SoftBusList *pendingList = g_pendingList[type]; DelPendingPacket() local
[all...] |
| /foundation/communication/bluetooth_service/services/bluetooth/stack/src/l2cap/ |
| H A D | l2cap_cmn.h | 178 List *pendingList, uint16_t lcid, const L2capSignalHeader *signal, uint64_t timeo, AlarmCallback timerExpired);
179 void L2capDestroyPendingRequest(List *pendingList, uint8_t identifier);
180 L2capPendingRequest *L2capGetPendingRequest(List *pendingList, uint8_t identifier);
181 L2capPendingRequest *L2capGetPendingRequest2(List *pendingList, const void *request);
182 void L2capClearPendingRequest(List *pendingList);
|
| H A D | l2cap_cmn.c | 513 List *pendingList, uint16_t lcid, const L2capSignalHeader *signal, uint64_t timeo, AlarmCallback timerExpired) in L2capCreatePendingRequest()
529 ListAddLast(pendingList, req); in L2capCreatePendingRequest()
533 void L2capDestroyPendingRequest(List *pendingList, uint8_t identifier) in L2capDestroyPendingRequest() argument
537 req = L2capGetPendingRequest(pendingList, identifier); in L2capDestroyPendingRequest()
539 ListRemoveNode(pendingList, req); in L2capDestroyPendingRequest()
548 L2capPendingRequest *L2capGetPendingRequest(List *pendingList, uint8_t identifier) in L2capGetPendingRequest() argument
553 node = ListGetFirstNode(pendingList); in L2capGetPendingRequest()
566 L2capPendingRequest *L2capGetPendingRequest2(List *pendingList, const void *request) in L2capGetPendingRequest2() argument
571 node = ListGetFirstNode(pendingList); in L2capGetPendingRequest2()
584 void L2capClearPendingRequest(List *pendingList) in L2capClearPendingRequest() argument
512 L2capCreatePendingRequest( List *pendingList, uint16_t lcid, const L2capSignalHeader *signal, uint64_t timeo, AlarmCallback timerExpired) L2capCreatePendingRequest() argument
[all...] |
| H A D | l2cap_inst.c | 402 conn->pendingList = ListCreate(NULL); in L2capNewConnection()
432 if (conn->pendingList != NULL) { in L2capDeleteConnection()
433 L2capClearPendingRequest(conn->pendingList); in L2capDeleteConnection()
434 ListDelete(conn->pendingList); in L2capDeleteConnection()
|
| H A D | l2cap_core.c | 71 req = L2capGetPendingRequest2(conn->pendingList, parameter); in L2capResponseTimeout()
73 ListRemoveNode(conn->pendingList, req); in L2capResponseTimeout()
118 L2capCreatePendingRequest(conn->pendingList, 0, &signal, L2CAP_DEFAULT_RTX, L2capResponseTimeoutCallback); in L2capSendEchoReq()
153 L2capCreatePendingRequest(conn->pendingList, chan->lcid, &signal, L2CAP_DEFAULT_RTX, L2capResponseTimeoutCallback); in L2capSendConnectionReq()
226 L2capCreatePendingRequest(conn->pendingList, chan->lcid, &signal, L2CAP_DEFAULT_RTX, L2capResponseTimeoutCallback); in L2capSendConfigurationReq()
344 L2capCreatePendingRequest(conn->pendingList, chan->lcid, &signal, L2CAP_DEFAULT_RTX, L2capResponseTimeoutCallback); in L2capSendDisconnectionReq()
381 L2capCreatePendingRequest(conn->pendingList, 0, &signal, L2CAP_DEFAULT_RTX, L2capResponseTimeoutCallback); in L2capSendInformationReq()
1502 L2capCreatePendingRequest(conn->pendingList, chan->lcid, &signal, L2CAP_DEFAULT_RTX, L2capResponseTimeoutCallback); in L2capConfigurationReqContinuation()
1523 L2capDestroyPendingRequest(conn->pendingList, signal->identifier); in L2capProcessConfigurationRsp()
1558 conn->pendingList, cha in L2capProcessConfigurationRsp()
[all...] |
| H A D | l2cap_le.c | 66 List *pendingList; // Pack struct L2capPendingRequest member
333 conn->pendingList = ListCreate(NULL); in L2capLeNewConnection()
360 if (conn->pendingList != NULL) { in L2capLeDeleteConnection()
361 L2capClearPendingRequest(conn->pendingList); in L2capLeDeleteConnection()
362 ListDelete(conn->pendingList); in L2capLeDeleteConnection()
404 lereq = L2capGetPendingRequest2(conn->pendingList, parameter); in L2capLeResponseTimeout()
406 ListRemoveNode(conn->pendingList, lereq); in L2capLeResponseTimeout()
466 conn->pendingList, chan->lcid, &signal, L2CAP_DEFAULT_RTX, L2capLeResponseTimeoutCallback); in L2capSendCreditBasedConnectionReq()
506 conn->pendingList, chan->lcid, &signal, L2CAP_DEFAULT_RTX, L2capLeResponseTimeoutCallback); in L2capLeSendDisconnectionReq()
683 L2capDestroyPendingRequest(conn->pendingList, signa in L2capLeProcessConnectionParameterUpdateRsp()
[all...] |
| H A D | l2cap_inst.h | 159 List *pendingList; // Pack struct L2capPendingRequest member
|
| /foundation/communication/dsoftbus/core/transmission/trans_channel/common/src/ |
| H A D | trans_lane_pending_ctl.c | 214 SoftBusList *pendingList = isAsync ? g_asyncReqLanePendingList : g_reqLanePendingList; in TransDelLaneReqFromPendingList() local
215 if (pendingList == NULL) { in TransDelLaneReqFromPendingList()
219 if (SoftBusMutexLock(&(pendingList->lock)) != SOFTBUS_OK) { in TransDelLaneReqFromPendingList()
226 LIST_FOR_EACH_ENTRY_SAFE(laneItem, next, &(pendingList->list), TransReqLaneItem, node) { in TransDelLaneReqFromPendingList()
233 pendingList->cnt--; in TransDelLaneReqFromPendingList()
238 (void)SoftBusMutexUnlock(&(pendingList->lock)); in TransDelLaneReqFromPendingList()
242 (void)SoftBusMutexUnlock(&(pendingList->lock)); in TransDelLaneReqFromPendingList()
490 SoftBusList *pendingList = isAsync ? g_asyncReqLanePendingList : g_reqLanePendingList; in TransUpdateLaneConnInfoByLaneHandle() local
491 if (pendingList == NULL) { in TransUpdateLaneConnInfoByLaneHandle()
495 if (SoftBusMutexLock(&(pendingList in TransUpdateLaneConnInfoByLaneHandle()
1551 SoftBusList *pendingList = isAsync ? g_asyncReqLanePendingList : g_reqLanePendingList; TransCancelLaneItemCondByLaneHandle() local
1837 SoftBusList *pendingList = g_freeLanePendingList; TransDelLaneFreeFromPending() local
[all...] |
| /foundation/communication/dsoftbus/core/bus_center/lnn/net_builder/include/ |
| H A D | lnn_net_builder.h | 91 ListNode pendingList; member
|
| /foundation/communication/dsoftbus/core/bus_center/lnn/net_builder/src/ |
| H A D | lnn_net_builder_init.c | 205 LIST_FOR_EACH_ENTRY_SAFE(item, next, &LnnGetNetBuilder()->pendingList, PendingJoinRequestNode, node) { in TryRemovePendingJoinRequest()
706 ListInit(&LnnGetNetBuilder()->pendingList); in InitNetBuilderLooper()
|
| H A D | lnn_net_builder.c | 315 LIST_FOR_EACH_ENTRY(item, &g_netBuilder.pendingList, PendingJoinRequestNode, node) { in IsSamePendingRequest()
347 ListTailInsert(&g_netBuilder.pendingList, &request->node); in TryPendingJoinRequest()
360 LIST_FOR_EACH_ENTRY_SAFE(item, next, &g_netBuilder.pendingList, PendingJoinRequestNode, node) { in RemovePendingRequestByAddrType()
|
| /foundation/communication/dsoftbus/tests/core/bus_center/lnn/net_builder/src/ |
| H A D | lnn_net_builder_mock_test.cpp | 1850 ListAdd(&g_netBuilder.pendingList, &request->node); in HWTEST_F()
|