Home
last modified time | relevance | path

Searched refs:pktSize (Results 1 - 25 of 26) sorted by relevance

12

/foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/src/
H A Dfillp_buf_item.c35 void *FillpCreateBufItemPool(int poolSize, int initSize, int pktSize) in FillpCreateBufItemPool() argument
40 ((int)sizeof(struct FillpPcbItem) + (int)(pktSize + FILLP_HLEN)), in FillpCreateBufItemPool()
H A Dpcb.c233 pcb->fpcb.pktSize = (FILLP_MAX_PKT_SIZE - FILLP_HLEN); in SpungePcbNew()
256 void SpungePcbSetPktSize(struct SpungePcb *pcb, FILLP_UINT32 pktSize) in SpungePcbSetPktSize() argument
258 pcb->fpcb.pktSize = pktSize; in SpungePcbSetPktSize()
H A Dnet.c62 void NetconnSetPktSize(struct FtNetconn *conn, FILLP_UINT32 pktSize) in NetconnSetPktSize() argument
64 SpungePcbSetPktSize(conn->pcb, pktSize); in NetconnSetPktSize()
H A Dspunge_core.c92 bytesExpected = (FILLP_UINT32)(pktNum * pcb->fpcb.pktSize); in SpungeCalExpectedBytes()
123 FILLP_SIZE_T pktSize = pcb->fpcb.pktSize; in SpungeDoSendCycle() local
141 /* If BytesExpected less than pktSize, no need to send, just store the remainBytes */ in SpungeDoSendCycle()
142 if (bytesExpected >= pktSize) { in SpungeDoSendCycle()
144 tmpBytes = (FILLP_UINT32)(bytesExpected - pktSize); in SpungeDoSendCycle()
1450 stb->maxPktSize = (FILLP_UINT32)g_appResource.flowControl.pktSize; in SpungeInitTokenBucket()
1482 if (stb->maxPktSize < (FILLP_UINT32)fpcb->pktSize) { in SpungeTokenBucketAddFpcb()
1483 stb->maxPktSize = (FILLP_UINT32)fpcb->pktSize; in SpungeTokenBucketAddFpcb()
/foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/src/fillp/
H A Dfillp_conn.c231 FILLP_UINT32 pktSize; in FillpDecodePktSize() local
232 if (bufLen != (FILLP_INT)sizeof(pktSize)) { in FillpDecodePktSize()
236 FILLP_INT err = memcpy_s(&pktSize, sizeof(pktSize), buf, (FILLP_UINT32)bufLen); in FillpDecodePktSize()
242 conn->peerPktSize = FILLP_NTOHL(pktSize); in FillpDecodePktSize()
495 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 in FillpInitNewPcbByNewConn()
[all...]
H A Dfillp_input.c231 FillpErrorType err = memcpy_s(pcbBuf->buf.p, (FILLP_UINT32)(pcb->pktSize + FILLP_HLEN), buf->p, in ProcessPcbItem()
909 if (buf->len > (FILLP_INT)pcb->pktSize) { in FillpDoInput()
911 FILLP_LOGINF("FillpDoInput: recv buffer length incorrect, dataLen = %d is greater than pktSize = %zu," in FillpDoInput()
913 buf->len, pcb->pktSize, head->flag, head->pktNum, head->seqNum); in FillpDoInput()
H A Dfillp_pcb.c228 pcb->itemPool = FillpCreateBufItemPool((int)fpcb->mpSendSize, initSize, (int)fpcb->pktSize); in InitItemPool()
300 pcb->itemPool = FillpCreateBufItemPool((int)fpcb->mpRecvSize, initSize, (int)fpcb->pktSize); in FillpInitRecvPcbBox()
H A Dfillp_flow_control.c179 flowControl->sendInterval = (FILLP_LLONG)(pcb->pktSize * FILLP_FC_IN_KBPS * FILLP_FC_IN_BIT); in FillpCalSendInterval()
H A Dfillp_mgt_msg_log.c308 FILLP_NTOHL(confirmAck->sendCache), FILLP_NTOHL(confirmAck->recvCache), FILLP_NTOHL(confirmAck->pktSize), in FillpConnConfirmAckLog()
H A Dfillp_output.c121 FILLP_GET_SOCKET(pcb)->index, sendPktNum, (sentBytes / (FILLP_UINT32)pcb->pktSize)); in FillpDoneSendAllData()
/foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/include/
H A Dfillp_buf_item.h32 void *FillpCreateBufItemPool(int poolSize, int initSize, int pktSize);
H A Dpcb.h86 void SpungePcbSetPktSize(struct SpungePcb *pcb, FILLP_UINT32 pktSize);
H A Dnet.h103 void NetconnSetPktSize(struct FtNetconn *conn, FILLP_UINT32 pktSize);
/foundation/communication/dsoftbus/components/nstackx/fillp/src/app_lib/src/
H A Dfillp_stack_app_config.c111 resource->flowControl.pktSize = globalConfig->flowControl.pktSize; in CopyGlobalConfig()
198 gresource->flowControl.pktSize = resource->flowControl.pktSize; in CopySockConfig()
H A Dfillp_stack_app_config_in.c40 if ((globalResource->flowControl.pktSize == 0) || in FtAppValidateFlowConfig()
41 (globalResource->flowControl.pktSize > (FILLP_FRAME_MTU - (FILLP_HLEN + UDP_HLEN + IP_HLEN)))) { in FtAppValidateFlowConfig()
42 FILLP_LOGERR("pktSize %u is invalid parameter!!!", globalResource->flowControl.pktSize); in FtAppValidateFlowConfig()
472 FILLP_LOGERR("fillp_sock_id:%d pktSize is invalid parameter!!!", sockIndex); in FtAppConfigSetPktSize()
478 resource->flowControl.pktSize = configValue; in FtAppConfigSetPktSize()
481 FILLP_LOGERR("fillp_sock_id:%d pktSize cannot be set if state is not listening or idle", sockIndex); in FtAppConfigSetPktSize()
485 resource->flowControl.pktSize = configValue; in FtAppConfigSetPktSize()
488 FILLP_LOGERR("fillp_sock_id:%d pktSize is invalid parameter!!!", sockIndex); in FtAppConfigSetPktSize()
1072 *(FILLP_UINT16 *)value = resource->flowControl.pktSize; in FtInnerAppConfigGet()
[all...]
H A Dfillp_dfx.c469 FILLP_DUMP_MSG_ADD_CHECK(data, *len, " packet size: %hu"CRLF, fc->pktSize); in DoShowSockConfigRes()
H A Dsocket_app.c467 FILLP_UINT32 pktSize = (FILLP_UINT32)SOCK_GET_PKTSIZE(sock); in SockSendmsgDataToBufCache() local
493 itemRemainLen = pktSize - item->dataOptLen; in SockSendmsgDataToBufCache()
/foundation/communication/dsoftbus/components/nstackx/fillp/src/public/include/
H A Dsockets.h76 FILLP_UINT16 pktSize; /* default pkt size to cal flow rate */ member
159 #define SOCK_GET_PKTSIZE(_sock) ((_sock)->netconn->pcb->fpcb.pktSize)
/foundation/multimedia/av_codec/services/media_engine/plugins/ffmpeg_adapter/demuxer/
H A Dblock_queue_pool.cpp211 uint32_t pktSize = static_cast<uint32_t>(pkt->size); in Pop() local
213 quePool_[queIndex].dataSize >= pktSize ? quePool_[queIndex].dataSize -= pktSize : 0; in Pop()
/foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/include/fillp/
H A Dfillp_pcb.h210 FILLP_SIZE_T pktSize; member
H A Dfillp.h298 FILLP_UINT32 pktSize; /* mtu , from server */ member
/foundation/communication/dsoftbus/components/nstackx/fillp/src/public/src/
H A Dspunge_message.c93 FILLP_LOGINF("conn:recvSize:%u,sendSize:%u,pktSize:%u,opersite:%u,slowStart:%u,addrType:%u", in SpungeHandleMsgAllocSock()
94 sock->resConf.common.sendCache, sock->resConf.common.recvCache, sock->resConf.flowControl.pktSize, in SpungeHandleMsgAllocSock()
516 sock->resConf.flowControl.pktSize = (FILLP_UINT16)netconn->pcb->fpcb.pktSize; in SpungeHandleMsgConnAccepted()
H A Dsocket_common.c123 FILLP_DEFAULT_APP_PKT_SIZE, /* flowControl.pktSize */
155 g_appResource.flowControl.pktSize = FILLP_DEFAULT_APP_PKT_SIZE; in InitGlobalAppResourceDefault()
/foundation/communication/bluetooth_service/services/bluetooth/stack/platform/src/
H A Dpacket.c248 uint32_t pktSize = PacketSize(pkt); in PacketMoveToOffset() local
249 if (*offset > pktSize) { in PacketMoveToOffset()
/foundation/communication/dsoftbus/components/nstackx/fillp/include/
H A Dfillpinc.h962 FILLP_UINT16 pktSize; member

Completed in 29 milliseconds

12