Home
last modified time | relevance | path

Searched refs:fpcb (Results 1 - 22 of 22) sorted by relevance

/foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/src/
H A Dpcb.c36 FillpErrorType err = FillpQueuePush(conn->pcb->fpcb.recv.recvBox, buf, FILLP_TRUE, (FILLP_UINT)count); in SpungePcbRecv()
134 ret = spcb->fpcb.sendFunc(conn, conn->sendIov[i].iov_base, conn->sendIov[i].iov_len, spcb); in SpungePcbSendmsgInner()
147 spcb->fpcb.sendmsgEio = FILLP_TRUE; in SpungePcbSendmsgInner()
157 struct FillpPcb *fpcb = (struct FillpPcb *)pcb; in SpungePcbSendmsg() local
158 struct SpungePcb *spcb = (struct SpungePcb *)fpcb->spcb; in SpungePcbSendmsg()
189 if ((conn->iovCount < UDP_MAX_SEG) && (fpcb->isLast == FILLP_FALSE) && send == FILLP_FALSE) { in SpungePcbSendmsg()
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 in SpungePcbNew()
[all...]
H A Dfillp_buf_item.c31 pcbItem->fpcb = FILLP_NULL_PTR; in FillpCreateDympCreateCb()
62 struct FillpPcb *fpcb = FILLP_NULL_PTR; in FillpFreeBufItem() local
66 fpcb = (struct FillpPcb *)(((struct FillpPcbItem *)data)->fpcb); in FillpFreeBufItem()
67 if ((fpcb != FILLP_NULL_PTR) && (fpcb->send.preItem == data)) { in FillpFreeBufItem()
68 fpcb->send.preItem = FILLP_NULL_PTR; in FillpFreeBufItem()
H A Dspunge_core.c65 FillpDoInput(&spcb->fpcb, &buf, inst); in SpungeDoRecvCycle()
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()
104 pcb->fpcb.statistics.traffic.packSendBytes += sendBytes; in SpungeDoSendUpdate()
105 pcb->fpcb.send.flowControl.remainBytes = (bytesExpected - (FILLP_UINT32)sendBytes); in SpungeDoSendUpdate()
107 pcb->fpcb in SpungeDoSendUpdate()
927 struct FillpPcb *fpcb = FILLP_NULL_PTR; SpungeLoopCheckUnsendBox() local
1316 SpungeItemRouteByToken(struct FillpPcbItem *item, struct FillpPcb *fpcb) SpungeItemRouteByToken() argument
1354 struct FillpPcb *fpcb = FILLP_NULL_PTR; SpungeClearItemWaitTokenList() local
1393 struct FillpPcb *fpcb = FILLP_NULL_PTR; SpungeCheckItemWaitTokenList() local
1473 SpungeTokenBucketAddFpcb(struct FillpPcb *fpcb) SpungeTokenBucketAddFpcb() argument
1493 SpungeTokenBucketDelFpcb(struct FillpPcb *fpcb) SpungeTokenBucketDelFpcb() argument
[all...]
H A Dnet.c157 FillpDisableConnRetryCheckTimer(&conn->pcb->fpcb); in FillpNetconnDestroy()
248 FillpEnablePackTimer(&conn->pcb->fpcb); in FillpNetconnSetState()
249 FillpEnableFcTimer(&conn->pcb->fpcb); in FillpNetconnSetState()
251 FillpEnableKeepAliveTimer(&conn->pcb->fpcb); in FillpNetconnSetState()
252 conn->pcb->fpcb.statistics.keepAlive.lastRecvTime = conn->pcb->fpcb.pcbInst->curTime; in FillpNetconnSetState()
256 conn->pcb->fpcb.dataBurstTimerNode.interval = in FillpNetconnSetState()
258 FillpEnableDataBurstTimer(&conn->pcb->fpcb); in FillpNetconnSetState()
261 SpungeTokenBucketAddFpcb(&conn->pcb->fpcb); in FillpNetconnSetState()
266 SpungeTokenBucketDelFpcb(&conn->pcb->fpcb); in FillpNetconnSetState()
[all...]
H A Dspunge_stack.c348 unsendBox = conn->pcb->fpcb.send.unsendBox; in SpungeConnCheckUnsendBoxEmpty()
403 pcb = &conn->pcb->fpcb; in SpungeCheckDisconn()
423 sendPcb = &conn->pcb->fpcb.send; in SpungeCheckDisconn()
424 FillpAckSendPcb(&conn->pcb->fpcb, 0); in SpungeCheckDisconn()
486 FillpEnableConnRetryCheckTimer(&conn->pcb->fpcb); in SpungeSendConnectMsg()
547 FillpPcbRemoveTimers(&conn->pcb->fpcb); in SpungeConnClosed()
H A Dsysio_udp.c474 return pcb->fpcb.sendFunc(conn, sendBuf->p, sendBuf->len + FILLP_HLEN, pcb); in SysioSendPacketUdp()
478 return FillpSendConnReq(&pcb->fpcb); in SysioSendPacketUdp()
/foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/src/fillp/
H A Dfillp_pcb.c79 static FILLP_INT FillpInitSendpcbPktSeqMap(struct FillpPcb *fpcb, struct FillpSendPcb *pcb) in FillpInitSendpcbPktSeqMap() argument
82 if (fpcb->mpSendSize > FILLP_MAX_PKTSEQ_HASH_SIZE) { in FillpInitSendpcbPktSeqMap()
85 if ((fpcb->mpSendSize & (fpcb->mpSendSize - 1)) == 0) { /* already Power of 2 */ in FillpInitSendpcbPktSeqMap()
86 pcb->pktSeqMap.size = fpcb->mpSendSize; in FillpInitSendpcbPktSeqMap()
88 for (pcb->pktSeqMap.size = 1; pcb->pktSeqMap.size <= fpcb->mpSendSize;) { in FillpInitSendpcbPktSeqMap()
93 if (fpcb->mpSendSize > FILLP_MAX_PKTSEQ_HASH_SIZE) { in FillpInitSendpcbPktSeqMap()
131 static FILLP_INT InitSendPcbSimplePar(struct FillpPcb *fpcb) in InitSendPcbSimplePar() argument
133 struct FillpSendPcb *pcb = &fpcb->send; in InitSendPcbSimplePar()
135 if (fpcb in InitSendPcbSimplePar()
180 InitSimplePcbPar(struct FillpSendPcb *pcb, struct FillpPcb *fpcb) InitSimplePcbPar() argument
222 InitItemPool(struct FillpPcb *fpcb) InitItemPool() argument
253 FillpInitSendpcb(struct FillpPcb *fpcb) FillpInitSendpcb() argument
293 FillpInitRecvPcbBox(struct FillpPcb *fpcb, struct FillpRecvPcb *pcb) FillpInitRecvPcbBox() argument
320 FillpInitRecvpcb(struct FillpPcb *fpcb) FillpInitRecvpcb() argument
365 InitSimpleStatics(const struct FillpPcb *fpcb, struct FillpStatisticsPcb *pcb) InitSimpleStatics() argument
402 FillpInitStastics(struct FillpPcb *fpcb) FillpInitStastics() argument
479 FillpPcbRemoveRecv(struct FillpPcb *fpcb) FillpPcbRemoveRecv() argument
509 FillpPcbSendFc(struct FillpPcb *fpcb) FillpPcbSendFc() argument
525 FillpPcbSend(struct FillpPcb *fpcb, struct FillpPcbItem *item[], FILLP_UINT32 itemCnt) FillpPcbSend() argument
548 FillpPcbFreeSendItemArray(struct FillpPcb *fpcb) FillpPcbFreeSendItemArray() argument
598 FillpPcbRemoveSend(struct FillpPcb *fpcb) FillpPcbRemoveSend() argument
632 FillpPcbRemoveTimers(struct FillpPcb *fpcb) FillpPcbRemoveTimers() argument
[all...]
H A Dfillp_output.c350 static FILLP_INT FillpItemRetrans(struct FillpPcbItem *item, struct FillpPcb *fpcb, struct FillpSendPcb *sendPcb) in FillpItemRetrans() argument
354 fpcb->statistics.traffic.totalRetryed++; in FillpItemRetrans()
357 sendPcb->lastSendTs = fpcb->pcbInst->curTime; in FillpItemRetrans()
361 if (FillpAddToUnackList(fpcb, item) != ERR_OK) { in FillpItemRetrans()
366 FillpFreeItemAndEvent(fpcb, item); in FillpItemRetrans()
368 fpcb->send.preItem = (void *)item; in FillpItemRetrans()
369 FillpAddToPktSeqHash(fpcb, item); in FillpItemRetrans()
374 FILLP_INT FillpSendItem(struct FillpPcbItem *item, struct FillpPcb *fpcb) in FillpSendItem() argument
376 struct FtNetconn *conn = (struct FtNetconn *)FILLP_GET_CONN(fpcb); in FillpSendItem()
377 struct FillpStatisticsPcb *stats = &(fpcb in FillpSendItem()
[all...]
H A Dfillp_conn.c495 newConn->pcb->fpcb.pktSize = UTILS_MIN(sock->resConf.flowControl.pktSize, newConn->peerPktSize); in FillpInitNewPcbByNewConn()
496 if ((newConn->pcb->fpcb.pktSize > (FILLP_MAX_PKT_SIZE - FILLP_HLEN)) || (newConn->pcb->fpcb.pktSize == 0)) { in FillpInitNewPcbByNewConn()
497 newConn->pcb->fpcb.pktSize = (FILLP_MAX_PKT_SIZE - FILLP_HLEN); in FillpInitNewPcbByNewConn()
500 newConn->pcb->fpcb.recv.pktRecvCache = (FILLP_UINT32)maxRecvCache * (FILLP_UINT32)newConn->pcb->fpcb.pktSize; in FillpInitNewPcbByNewConn()
501 newConn->pcb->fpcb.send.pktSendCache = (FILLP_UINT32)maxSendCache * (FILLP_UINT32)newConn->pcb->fpcb.pktSize; in FillpInitNewPcbByNewConn()
503 if (((newConn->pcb->fpcb.recv.pktRecvCache / newConn->pcb->fpcb in FillpInitNewPcbByNewConn()
510 struct FillpPcb *fpcb = &(newConn->pcb->fpcb); FillpInitNewPcbByNewConn() local
921 FillpCheckandcopyConfirmAckAddr(struct FillpPcb *fpcb, FILLP_CONST struct FillpPktConnConfirmAck *confirmAck) FillpCheckandcopyConfirmAckAddr() argument
[all...]
H A Dfillp_input.c195 item->fpcb = pcb; in FillpDataInput()
/foundation/communication/dsoftbus/components/nstackx/fillp/src/public/src/
H A Dspunge_message.c296 static void SpungeStartConnRetryTimer(struct FillpPcb *fpcb, FILLP_CONST struct FtSocket *sock) in SpungeStartConnRetryTimer() argument
298 FILLP_TIMING_WHEEL_INIT_NODE(&fpcb->connRetryTimeoutTimerNode); in SpungeStartConnRetryTimer()
299 fpcb->connRetryTimeoutTimerNode.cbNode.cb = SpungeSendConnectMsg; in SpungeStartConnRetryTimer()
300 fpcb->connRetryTimeoutTimerNode.cbNode.arg = (void *)sock->netconn; in SpungeStartConnRetryTimer()
301 fpcb->connRetryTimeoutTimerNode.interval = (FILLP_UINT32)FILLP_UTILS_MS2US(sock->resConf.common.connRetryTimeout); in SpungeStartConnRetryTimer()
303 FillpEnableConnRetryCheckTimer(fpcb); in SpungeStartConnRetryTimer()
333 SpungeStartConnRetryTimer(&sock->netconn->pcb->fpcb, sock); in SpungeHandleMsgConnect()
340 FillpDisableConnRetryCheckTimer(&sock->netconn->pcb->fpcb); in SpungeHandleMsgConnect()
514 FillpSendConnConfirmAck(&netconn->pcb->fpcb); in SpungeHandleMsgConnAccepted()
516 sock->resConf.flowControl.pktSize = (FILLP_UINT16)netconn->pcb->fpcb in SpungeHandleMsgConnAccepted()
[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)
/foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/include/
H A Dspunge_core.h117 FILLP_INT SpungeItemRouteByToken(struct FillpPcbItem *item, struct FillpPcb *fpcb);
119 void SpungeTokenBucketAddFpcb(struct FillpPcb *fpcb);
120 void SpungeTokenBucketDelFpcb(struct FillpPcb *fpcb);
H A Dpcb.h48 struct FillpPcb fpcb; member
/foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/include/fillp/
H A Dfillp_output.h28 FILLP_INT FillpSendItem(struct FillpPcbItem *item, struct FillpPcb *fpcb);
H A Dfillp_pcb.h260 void FillpPcbRemoveTimers(struct FillpPcb *fpcb);
262 void FillpPcbSendFc(struct FillpPcb *fpcb);
263 void FillpPcbSend(struct FillpPcb *fpcb, struct FillpPcbItem *item[], FILLP_UINT32 itemCnt);
H A Dfillp.h93 void *fpcb; member
/foundation/communication/dsoftbus/components/nstackx/fillp/src/app_lib/src/
H A Dsocket_opt.c41 sendPcb = &(sock->netconn->pcb->fpcb.send); in SockGetOptSendCache()
221 sock->netconn->pcb->fpcb.fcAlg = (FILLP_UINT8)FILLP_SUPPORT_ALG_N(alg); in SockSetFcAlg()
223 sock->netconn->pcb->fpcb.fcAlg = FILLP_SUPPORT_ALG_BASE; in SockSetFcAlg()
H A Dfillp_stack_app_config.c355 statisticsPcb = &(netconn->pcb->fpcb.statistics); in FtGetAppFcPeriodRecvRate()
369 statisticsPcb = &(netconn->pcb->fpcb.statistics); in FtGetAppFcPeriodRecvRateBps()
382 statisticsPcb = &(netconn->pcb->fpcb.statistics); in FtGetAppFcPeriodRecvPktLost()
399 appFcStastics = &(netconn->pcb->fpcb.statistics.appFcStastics); in FtGetAppFcPeriodStastics()
H A Dfillp_dfx.c283 const struct FillpPcb *pcb = &sock->netconn->pcb->fpcb; in FillpDfxSockQosNotify()
526 const struct FillpSendPcb *sendPcb = &sock->netconn->pcb->fpcb.send; in DoShowSockList()
598 const struct FillpPcb *pcb = &sock->netconn->pcb->fpcb; in DoShowSockQos()
669 struct FillpFrameStats *stats = &sock->netconn->pcb->fpcb.frameHandle.stats; in DoShowFrameStats()
H A Dsocket_app.c394 if (!FillpPcbGetDirectlySend(&sock->netconn->pcb->fpcb)) { in SockSendmsgPushOrSendItem()
400 (tmpItemCnt >= (FillpPcbGetSendCacheSize(&sock->netconn->pcb->fpcb) >> 1))) { /* > half of the cache */ in SockSendmsgPushOrSendItem()
401 FillpPcbSend(&sock->netconn->pcb->fpcb, itemList, tmpItemCnt); in SockSendmsgPushOrSendItem()
416 item->fpcb = (void *)&sock->netconn->pcb->fpcb; in SockSendMsgSetItem()
441 FillpFrameTxInitItem(&sock->netconn->pcb->fpcb.frameHandle, item, frame, (FILLP_UINT32)bufLen, isFirstPkt); in SockItemSetFrameInfo()
454 if (FillpPcbGetDirectlySend(&sock->netconn->pcb->fpcb) && itemCnt > 0) { in SockSendLastItem()
455 FillpPcbSend(&sock->netconn->pcb->fpcb, itemList, itemCnt); in SockSendLastItem()
H A Dapi.c1143 &((struct FtNetconn *)sock->netconn)->pcb->fpcb.statistics, sizeof(struct FillpStatisticsPcb)); in FtFillpStatsGet()
1370 pcb = &(((struct FtNetconn *)sock->netconn)->pcb->fpcb.statistics); in FtFillpStatShow()

Completed in 22 milliseconds