Home
last modified time | relevance | path

Searched refs:pcb (Results 1 – 25 of 36) sorted by relevance

12

/ohos5.0/foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/src/fillp/
H A Dfillp_pcb.c62 pcb->unackList.hashModSize = pcb->unackList.size - 1; in FillpInitSendpcbUnackList()
98 pcb->pktSeqMap.hashModSize = pcb->pktSeqMap.size - 1; in FillpInitSendpcbPktSeqMap()
213 pcb->nackPktStartNum = pcb->pktStartNum; in InitSimplePcbPar()
214 pcb->nackPktEndNum = pcb->pktStartNum; in InitSimplePcbPar()
347 pcb->recvBox = FillpInitRecvPcbBox(fpcb, pcb); in FillpInitRecvpcb()
650 pcb->packTimerNode.cbNode.arg = (void *)pcb; in FillpInitPcbTimeNode()
654 pcb->FcTimerNode.cbNode.arg = (void *)pcb; in FillpInitPcbTimeNode()
658 pcb->sendTimerNode.cbNode.arg = (void *)pcb; in FillpInitPcbTimeNode()
662 pcb->keepAliveTimerNode.cbNode.arg = (void *)pcb; in FillpInitPcbTimeNode()
668 pcb->delayNackTimerNode.cbNode.arg = (void *)pcb; in FillpInitPcbTimeNode()
[all …]
H A Dfillp_timer.c165 pcb->algFuncs.packTimer(pcb); in FillpPackTimerCb()
207 pcb->send.flowControl.sendTime = pcb->pcbInst->curTime; in FillpEnableSendTimer()
212 pcb->send.flowControl.sendTime + pcb->sendTimerNode.interval, &pcb->sendTimerNode); in FillpEnableSendTimer()
228 pcb->packTimerNode.interval + pcb->pcbInst->curTime, &pcb->packTimerNode); in FillpEnablePackTimer()
243 pcb->FcTimerNode.interval + pcb->pcbInst->curTime, &pcb->FcTimerNode); in FillpEnableFcTimer()
257 pcb->keepAliveTimerNode.interval + pcb->pcbInst->curTime, &pcb->keepAliveTimerNode); in FillpEnableKeepAliveTimer()
274 pcb->pcbInst->curTime + pcb->delayNackTimerNode.interval, &pcb->delayNackTimerNode); in FillpEnableDelayNackTimer()
291 pcb->pcbInst->curTime + pcb->dataBurstTimerNode.interval, &pcb->dataBurstTimerNode); in FillpEnableDataBurstTimer()
305 … pcb->pcbInst->curTime + pcb->connRetryTimeoutTimerNode.interval, &pcb->connRetryTimeoutTimerNode); in FillpEnableConnRetryCheckTimer()
319 pcb->pcbInst->curTime + pcb->finCheckTimer.interval, &pcb->finCheckTimer); in FillpEnableFinCheckTimer()
[all …]
H A Dfillp_common.c432 FILLP_GET_SOCKET(pcb)->index, pcb->recv.pktNum, pcb->recv.lastPackPktNum, in FillpUploadRecvBox()
433 (pcb->recv.pktNum - pcb->recv.lastPackPktNum), pcb->mpRecvSize); in FillpUploadRecvBox()
454 FILLP_GET_CONN(pcb)->pcb); in FillpSendRepaetNack()
506 pcb->send.retryIndex = pcb->send.retryIndex % pcb->statistics.nack.historyNackQueueLen; in FillpSendNack()
571 if (pcb->recv.nackList.size >= pcb->mpRecvSize) { in FillpCheckAndUpdateDelayNackList()
712 pcb->algFuncs.calPackInterval(pcb); in FillpCalPackInterval()
715 pcb->send.retramistRto = pcb->rtt; in FillpCalPackInterval()
729 … FILLP_GET_SOCKET(pcb)->index, pcb->packTimerNode.interval, pcb->FcTimerNode.interval, pcb->rtt, in FillpCalPackInterval()
760 FillpAjustTlpParameterByRtt(pcb, (FILLP_LLONG)pcb->rtt); in FillpAdjustFcParamsByRtt()
787 pcb->recv.lastPackPktNum = pcb->recv.pktNum; in FillpBuildAndSendPack()
[all …]
H A Dfillp_input.c69 pcb->packTimerNode.interval = pcb->statistics.pack.packInterval; in FillpChangePackInteval()
568 FILLP_GET_SOCKET(pcb)->index, ackSeqNum, pcb->send.seqNum, pcb->send.ackSeqNum, in FillpCheckPackNumber()
569 pcb->send.unSendList.size, pcb->send.unrecvList.nodeNum, pcb->send.unackList.count, in FillpCheckPackNumber()
570 … pcb->send.itemWaitTokenLists.nodeNum, pcb->send.redunList.nodeNum, pcb->send.curItemCount, in FillpCheckPackNumber()
626 pcb->algFuncs.hdlPackFlag(pcb, pack); in FillpHandleAdhocpackFlag()
685 pcb->packTimerNode.interval = pcb->statistics.pack.packInterval; in FillpHandlePackFlag()
688 pcb->algFuncs.hdlPackFlag(pcb, pack); in FillpHandlePackFlag()
719 …FILLP_GET_SOCKET(pcb)->index, pcb->statistics.debugPcb.nackSend, pcb->statistics.debugPcb.nackFail… in FillpPackInputLog()
720 …pcb->statistics.debugPcb.nackRcv, pcb->statistics.debugPcb.packSend, pcb->statistics.debugPcb.pack… in FillpPackInputLog()
725 …FILLP_GET_SOCKET(pcb)->index, pcb->statistics.traffic.totalSend, pcb->statistics.traffic.totalSend… in FillpPackInputLog()
[all …]
H A Dfillp_flow_control.c204 … pcb->send.unrecvList.nodeNum + pcb->send.itemWaitTokenLists.nodeNum + pcb->send.redunList.nodeNum; in FillpFcTailProtected()
210 deltaUs = pcb->pcbInst->curTime - pcb->send.lastSendTs; in FillpFcTailProtected()
237 pcb->algFuncs.analysisPack(pcb, (void *)pack); in FillpFcPackInput()
248 pcb->algFuncs.analysisNack(pcb, (void *)nack); in FillpFcNackInput()
297 pcb->statistics.keepAlive.lastRecvTime = pcb->pcbInst->curTime; in FillpFcInit()
298 pcb->statistics.keepAlive.lastDataRecvTime = pcb->pcbInst->curTime; in FillpFcInit()
302 FILLP_GET_SOCKET(pcb)->index, pcb->fcAlg, pcb->characters, FILLP_GET_CONN(pcb)->peerFcAlgs, in FillpFcInit()
311 ret = pcb->algFuncs.fcInit(pcb); in FillpFcInit()
320 pcb->algFuncs.fcDeinit(pcb); in FillpFcDeinit()
333 … FILLP_GET_SOCKET(pcb)->index, pcb->pcbInst->curTime, pcb->recv.seqNum, pcb->recv.pktNum); in FillpFcDataInput()
[all …]
H A Dfillp_flow_control_alg0.c42 FillpCalSendInterval(pcb); in FillpAlg0CalSendInterval()
100 FillpAlg0FlowControlInit(pcb, alg); in FillpAlg0FcInit()
101 pcb->send.flowControl.fcAlg = alg; in FillpAlg0FcInit()
102 pcb->lastCalcTime = 0; in FillpAlg0FcInit()
106 pcb->send.retramistRto = (FILLP_ULLONG)pcb->rtt; in FillpAlg0FcInit()
109 FillpAlg0CalSendInterval(pcb); in FillpAlg0FcInit()
181 FillpAlg0CalSendInterval(pcb); in FillpAlg0FcHandleInit()
183 pcb->send.tailProtect.judgeThreshold = pcb->send.tailProtect.minJudgeThreshold; in FillpAlg0FcHandleInit()
203 FillpAlg0CalSendInterval(pcb); in FillpAlg0FcHandleBwProbe()
243 detaUs = pcb->pcbInst->curTime - pcb->statistics.debugPcb.packRecvedTimeInterval; in FillpAlg0AnalysePack()
[all …]
H A Dfillp_conn.c67 if ((pcb->recv.seqNum == pcb->recv.seqStartNum) && (pcb->send.maxAckNumFromReceiver == in FillpConnReqStateCheck()
467 FILLP_GET_CONN(pcb)->calcRttDuringConnect = pcb->rtt; in FillpConnReqAckInput()
725 if ((pcb->recv.seqNum == pcb->recv.seqStartNum) && (pcb->send.maxAckNumFromReceiver == in FillpConfirmCheckState()
1037 pcb->recv.endSeqNum = pcb->recv.seqStartNum; in FillpSaveConfirmActToPcb()
1038 pcb->statistics.pack.packPktNum = pcb->recv.pktNum; in FillpSaveConfirmActToPcb()
1351 pcb->send.pktNum = pcb->send.pktStartNum; in FillpSendConnReqBuild()
1352 pcb->send.ackSeqNum = pcb->send.seqStartNum; in FillpSendConnReqBuild()
1353 pcb->send.maxAckNumFromReceiver = pcb->send.ackSeqNum; in FillpSendConnReqBuild()
1354 pcb->send.seqNum = pcb->send.seqStartNum; in FillpSendConnReqBuild()
1356 pcb->localUniqueId = pcb->send.seqStartNum; in FillpSendConnReqBuild()
[all …]
H A Dfillp_output.c52 struct FillpPcb *pcb) in FillpGetSendItem() argument
65 item->seqNum = pcb->send.seqNum; in FillpGetSendItem()
114 pcb->send.unSendList.size, pcb->send.unackList.count, pcb->send.unrecvList.nodeNum, in FillpDoneSendAllData()
115 pcb->send.redunList.nodeNum, pcb->send.itemWaitTokenLists.nodeNum, in FillpDoneSendAllData()
121 FILLP_GET_SOCKET(pcb)->index, sendPktNum, (sentBytes / (FILLP_UINT32)pcb->pktSize)); in FillpDoneSendAllData()
127 pcb->sendmsgFunc(FILLP_NULL_PTR, FILLP_NULL_PTR, 0, pcb); in FillpDoneSendAllData()
154 pcb->isLast = FILLP_TRUE; in FillpBeforeSendItem()
234 FILLP_UNUSED_PARA(pcb); in FillpBuildPktDataOptions()
272 pcb->send.pktNum); in FillpBuildDataPkt()
475 if ((!pcb->statistics.pack.peerRtt) && pcb->rtt) { in FillpSetSimplePack()
[all …]
/ohos5.0/foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/src/
H A Dpcb.c214 pcb->conn = argConn; in SpungePcbNew()
215 pcb->fpcb.spcb = (void *)pcb; in SpungePcbNew()
216 pcb->fpcb.resInited = 0; in SpungePcbNew()
218 pcb->fpcb.mpRecvSize = 0; in SpungePcbNew()
219 pcb->fpcb.mpSendSize = 0; in SpungePcbNew()
221 pcb->fpcb.pcbInst = inst; in SpungePcbNew()
223 pcb->fpcb.peerUniqueId = 0; in SpungePcbNew()
243 return pcb; in SpungePcbNew()
280 pcb->addrType = addrType; in SpungePcbSetAddrType()
285 pcb->localPort = port; in SpungePcbSetLocalPort()
[all …]
H A Dnet.c64 SpungePcbSetPktSize(conn->pcb, pktSize); in NetconnSetPktSize()
69 SpungePcbSetOppositeRate(conn->pcb, rate); in NetconnSetOpersiteRate()
84 SpungePcbSetLocalPort(conn->pcb, port); in NetconnSetLocalPort()
89 SpungePcbSetAddrType(conn->pcb, addrType); in NetconnSetAddrType()
124 conn->pcb = SpungePcbNew(conn, inst); in FillpNetconnAlloc()
125 if (conn->pcb == FILLP_NULL_PTR) { in FillpNetconnAlloc()
131 conn->pcb->conn = conn; in FillpNetconnAlloc()
161 SpungePcbRemove(conn->pcb); in FillpNetconnDestroy()
162 conn->pcb = FILLP_NULL_PTR; in FillpNetconnDestroy()
252 conn->pcb->fpcb.statistics.keepAlive.lastRecvTime = conn->pcb->fpcb.pcbInst->curTime; in FillpNetconnSetState()
[all …]
H A Dspunge_stack.c394 struct FillpPcb *pcb = FILLP_NULL_PTR; in SpungeCheckDisconn() local
403 pcb = &conn->pcb->fpcb; in SpungeCheckDisconn()
423 sendPcb = &conn->pcb->fpcb.send; in SpungeCheckDisconn()
424 FillpAckSendPcb(&conn->pcb->fpcb, 0); in SpungeCheckDisconn()
437 pcb->finCheckTimer.interval = in SpungeCheckDisconn()
443 if (pcb->isFinAckReceived != FILLP_TRUE) { in SpungeCheckDisconn()
444 FillpSendFin(pcb); in SpungeCheckDisconn()
448 FillpEnableFinCheckTimer(pcb); in SpungeCheckDisconn()
517 FILLP_UNUSED_PARA(pcb); in SpungeFreeUnsendBox()
539 if (conn->pcb == FILLP_NULL_PTR) { in SpungeConnClosed()
[all …]
H A Dspunge_core.c97 sock->index, pcb->fpcb.send.unrecvList.nodeNum, pcb->fpcb.send.unackList.count); in SpungeCalExpectedBytes()
118 if ((pcb == FILLP_NULL_PTR) || (pcb->conn == FILLP_NULL_PTR)) { in SpungeDoSendCycle()
138 pcb->fpcb.algFuncs.updateExpectSendBytes(&pcb->fpcb, &bytesExpected); in SpungeDoSendCycle()
155 if ((pcb->fpcb.send.flowControl.remainBytes) || (!HLIST_EMPTY(&pcb->fpcb.send.unSendList)) || in SpungeDoSendCycle()
156 (pcb->fpcb.send.redunList.nodeNum) || (pcb->fpcb.send.unrecvList.nodeNum)) { in SpungeDoSendCycle()
942 fpcb = &(netconn->pcb->fpcb); in SpungeLoopCheckUnsendBox()
1161 pcb->fpcb.recv.oppositeSetRate = pcb->rateControl.recv.curMaxRateLimitation; in FillpCalculateFairness()
1164 pcb->fpcb.send.flowControl.sendRateLimit = pcb->rateControl.send.curMaxRateLimitation; in FillpCalculateFairness()
1190 if (pcb == FILLP_NULL_PTR) { in FillpCheckPcbNackListToSend()
1622 FillpDataToStack(pcb, item); in SpungePushRecvdDataToStack()
[all …]
H A Dsysio_udp.c382 struct SpungePcb *pcb = (struct SpungePcb *)argPcb; in SysioConnectUdp() local
384 FILLP_UINT32 addrHashKey = UtilsAddrHashKey((struct sockaddr_in *)&pcb->remoteAddr); 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
466 struct SpungePcb *pcb = (struct SpungePcb*)argPcb; in SysioSendPacketUdp() local
467 struct FtNetconn *conn = (struct FtNetconn *)pcb->conn; in SysioSendPacketUdp()
474 return pcb->fpcb.sendFunc(conn, sendBuf->p, sendBuf->len + FILLP_HLEN, pcb); in SysioSendPacketUdp()
478 return FillpSendConnReq(&pcb->fpcb); in SysioSendPacketUdp()
[all …]
/ohos5.0/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) argument
37 #define FILLP_GET_SOCKET(pcb) ((struct FtSocket*)(FILLP_GET_CONN(pcb)->sock)) argument
38 #define FILLP_GET_CONN_STATE(pcb) NETCONN_GET_STATE(FILLP_GET_CONN(pcb)) argument
42 #define FILLP_UNACKLIST_HASHINDEX(seqNum, pcb) \ argument
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_LLONG rtt);
49 void FillpFreeItemAndEvent(struct FillpPcb *pcb, struct FillpPcbItem *item);
50 void FillpAdjustFcParamsByRtt(struct FillpPcb *pcb);
52 IGNORE_OVERFLOW void FillpUploadRecvBox(struct FillpPcb *pcb);
[all …]
H A Dfillp.h395 void FillpSendConnConfirmAck(struct FillpPcb *pcb);
396 FILLP_INT FillpSendConnReq(struct FillpPcb *pcb);
397 void FillpSendFin(struct FillpPcb *pcb);
416 void FillpEnableSendTimer(struct FillpPcb *pcb);
417 void FillpDisableSendTimer(struct FillpPcb *pcb);
418 void FillpEnablePackTimer(struct FillpPcb *pcb);
419 void FillpDisablePackTimer(struct FillpPcb *pcb);
420 void FillpEnableFcTimer(struct FillpPcb *pcb);
421 void FillpDisableFcTimer(struct FillpPcb *pcb);
422 void FillpEnableKeepAliveTimer(struct FillpPcb *pcb);
[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_UINT32 ones);
[all …]
H A Dfillp_pcb.h238 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
246 return (pcb->send.directlySend == 0) ? FILLP_FALSE : FILLP_TRUE; in FillpPcbGetDirectlySend()
249 static __inline FILLP_UINT32 FillpPcbGetSendCacheSize(struct FillpPcb *pcb) in FillpPcbGetSendCacheSize() argument
251 return pcb->mpSendSize; in FillpPcbGetSendCacheSize()
255 void FillpRemovePcb(struct FillpPcb *pcb);
257 FILLP_UINT32 FillpGetSendpcbUnackListPktNum(struct FillpSendPcb *pcb);
258 FILLP_UINT32 FillpGetRecvpcbRecvlistPktNum(struct FillpRecvPcb *pcb);
[all …]
H A Dfillp_output.h29 FILLP_UINT32 FillpSendOne(struct FillpPcb *pcb, FILLP_UINT32 totalSendBytes, FILLP_UINT32 sendPktNu…
30 void FillpSendAdhocpackToDetectRtt(struct FillpPcb *pcb);
31 FILLP_BOOL FillpSendPackWithPcbBuffer(struct FillpPcb *pcb);
/ohos5.0/foundation/communication/dsoftbus/components/nstackx/fillp/src/app_lib/src/
H A Dapi.c1179 FILLP_SHOWDATABUTT("peerRtt: %u", pcb->pack.peerRtt); in FtFillpStatPackStat()
1279 … pcb->traffic.totalSend, pcb->traffic.totalSendBytes, pcb->traffic.totalSendFailed); in FtFillpStatTraffic()
1281 … pcb->traffic.totalRecved, pcb->traffic.totalRecvedBytes, pcb->traffic.totalDroped); in FtFillpStatTraffic()
1301 IN FILLP_CONST struct FillpStatisticsPcb *pcb) in FtFillpInnerStatShow() argument
1304 FtFillpStatPackStat(pcb); in FtFillpInnerStatShow()
1308 FtFillpStatKeepAlive(pcb); in FtFillpInnerStatShow()
1312 FtFillpStatDebugStat(pcb); in FtFillpInnerStatShow()
1316 FtFillpStatTraffic(pcb); in FtFillpInnerStatShow()
1339 struct FillpStatisticsPcb *pcb = FILLP_NULL_PTR; in FtFillpStatShow() local
1370 pcb = &(((struct FtNetconn *)sock->netconn)->pcb->fpcb.statistics); in FtFillpStatShow()
[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()
598 const struct FillpPcb *pcb = &sock->netconn->pcb->fpcb; in DoShowSockQos() local
599 const struct FillpStatisticsTraffic *traffic = &(pcb->statistics.traffic); in DoShowSockQos()
600 const struct FillAppFcStastics *appFcStastics = &(pcb->statistics.appFcStastics); in DoShowSockQos()
602 pcb->connTimestamp); in DoShowSockQos()
[all …]
/ohos5.0/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);
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_UINT16 addrType);
91 void SpungePcbSetLocalPort(struct SpungePcb *pcb, FILLP_INT port);
[all …]
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);
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);
/ohos5.0/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->a… in SpungeConnMsgGetSock()
373 struct SpungePcb *pcb = FILLP_NULL_PTR; in SpungeBindMsgCheckState() local
384 pcb = conn->pcb; in SpungeBindMsgCheckState()
385 if (pcb == FILLP_NULL_PTR) { in SpungeBindMsgCheckState()
411 *pPcb = pcb; in SpungeBindMsgCheckState()
440 err = memcpy_s(&pcb->localAddr, sizeof(pcb->localAddr), localAddr, addrLen); in SpungeHandleMsgBind()
456 …Sock->ioSock->ops->bind((void *)osSock->ioSock, (void *)conn->pcb, (struct sockaddr *)&pcb->localA… in SpungeHandleMsgBind()
527 … netconn->pcb->fpcb.recv.seqNum, netconn->pcb->fpcb.recv.pktNum, sock->resConf.flowControl.maxRate, in SpungeHandleMsgConnAccepted()
832 struct FillpPcb *pcb = &sock->netconn->pcb->fpcb; in SpungeHandleMsgSetKeepAlive() local
833 FillpDisableKeepAliveTimer(pcb); in SpungeHandleMsgSetKeepAlive()
[all …]
/ohos5.0/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)

12