Home
last modified time | relevance | path

Searched refs:itemWaitTokenLists (Results 1 – 9 of 9) sorted by relevance

/ohos5.0/foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/src/fillp/
H A Dfillp_pcb.c146 ret = SkiplistInit(&pcb->itemWaitTokenLists, FillpSkiplistCmp); in InitSendPcbSimplePar()
157 SkiplistDestroy(&pcb->itemWaitTokenLists); in InitSendPcbSimplePar()
166 SkiplistDestroy(&pcb->itemWaitTokenLists); in InitSendPcbSimplePar()
173 SkiplistDestroy(&pcb->itemWaitTokenLists); in InitSendPcbSimplePar()
198 SkiplistDestroy(&pcb->itemWaitTokenLists); in InitSimplePcbPar()
238 SkiplistDestroy(&pcb->itemWaitTokenLists); in InitItemPool()
283 SkiplistDestroy(&pcb->itemWaitTokenLists); in FillpInitSendpcb()
557 loopCount = pcb->itemWaitTokenLists.nodeNum; in FillpPcbFreeSendItemArray()
559 item = SkipListPopValue(&pcb->itemWaitTokenLists); in FillpPcbFreeSendItemArray()
609 SkiplistDestroy(&pcb->itemWaitTokenLists); in FillpPcbRemoveSend()
H A Dfillp_common.c187 node = SkipListGetPop(&pcb->send.itemWaitTokenLists); in FillpAckItemWaitTklist()
196 (void)SkipListPopValue(&pcb->send.itemWaitTokenLists); in FillpAckItemWaitTklist()
203 node = SkipListGetPop(&pcb->send.itemWaitTokenLists); in FillpAckItemWaitTklist()
354 pcb->send.itemWaitTokenLists.nodeNum + pcb->send.redunList.nodeNum; in FillpAckSendPcb()
H A Dfillp_flow_control.c204 … pcb->send.unrecvList.nodeNum + pcb->send.itemWaitTokenLists.nodeNum + pcb->send.redunList.nodeNum; in FillpFcTailProtected()
H A Dfillp_input.c570 … pcb->send.itemWaitTokenLists.nodeNum, pcb->send.redunList.nodeNum, pcb->send.curItemCount, in FillpCheckPackNumber()
737 pcb->send.itemWaitTokenLists.nodeNum); in FillpPackInputLog()
H A Dfillp_output.c115 pcb->send.redunList.nodeNum, pcb->send.itemWaitTokenLists.nodeNum, in FillpDoneSendAllData()
/ohos5.0/foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/include/fillp/
H A Dfillp_pcb.h131 struct SkipList itemWaitTokenLists; member
241 … pcb->send.redunList.nodeNum + pcb->send.unackList.count + pcb->send.itemWaitTokenLists.nodeNum); in FillpPcbGetTotalPktCnt()
/ohos5.0/foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/src/
H A Dspunge_core.c1326 …if ((stb->rate == 0) && (fpcb->send.itemWaitTokenLists.nodeNum == 0)) { /* no limit or limit -> no… in SpungeItemRouteByToken()
1328 …} else if ((stb->tokenCount >= (FILLP_UINT32)item->dataLen) && (fpcb->send.itemWaitTokenLists.node… in SpungeItemRouteByToken()
1334 …if (SkipListInsert(&fpcb->send.itemWaitTokenLists, (void *)item, &item->skipListNode, FILLP_TRUE) … in SpungeItemRouteByToken()
1360 item = (struct FillpPcbItem *)SkipListPopValue(&(fpcb->send.itemWaitTokenLists)); in SpungeClearItemWaitTokenList()
1374 item = (struct FillpPcbItem *)SkipListPopValue(&(fpcb->send.itemWaitTokenLists)); in SpungeClearItemWaitTokenList()
1416 node = SkipListGetPop(&(fpcb->send.itemWaitTokenLists)); in SpungeCheckItemWaitTokenList()
1429 (void)SkipListPopValue(&fpcb->send.itemWaitTokenLists); in SpungeCheckItemWaitTokenList()
1510 stb->waitPktCount -= (FILLP_ULLONG)fpcb->send.itemWaitTokenLists.nodeNum; in SpungeTokenBucketDelFpcb()
H A Dspunge_stack.c428 sendPcb->itemWaitTokenLists.nodeNum || sendPcb->redunList.nodeNum)) { in SpungeCheckDisconn()
/ohos5.0/foundation/communication/dsoftbus/components/nstackx/fillp/src/app_lib/src/
H A Dsocket_opt.c45 sendPcb->itemWaitTokenLists.nodeNum); in SockGetOptSendCache()