/ohos5.0/foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/src/fillp/ |
H A D | fillp_timer.c | 44 static void FillpCalFcAppStastics(struct FillpPcb *pcb) in FillpCalFcAppStastics() 101 static void FillpCalRecvRate(struct FillpPcb *pcb) in FillpCalRecvRate() 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() 239 void FillpEnableFcTimer(struct FillpPcb *pcb) in FillpEnableFcTimer() 246 void FillpDisableFcTimer(struct FillpPcb *pcb) in FillpDisableFcTimer() 253 void FillpEnableKeepAliveTimer(struct FillpPcb *pcb) in FillpEnableKeepAliveTimer() 268 void FillpEnableDelayNackTimer(struct FillpPcb *pcb) in FillpEnableDelayNackTimer() [all …]
|
H A D | fillp_pcb.c | 119 static void FillpFreeRecvItemPool(struct FillpRecvPcb *pcb) in FillpFreeRecvItemPool() 133 struct FillpSendPcb *pcb = &fpcb->send; in InitSendPcbSimplePar() local 224 struct FillpSendPcb *pcb = &fpcb->send; in InitItemPool() local 255 struct FillpSendPcb *pcb = &fpcb->send; in FillpInitSendpcb() local 322 struct FillpRecvPcb *pcb = &fpcb->recv; in FillpInitRecvpcb() local 405 struct FillpStatisticsPcb *pcb = &fpcb->statistics; in FillpInitStastics() local 481 struct FillpRecvPcb *pcb = &fpcb->recv; in FillpPcbRemoveRecv() local 550 struct FillpSendPcb *pcb = &fpcb->send; in FillpPcbFreeSendItemArray() local 600 struct FillpSendPcb *pcb = &fpcb->send; in FillpPcbRemoveSend() local 644 static void FillpInitPcbTimeNode(struct FillpPcb *pcb) in FillpInitPcbTimeNode() [all …]
|
H A 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() 207 static int FillpAckUnrecvList(struct FillpPcb *pcb, FILLP_UINT32 seqNum) in FillpAckUnrecvList() 242 static void FillpAckRedunlist(struct FillpPcb *pcb, FILLP_UINT32 seqNum) in FillpAckRedunlist() 286 IGNORE_OVERFLOW static void FillpAckUnackList(struct FillpPcb *pcb, in FillpAckUnackList() 363 static void FillpSendAdhocpack(struct FillpPcb *pcb) in FillpSendAdhocpack() 381 IGNORE_OVERFLOW void FillpUploadRecvBox(struct FillpPcb *pcb) in FillpUploadRecvBox() 625 void FillpDataToStack(struct FillpPcb *pcb, struct FillpPcbItem *item) in FillpDataToStack() 709 static void FillpCalPackInterval(struct FillpPcb *pcb) in FillpCalPackInterval() 733 static void FillpCalNackDelayTimeByPackInterval(struct FillpPcb *pcb) in FillpCalNackDelayTimeByPackInterval() [all …]
|
H A 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
|
H A D | fillp_input.c | 59 static void FillpChangePackInteval(struct FillpPcb *pcb) in FillpChangePackInteval() 152 static void FillpProcessItemData(struct FillpPcb *pcb, struct FillpPcbItem *item, in FillpProcessItemData() 259 static void FillpHdlDataInput(struct FillpPcb *pcb, FILLP_CONST struct NetBuf *buf) in FillpHdlDataInput() 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() 433 static void FillpNackInput(struct FillpPcb *pcb, FILLP_CONST struct NetBuf *p) in FillpNackInput() 560 IGNORE_OVERFLOW static FILLP_BOOL FillpCheckPackNumber(struct FillpPcb *pcb, in FillpCheckPackNumber() 593 static void FillpHandleAdhocpackFlag(struct FillpPcb *pcb, struct FillpPktPack *pack) in FillpHandleAdhocpackFlag() 646 static void FillpHdlAdhocpack(struct FillpPcb *pcb, struct FillpPktPack *pack) in FillpHdlAdhocpack() 716 static void FillpPackInputLog(FILLP_CONST struct FillpPcb *pcb) in FillpPackInputLog() [all …]
|
H A D | fillp_flow_control.c | 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() 342 void FillpFcRecvDropOne(struct FillpPcb *pcb) in FillpFcRecvDropOne() 349 void FillpFcRecvOutOfOrder(struct FillpPcb *pcb) in FillpFcRecvOutOfOrder() 355 void FillpFcRecvLost(struct FillpPcb *pcb, FILLP_UINT32 ones) in FillpFcRecvLost() [all …]
|
H A D | fillp_output.c | 30 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() 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() 434 void FillpSendAdhocpackToDetectRtt(struct FillpPcb *pcb) in FillpSendAdhocpackToDetectRtt() 485 static FILLP_BOOL FillpSendPack(struct FillpPcb *pcb, struct FillpPktPack *pack) in FillpSendPack() [all …]
|
H A D | fillp_conn.c | 91 void FillpConnReqInput(struct FillpPcb *pcb, FILLP_CONST struct NetBuf *p) in FillpConnReqInput() 427 void FillpConnReqAckInput(struct FillpPcb *pcb, FILLP_CONST struct NetBuf *p) in FillpConnReqAckInput() 891 void FillpConnConnectionEstFailure(struct FillpPcb *pcb, FILLP_CONST struct NetBuf *p) in FillpConnConnectionEstFailure() 1042 void FillpConnConfirmAckInput(struct FillpPcb *pcb, FILLP_CONST struct NetBuf *p) in FillpConnConfirmAckInput() 1088 static void ConnectingHandleFinInput(struct FillpPcb *pcb, struct FtSocket *sock, in ConnectingHandleFinInput() 1375 FILLP_INT FillpSendConnReq(struct FillpPcb *pcb) in FillpSendConnReq() 1431 static FILLP_UINT16 FillpSendConnReqAckBuild(FILLP_CONST struct FillpPcb *pcb, in FillpSendConnReqAckBuild() 1694 void FillpSendConnConfirmAck(struct FillpPcb *pcb) in FillpSendConnConfirmAck() 1859 void FillpSendFin(struct FillpPcb *pcb) in FillpSendFin() 1877 void FillpSendFinAck(struct FillpPcb *pcb, struct sockaddr *remoteAddr) in FillpSendFinAck() [all …]
|
/ohos5.0/foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/src/ |
H A D | pcb.c | 62 struct SpungePcb *pcb = (struct SpungePcb *)ppcb; in SpungePcbSend() local 196 void SpcbAddPcbToSpinst(struct SpungeInstance *inst, struct SpungePcb *pcb) in SpcbAddPcbToSpinst() 201 void SpcbDeleteFromSpinst(struct SpungeInstance *inst, struct SpungePcb *pcb) in SpcbDeleteFromSpinst() 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() 271 void SpungePcbSetPackInterval(struct SpungePcb *pcb, FILLP_UINT32 interval) in SpungePcbSetPackInterval() 278 void SpungePcbSetAddrType(struct SpungePcb *pcb, FILLP_UINT16 addrType) in SpungePcbSetAddrType() 283 void SpungePcbSetLocalPort(struct SpungePcb *pcb, FILLP_INT port) in SpungePcbSetLocalPort() 288 void SpungePcbSetDirectlySend(struct SpungePcb *pcb, FILLP_INT directlySend) in SpungePcbSetDirectlySend() [all …]
|
H A D | spunge_stack.c | 375 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()
|
H A D | sysio_udp.c | 382 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
|
H A D | spunge_core.c | 73 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
|
/ohos5.0/foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/include/fillp/ |
H A 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
|
H A D | fillp_pcb.h | 238 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()
|
/ohos5.0/foundation/communication/dsoftbus/components/nstackx/fillp/src/app_lib/src/ |
H A D | api.c | 1165 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
|
H A D | fillp_dfx.c | 283 const struct FillpPcb *pcb = &sock->netconn->pcb->fpcb; in FillpDfxSockQosNotify() local 598 const struct FillpPcb *pcb = &sock->netconn->pcb->fpcb; in DoShowSockQos() local
|
/ohos5.0/foundation/communication/dsoftbus/components/nstackx/fillp/src/public/src/ |
H A D | spunge_message.c | 373 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
|
/ohos5.0/foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/include/ |
H A D | net.h | 59 struct SpungePcb *pcb; member
|