| /foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/src/fillp/ |
| H A D | fillp_common.c | 42 static void FillpDelPktSeqHashItem(FILLP_UINT32 pktNum, FILLP_CONST struct FillpHashLlist *mapList) in FillpDelPktSeqHashItem() argument
44 FILLP_UINT32 hashIndex = (FILLP_UINT32)(pktNum & mapList->hashModSize); in FillpDelPktSeqHashItem()
53 if (item->pktNum == pktNum) { in FillpDelPktSeqHashItem()
55 } else if (FillpNumIsbigger(item->pktNum, pktNum)) { in FillpDelPktSeqHashItem()
103 FillpDelPktSeqHashItem(item->pktNum, &pcb->send.pktSeqMap); in FillpMoveOneNode()
430 if ((pcb->recv.pktNum - pcb->recv.lastPackPktNum) >= ADHOC_PACK_TRIGGLE_THRESHOLD) { in FillpUploadRecvBox()
431 FILLP_LOGDBG("fillp_sock_id:%d pktNum=%u lastPackPktNum=%u, diff=%u size=%u sending PACK", in FillpUploadRecvBox()
432 FILLP_GET_SOCKET(pcb)->index, pcb->recv.pktNum, pc in FillpUploadRecvBox()
472 FILLP_UINT32 pktNum = endPktNum; FillpSendNack() local
[all...] |
| H A D | fillp_input.c | 196 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()
354 static FILLP_INT FillpGetSeqFromPktSeqHash(FILLP_UINT32 pktNum, FILLP_CONST struct FillpHashLlist *mapList, in FillpGetSeqFromPktSeqHash() argument
357 FILLP_UINT32 hashIndex = (FILLP_UINT32)(pktNum & mapList->hashModSize); in FillpGetSeqFromPktSeqHash()
365 if (item->pktNum == pktNum) { in FillpGetSeqFromPktSeqHash()
[all...] |
| H A D | fillp_timer.c | 58 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 D | fillp_conn.c | 49 tmpHead1->pktNum = FILLP_HTONL(pktHdr->pktNum); in FillpConnReqInputTrace()
418 tmpHead->pktNum = FILLP_HTONL(pktHdr->pktNum); in FillpConnReqAckTrace()
526 newConn->pcb->fpcb.send.pktNum = confirm->cookieContent.localPacketSeqNumber; in FillpInitNewPcbByConfirm()
536 newConn->pcb->fpcb.recv.pktNum = confirm->cookieContent.remotePacketSeqNumber; in FillpInitNewPcbByConfirm()
542 newConn->pcb->fpcb.statistics.appFcStastics.pktNum = confirm->cookieContent.remotePacketSeqNumber; in FillpInitNewPcbByConfirm()
715 tempHdr->pktNum = FILLP_HTONL(pktHdr->pktNum); in FillpConnConfirmTrace()
827 sock->index, SYS_ARCH_GET_CUR_TIME_LONGLONG(), pcb->send.seqNum, pcb->send.pktNum, pc in FillpHandleConnConfirmAckInput()
[all...] |
| H A D | fillp_output.c | 110 FILLP_LOGDBG("fillp_sock_id:%d, appLimited triggle, pktNum:%u, seqNum:%u, sc:%u, " in FillpDoneSendAllData()
113 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()
400 * calculate loss rate by pktNum at recv endpoint, in FillpSendItem()
401 * so pktNum shoul in FillpSendItem()
[all...] |
| H A D | fillp_flow_control.c | 144 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 D | fillp_mgt_msg_log.c | 34 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 D | fillp_pcb.c | 51 if (value1->pktNum == value2->pktNum) { in FillpSkiplistRecvcmp()
433 pcb->appFcStastics.pktNum = 0; in FillpInitStastics()
|
| H A D | fillp_frame.c | 197 FILLP_LOGERR("invalid frame info len %u, seqNum: %u, pktNum: %u", optLen, item->seqNum, item->pktNum); in FillpFrameParseOption()
|
| /foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/include/fillp/ |
| H A D | fillp_pcb.h | 85 FILLP_UINT32 pktNum; /* the newest pkt num received */ member
140 FILLP_UINT32 pktNum; member
|
| H A D | fillp.h | 95 FILLP_UINT32 pktNum; member
149 FILLP_UINT32 pktNum; member
|
| /foundation/communication/dsoftbus/tests/sdk/transmission/trans_channel/qos/ |
| H A D | trans_qos_stat_server_test.cpp | 78 printf("pktNum:%u\n", tvList->info.appStatistics.pktNum); in OnQosEvent()
|
| /foundation/communication/dsoftbus/interfaces/kits/transport/ |
| H A D | session.h | 227 uint32_t pktNum; /**< Number of packets */ member
|
| /foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/src/ |
| H A D | spunge_core.c | 77 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()
|
| /foundation/communication/dsoftbus/components/nstackx/fillp/src/public/src/ |
| H A D | spunge_message.c | 526 sock->index, 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()
|
| /foundation/communication/dsoftbus/components/nstackx/fillp/include/ |
| H A D | fillpinc.h | 1229 FILLP_UINT32 pktNum; member
|
| /foundation/communication/dsoftbus/sdk/transmission/trans_channel/udp/stream/libsoftbus_stream/ |
| H A D | vtp_stream_socket.cpp | 382 metricList.info.appStatistics.pktNum = fillpPcbStats.appFcStastics.pktNum; in FillpAppStatistics()
|