Home
last modified time | relevance | path

Searched refs:unrecvList (Results 1 – 10 of 10) sorted by relevance

/ohos5.0/foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/src/fillp/
H A Dfillp_pcb.c69 SkiplistDestroy(&pcb->unrecvList); in FillpInitSendpcbUnackList()
107 SkiplistDestroy(&pcb->unrecvList); in FillpInitSendpcbPktSeqMap()
140 ret = SkiplistInit(&pcb->unrecvList, FillpSkiplistCmp); in InitSendPcbSimplePar()
149 SkiplistDestroy(&pcb->unrecvList); in InitSendPcbSimplePar()
156 SkiplistDestroy(&pcb->unrecvList); in InitSendPcbSimplePar()
196 SkiplistDestroy(&pcb->unrecvList); in InitSimplePcbPar()
236 SkiplistDestroy(&pcb->unrecvList); in InitItemPool()
281 SkiplistDestroy(&pcb->unrecvList); in FillpInitSendpcb()
583 loopCount = pcb->unrecvList.nodeNum; in FillpPcbFreeSendItemArray()
585 item = SkipListPopValue(&pcb->unrecvList); in FillpPcbFreeSendItemArray()
[all …]
H A Dfillp_output.c36 if (SkipListInsert(&sendPcb->unrecvList, item, &item->skipListNode, FILLP_TRUE) != ERR_OK) { in FillpMoveRedundantItemToUnrecvList()
54 struct FillpPcbItem *item = (struct FillpPcbItem *)SkipListPopValue(&sendPcb->unrecvList); in FillpGetSendItem()
114 pcb->send.unSendList.size, pcb->send.unackList.count, pcb->send.unrecvList.nodeNum, in FillpDoneSendAllData()
330 … if (SkipListInsert(&pcb->send.unrecvList, item, &item->skipListNode, FILLP_TRUE) != ERR_OK) { in FillpAddToUnackList()
415 …if (SkipListInsert(&sendPcb->unrecvList, (void *)item, &item->skipListNode, FILLP_TRUE) != ERR_OK)… in FillpSendItem()
H A Dfillp_common.c104 if (SkipListInsert(&pcb->send.unrecvList, (void *)item, &item->skipListNode, FILLP_TRUE) != in FillpMoveOneNode()
165 if (pcb->send.unrecvList.nodeNum > 0) { in FillpMoveUnackToUnrecvAll()
219 node = SkipListGetPop(&pcb->send.unrecvList); in FillpAckUnrecvList()
226 (void)SkipListPopValue(&pcb->send.unrecvList); in FillpAckUnrecvList()
237 node = SkipListGetPop(&pcb->send.unrecvList); in FillpAckUnrecvList()
353 pktSendCnt = pcb->send.unackList.count + pcb->send.unrecvList.nodeNum + in FillpAckSendPcb()
H A Dfillp_input.c413 … if (SkipListInsert(&pcb->send.unrecvList, unackItem, &unackItem->skipListNode, FILLP_TRUE)) { in ProtectLongLoopRun()
462 (seqPktNum.beginPktNum + 1), pcb->send.unrecvList.nodeNum, pcb->send.unackList.count); in FillpNackInput()
480 if (pcb->send.unrecvList.nodeNum) { in FillpNackInput()
569 pcb->send.unSendList.size, pcb->send.unrecvList.nodeNum, pcb->send.unackList.count, in FillpCheckPackNumber()
736 FILLP_GET_SOCKET(pcb)->index, pcb->send.unackList.count, pcb->send.unrecvList.nodeNum, in FillpPackInputLog()
H A Dfillp_flow_control.c204 … pcb->send.unrecvList.nodeNum + pcb->send.itemWaitTokenLists.nodeNum + pcb->send.redunList.nodeNum; in FillpFcTailProtected()
/ohos5.0/foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/include/fillp/
H A Dfillp_pcb.h126 struct SkipList unrecvList; member
240 return (pcb->send.unSendList.size + pcb->send.unrecvList.nodeNum + in FillpPcbGetTotalPktCnt()
/ohos5.0/foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/src/
H A Dspunge_core.c97 sock->index, pcb->fpcb.send.unrecvList.nodeNum, pcb->fpcb.send.unackList.count); in SpungeCalExpectedBytes()
156 (pcb->fpcb.send.redunList.nodeNum) || (pcb->fpcb.send.unrecvList.nodeNum)) { in SpungeDoSendCycle()
1365 …if (SkipListInsert(&fpcb->send.unrecvList, (void *)item, &item->skipListNode, FILLP_TRUE) != ERR_O… in SpungeClearItemWaitTokenList()
1377 if (fpcb->send.unrecvList.nodeNum != 0) { in SpungeClearItemWaitTokenList()
H A Dspunge_stack.c427 sendPcb->unrecvList.nodeNum || !HLIST_EMPTY(&sendPcb->unSendList) || in SpungeCheckDisconn()
/ohos5.0/foundation/communication/dsoftbus/components/nstackx/fillp/src/app_lib/src/
H A Dsocket_opt.c44 sendPcb->unackList.count + sendPcb->redunList.nodeNum + sendPcb->unrecvList.nodeNum + in SockGetOptSendCache()
H A Dfillp_dfx.c549 …sendPcb->unrecvList.nodeNum, localAddr, FILLP_NTOHS(local->sin_port), peerAddr, FILLP_NTOHS(peer->… in DoShowSockList()