Home
last modified time | relevance | path

Searched refs:endPktNum (Results 1 - 8 of 8) sorted by relevance

/foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/src/fillp/
H A Dfillp_common.c469 void FillpSendNack(struct FillpPcb *pcb, FILLP_UINT32 startPktNum, FILLP_UINT32 endPktNum) in FillpSendNack() argument
472 FILLP_UINT32 pktNum = endPktNum; in FillpSendNack()
473 FILLP_UINT32 lostPktNum = (endPktNum - startPktNum) - 1; in FillpSendNack()
512 static void FillpAddNodeAtDelayNackListTail(struct FillpPcb *pcb, FILLP_UINT32 startPktNum, FILLP_UINT32 endPktNum) in FillpAddNodeAtDelayNackListTail() argument
522 nackNode->endPktNum = endPktNum; in FillpAddNodeAtDelayNackListTail()
543 FILLP_UINT32 endPktNum = nackNode->endPktNum; in FillpCheckAndUpdateDelayNackList() local
545 if (FillpNumIsbigger(curRecvPktNum, endPktNum)) { in FillpCheckAndUpdateDelayNackList()
550 } else if (curRecvPktNum == endPktNum) { in FillpCheckAndUpdateDelayNackList()
[all...]
H A Dfillp_input.c327 (pcb->send.nackPktEndNum == seqPktNum->endPktNum)) { in FillpCheckNackSeq()
386 (FillpNumIsbigger(seqPktNum->endPktNum, pktIndex)) && (protectLoopCounter <= identifyGap); in ProtectLongLoopRun()
451 seqPktNum.endPktNum = FILLP_NTOHL(nack->lastPktNum); in FillpNackInput()
458 pcb->send.nackPktEndNum = seqPktNum.endPktNum; in FillpNackInput()
460 FILLP_LOGDBG("recv NACK sockId:%d,seqNum:%u,startPKTNum:%u,endPktNum:%u,gap:%u,unrecvList:%u,unackList:%u", in FillpNackInput()
461 FILLP_GET_SOCKET(pcb)->index, pktHdr->seqNum, pktHdr->pktNum, seqPktNum.endPktNum, seqPktNum.endPktNum - in FillpNackInput()
467 if (FillpNumIsbigger(seqPktNum.endPktNum, startLoop)) { in FillpNackInput()
468 identifyGap = (seqPktNum.endPktNum - startLoop); in FillpNackInput()
470 FILLP_LOGDTL("curPktNum(%u) is smaller than lastPktNum(%u)", seqPktNum.endPktNum, seqPktNu in FillpNackInput()
[all...]
H A Dfillp_flow_control.c124 FILLP_BOOL FillpAppLimitedStatus(struct FillpPcb *pcb, FILLP_UINT32 beginPktNum, FILLP_UINT32 endPktNum) in FillpAppLimitedStatus() argument
134 if (!FillpNumIsbigger(endPktNum, beginPktNum)) { in FillpAppLimitedStatus()
138 for (i = beginPktNum, j = 0; !FillpNumIsbigger(i, endPktNum) && j < mapList->count; i++, j++) { in FillpAppLimitedStatus()
144 if (FillpNumIsbigger(item->pktNum, endPktNum)) { in FillpAppLimitedStatus()
/foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/include/fillp/
H A Dfillp_flow_control.h69 FILLP_BOOL FillpAppLimitedStatus(struct FillpPcb *pcb, FILLP_UINT32 beginPktNum, FILLP_UINT32 endPktNum);
H A Dfillp_common.h53 void FillpSendNack(struct FillpPcb *pcb, FILLP_UINT32 startPktNum, FILLP_UINT32 endPktNum);
H A Dfillp.h206 FILLP_UINT32 endPktNum; /* use in appLimited */ member
242 FILLP_UINT32 endPktNum; member
H A Dfillp_pcb.h58 FILLP_UINT32 endPktNum; member
/foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/src/
H A Dspunge_core.c1212 FILLP_UINT32 endPktNum = nackNode->endPktNum; in FillpCheckPcbNackListToSend() local
1213 FillpSendNack(&(pcb->fpcb), startPktNum, endPktNum); in FillpCheckPcbNackListToSend()

Completed in 11 milliseconds