Home
last modified time | relevance | path

Searched refs:pcb (Results 1 - 25 of 32) sorted by relevance

12

/foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/src/fillp/
H A Dfillp_pcb.c31 #define FILLP_PCB_GET_CONN(pcb) (struct FtNetconn *)((struct SpungePcb *)((pcb)->spcb))->conn
58 static FILLP_INT FillpInitSendpcbUnackList(struct FillpSendPcb *pcb) in FillpInitSendpcbUnackList() argument
61 pcb->unackList.size = FILLP_UNACK_HASH_SIZE; in FillpInitSendpcbUnackList()
62 pcb->unackList.hashModSize = pcb->unackList.size - 1; in FillpInitSendpcbUnackList()
63 pcb->unackList.count = 0; in FillpInitSendpcbUnackList()
64 pcb->unackList.hashMap = in FillpInitSendpcbUnackList()
65 (struct Hlist *)SpungeAlloc(pcb->unackList.size, sizeof(struct Hlist), SPUNGE_ALLOC_TYPE_CALLOC); in FillpInitSendpcbUnackList()
66 if (pcb in FillpInitSendpcbUnackList()
79 FillpInitSendpcbPktSeqMap(struct FillpPcb *fpcb, struct FillpSendPcb *pcb) FillpInitSendpcbPktSeqMap() argument
119 FillpFreeRecvItemPool(struct FillpRecvPcb *pcb) FillpFreeRecvItemPool() argument
125 FillpFreeSendItemPool(struct FillpSendPcb *pcb) FillpFreeSendItemPool() argument
133 struct FillpSendPcb *pcb = &fpcb->send; InitSendPcbSimplePar() local
180 InitSimplePcbPar(struct FillpSendPcb *pcb, struct FillpPcb *fpcb) InitSimplePcbPar() argument
224 struct FillpSendPcb *pcb = &fpcb->send; InitItemPool() local
255 struct FillpSendPcb *pcb = &fpcb->send; FillpInitSendpcb() local
293 FillpInitRecvPcbBox(struct FillpPcb *fpcb, struct FillpRecvPcb *pcb) FillpInitRecvPcbBox() argument
322 struct FillpRecvPcb *pcb = &fpcb->recv; FillpInitRecvpcb() local
365 InitSimpleStatics(const struct FillpPcb *fpcb, struct FillpStatisticsPcb *pcb) InitSimpleStatics() argument
405 struct FillpStatisticsPcb *pcb = &fpcb->statistics; FillpInitStastics() local
449 FillpPcbFreeRecvItemArray(struct FillpRecvPcb *pcb) FillpPcbFreeRecvItemArray() argument
481 struct FillpRecvPcb *pcb = &fpcb->recv; FillpPcbRemoveRecv() local
550 struct FillpSendPcb *pcb = &fpcb->send; FillpPcbFreeSendItemArray() local
600 struct FillpSendPcb *pcb = &fpcb->send; FillpPcbRemoveSend() local
644 FillpInitPcbTimeNode(struct FillpPcb *pcb) FillpInitPcbTimeNode() argument
680 FillpInitPcb(struct FillpPcb *pcb, FILLP_INT mpSendSize, FILLP_INT mpRecvSize) FillpInitPcb() argument
720 FillpRemovePcb(struct FillpPcb *pcb) FillpRemovePcb() argument
735 FillpGetSendpcbUnackListPktNum(struct FillpSendPcb *pcb) FillpGetSendpcbUnackListPktNum() argument
744 FillpGetRecvpcbRecvlistPktNum(struct FillpRecvPcb *pcb) FillpGetRecvpcbRecvlistPktNum() argument
753 FillpGetSockPackInterval(FILLP_CONST struct FillpPcb *pcb) FillpGetSockPackInterval() argument
[all...]
H A Dfillp_timer.c28 static void FillpEnablePackTimerInCb(struct FillpPcb *pcb, FILLP_BOOL enNormalPackTimer) in FillpEnablePackTimerInCb() argument
31 FillpEnablePackTimer(pcb); in FillpEnablePackTimerInCb()
34 static void LogFcFcAppStastics(const struct FillpPcb *pcb, const struct FillAppFcStastics *appFcStastics) in LogFcFcAppStastics() argument
38 FILLP_GET_SOCKET(pcb)->index, appFcStastics->periodRtt, appFcStastics->periodRecvRate, in LogFcFcAppStastics()
44 static void FillpCalFcAppStastics(struct FillpPcb *pcb) in FillpCalFcAppStastics() argument
46 struct FtSocket *sock = FILLP_GET_SOCKET(pcb); in FillpCalFcAppStastics()
47 struct FillpPackStastics *packStastics = &pcb->statistics.pack; in FillpCalFcAppStastics()
48 struct FillAppFcStastics *appFcStastics = &pcb->statistics.appFcStastics; in FillpCalFcAppStastics()
58 FILLP_UINT32 pktData = pcb->recv.pktNum - appFcStastics->pktNum; in FillpCalFcAppStastics()
67 FILLP_GET_SOCKET(pcb) in FillpCalFcAppStastics()
101 FillpCalRecvRate(struct FillpPcb *pcb) FillpCalRecvRate() argument
150 struct FillpPcb *pcb = (struct FillpPcb *)argPcb; FillpPackTimerCb() local
181 struct FillpPcb *pcb = (struct FillpPcb *)argPcb; FillpSendTimerCb() local
195 FillpEnableSendTimer(struct FillpPcb *pcb) FillpEnableSendTimer() argument
215 FillpDisableSendTimer(struct FillpPcb *pcb) FillpDisableSendTimer() argument
222 FillpEnablePackTimer(struct FillpPcb *pcb) FillpEnablePackTimer() argument
232 FillpDisablePackTimer(struct FillpPcb *pcb) FillpDisablePackTimer() argument
239 FillpEnableFcTimer(struct FillpPcb *pcb) FillpEnableFcTimer() argument
246 FillpDisableFcTimer(struct FillpPcb *pcb) FillpDisableFcTimer() argument
253 FillpEnableKeepAliveTimer(struct FillpPcb *pcb) FillpEnableKeepAliveTimer() argument
261 FillpDisableKeepAliveTimer(struct FillpPcb *pcb) FillpDisableKeepAliveTimer() argument
268 FillpEnableDelayNackTimer(struct FillpPcb *pcb) FillpEnableDelayNackTimer() argument
278 FillpDisableDelayNackTimer(struct FillpPcb *pcb) FillpDisableDelayNackTimer() argument
285 FillpEnableDataBurstTimer(struct FillpPcb *pcb) FillpEnableDataBurstTimer() argument
294 FillpDisableDataBurstTimer(struct FillpPcb *pcb) FillpDisableDataBurstTimer() argument
301 FillpEnableConnRetryCheckTimer(struct FillpPcb *pcb) FillpEnableConnRetryCheckTimer() argument
308 FillpDisableConnRetryCheckTimer(struct FillpPcb *pcb) FillpDisableConnRetryCheckTimer() argument
315 FillpEnableFinCheckTimer(struct FillpPcb *pcb) FillpEnableFinCheckTimer() argument
323 FillpDisableFinCheckTimer(struct FillpPcb *pcb) FillpDisableFinCheckTimer() argument
332 struct FillpPcb *pcb = (struct FillpPcb *)argPcb; FillpFcTimerCb() local
[all...]
H A Dfillp_common.c26 void FillpFreeItemAndEvent(struct FillpPcb *pcb, struct FillpPcbItem *item) in FillpFreeItemAndEvent() argument
29 (void)SYS_ARCH_ATOMIC_INC(&(FILLP_GET_SOCKET(pcb)->sendEventCount), 1); in FillpFreeItemAndEvent()
31 (void)SYS_ARCH_SEM_POST(&pcb->send.sendSem); in FillpFreeItemAndEvent()
35 void InsertUnrecvListFail(struct FillpPcb *pcb, struct FillpPcbItem *item) in InsertUnrecvListFail() argument
38 FILLP_GET_SOCKET(pcb)->index, item->seqNum, item->dataLen); in InsertUnrecvListFail()
39 FillpFreeItemAndEvent(pcb, item); in InsertUnrecvListFail()
66 void FillpMoveUnackToUnrecv(FILLP_UINT32 ackSeq, FILLP_UINT32 lostSeq, struct FillpPcb *pcb, in FillpMoveUnackToUnrecv() argument
69 FillpMoveUnackToUnrecvAll(ackSeq, lostSeq, pcb, isFromPack, FILLP_FALSE); in FillpMoveUnackToUnrecv()
72 static FILLP_BOOL FillpMoveOneNode(struct Hlist *list, FILLP_UINT32 lostSeq, struct FillpPcb *pcb, in FillpMoveOneNode() argument
76 struct FillpHashLlist *unackList = &pcb in FillpMoveOneNode()
129 FillpMoveUnackToUnrecvAll(FILLP_UINT32 ackSeq, FILLP_UINT32 lostSeq, struct FillpPcb *pcb, FILLP_BOOL isFromPack, FILLP_BOOL onePktOnly) FillpMoveUnackToUnrecvAll() argument
178 FillpAckItemWaitTklist(struct FillpPcb *pcb, FILLP_UINT32 seqNum) FillpAckItemWaitTklist() argument
207 FillpAckUnrecvList(struct FillpPcb *pcb, FILLP_UINT32 seqNum) FillpAckUnrecvList() argument
242 FillpAckRedunlist(struct FillpPcb *pcb, FILLP_UINT32 seqNum) FillpAckRedunlist() argument
271 FreeUnackList(struct FillpPcb *pcb, struct FillpPcbItem *item, struct Hlist *tempCtl) FreeUnackList() argument
286 FillpAckUnackList(struct FillpPcb *pcb, FILLP_UINT32 curSeq, FILLP_INT cntLimit) FillpAckUnackList() argument
348 FillpAckSendPcb(struct FillpPcb *pcb, FILLP_INT cntLimit) FillpAckSendPcb() argument
363 FillpSendAdhocpack(struct FillpPcb *pcb) FillpSendAdhocpack() argument
381 FillpUploadRecvBox(struct FillpPcb *pcb) FillpUploadRecvBox() argument
442 FillpSendRepaetNack(struct FillpPcb *pcb, struct FillpPktNack *nack) FillpSendRepaetNack() argument
469 FillpSendNack(struct FillpPcb *pcb, FILLP_UINT32 startPktNum, FILLP_UINT32 endPktNum) FillpSendNack() argument
512 FillpAddNodeAtDelayNackListTail(struct FillpPcb *pcb, FILLP_UINT32 startPktNum, FILLP_UINT32 endPktNum) FillpAddNodeAtDelayNackListTail() argument
533 FillpCheckAndUpdateDelayNackList(struct FillpPcb *pcb, FILLP_UINT32 curRecvPktNum) FillpCheckAndUpdateDelayNackList() argument
593 FillBiggerItem(struct FillpPcb *pcb, struct FillpPcbItem *item) FillBiggerItem() argument
619 FillpRecvDropItem(struct FillpPcb *pcb, struct FillpPcbItem *item) FillpRecvDropItem() argument
625 FillpDataToStack(struct FillpPcb *pcb, struct FillpPcbItem *item) FillpDataToStack() argument
683 FillpAjustTlpParameterByRtt(struct FillpPcb *pcb, FILLP_LLONG rtt) FillpAjustTlpParameterByRtt() argument
709 FillpCalPackInterval(struct FillpPcb *pcb) FillpCalPackInterval() argument
733 FillpCalNackDelayTimeByPackInterval(struct FillpPcb *pcb) FillpCalNackDelayTimeByPackInterval() argument
755 FillpAdjustFcParamsByRtt(struct FillpPcb *pcb) FillpAdjustFcParamsByRtt() argument
764 FillpBuildAndSendPack(struct FillpPcb *pcb, struct FtSocket *ftSock, struct FillpPktPack *pack, FILLP_UINT16 dataLen) FillpBuildAndSendPack() argument
[all...]
H A Dfillp_input.c59 static void FillpChangePackInteval(struct FillpPcb *pcb) in FillpChangePackInteval() argument
61 struct FtNetconn *conn = FILLP_GET_CONN(pcb); in FillpChangePackInteval()
62 if (pcb->packState == FILLP_PACK_STATE_KEEP_ALIVE || in FillpChangePackInteval()
64 pcb->packTimerNode.interval != pcb->statistics.pack.packIntervalBackup)) { in FillpChangePackInteval()
66 pcb->statistics.pack.packIntervalBackup, pcb->statistics.pack.packInterval); in FillpChangePackInteval()
67 pcb->statistics.pack.packInterval = pcb->statistics.pack.packIntervalBackup; in FillpChangePackInteval()
68 FillpDisablePackTimer(pcb); in FillpChangePackInteval()
75 FillpProcessDataOptions(FillpDataOption *dataOption, struct FillpPcb *pcb, struct FillpPcbItem *item) FillpProcessDataOptions() argument
107 FillpAnalysisDataOptions(struct FillpPcb *pcb, struct FillpPcbItem *item) FillpAnalysisDataOptions() argument
152 FillpProcessItemData(struct FillpPcb *pcb, struct FillpPcbItem *item, FILLP_CONST struct FillpPktHead *pktHdr) FillpProcessItemData() argument
188 FillpDataInput(struct FillpPcb *pcb, struct FillpPcbItem *item) FillpDataInput() argument
221 ProcessPcbItem(struct FillpPcb *pcb, FILLP_CONST struct NetBuf *buf, struct FillpPcbItem *pcbBuf) ProcessPcbItem() argument
259 FillpHdlDataInput(struct FillpPcb *pcb, FILLP_CONST struct NetBuf *buf) FillpHdlDataInput() argument
298 FillpCheckNackPacket(FILLP_CONST struct FillpPcb *pcb, FILLP_CONST struct NetBuf *p) FillpCheckNackPacket() argument
315 FillpCheckNackSeq(FILLP_CONST struct FillpPcb *pcb, FILLP_CONST struct FillpPktHead *pktHdr, FILLP_CONST struct FillpSeqPktNum *seqPktNum) FillpCheckNackSeq() argument
377 ProtectLongLoopRun(struct FillpPcb *pcb, FILLP_UINT32 identifyGap, struct FillpSeqPktNum *seqPktNum, FILLP_INT *isUsed) ProtectLongLoopRun() argument
433 FillpNackInput(struct FillpPcb *pcb, FILLP_CONST struct NetBuf *p) FillpNackInput() argument
490 FillpCheckPackInput(struct FillpPcb *pcb, FILLP_CONST struct NetBuf *p) FillpCheckPackInput() argument
509 FillpPackInputSendMsgTrace(FILLP_CONST struct FillpPcb *pcb, FILLP_CONST struct FillpPktHead *pktHdr, FILLP_CONST struct FillpPktPack *pack) FillpPackInputSendMsgTrace() argument
560 FillpCheckPackNumber(struct FillpPcb *pcb, struct FillpPktPack *pack, FILLP_UINT32 ackSeqNum, FILLP_UINT32 lostSeqNum) FillpCheckPackNumber() argument
593 FillpHandleAdhocpackFlag(struct FillpPcb *pcb, struct FillpPktPack *pack) FillpHandleAdhocpackFlag() argument
630 FillpTryAckSendPcbByPackInfo(struct FillpPcb *pcb, FILLP_CONST struct FillpPktPack *pack, FILLP_UINT32 ackSeqNum, FILLP_UINT32 lostSeqNum) FillpTryAckSendPcbByPackInfo() argument
646 FillpHdlAdhocpack(struct FillpPcb *pcb, struct FillpPktPack *pack) FillpHdlAdhocpack() argument
653 FillpChangePackInterval(struct FillpPcb *pcb, FILLP_CONST struct FtSocket *sock, FILLP_CONST struct FillpPktPack *pack) FillpChangePackInterval() argument
664 FillpHandlePackFlag(struct FillpPcb *pcb, struct FillpPktPack *pack) FillpHandlePackFlag() argument
694 MoveUnackToUnrecvByPackInfo(struct FillpPcb *pcb, FILLP_UINT32 ackSeqNum, FILLP_UINT32 lostSeqNum) MoveUnackToUnrecvByPackInfo() argument
716 FillpPackInputLog(FILLP_CONST struct FillpPcb *pcb) FillpPackInputLog() argument
741 FillpPackInput(struct FillpPcb *pcb, FILLP_CONST struct NetBuf *p) FillpPackInput() argument
792 FillpHdlConnect(struct FillpPcb *pcb, FILLP_CONST struct NetBuf *buf, struct SpungeInstance *inst, FILLP_UINT16 flag) FillpHdlConnect() argument
840 FillpDoInputPktType(struct FillpPcb *pcb, FILLP_CONST struct NetBuf *buf, struct SpungeInstance *inst, FILLP_UINT16 flag) FillpDoInputPktType() argument
873 FillpDoInput(struct FillpPcb *pcb, FILLP_CONST struct NetBuf *buf, struct SpungeInstance *inst) FillpDoInput() argument
[all...]
H A Dfillp_flow_control.c124 FILLP_BOOL FillpAppLimitedStatus(struct FillpPcb *pcb, FILLP_UINT32 beginPktNum, FILLP_UINT32 endPktNum) in FillpAppLimitedStatus() argument
126 struct FillpHashLlist *mapList = &pcb->send.pktSeqMap; in FillpAppLimitedStatus()
164 void FillpCalSendInterval(struct FillpPcb *pcb) in FillpCalSendInterval() argument
166 struct FillpFlowControl *flowControl = &pcb->send.flowControl; in FillpCalSendInterval()
167 struct FtSocket *sock = FILLP_GET_SOCKET(pcb); in FillpCalSendInterval()
179 flowControl->sendInterval = (FILLP_LLONG)(pcb->pktSize * FILLP_FC_IN_KBPS * FILLP_FC_IN_BIT); in FillpCalSendInterval()
186 pcb->sendTimerNode.interval = (FILLP_UINT32)(flowControl->sendInterval / FILLP_FC_IN_BIT); in FillpCalSendInterval()
187 FILLP_LOGDBG("Send interval %lld, timer_interval:%u", flowControl->sendInterval, pcb->sendTimerNode.interval); in FillpCalSendInterval()
190 void FillpFcTailProtected(struct FillpPcb *pcb, struct FillpPktPack *pack) in FillpFcTailProtected() argument
202 FILLP_UINT32 unackNum = pcb in FillpFcTailProtected()
234 FillpFcPackInput(struct FillpPcb *pcb, struct FillpPktPack *pack) FillpFcPackInput() argument
245 FillpFcNackInput(struct FillpPcb *pcb, struct FillpPktNack *nack) FillpFcNackInput() argument
252 FillpGetAlgFun(struct FillpPcb *pcb) FillpGetAlgFun() argument
268 FillpFcInit(struct FillpPcb *pcb) FillpFcInit() argument
317 FillpFcDeinit(struct FillpPcb *pcb) FillpFcDeinit() argument
326 FillpFcDataInput(struct FillpPcb *pcb, FILLP_CONST struct FillpPktHead *pkt) FillpFcDataInput() argument
342 FillpFcRecvDropOne(struct FillpPcb *pcb) FillpFcRecvDropOne() argument
349 FillpFcRecvOutOfOrder(struct FillpPcb *pcb) FillpFcRecvOutOfOrder() argument
355 FillpFcRecvLost(struct FillpPcb *pcb, FILLP_UINT32 ones) FillpFcRecvLost() argument
362 struct FillpPcb *pcb = (struct FillpPcb *)arg; FillpFcCycle() local
[all...]
H A Dfillp_flow_control_alg0.c30 void FillpAlg0CalSendInterval(struct FillpPcb *pcb) in FillpAlg0CalSendInterval() argument
32 struct FillpFlowControl *flowControl = &pcb->send.flowControl; in FillpAlg0CalSendInterval()
42 FillpCalSendInterval(pcb); in FillpAlg0CalSendInterval()
52 static void FillpAlg0FlowControlInit(struct FillpPcb *pcb, struct FillpFlowControlAlg0 *alg) in FillpAlg0FlowControlInit() argument
55 alg->flowControl = &pcb->send.flowControl; in FillpAlg0FlowControlInit()
67 alg->maxRateAllowed = FILLP_GET_SOCKET(pcb)->resConf.flowControl.maxRate; in FillpAlg0FlowControlInit()
80 struct FillpPcb *pcb = (struct FillpPcb *)argPcb; in FillpAlg0FcInit() local
83 if (SockUpdatePktDataOpt(FILLP_GET_SOCKET(pcb), FILLP_OPT_FLAG_TIMESTAMP, 0) != ERR_OK) { in FillpAlg0FcInit()
100 FillpAlg0FlowControlInit(pcb, alg); in FillpAlg0FcInit()
101 pcb in FillpAlg0FcInit()
119 struct FillpPcb *pcb = (struct FillpPcb *)argPcb; FillpAlg0FcDeinit() local
137 struct FillpPcb *pcb = (struct FillpPcb *)argPcb; FillpAlg0CalPackInterval() local
142 FillpAlg0CalMaxPackRcvInterval(struct FillpPcb *pcb, FILLP_LLONG detaUs, FILLP_UINT32 packRate, FILLP_UINT32 periodSendRate) FillpAlg0CalMaxPackRcvInterval() argument
156 FillpAlg0FcHandleInit(struct FillpPcb *pcb, FILLP_CONST struct FillpPktPack *pack) FillpAlg0FcHandleInit() argument
189 FillpAlg0FcHandleBwProbe(struct FillpPcb *pcb, FILLP_CONST struct FillpPktPack *pack) FillpAlg0FcHandleBwProbe() argument
206 FillpAlg0PackStateProcess(struct FillpPcb *pcb, struct FillpPktPack *pack) FillpAlg0PackStateProcess() argument
237 struct FillpPcb *pcb = (struct FillpPcb *)argPcb; FillpAlg0AnalysePack() local
[all...]
H A Dfillp_output.c30 static void FillpMoveRedundantItemToUnrecvList(struct FillpPcb *pcb) in FillpMoveRedundantItemToUnrecvList() argument
33 struct FillpSendPcb *sendPcb = &pcb->send; in FillpMoveRedundantItemToUnrecvList()
38 FILLP_GET_SOCKET(pcb)->index, item->seqNum, item->dataLen); in FillpMoveRedundantItemToUnrecvList()
41 (void)SYS_ARCH_ATOMIC_INC(&(FILLP_GET_SOCKET(pcb)->sendEventCount), 1); in FillpMoveRedundantItemToUnrecvList()
43 (void)SYS_ARCH_SEM_POST(&pcb->send.send_sem); in FillpMoveRedundantItemToUnrecvList()
52 struct FillpPcb *pcb) in FillpGetSendItem()
65 item->seqNum = pcb->send.seqNum; in FillpGetSendItem()
81 static FILLP_BOOL FillpIsAskMoreBuf(struct FillpSendPcb *sendPcb, struct FillpPcb *pcb) in FillpIsAskMoreBuf() argument
91 struct FtSocket *sock = FILLP_GET_SOCKET(pcb); in FillpIsAskMoreBuf()
103 static void FillpDoneSendAllData(struct FillpSendPcb *sendPcb, struct FillpPcb *pcb, in FillpDoneSendAllData() argument
51 FillpGetSendItem(struct FillpSendPcb *sendPcb, struct FillpPcb *pcb) FillpGetSendItem() argument
132 FillpBeforeSendItem(struct FillpPcbItem *item, struct FillpPcb *pcb, FILLP_UINT32 sentBytes, FILLP_UINT32 totalBytes) FillpBeforeSendItem() argument
161 FillpSendOne(struct FillpPcb *pcb, FILLP_UINT32 totalBytes, FILLP_UINT32 sendPktNum) FillpSendOne() argument
219 FillpBuildPktDataOptions(FILLP_CONST struct FillpPcb *pcb, struct FillpPcbItem *item, FILLP_CHAR *dataOptionAddr) FillpBuildPktDataOptions() argument
237 FillpBuildDataPkt(struct FillpPcb *pcb, struct FillpPcbItem *item) FillpBuildDataPkt() argument
326 FillpAddToUnackList(struct FillpPcb *pcb, struct FillpPcbItem *item) FillpAddToUnackList() argument
344 FillpAddToPktSeqHash(FILLP_CONST struct FillpPcb *pcb, struct FillpPcbItem *item) FillpAddToPktSeqHash() argument
434 FillpSendAdhocpackToDetectRtt(struct FillpPcb *pcb) FillpSendAdhocpackToDetectRtt() argument
454 FillpSetSimplePack(FILLP_CONST struct FillpPcb *pcb, struct FillpPktPack *pack, FILLP_CONST struct FtSocket *ftSock) FillpSetSimplePack() argument
485 FillpSendPack(struct FillpPcb *pcb, struct FillpPktPack *pack) FillpSendPack() argument
512 FillpSendPackWithPcbBuffer(struct FillpPcb *pcb) FillpSendPackWithPcbBuffer() argument
[all...]
H A Dfillp_conn.c33 static void FillpConnReqInputTrace(FILLP_CONST struct FillpPcb *pcb, FILLP_CONST struct FtSocket *sock, in FillpConnReqInputTrace() argument
58 sizeof(struct FillpPktConnReq), FILLP_GET_SOCKET(pcb)->index, fillpTrcDesc, in FillpConnReqInputTrace()
63 static FILLP_INT FillpConnReqStateCheck(struct FillpPcb *pcb, FILLP_CONST struct FtSocket *sock) in FillpConnReqStateCheck() argument
65 FILLP_UINT8 connState = FILLP_GET_CONN_STATE(pcb); in FillpConnReqStateCheck()
67 if ((pcb->recv.seqNum == pcb->recv.seqStartNum) && (pcb->send.maxAckNumFromReceiver == in FillpConnReqStateCheck()
68 pcb->send.seqStartNum)) { /* Only if no data received or no data acked */ in FillpConnReqStateCheck()
73 FillpSendConnConfirmAck(pcb); in FillpConnReqStateCheck()
91 void FillpConnReqInput(struct FillpPcb *pcb, FILLP_CONS argument
371 FillpDecodeConnReqAckClientPara(struct FillpPcb *pcb, FILLP_CONST struct NetBuf *p, struct FillpConnReqAckClient *reqAck) FillpDecodeConnReqAckClientPara() argument
427 FillpConnReqAckInput(struct FillpPcb *pcb, FILLP_CONST struct NetBuf *p) FillpConnReqAckInput() argument
559 FillpInitNewConnByConfirm(struct FillpPcb *pcb, struct FtNetconn *newConn, FILLP_CONST struct FillpPktConnConfirm *confirm, FILLP_CONST struct FtNetconn *conn, FILLP_CONST struct NetBuf *p) FillpInitNewConnByConfirm() argument
631 FillpProcessConnConfirm(struct FillpPcb *pcb, FILLP_CONST struct NetBuf *p, FILLP_CONST struct FillpPktConnConfirm *confirm, FILLP_CONST struct FtNetconn *conn, struct SpungeInstance *inst) FillpProcessConnConfirm() argument
722 FillpConfirmCheckState(FILLP_UINT8 connState, struct FtSocket *sock, struct FillpPcb *pcb) FillpConfirmCheckState() argument
748 FillpConnConfirmInput(struct FillpPcb *pcb, FILLP_CONST struct NetBuf *p, struct SpungeInstance *inst) FillpConnConfirmInput() argument
811 FillpHandleConnConfirmAckInput(struct FtSocket *sock, struct FtNetconn *conn, struct FillpPcb *pcb, FILLP_CONST struct NetBuf *p) FillpHandleConnConfirmAckInput() argument
841 FillpCheckConfirmAckInfoIsValid(struct FillpPcb *pcb, struct FtSocket *sock, struct FillpPktConnConfirmAck *confirmAck) FillpCheckConfirmAckInfoIsValid() argument
891 FillpConnConnectionEstFailure(struct FillpPcb *pcb, FILLP_CONST struct NetBuf *p) FillpConnConnectionEstFailure() argument
970 FillpCheckConfirmAckPar(struct FillpPcb *pcb, FILLP_CONST struct NetBuf *p) FillpCheckConfirmAckPar() argument
1028 FillpSaveConfirmActToPcb(struct FillpPktConnConfirmAck *confirmAck, struct FillpPcb *pcb) FillpSaveConfirmActToPcb() argument
1042 FillpConnConfirmAckInput(struct FillpPcb *pcb, FILLP_CONST struct NetBuf *p) FillpConnConfirmAckInput() argument
1088 ConnectingHandleFinInput(struct FillpPcb *pcb, struct FtSocket *sock, struct FtNetconn *conn, FILLP_CONST struct NetBuf *p, FILLP_CONST struct FillpFinFlags *flags) ConnectingHandleFinInput() argument
1115 FillpStateClosingHandleFinInput(struct FillpPcb *pcb, struct FtNetconn *conn, FILLP_BOOL isAck, FILLP_BOOL isWr, FILLP_BOOL *pcbFreed) FillpStateClosingHandleFinInput() argument
1222 FillpHandleFin(struct FillpPcb *pcb, FILLP_CONST struct NetBuf *p, FILLP_BOOL *pcbFreed) FillpHandleFin() argument
1299 FillpFinInput(struct FillpPcb *pcb, FILLP_CONST struct NetBuf *p, FILLP_BOOL *pcbFreed) FillpFinInput() argument
1338 FillpSendConnReqBuild(struct FillpPcb *pcb, struct FillpPktConnReq *req, FILLP_LLONG curTime) FillpSendConnReqBuild() argument
1375 FillpSendConnReq(struct FillpPcb *pcb) FillpSendConnReq() argument
1431 FillpSendConnReqAckBuild(FILLP_CONST struct FillpPcb *pcb, FILLP_CONST FillpCookieContent *stateCookie, FILLP_ULLONG timestamp) FillpSendConnReqAckBuild() argument
1493 FillpSendConnReqAck(struct FillpPcb *pcb, FILLP_CONST FillpCookieContent *stateCookie, FILLP_ULLONG timestamp) FillpSendConnReqAck() argument
1547 ConnConfirmBuild(struct FillpPcb *pcb, FILLP_CONST struct FillpConnReqAckClient *reqAck, struct FillpPktHead *pktHdr) ConnConfirmBuild() argument
1593 ConnConfirmEncodeExtPara(const struct FillpPcb *pcb, FILLP_INT32 encMsgLen) ConnConfirmEncodeExtPara() argument
1647 FillpSendConnConfirm(struct FillpPcb *pcb, FILLP_CONST struct FillpConnReqAckClient *reqAck) FillpSendConnConfirm() argument
1694 FillpSendConnConfirmAck(struct FillpPcb *pcb) FillpSendConnConfirmAck() argument
1751 FillpSendFinBuild(FILLP_CONST struct FillpPcb *pcb, struct FillpPktFin *req, FILLP_CONST struct FillpFinFlags *flags) FillpSendFinBuild() argument
1783 FillpSendFinInnerImpl(struct FillpPcb *pcb, FILLP_CONST struct FillpFinFlags *flags, struct sockaddr *remoteAddr) FillpSendFinInnerImpl() argument
1836 FillpSendFinInner(struct FillpPcb *pcb, FILLP_BOOL wrSet, FILLP_BOOL rdSet, FILLP_BOOL ackSet, struct sockaddr *remoteAddr) FillpSendFinInner() argument
1848 FillpSendRstWithVersionImcompatible(struct FillpPcb *pcb, struct sockaddr *remoteAddr) FillpSendRstWithVersionImcompatible() argument
1859 FillpSendFin(struct FillpPcb *pcb) FillpSendFin() argument
1877 FillpSendFinAck(struct FillpPcb *pcb, struct sockaddr *remoteAddr) FillpSendFinAck() argument
1882 FillpSendRst(struct FillpPcb *pcb, struct sockaddr *remoteAddr) FillpSendRst() argument
1889 FillpGenerateCookie(IN FILLP_CONST struct FillpPcb *pcb, IN struct FillpPktConnReq *req, IN FILLP_CONST struct sockaddr_in6 *remoteAddr, IN FILLP_UINT16 serverPort, OUT FillpCookieContent *stateCookie) FillpGenerateCookie() argument
1939 FillpValidateCookieHmac(FILLP_CONST struct FillpPcb *pcb, FILLP_CONST FillpCookieContent *stateCookie) FillpValidateCookieHmac() argument
1995 FillpValidateCookie(IN FILLP_CONST struct FillpPcb *pcb, IN FILLP_UINT16 serverPort, IN FILLP_CONST struct sockaddr_in6 *clientAddr, IN FILLP_CONST FillpCookieContent *stateCookie) FillpValidateCookie() argument
[all...]
/foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/src/
H A Dpcb.c16 #include "pcb.h"
36 FillpErrorType err = FillpQueuePush(conn->pcb->fpcb.recv.recvBox, buf, FILLP_TRUE, (FILLP_UINT)count); in SpungePcbRecv()
62 struct SpungePcb *pcb = (struct SpungePcb *)ppcb; in SpungePcbSend() local
75 (struct sockaddr *)&pcb->remoteAddr, in SpungePcbSend()
76 pcb->addrLen)) { in SpungePcbSend()
153 FILLP_INT SpungePcbSendmsg(void *arg, FILLP_CONST char *buf, FILLP_INT size, void *pcb) in SpungePcbSendmsg() argument
157 struct FillpPcb *fpcb = (struct FillpPcb *)pcb; in SpungePcbSendmsg()
196 void SpcbAddPcbToSpinst(struct SpungeInstance *inst, struct SpungePcb *pcb) in SpcbAddPcbToSpinst() argument
198 SpinstAddToPcbList(inst, &pcb->udpNode); in SpcbAddPcbToSpinst()
201 void SpcbDeleteFromSpinst(struct SpungeInstance *inst, struct SpungePcb *pcb) in SpcbDeleteFromSpinst() argument
208 struct SpungePcb *pcb = (struct SpungePcb *)SpungeAlloc(1, sizeof(struct SpungePcb), SPUNGE_ALLOC_TYPE_CALLOC); SpungePcbNew() local
246 SpungePcbSetSendCacheSize(struct SpungePcb *pcb, FILLP_UINT32 cacheSize) SpungePcbSetSendCacheSize() argument
251 SpungePcbSetRecvCacheSize(struct SpungePcb *pcb, FILLP_UINT32 cacheSize) SpungePcbSetRecvCacheSize() argument
256 SpungePcbSetPktSize(struct SpungePcb *pcb, FILLP_UINT32 pktSize) SpungePcbSetPktSize() argument
261 SpungePcbSetOppositeRate(struct SpungePcb *pcb, FILLP_UINT32 rate) SpungePcbSetOppositeRate() argument
266 SpungePcbSetSlowStart(struct SpungePcb *pcb, FILLP_BOOL slowStart) SpungePcbSetSlowStart() argument
271 SpungePcbSetPackInterval(struct SpungePcb *pcb, FILLP_UINT32 interval) SpungePcbSetPackInterval() argument
278 SpungePcbSetAddrType(struct SpungePcb *pcb, FILLP_UINT16 addrType) SpungePcbSetAddrType() argument
283 SpungePcbSetLocalPort(struct SpungePcb *pcb, FILLP_INT port) SpungePcbSetLocalPort() argument
288 SpungePcbSetDirectlySend(struct SpungePcb *pcb, FILLP_INT directlySend) SpungePcbSetDirectlySend() argument
293 SpungePcbRemove(struct SpungePcb *pcb) SpungePcbRemove() argument
[all...]
H A Dnet.c56 SpungePcbSetSendCacheSize(conn->pcb, cacheSize); in NetconnSetSendCacheSize()
60 SpungePcbSetRecvCacheSize(conn->pcb, cacheSize); in NetconnSetRecvCacheSize()
64 SpungePcbSetPktSize(conn->pcb, pktSize); in NetconnSetPktSize()
69 SpungePcbSetOppositeRate(conn->pcb, rate); in NetconnSetOpersiteRate()
74 SpungePcbSetSlowStart(conn->pcb, slowStart); in NetconnSetSlowStart()
79 SpungePcbSetPackInterval(conn->pcb, interval); in NetconnSetPackInterval()
84 SpungePcbSetLocalPort(conn->pcb, port); in NetconnSetLocalPort()
89 SpungePcbSetAddrType(conn->pcb, addrType); in NetconnSetAddrType()
94 SpungePcbSetDirectlySend(conn->pcb, directlySend); in NetconnSetDirectlySend()
124 conn->pcb in FillpNetconnAlloc()
[all...]
H A Dspunge_stack.c240 (sock->netconn != FILLP_NULL_PTR) && (sock->netconn->pcb != FILLP_NULL_PTR) && in SpungeCloseCBSocket()
246 FILLP_SOCKETCLOSE_CBK(udpSock->udpSock, (struct sockaddr *)&sock->netconn->pcb->localAddr, in SpungeCloseCBSocket()
247 (struct sockaddr *)&sock->netconn->pcb->remoteAddr); in SpungeCloseCBSocket()
344 if ((conn == FILLP_NULL_PTR) || (conn->pcb == FILLP_NULL_PTR)) { in SpungeConnCheckUnsendBoxEmpty()
348 unsendBox = conn->pcb->fpcb.send.unsendBox; in SpungeConnCheckUnsendBoxEmpty()
375 static int SpungeDestroyNoWait(struct FillpPcb *pcb, struct FtSocket *sock, struct FtNetconn *conn) in SpungeDestroyNoWait() argument
381 if (pcb->pcbInst->waitTobeCoreKilled == FILLP_TRUE) { in SpungeDestroyNoWait()
394 struct FillpPcb *pcb = FILLP_NULL_PTR; in SpungeCheckDisconn() local
398 if (sock == FILLP_NULL_PTR || conn->pcb == FILLP_NULL_PTR) { in SpungeCheckDisconn()
399 FILLP_LOGERR("NULL pointer sock or conn->pcb"); in SpungeCheckDisconn()
515 SpungeFreeUnsendBox(struct FillpPcb *pcb) SpungeFreeUnsendBox() argument
[all...]
H A Dsysio_udp.c320 FILLP_LOGERR("Failed to allocate memory for pcb hash bucket"); in SysioCreateSocketUdp()
382 struct SpungePcb *pcb = (struct SpungePcb *)argPcb; in SysioConnectUdp() local
384 FILLP_UINT32 addrHashKey = UtilsAddrHashKey((struct sockaddr_in *)&pcb->remoteAddr); in SysioConnectUdp()
385 HlistAddTail(&udpSock->pcbHash[addrHashKey & (UDP_HASH_TABLE_SIZE - 1)].list, &pcb->hashNode); in SysioConnectUdp()
393 struct SpungePcb *pcb = (struct SpungePcb*)argPcb; in SysioRemovePcbUdp() local
397 FILLP_UINT32 addrHashKey = UtilsAddrHashKey((struct sockaddr_in *)&pcb->remoteAddr); in SysioRemovePcbUdp()
404 if (node == &pcb->hashNode) { in SysioRemovePcbUdp()
436 struct SpungePcb *pcb = (struct SpungePcb *)argPcb; in SysioHandlePacketUdp() local
440 FILLP_UINT32 addrHashKey = UtilsAddrHashKey((struct sockaddr_in *)&pcb->remoteAddr); in SysioHandlePacketUdp()
441 HlistAddTail(&udpSock->pcbHash[addrHashKey & (UDP_HASH_TABLE_SIZE - 1)].list, &pcb in SysioHandlePacketUdp()
466 struct SpungePcb *pcb = (struct SpungePcb*)argPcb; SysioSendPacketUdp() local
[all...]
H A Dspunge_core.c73 static FILLP_UINT32 SpungeCalExpectedBytes(FILLP_UINT32 *sendPktNum, struct SpungePcb *pcb, in SpungeCalExpectedBytes() argument
88 pcb->fpcb.statistics.traffic.packExpSendBytes += bytesExpected; in SpungeCalExpectedBytes()
89 bytesExpected += pcb->fpcb.send.flowControl.remainBytes; in SpungeCalExpectedBytes()
92 bytesExpected = (FILLP_UINT32)(pktNum * pcb->fpcb.pktSize); in SpungeCalExpectedBytes()
93 pcb->fpcb.statistics.traffic.packExpSendBytes += bytesExpected; in SpungeCalExpectedBytes()
97 sock->index, pcb->fpcb.send.unrecvList.nodeNum, pcb->fpcb.send.unackList.count); in SpungeCalExpectedBytes()
101 static void SpungeDoSendUpdate(struct SpungePcb *pcb, FILLP_UINT32 sendBytes, FILLP_UINT32 bytesExpected) in SpungeDoSendUpdate() argument
104 pcb->fpcb.statistics.traffic.packSendBytes += sendBytes; in SpungeDoSendUpdate()
105 pcb in SpungeDoSendUpdate()
111 SpungeDoSendCycle(struct SpungePcb *pcb, struct SpungeInstance *inst, FILLP_LLONG detaTime) SpungeDoSendCycle() argument
1108 struct SpungePcb *pcb = FILLP_NULL_PTR; FillpCalculateFairness() local
1184 struct SpungePcb *pcb = ((struct FillpPcb *)args)->spcb; FillpCheckPcbNackListToSend() local
1619 struct FillpPcb *pcb = (struct FillpPcb *)arg; SpungePushRecvdDataToStack() local
[all...]
/foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/include/fillp/
H A Dfillp_common.h36 #define FILLP_GET_CONN(pcb) ((struct FtNetconn*) ((struct SpungePcb*) ((pcb)->spcb))->conn)
37 #define FILLP_GET_SOCKET(pcb) ((struct FtSocket*)(FILLP_GET_CONN(pcb)->sock))
38 #define FILLP_GET_CONN_STATE(pcb) NETCONN_GET_STATE(FILLP_GET_CONN(pcb))
42 #define FILLP_UNACKLIST_HASHINDEX(seqNum, pcb) \
43 (((seqNum) / FILLP_UNACK_HASH_MOD) & (pcb)->send.unackList.hashModSize)
47 void InsertUnrecvListFail(struct FillpPcb *pcb, struct FillpPcbItem *item);
48 void FillpAjustTlpParameterByRtt(struct FillpPcb *pcb, FILLP_LLON
[all...]
H A Dfillp_flow_control.h57 void fillp_analyse_pack(struct FillpPcb *pcb, struct FillpPktPack *pack);
58 void FillpFcTailProtected(struct FillpPcb *pcb, struct FillpPktPack *pack);
59 void FillpFcPackInput(struct FillpPcb *pcb, struct FillpPktPack *pack);
60 void FillpFcNackInput(struct FillpPcb *pcb, struct FillpPktNack *nack);
62 FILLP_INT FillpFcInit(struct FillpPcb *pcb);
63 void FillpFcDeinit(struct FillpPcb *pcb);
64 void FillpFcDataInput(struct FillpPcb *pcb, FILLP_CONST struct FillpPktHead *pkt);
65 void FillpFcRecvDropOne(struct FillpPcb *pcb);
66 void FillpFcRecvOutOfOrder(struct FillpPcb *pcb);
68 void FillpFcRecvLost(struct FillpPcb *pcb, FILLP_UINT3
[all...]
H A Dfillp_pcb.h40 typedef FILLP_INT (*fillpSendFunc)(void *arg, FILLP_CONST char *buf, FILLP_INT size, void *pcb);
41 typedef FILLP_INT (*fillpSendmsgFunc)(void *arg, FILLP_CONST char *buf, FILLP_INT size, void *pcb);
122 #define FILLP_DIFFER_TRANSMIT_PCB_MAX_CNT 32 /* max count of the pcb which will using differentiated transmission
238 static __inline FILLP_UINT32 FillpPcbGetTotalPktCnt(struct FillpPcb *pcb) in FillpPcbGetTotalPktCnt() argument
240 return (pcb->send.unSendList.size + pcb->send.unrecvList.nodeNum + in FillpPcbGetTotalPktCnt()
241 pcb->send.redunList.nodeNum + pcb->send.unackList.count + pcb->send.itemWaitTokenLists.nodeNum); in FillpPcbGetTotalPktCnt()
244 static __inline FILLP_BOOL FillpPcbGetDirectlySend(struct FillpPcb *pcb) in FillpPcbGetDirectlySend() argument
249 FillpPcbGetSendCacheSize(struct FillpPcb *pcb) FillpPcbGetSendCacheSize() argument
[all...]
H A Dfillp.h395 void FillpSendConnConfirmAck(struct FillpPcb *pcb);
396 FILLP_INT FillpSendConnReq(struct FillpPcb *pcb);
397 void FillpSendFin(struct FillpPcb *pcb);
398 void FillpSendFinAck(struct FillpPcb *pcb, struct sockaddr *remoteAddr);
399 void FillpSendRst(struct FillpPcb *pcb, struct sockaddr *remoteAddr);
400 void FillpSendRstWithVersionImcompatible(struct FillpPcb *pcb, struct sockaddr *remoteAddr);
402 void FillpGenerateCookie(IN FILLP_CONST struct FillpPcb *pcb, IN struct FillpPktConnReq *req,
405 FILLP_INT FillpValidateCookie(IN FILLP_CONST struct FillpPcb *pcb, IN FILLP_UINT16 serverPort,
408 void FillpSendConnReqAck(struct FillpPcb *pcb, FILLP_CONST FillpCookieContent *stateCookie, FILLP_ULLONG timestamp);
410 void FillpSendConnConfirm(struct FillpPcb *pcb, FILLP_CONS
[all...]
H A Dfillp_output.h29 FILLP_UINT32 FillpSendOne(struct FillpPcb *pcb, FILLP_UINT32 totalSendBytes, FILLP_UINT32 sendPktNum);
30 void FillpSendAdhocpackToDetectRtt(struct FillpPcb *pcb);
31 FILLP_BOOL FillpSendPackWithPcbBuffer(struct FillpPcb *pcb);
/foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/include/
H A Dpcb.h76 void SpcbAddPcbToSpinst(struct SpungeInstance *inst, struct SpungePcb *pcb);
77 void SpcbDeleteFromSpinst(struct SpungeInstance *inst, struct SpungePcb *pcb);
82 void SpungePcbRemove(struct SpungePcb *pcb);
84 void SpungePcbSetSendCacheSize(struct SpungePcb *pcb, FILLP_UINT32 cahceSize);
85 void SpungePcbSetRecvCacheSize(struct SpungePcb *pcb, FILLP_UINT32 cahceSize);
86 void SpungePcbSetPktSize(struct SpungePcb *pcb, FILLP_UINT32 pktSize);
87 void SpungePcbSetOppositeRate(struct SpungePcb *pcb, FILLP_UINT32 rate);
88 void SpungePcbSetSlowStart(struct SpungePcb *pcb, FILLP_BOOL slowStart);
89 void SpungePcbSetPackInterval(struct SpungePcb *pcb, FILLP_UINT32 interval);
90 void SpungePcbSetAddrType(struct SpungePcb *pcb, FILLP_UINT1
[all...]
H A Dspunge_stack.h26 void SpungeDoPackCycle(struct SpungePcb *pcb, struct SpungeInstance *inst);
28 void SpungeDoSendCycle(struct SpungePcb *pcb, struct SpungeInstance *inst, FILLP_LLONG detaTime);
33 void SpungeFreeUnsendBox(struct FillpPcb *pcb);
H A Dsysio.h38 int (*connect)(void *sock, void *pcb);
40 int (*handlePacket)(int msgType, void *argSock, void *pcb, void *buf);
41 int (*sendPacket)(int msgType, void *argSock, void *pcb, void *buf);
42 void (*removePcb)(void *argSock, void *pcb);
/foundation/communication/dsoftbus/components/nstackx/fillp/src/app_lib/src/
H A Dapi.c1141 if ((sock->netconn != FILLP_NULL_PTR) && (((struct FtNetconn *)sock->netconn)->pcb != FILLP_NULL_PTR)) { in FtFillpStatsGet()
1143 &((struct FtNetconn *)sock->netconn)->pcb->fpcb.statistics, sizeof(struct FillpStatisticsPcb)); in FtFillpStatsGet()
1145 FILLP_LOGERR(" error: netconn/pcb is NULLPTR"); in FtFillpStatsGet()
1159 Input : pcb - socket pcb for which pack info needs to be displayed.
1165 void FtFillpStatPackStat(FILLP_CONST struct FillpStatisticsPcb *pcb) in FtFillpStatPackStat() argument
1168 FILLP_SHOWDATABUTT("packInterval: %u", pcb->pack.packInterval); in FtFillpStatPackStat()
1169 FILLP_SHOWDATABUTT("packTimePassed: %lld", pcb->pack.packTimePassed); in FtFillpStatPackStat()
1171 FILLP_SHOWDATABUTT("periodRecvRate: %u", pcb->pack.periodRecvRate); in FtFillpStatPackStat()
1172 FILLP_SHOWDATABUTT("maxRecvRate: %u", pcb in FtFillpStatPackStat()
1202 FtFillpStatKeepAlive(FILLP_CONST struct FillpStatisticsPcb *pcb) FtFillpStatKeepAlive() argument
1224 FtFillpStatDebugStat(FILLP_CONST struct FillpStatisticsPcb *pcb) FtFillpStatDebugStat() argument
1276 FtFillpStatTraffic(FILLP_CONST struct FillpStatisticsPcb *pcb) FtFillpStatTraffic() argument
1299 FtFillpInnerStatShow( IN FILLP_UINT32 fillpStatsType, IN FILLP_CONST struct FillpStatisticsPcb *pcb) FtFillpInnerStatShow() argument
1339 struct FillpStatisticsPcb *pcb = FILLP_NULL_PTR; FtFillpStatShow() local
[all...]
H A Dfillp_dfx.c283 const struct FillpPcb *pcb = &sock->netconn->pcb->fpcb; in FillpDfxSockQosNotify() local
284 const struct FillpStatisticsTraffic *traffic = &(pcb->statistics.traffic); in FillpDfxSockQosNotify()
285 const struct FillAppFcStastics *appFcStastics = &(pcb->statistics.appFcStastics); in FillpDfxSockQosNotify()
524 struct sockaddr_in *local = (struct sockaddr_in *)&sock->netconn->pcb->localAddr; in DoShowSockList()
525 struct sockaddr_in *peer = (struct sockaddr_in *)&sock->netconn->pcb->remoteAddr; in DoShowSockList()
526 const struct FillpSendPcb *sendPcb = &sock->netconn->pcb->fpcb.send; in DoShowSockList()
580 if (sock->netconn == FILLP_NULL_PTR || sock->netconn->pcb == FILLP_NULL_PTR) { in FillpDumpShowSockList()
598 const struct FillpPcb *pcb = &sock->netconn->pcb in DoShowSockQos() local
[all...]
/foundation/communication/dsoftbus/components/nstackx/fillp/src/public/src/
H A Dspunge_message.c270 err = memcpy_s(&sock->netconn->pcb->remoteAddr, sizeof(sock->netconn->pcb->remoteAddr), connMsg->addr, in SpungeConnMsgGetSock()
277 sock->netconn->pcb->addrLen = (FILLP_UINT16)connMsg->addrLen; in SpungeConnMsgGetSock()
323 osSock->ioSock->ops->connect(osSock->ioSock, sock->netconn->pcb) != ERR_OK) { in SpungeHandleMsgConnect()
333 SpungeStartConnRetryTimer(&sock->netconn->pcb->fpcb, sock); in SpungeHandleMsgConnect()
339 (void *)sock->netconn->pcb, FILLP_NULL_PTR) == -1)) { in SpungeHandleMsgConnect()
340 FillpDisableConnRetryCheckTimer(&sock->netconn->pcb->fpcb); in SpungeHandleMsgConnect()
373 struct SpungePcb *pcb = FILLP_NULL_PTR; in SpungeBindMsgCheckState() local
384 pcb = conn->pcb; in SpungeBindMsgCheckState()
421 struct SpungePcb *pcb = FILLP_NULL_PTR; SpungeHandleMsgBind() local
768 struct SpungePcb *pcb = FILLP_NULL_PTR; SpungeHandleMsgSetNackDelay() local
832 struct FillpPcb *pcb = &sock->netconn->pcb->fpcb; SpungeHandleMsgSetKeepAlive() local
[all...]
/foundation/communication/dsoftbus/components/nstackx/fillp/src/public/include/
H A Dsockets.h156 #define SOCK_GET_SENDPKTPOOL(_sock) ((_sock)->netconn->pcb->fpcb.send.itemPool)
157 #define SOCK_GET_SENDBOX(_sock) ((_sock)->netconn->pcb->fpcb.send.unsendBox)
158 #define SOCK_GET_RECVBOX(_sock) ((_sock)->netconn->pcb->fpcb.recv.recvBox)
159 #define SOCK_GET_PKTSIZE(_sock) ((_sock)->netconn->pcb->fpcb.pktSize)
167 #define SOCK_GET_SENDSEM(_sock) ((_sock)->netconn->pcb->fpcb.send.sendSem)
168 #define SOCK_GET_RECVSEM(_sock) ((_sock)->netconn->pcb->fpcb.recv.recvSem)

Completed in 19 milliseconds

12