Home
last modified time | relevance | path

Searched refs:pktNum (Results 1 – 17 of 17) sorted by relevance

/ohos5.0/foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/src/fillp/
H A Dfillp_common.c53 if (item->pktNum == pktNum) { in FillpDelPktSeqHashItem()
55 } else if (FillpNumIsbigger(item->pktNum, pktNum)) { in FillpDelPktSeqHashItem()
595 if ((pcb->recv.pktNum + 1) != item->pktNum) { in FillBiggerItem()
606 FillpAddNodeAtDelayNackListTail(pcb, pcb->recv.pktNum, item->pktNum); in FillBiggerItem()
609 FillpSendNack(pcb, pcb->recv.pktNum, item->pktNum); in FillBiggerItem()
611 FILLP_GET_SOCKET(pcb)->index, item->seqNum, item->pktNum, pcb->recv.pktNum, in FillBiggerItem()
612 item->pktNum - pcb->recv.pktNum, item->dataLen); in FillBiggerItem()
616 pcb->recv.pktNum = item->pktNum; in FillBiggerItem()
631 if (FillpNumIsbigger(item->pktNum, pcb->recv.pktNum)) { in FillpDataToStack()
776 pktHead->pktNum = pcb->recv.pktNum; in FillpBuildAndSendPack()
[all …]
H A Dfillp_input.c196 item->pktNum = pktHdr->pktNum; in FillpDataInput()
289 FillpSendNack(pcb, (FILLP_UINT32)(item->pktNum - 1), (FILLP_UINT32)(item->pktNum + 1)); in FillpHdlDataInput()
343 tmpHead->pktNum = FILLP_HTONL(pktHdr->pktNum); in FillpNackInputTrace()
365 if (item->pktNum == pktNum) { in FillpGetSeqFromPktSeqHash()
368 } else if (FillpNumIsbigger(item->pktNum, pktNum)) { in FillpGetSeqFromPktSeqHash()
452 seqPktNum.beginPktNum = pktHdr->pktNum; in FillpNackInput()
530 tmpHead->pktNum = FILLP_HTONL(pktHdr->pktNum); in FillpPackInputSendMsgTrace()
575 if (FillpNumIsbigger(pktHdr->pktNum, pcb->send.pktNum)) { in FillpCheckPackNumber()
576 FILLP_LOGDBG("error: ack pktnum =%u sendpktnum = %u", pktHdr->pktNum, pcb->send.pktNum); in FillpCheckPackNumber()
893 tmpHead.pktNum = head->pktNum; in FillpDoInput()
[all …]
H A Dfillp_timer.c58 FILLP_UINT32 pktData = pcb->recv.pktNum - appFcStastics->pktNum; in FillpCalFcAppStastics()
67 FILLP_GET_SOCKET(pcb)->index, pcb->recv.pktNum, appFcStastics->pktNum, in FillpCalFcAppStastics()
94 appFcStastics->pktNum = pcb->recv.pktNum; in FillpCalFcAppStastics()
107 FILLP_UINT32 pktData = pcb->recv.pktNum - packStastics->packPktNum; in FillpCalRecvRate()
143 packStastics->packPktNum = pcb->recv.pktNum; in FillpCalRecvRate()
H A Dfillp_conn.c49 tmpHead1->pktNum = FILLP_HTONL(pktHdr->pktNum); in FillpConnReqInputTrace()
418 tmpHead->pktNum = FILLP_HTONL(pktHdr->pktNum); in FillpConnReqAckTrace()
715 tempHdr->pktNum = FILLP_HTONL(pktHdr->pktNum); in FillpConnConfirmTrace()
1015 tmpHeader->pktNum = FILLP_HTONL(pktHdr->pktNum); in FillpConnConfirmAckTrace()
1033 pcb->recv.pktNum = tmpHeader->pktNum; in FillpSaveConfirmActToPcb()
1039 pcb->statistics.appFcStastics.pktNum = pcb->recv.pktNum; in FillpSaveConfirmActToPcb()
1166 tmpHead->pktNum = FILLP_HTONL(pktHdr->pktNum); in FillpFinInputTrace()
1369 pktHdr->pktNum = FILLP_HTONL(pktHdr->pktNum); in FillpSendConnReqBuild()
1444 pktHdr->pktNum = 0; in FillpSendConnReqAckBuild()
1553 pktHdr->pktNum = 0; in ConnConfirmBuild()
[all …]
H A Dfillp_output.c113 FILLP_GET_SOCKET(pcb)->index, item->pktNum, item->seqNum, item->sendCount, in FillpDoneSendAllData()
249 item->pktNum = ++sendPcb->pktNum; in FillpBuildDataPkt()
265 pktHdr->pktNum = FILLP_HTONL(item->pktNum); in FillpBuildDataPkt()
272 pcb->send.pktNum); in FillpBuildDataPkt()
346 … struct Hlist *list = &pcb->send.pktSeqMap.hashMap[item->pktNum & pcb->send.pktSeqMap.hashModSize]; in FillpAddToPktSeqHash()
427 sendPcb->pktNum--; in FillpSendItem()
H A Dfillp_mgt_msg_log.c34 …FILLP_PKT_GET_FLAG((_hdr)->flag), (_hdr)->dataLen, (_hdr)->seqNum, (_hdr)->pktNum, ##__VA_ARGS__);…
62 out->pktNum = FILLP_NTOHL(in->pktNum); in FillpHeaderNtoH()
H A Dfillp_flow_control.c144 if (FillpNumIsbigger(item->pktNum, endPktNum)) { in FillpAppLimitedStatus()
148 if ((!FillpNumIsbigger(beginPktNum, item->pktNum)) && in FillpAppLimitedStatus()
333 … FILLP_GET_SOCKET(pcb)->index, pcb->pcbInst->curTime, pcb->recv.seqNum, pcb->recv.pktNum); in FillpFcDataInput()
H A Dfillp_pcb.c51 if (value1->pktNum == value2->pktNum) { in FillpSkiplistRecvcmp()
433 pcb->appFcStastics.pktNum = 0; in FillpInitStastics()
H A Dfillp_frame.c197 …LP_LOGERR("invalid frame info len %u, seqNum: %u, pktNum: %u", optLen, item->seqNum, item->pktNum); in FillpFrameParseOption()
/ohos5.0/foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/include/fillp/
H A Dfillp_pcb.h85 FILLP_UINT32 pktNum; /* the newest pkt num received */ member
140 FILLP_UINT32 pktNum; member
H A Dfillp.h95 FILLP_UINT32 pktNum; member
149 FILLP_UINT32 pktNum; member
/ohos5.0/foundation/communication/dsoftbus/tests/sdk/transmission/trans_channel/qos/
H A Dtrans_qos_stat_server_test.cpp77 printf("pktNum:%u\n", tvList->info.appStatistics.pktNum); in OnQosEvent()
/ohos5.0/foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/src/
H A Dspunge_core.c77 FILLP_UINT32 pktNum = sock->resConf.udp.txBurst; in SpungeCalExpectedBytes() local
80 pktNum = (FILLP_UINT32)(detaTime / flowControl->sendInterval); in SpungeCalExpectedBytes()
83 if (pktNum <= (sock->resConf.udp.txBurst)) { in SpungeCalExpectedBytes()
91 pktNum = sock->resConf.udp.txBurst; in SpungeCalExpectedBytes()
92 bytesExpected = (FILLP_UINT32)(pktNum * pcb->fpcb.pktSize); in SpungeCalExpectedBytes()
95 *sendPktNum = pktNum; in SpungeCalExpectedBytes()
/ohos5.0/foundation/communication/dsoftbus/interfaces/kits/transport/
H A Dsession.h227 uint32_t pktNum; /**< Number of packets */ member
/ohos5.0/foundation/communication/dsoftbus/components/nstackx/fillp/src/public/src/
H A Dspunge_message.c526 …, SYS_ARCH_GET_CUR_TIME_LONGLONG(), netconn->pcb->fpcb.send.seqNum, netconn->pcb->fpcb.send.pktNum, in SpungeHandleMsgConnAccepted()
527 … netconn->pcb->fpcb.recv.seqNum, netconn->pcb->fpcb.recv.pktNum, sock->resConf.flowControl.maxRate, in SpungeHandleMsgConnAccepted()
/ohos5.0/foundation/communication/dsoftbus/components/nstackx/fillp/include/
H A Dfillpinc.h1229 FILLP_UINT32 pktNum; member
/ohos5.0/foundation/communication/dsoftbus/sdk/transmission/trans_channel/udp/stream/libsoftbus_stream/
H A Dvtp_stream_socket.cpp382 metricList.info.appStatistics.pktNum = fillpPcbStats.appFcStastics.pktNum; in FillpAppStatistics()