| /foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/src/fillp/ |
| D | fillp_timer.c | 28 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 …]
|
| D | fillp_pcb.c | 31 #define FILLP_PCB_GET_CONN(pcb) (struct FtNetconn *)((struct SpungePcb *)((pcb)->spcb))->conn argument
57 static FILLP_INT FillpInitSendpcbUnackList(struct FillpSendPcb *pcb) in FillpInitSendpcbUnackList()
78 static FILLP_INT FillpInitSendpcbPktSeqMap(struct FillpPcb *fpcb, struct FillpSendPcb *pcb) in FillpInitSendpcbPktSeqMap()
118 static void FillpFreeRecvItemPool(struct FillpRecvPcb *pcb) in FillpFreeRecvItemPool()
124 static void FillpFreeSendItemPool(struct FillpSendPcb *pcb) in FillpFreeSendItemPool()
132 struct FillpSendPcb *pcb = &fpcb->send; in InitSendPcbSimplePar() local
179 static FILLP_INT InitSimplePcbPar(struct FillpSendPcb *pcb, struct FillpPcb *fpcb) in InitSimplePcbPar()
223 struct FillpSendPcb *pcb = &fpcb->send; in InitItemPool() local
254 struct FillpSendPcb *pcb = &fpcb->send; in FillpInitSendpcb() local
292 static FillpQueue *FillpInitRecvPcbBox(struct FillpPcb *fpcb, struct FillpRecvPcb *pcb) in FillpInitRecvPcbBox()
[all …]
|
| D | fillp_common.c | 26 void FillpFreeItemAndEvent(struct FillpPcb *pcb, struct FillpPcbItem *item) in FillpFreeItemAndEvent()
35 void InsertUnrecvListFail(struct FillpPcb *pcb, struct FillpPcbItem *item) in InsertUnrecvListFail()
68 void FillpMoveUnackToUnrecv(FILLP_UINT32 ackSeq, FILLP_UINT32 lostSeq, struct FillpPcb *pcb, in FillpMoveUnackToUnrecv()
74 static FILLP_BOOL FillpMoveOneNode(struct Hlist *list, FILLP_UINT32 lostSeq, struct FillpPcb *pcb, in FillpMoveOneNode()
131 void FillpMoveUnackToUnrecvAll(FILLP_UINT32 ackSeq, FILLP_UINT32 lostSeq, struct FillpPcb *pcb, in FillpMoveUnackToUnrecvAll()
182 static void FillpAckItemWaitTklist(struct FillpPcb *pcb, FILLP_UINT32 seqNum) in FillpAckItemWaitTklist()
213 static int FillpAckUnrecvList(struct FillpPcb *pcb, FILLP_UINT32 seqNum) in FillpAckUnrecvList()
248 static void FillpAckRedunlist(struct FillpPcb *pcb, FILLP_UINT32 seqNum) in FillpAckRedunlist()
279 static void FreeUnackList(struct FillpPcb *pcb, struct FillpPcbItem *item, struct Hlist *tempCtl) in FreeUnackList()
294 static void FillpAckUnackList(struct FillpPcb *pcb, FILLP_UINT32 curSeq, FILLP_INT cntLimit) in FillpAckUnackList()
[all …]
|
| D | fillp_flow_control_alg0.c | 30 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
|
| D | fillp_input.c | 57 static void FillpChangePackInteval(struct FillpPcb *pcb) in FillpChangePackInteval()
74 static FILLP_INT FillpProcessDataOptions(FillpDataOption *dataOption, struct FillpPcb *pcb, struct … in FillpProcessDataOptions()
106 static FILLP_INT FillpAnalysisDataOptions(struct FillpPcb *pcb, struct FillpPcbItem *item) in FillpAnalysisDataOptions()
151 static void FillpProcessItemData(struct FillpPcb *pcb, struct FillpPcbItem *item, in FillpProcessItemData()
191 static void FillpDataInput(struct FillpPcb *pcb, struct FillpPcbItem *item) in FillpDataInput()
224 static void ProcessPcbItem(struct FillpPcb *pcb, FILLP_CONST struct NetBuf *buf, struct FillpPcbIte… in ProcessPcbItem()
269 static void FillpHdlDataInput(struct FillpPcb *pcb, FILLP_CONST struct NetBuf *buf) in FillpHdlDataInput()
307 static int FillpCheckNackPacket(FILLP_CONST struct FillpPcb *pcb, FILLP_CONST struct NetBuf *p) in FillpCheckNackPacket()
324 static int FillpCheckNackSeq(FILLP_CONST struct FillpPcb *pcb, FILLP_CONST struct FillpPktHead *pkt… in FillpCheckNackSeq()
387 static FILLP_UINT32 ProtectLongLoopRun(struct FillpPcb *pcb, FILLP_UINT32 identifyGap, in ProtectLongLoopRun()
[all …]
|
| D | fillp_flow_control.c | 123 FILLP_BOOL FillpAppLimitedStatus(struct FillpPcb *pcb, FILLP_UINT32 beginPktNum, FILLP_UINT32 endPk… in FillpAppLimitedStatus()
163 void FillpCalSendInterval(struct FillpPcb *pcb) in FillpCalSendInterval()
191 void FillpFcTailProtected(struct FillpPcb *pcb, struct FillpPktPack *pack) in FillpFcTailProtected()
237 void FillpFcPackInput(struct FillpPcb *pcb, struct FillpPktPack *pack) in FillpFcPackInput()
250 void FillpFcNackInput(struct FillpPcb *pcb, struct FillpPktNack *nack) in FillpFcNackInput()
257 static int FillpGetAlgFun(struct FillpPcb *pcb) in FillpGetAlgFun()
273 FILLP_INT FillpFcInit(struct FillpPcb *pcb) in FillpFcInit()
322 void FillpFcDeinit(struct FillpPcb *pcb) in FillpFcDeinit()
331 void FillpFcDataInput(struct FillpPcb *pcb, FILLP_CONST struct FillpPktHead *pkt) in FillpFcDataInput()
349 void FillpFcRecvDropOne(struct FillpPcb *pcb) in FillpFcRecvDropOne()
[all …]
|
| D | fillp_output.c | 30 static void FillpMoveRedundantItemToUnrecvList(struct FillpPcb *pcb) in FillpMoveRedundantItemToUnrecvList()
52 static struct FillpPcbItem *FillpGetSendItem(struct FillpSendPcb *sendPcb, 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()
238 static void FillpBuildDataPkt(struct FillpPcb *pcb, struct FillpPcbItem *item) in FillpBuildDataPkt()
330 static FillpErrorType FillpAddToUnackList(struct FillpPcb *pcb, struct FillpPcbItem *item) in FillpAddToUnackList()
348 static void FillpAddToPktSeqHash(FILLP_CONST struct FillpPcb *pcb, struct FillpPcbItem *item) in FillpAddToPktSeqHash()
[all …]
|
| D | fillp_conn.c | 31 static void FillpConnReqInputTrace(FILLP_CONST struct FillpPcb *pcb, FILLP_CONST struct FtSocket *s… in FillpConnReqInputTrace()
61 static FILLP_INT FillpConnReqStateCheck(struct FillpPcb *pcb, FILLP_CONST struct FtSocket *sock) in FillpConnReqStateCheck()
89 void FillpConnReqInput(struct FillpPcb *pcb, FILLP_CONST struct NetBuf *p) in FillpConnReqInput()
349 static FILLP_INT32 FillpDecodeConnReqAckClientPara(struct FillpPcb *pcb, FILLP_CONST struct NetBuf … in FillpDecodeConnReqAckClientPara()
402 void FillpConnReqAckInput(struct FillpPcb *pcb, FILLP_CONST struct NetBuf *p) in FillpConnReqAckInput()
536 static FILLP_INT FillpInitNewConnByConfirm(struct FillpPcb *pcb, struct FtNetconn *newConn, in FillpInitNewConnByConfirm()
608 static void FillpProcessConnConfirm(struct FillpPcb *pcb, FILLP_CONST struct NetBuf *p, in FillpProcessConnConfirm()
700 …LLP_BOOL FillpConfirmCheckState(FILLP_UINT8 connState, struct FtSocket *sock, struct FillpPcb *pcb) in FillpConfirmCheckState()
726 void FillpConnConfirmInput(struct FillpPcb *pcb, FILLP_CONST struct NetBuf *p, struct SpungeInstanc… in FillpConnConfirmInput()
788 …FillpHandleConnConfirmAckInput(struct FtSocket *sock, struct FtNetconn *conn, struct FillpPcb *pcb, in FillpHandleConnConfirmAckInput()
[all …]
|
| /foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/src/ |
| D | pcb.c | 61 struct SpungePcb *pcb = (struct SpungePcb *)ppcb; in SpungePcbSend() local
149 FILLP_INT SpungePcbSendmsg(void *arg, FILLP_CONST char *buf, FILLP_INT size, void *pcb) in SpungePcbSendmsg()
192 void SpcbAddPcbToSpinst(struct SpungeInstance *inst, struct SpungePcb *pcb) in SpcbAddPcbToSpinst()
197 void SpcbDeleteFromSpinst(struct SpungeInstance *inst, struct SpungePcb *pcb) in SpcbDeleteFromSpinst()
204 …struct SpungePcb *pcb = (struct SpungePcb *)SpungeAlloc(1, sizeof(struct SpungePcb), SPUNGE_ALLOC_… in SpungePcbNew() local
242 void SpungePcbSetSendCacheSize(struct SpungePcb *pcb, FILLP_UINT32 cacheSize) in SpungePcbSetSendCacheSize()
247 void SpungePcbSetRecvCacheSize(struct SpungePcb *pcb, FILLP_UINT32 cacheSize) in SpungePcbSetRecvCacheSize()
252 void SpungePcbSetPktSize(struct SpungePcb *pcb, FILLP_UINT32 pktSize) in SpungePcbSetPktSize()
257 void SpungePcbSetOppositeRate(struct SpungePcb *pcb, FILLP_UINT32 rate) in SpungePcbSetOppositeRate()
262 void SpungePcbSetSlowStart(struct SpungePcb *pcb, FILLP_BOOL slowStart) in SpungePcbSetSlowStart()
[all …]
|
| D | spunge_stack.c | 385 static int SpungeDestroyNoWait(struct FillpPcb *pcb, struct FtSocket *sock, struct FtNetconn *conn) in SpungeDestroyNoWait()
404 struct FillpPcb *pcb = FILLP_NULL_PTR; in SpungeCheckDisconn() local
528 void SpungeFreeUnsendBox(struct FillpPcb *pcb) in SpungeFreeUnsendBox()
|
| D | sysio_udp.c | 382 struct SpungePcb *pcb = (struct SpungePcb *)argPcb; in SysioConnectUdp() local
393 struct SpungePcb *pcb = (struct SpungePcb*)argPcb; in SysioRemovePcbUdp() local
438 struct SpungePcb *pcb = (struct SpungePcb *)argPcb; in SysioHandlePacketUdp() local
468 struct SpungePcb *pcb = (struct SpungePcb*)argPcb; in SysioSendPacketUdp() local
|
| D | spunge_core.c | 72 static FILLP_UINT32 SpungeCalExpectedBytes(FILLP_UINT32 *sendPktNum, struct SpungePcb *pcb, in SpungeCalExpectedBytes()
100 static void SpungeDoSendUpdate(struct SpungePcb *pcb, FILLP_UINT32 sendBytes, FILLP_UINT32 bytesExp… in SpungeDoSendUpdate()
110 void SpungeDoSendCycle(struct SpungePcb *pcb, struct SpungeInstance *inst, FILLP_LLONG detaTime) in SpungeDoSendCycle()
1110 struct SpungePcb *pcb = FILLP_NULL_PTR; in FillpCalculateFairness() local
1188 struct SpungePcb *pcb = ((struct FillpPcb *)args)->spcb; in FillpCheckPcbNackListToSend() local
1626 struct FillpPcb *pcb = (struct FillpPcb *)arg; in SpungePushRecvdDataToStack() local
|
| /foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/include/fillp/ |
| D | fillp_common.h | 36 #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
|
| D | fillp_pcb.h | 236 static __inline FILLP_UINT32 FillpPcbGetTotalPktCnt(struct FillpPcb *pcb) in FillpPcbGetTotalPktCnt()
242 static __inline FILLP_BOOL FillpPcbGetDirectlySend(struct FillpPcb *pcb) in FillpPcbGetDirectlySend()
247 static __inline FILLP_UINT32 FillpPcbGetSendCacheSize(struct FillpPcb *pcb) in FillpPcbGetSendCacheSize()
|
| /foundation/communication/dsoftbus/components/nstackx/fillp/src/app_lib/src/ |
| D | api.c | 1166 void FtFillpStatPackStat(FILLP_CONST struct FillpStatisticsPcb *pcb) in FtFillpStatPackStat()
1203 void FtFillpStatKeepAlive(FILLP_CONST struct FillpStatisticsPcb *pcb) in FtFillpStatKeepAlive()
1225 void FtFillpStatDebugStat(FILLP_CONST struct FillpStatisticsPcb *pcb) in FtFillpStatDebugStat()
1277 void FtFillpStatTraffic(FILLP_CONST struct FillpStatisticsPcb *pcb) in FtFillpStatTraffic()
1302 IN FILLP_CONST struct FillpStatisticsPcb *pcb) in FtFillpInnerStatShow()
1340 struct FillpStatisticsPcb *pcb = FILLP_NULL_PTR; in FtFillpStatShow() local
|
| /foundation/communication/dsoftbus/components/nstackx/fillp/src/public/src/ |
| D | spunge_message.c | 375 struct SpungePcb *pcb = FILLP_NULL_PTR; in SpungeBindMsgCheckState() local
423 struct SpungePcb *pcb = FILLP_NULL_PTR; in SpungeHandleMsgBind() local
773 struct SpungePcb *pcb = FILLP_NULL_PTR; in SpungeHandleMsgSetNackDelay() local
839 struct FillpPcb *pcb = &sock->netconn->pcb->fpcb; in SpungeHandleMsgSetKeepAlive() local
|
| /foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/include/ |
| D | net.h | 59 struct SpungePcb *pcb; member
|