Home
last modified time | relevance | path

Searched defs:pcb (Results 1 – 18 of 18) sorted by relevance

/foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/src/fillp/
Dfillp_timer.c28 static void FillpEnablePackTimerInCb(struct FillpPcb *pcb, FILLP_BOOL enNormalPackTimer) in FillpEnablePackTimerInCb()
34 static void LogFcFcAppStastics(const struct FillpPcb *pcb, const struct FillAppFcStastics *appFcSta… in LogFcFcAppStastics()
44 static void FillpCalFcAppStastics(struct FillpPcb *pcb) in FillpCalFcAppStastics()
101 static void FillpCalRecvRate(struct FillpPcb *pcb) in FillpCalRecvRate()
150 struct FillpPcb *pcb = (struct FillpPcb *)argPcb; in FillpPackTimerCb() local
181 struct FillpPcb *pcb = (struct FillpPcb *)argPcb; in FillpSendTimerCb() local
195 void FillpEnableSendTimer(struct FillpPcb *pcb) in FillpEnableSendTimer()
215 void FillpDisableSendTimer(struct FillpPcb *pcb) in FillpDisableSendTimer()
222 void FillpEnablePackTimer(struct FillpPcb *pcb) in FillpEnablePackTimer()
232 void FillpDisablePackTimer(struct FillpPcb *pcb) in FillpDisablePackTimer()
[all …]
Dfillp_pcb.c31 #define FILLP_PCB_GET_CONN(pcb) (struct FtNetconn *)((struct SpungePcb *)((pcb)->spcb))->conn argument
58 static FILLP_INT FillpInitSendpcbUnackList(struct FillpSendPcb *pcb) in FillpInitSendpcbUnackList()
79 static FILLP_INT FillpInitSendpcbPktSeqMap(struct FillpPcb *fpcb, struct FillpSendPcb *pcb) in FillpInitSendpcbPktSeqMap()
119 static void FillpFreeRecvItemPool(struct FillpRecvPcb *pcb) in FillpFreeRecvItemPool()
125 static void FillpFreeSendItemPool(struct FillpSendPcb *pcb) in FillpFreeSendItemPool()
133 struct FillpSendPcb *pcb = &fpcb->send; in InitSendPcbSimplePar() local
180 static FILLP_INT InitSimplePcbPar(struct FillpSendPcb *pcb, struct FillpPcb *fpcb) in InitSimplePcbPar()
224 struct FillpSendPcb *pcb = &fpcb->send; in InitItemPool() local
255 struct FillpSendPcb *pcb = &fpcb->send; in FillpInitSendpcb() local
293 static FillpQueue *FillpInitRecvPcbBox(struct FillpPcb *fpcb, struct FillpRecvPcb *pcb) in FillpInitRecvPcbBox()
[all …]
Dfillp_common.c26 void FillpFreeItemAndEvent(struct FillpPcb *pcb, struct FillpPcbItem *item) in FillpFreeItemAndEvent()
35 void InsertUnrecvListFail(struct FillpPcb *pcb, struct FillpPcbItem *item) in InsertUnrecvListFail()
66 void FillpMoveUnackToUnrecv(FILLP_UINT32 ackSeq, FILLP_UINT32 lostSeq, struct FillpPcb *pcb, in FillpMoveUnackToUnrecv()
72 static FILLP_BOOL FillpMoveOneNode(struct Hlist *list, FILLP_UINT32 lostSeq, struct FillpPcb *pcb, in FillpMoveOneNode()
129 void FillpMoveUnackToUnrecvAll(FILLP_UINT32 ackSeq, FILLP_UINT32 lostSeq, struct FillpPcb *pcb, in FillpMoveUnackToUnrecvAll()
178 static void FillpAckItemWaitTklist(struct FillpPcb *pcb, FILLP_UINT32 seqNum) in FillpAckItemWaitTklist()
207 static int FillpAckUnrecvList(struct FillpPcb *pcb, FILLP_UINT32 seqNum) in FillpAckUnrecvList()
242 static void FillpAckRedunlist(struct FillpPcb *pcb, FILLP_UINT32 seqNum) in FillpAckRedunlist()
271 static void FreeUnackList(struct FillpPcb *pcb, struct FillpPcbItem *item, struct Hlist *tempCtl) in FreeUnackList()
286 IGNORE_OVERFLOW static void FillpAckUnackList(struct FillpPcb *pcb, in FillpAckUnackList()
[all …]
Dfillp_flow_control_alg0.c30 void FillpAlg0CalSendInterval(struct FillpPcb *pcb) in FillpAlg0CalSendInterval()
52 static void FillpAlg0FlowControlInit(struct FillpPcb *pcb, struct FillpFlowControlAlg0 *alg) in FillpAlg0FlowControlInit()
80 struct FillpPcb *pcb = (struct FillpPcb *)argPcb; in FillpAlg0FcInit() local
119 struct FillpPcb *pcb = (struct FillpPcb *)argPcb; in FillpAlg0FcDeinit() local
137 struct FillpPcb *pcb = (struct FillpPcb *)argPcb; in FillpAlg0CalPackInterval() local
142 static void FillpAlg0CalMaxPackRcvInterval(struct FillpPcb *pcb, FILLP_LLONG detaUs, FILLP_UINT32 p… in FillpAlg0CalMaxPackRcvInterval()
156 static void FillpAlg0FcHandleInit(struct FillpPcb *pcb, FILLP_CONST struct FillpPktPack *pack) in FillpAlg0FcHandleInit()
189 static void FillpAlg0FcHandleBwProbe(struct FillpPcb *pcb, FILLP_CONST struct FillpPktPack *pack) in FillpAlg0FcHandleBwProbe()
206 static void FillpAlg0PackStateProcess(struct FillpPcb *pcb, struct FillpPktPack *pack) in FillpAlg0PackStateProcess()
237 struct FillpPcb *pcb = (struct FillpPcb *)argPcb; in FillpAlg0AnalysePack() local
Dfillp_input.c59 static void FillpChangePackInteval(struct FillpPcb *pcb) in FillpChangePackInteval()
75 static FILLP_INT FillpProcessDataOptions(FillpDataOption *dataOption, struct FillpPcb *pcb, struct … in FillpProcessDataOptions()
107 static FILLP_INT FillpAnalysisDataOptions(struct FillpPcb *pcb, struct FillpPcbItem *item) in FillpAnalysisDataOptions()
152 static void FillpProcessItemData(struct FillpPcb *pcb, struct FillpPcbItem *item, in FillpProcessItemData()
188 IGNORE_OVERFLOW static void FillpDataInput(struct FillpPcb *pcb, struct FillpPcbItem *item) in FillpDataInput()
221 static void ProcessPcbItem(struct FillpPcb *pcb, FILLP_CONST struct NetBuf *buf, struct FillpPcbIte… in ProcessPcbItem()
259 static void FillpHdlDataInput(struct FillpPcb *pcb, FILLP_CONST struct NetBuf *buf) in FillpHdlDataInput()
298 static int FillpCheckNackPacket(FILLP_CONST struct FillpPcb *pcb, FILLP_CONST struct NetBuf *p) in FillpCheckNackPacket()
315 IGNORE_OVERFLOW static int FillpCheckNackSeq(FILLP_CONST struct FillpPcb *pcb, in FillpCheckNackSeq()
377 static FILLP_UINT32 ProtectLongLoopRun(struct FillpPcb *pcb, FILLP_UINT32 identifyGap, in ProtectLongLoopRun()
[all …]
Dfillp_flow_control.c124 FILLP_BOOL FillpAppLimitedStatus(struct FillpPcb *pcb, FILLP_UINT32 beginPktNum, FILLP_UINT32 endPk… in FillpAppLimitedStatus()
164 void FillpCalSendInterval(struct FillpPcb *pcb) in FillpCalSendInterval()
190 void FillpFcTailProtected(struct FillpPcb *pcb, struct FillpPktPack *pack) in FillpFcTailProtected()
234 void FillpFcPackInput(struct FillpPcb *pcb, struct FillpPktPack *pack) in FillpFcPackInput()
245 void FillpFcNackInput(struct FillpPcb *pcb, struct FillpPktNack *nack) in FillpFcNackInput()
252 static int FillpGetAlgFun(struct FillpPcb *pcb) in FillpGetAlgFun()
268 FILLP_INT FillpFcInit(struct FillpPcb *pcb) in FillpFcInit()
317 void FillpFcDeinit(struct FillpPcb *pcb) in FillpFcDeinit()
326 void FillpFcDataInput(struct FillpPcb *pcb, FILLP_CONST struct FillpPktHead *pkt) in FillpFcDataInput()
342 void FillpFcRecvDropOne(struct FillpPcb *pcb) in FillpFcRecvDropOne()
[all …]
Dfillp_output.c30 static void FillpMoveRedundantItemToUnrecvList(struct FillpPcb *pcb) in FillpMoveRedundantItemToUnrecvList()
52 struct FillpPcb *pcb) in FillpGetSendItem()
81 static FILLP_BOOL FillpIsAskMoreBuf(struct FillpSendPcb *sendPcb, struct FillpPcb *pcb) in FillpIsAskMoreBuf()
103 static void FillpDoneSendAllData(struct FillpSendPcb *sendPcb, struct FillpPcb *pcb, in FillpDoneSendAllData()
132 static FILLP_UINT32 FillpBeforeSendItem(struct FillpPcbItem *item, struct FillpPcb *pcb, in FillpBeforeSendItem()
161 FILLP_UINT32 FillpSendOne(struct FillpPcb *pcb, FILLP_UINT32 totalBytes, FILLP_UINT32 sendPktNum) in FillpSendOne()
219 static void FillpBuildPktDataOptions(FILLP_CONST struct FillpPcb *pcb, in FillpBuildPktDataOptions()
237 static void FillpBuildDataPkt(struct FillpPcb *pcb, struct FillpPcbItem *item) in FillpBuildDataPkt()
326 static FillpErrorType FillpAddToUnackList(struct FillpPcb *pcb, struct FillpPcbItem *item) in FillpAddToUnackList()
344 static void FillpAddToPktSeqHash(FILLP_CONST struct FillpPcb *pcb, struct FillpPcbItem *item) in FillpAddToPktSeqHash()
[all …]
Dfillp_conn.c33 static void FillpConnReqInputTrace(FILLP_CONST struct FillpPcb *pcb, FILLP_CONST struct FtSocket *s… in FillpConnReqInputTrace()
63 static FILLP_INT FillpConnReqStateCheck(struct FillpPcb *pcb, FILLP_CONST struct FtSocket *sock) in FillpConnReqStateCheck()
91 void FillpConnReqInput(struct FillpPcb *pcb, FILLP_CONST struct NetBuf *p) in FillpConnReqInput()
371 static FILLP_INT32 FillpDecodeConnReqAckClientPara(struct FillpPcb *pcb, FILLP_CONST struct NetBuf … in FillpDecodeConnReqAckClientPara()
427 void FillpConnReqAckInput(struct FillpPcb *pcb, FILLP_CONST struct NetBuf *p) in FillpConnReqAckInput()
559 static FILLP_INT FillpInitNewConnByConfirm(struct FillpPcb *pcb, struct FtNetconn *newConn, in FillpInitNewConnByConfirm()
631 static void FillpProcessConnConfirm(struct FillpPcb *pcb, FILLP_CONST struct NetBuf *p, in FillpProcessConnConfirm()
722 …LLP_BOOL FillpConfirmCheckState(FILLP_UINT8 connState, struct FtSocket *sock, struct FillpPcb *pcb) in FillpConfirmCheckState()
748 void FillpConnConfirmInput(struct FillpPcb *pcb, FILLP_CONST struct NetBuf *p, struct SpungeInstanc… in FillpConnConfirmInput()
811 …FillpHandleConnConfirmAckInput(struct FtSocket *sock, struct FtNetconn *conn, struct FillpPcb *pcb, in FillpHandleConnConfirmAckInput()
[all …]
/foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/src/
Dpcb.c62 struct SpungePcb *pcb = (struct SpungePcb *)ppcb; in SpungePcbSend() local
153 FILLP_INT SpungePcbSendmsg(void *arg, FILLP_CONST char *buf, FILLP_INT size, void *pcb) in SpungePcbSendmsg()
196 void SpcbAddPcbToSpinst(struct SpungeInstance *inst, struct SpungePcb *pcb) in SpcbAddPcbToSpinst()
201 void SpcbDeleteFromSpinst(struct SpungeInstance *inst, struct SpungePcb *pcb) in SpcbDeleteFromSpinst()
208 …struct SpungePcb *pcb = (struct SpungePcb *)SpungeAlloc(1, sizeof(struct SpungePcb), SPUNGE_ALLOC_… in SpungePcbNew() local
246 void SpungePcbSetSendCacheSize(struct SpungePcb *pcb, FILLP_UINT32 cacheSize) in SpungePcbSetSendCacheSize()
251 void SpungePcbSetRecvCacheSize(struct SpungePcb *pcb, FILLP_UINT32 cacheSize) in SpungePcbSetRecvCacheSize()
256 void SpungePcbSetPktSize(struct SpungePcb *pcb, FILLP_UINT32 pktSize) in SpungePcbSetPktSize()
261 void SpungePcbSetOppositeRate(struct SpungePcb *pcb, FILLP_UINT32 rate) in SpungePcbSetOppositeRate()
266 void SpungePcbSetSlowStart(struct SpungePcb *pcb, FILLP_BOOL slowStart) in SpungePcbSetSlowStart()
[all …]
Dspunge_stack.c375 static int SpungeDestroyNoWait(struct FillpPcb *pcb, struct FtSocket *sock, struct FtNetconn *conn) in SpungeDestroyNoWait()
394 struct FillpPcb *pcb = FILLP_NULL_PTR; in SpungeCheckDisconn() local
515 void SpungeFreeUnsendBox(struct FillpPcb *pcb) in SpungeFreeUnsendBox()
Dsysio_udp.c382 struct SpungePcb *pcb = (struct SpungePcb *)argPcb; in SysioConnectUdp() local
393 struct SpungePcb *pcb = (struct SpungePcb*)argPcb; in SysioRemovePcbUdp() local
436 struct SpungePcb *pcb = (struct SpungePcb *)argPcb; in SysioHandlePacketUdp() local
466 struct SpungePcb *pcb = (struct SpungePcb*)argPcb; in SysioSendPacketUdp() local
Dspunge_core.c73 static FILLP_UINT32 SpungeCalExpectedBytes(FILLP_UINT32 *sendPktNum, struct SpungePcb *pcb, in SpungeCalExpectedBytes()
101 static void SpungeDoSendUpdate(struct SpungePcb *pcb, FILLP_UINT32 sendBytes, FILLP_UINT32 bytesExp… in SpungeDoSendUpdate()
111 void SpungeDoSendCycle(struct SpungePcb *pcb, struct SpungeInstance *inst, FILLP_LLONG detaTime) in SpungeDoSendCycle()
1108 struct SpungePcb *pcb = FILLP_NULL_PTR; in FillpCalculateFairness() local
1184 struct SpungePcb *pcb = ((struct FillpPcb *)args)->spcb; in FillpCheckPcbNackListToSend() local
1619 struct FillpPcb *pcb = (struct FillpPcb *)arg; in SpungePushRecvdDataToStack() local
/foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/include/fillp/
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
Dfillp_pcb.h238 static __inline FILLP_UINT32 FillpPcbGetTotalPktCnt(struct FillpPcb *pcb) in FillpPcbGetTotalPktCnt()
244 static __inline FILLP_BOOL FillpPcbGetDirectlySend(struct FillpPcb *pcb) in FillpPcbGetDirectlySend()
249 static __inline FILLP_UINT32 FillpPcbGetSendCacheSize(struct FillpPcb *pcb) in FillpPcbGetSendCacheSize()
/foundation/communication/dsoftbus/components/nstackx/fillp/src/app_lib/src/
Dapi.c1165 void FtFillpStatPackStat(FILLP_CONST struct FillpStatisticsPcb *pcb) in FtFillpStatPackStat()
1202 void FtFillpStatKeepAlive(FILLP_CONST struct FillpStatisticsPcb *pcb) in FtFillpStatKeepAlive()
1224 void FtFillpStatDebugStat(FILLP_CONST struct FillpStatisticsPcb *pcb) in FtFillpStatDebugStat()
1276 void FtFillpStatTraffic(FILLP_CONST struct FillpStatisticsPcb *pcb) in FtFillpStatTraffic()
1301 IN FILLP_CONST struct FillpStatisticsPcb *pcb) in FtFillpInnerStatShow()
1339 struct FillpStatisticsPcb *pcb = FILLP_NULL_PTR; in FtFillpStatShow() local
Dfillp_dfx.c283 const struct FillpPcb *pcb = &sock->netconn->pcb->fpcb; in FillpDfxSockQosNotify() local
598 const struct FillpPcb *pcb = &sock->netconn->pcb->fpcb; in DoShowSockQos() local
/foundation/communication/dsoftbus/components/nstackx/fillp/src/public/src/
Dspunge_message.c373 struct SpungePcb *pcb = FILLP_NULL_PTR; in SpungeBindMsgCheckState() local
421 struct SpungePcb *pcb = FILLP_NULL_PTR; in SpungeHandleMsgBind() local
768 struct SpungePcb *pcb = FILLP_NULL_PTR; in SpungeHandleMsgSetNackDelay() local
832 struct FillpPcb *pcb = &sock->netconn->pcb->fpcb; in SpungeHandleMsgSetKeepAlive() local
/foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/include/
Dnet.h59 struct SpungePcb *pcb; member