Home
last modified time | relevance | path

Searched refs:resConf (Results 1 – 20 of 20) sorted by relevance

/ohos5.0/foundation/communication/dsoftbus/components/nstackx/fillp/src/public/src/
H A Dspunge_message.c89 NetconnSetRecvCacheSize(conn, sock->resConf.common.recvCache); in SpungeHandleMsgAllocSock()
90 NetconnSetSendCacheSize(conn, sock->resConf.common.sendCache); in SpungeHandleMsgAllocSock()
94 … sock->resConf.common.sendCache, sock->resConf.common.recvCache, sock->resConf.flowControl.pktSize, in SpungeHandleMsgAllocSock()
95 …sock->resConf.flowControl.oppositeSetRate, sock->resConf.flowControl.slowStart, sock->sockAddrType… in SpungeHandleMsgAllocSock()
516 sock->resConf.flowControl.pktSize = (FILLP_UINT16)netconn->pcb->fpcb.pktSize; in SpungeHandleMsgConnAccepted()
519 …sock->resConf.flowControl.maxRate = UTILS_MIN(sock->resConf.flowControl.maxRate, g_resource.flowCo… in SpungeHandleMsgConnAccepted()
520 sock->resConf.flowControl.maxRecvRate = UTILS_MIN(sock->resConf.flowControl.maxRecvRate, in SpungeHandleMsgConnAccepted()
528 sock->resConf.flowControl.maxRecvRate); in SpungeHandleMsgConnAccepted()
718 ret = SysArchSetSockSndbuf(sysosSocket, sock->resConf.common.udpSendBufSize); in SpungeHandleMsgSetSendBuf()
753 ret = SysArchSetSockRcvbuf(sysosSocket, sock->resConf.common.recvBufSize); in SpungeHandleMsgSetRecvBuf()
[all …]
/ohos5.0/foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/src/
H A Dspunge_core.c77 FILLP_UINT32 pktNum = sock->resConf.udp.txBurst; in SpungeCalExpectedBytes()
83 if (pktNum <= (sock->resConf.udp.txBurst)) { in SpungeCalExpectedBytes()
91 pktNum = sock->resConf.udp.txBurst; in SpungeCalExpectedBytes()
561 static void FtGetSpungeRes(struct SpungeResConf *resConf) in FtGetSpungeRes() argument
566 resConf->maxSockNum = g_resource.common.maxSockNum; in FtGetSpungeRes()
567 resConf->maxConnNum = g_resource.common.maxConnNum; in FtGetSpungeRes()
616 g_spunge->insNum = g_spunge->resConf.maxInstNum; in FtInitGlobalInstPool()
629 g_spunge->sockTable = SpungeCreateSockTable(g_spunge->resConf.maxSockNum); in FtInitGlobalSockTable()
641 if (netPoolInitSize > g_spunge->resConf.maxConnNum) { in FtInitGlobalNetPool()
642 netPoolInitSize = g_spunge->resConf.maxConnNum; in FtInitGlobalNetPool()
[all …]
H A Dspunge_stack.c438 … (FILLP_UINT32)FILLP_UTILS_MS2US((FILLP_LLONG)sock->resConf.common.disconnectRetryTimeout); in SpungeCheckDisconn()
/ohos5.0/foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/src/fillp/
H A Dfillp_flow_control.c169 if (sock->resConf.flowControl.constRateEnbale) { in FillpCalSendInterval()
170 flowControl->sendRate = sock->resConf.flowControl.maxRate; in FillpCalSendInterval()
377 … if (detaTime >= (FILLP_LLONG)FILLP_UTILS_MS2US((FILLP_LLONG)sock->resConf.common.keepAliveTime)) { in FillpFcCycle()
379 sock->index, detaTime, sock->resConf.common.keepAliveTime); in FillpFcCycle()
390 … (FILLP_UINT32)(FILLP_UTILS_MS2US((FILLP_LLONG)sock->resConf.common.keepAliveTime) - detaTime); in FillpFcCycle()
392 … pcb->keepAliveTimerNode.interval, sock->index, detaTime, sock->resConf.common.keepAliveTime); in FillpFcCycle()
H A Dfillp_conn.c551 NetconnSetPktSize(conn, sock->resConf.flowControl.pktSize); in FillpInitNewconnBySock()
552 NetconnSetOpersiteRate(conn, sock->resConf.flowControl.oppositeSetRate); in FillpInitNewconnBySock()
553 NetconnSetSlowStart(conn, sock->resConf.flowControl.slowStart); in FillpInitNewconnBySock()
554 NetconnSetPackInterval(conn, sock->resConf.flowControl.packInterval); in FillpInitNewconnBySock()
570 maxSendCache = sock->resConf.common.maxServerAllowSendCache; in FillpInitNewConnByConfirm()
571 maxRecvCache = sock->resConf.common.maxServerAllowRecvCache; in FillpInitNewConnByConfirm()
651 FillpInitPeerOfNewconn(newConn, sock->resConf.flowControl.pktSize); in FillpProcessConnConfirm()
816 if (sock->resConf.flowControl.maxRate > g_resource.flowControl.maxRate) { in FillpHandleConnConfirmAckInput()
817 sock->resConf.flowControl.maxRate = g_resource.flowControl.maxRate; in FillpHandleConnConfirmAckInput()
828 … pcb->recv.pktNum, sock->resConf.flowControl.maxRate, sock->resConf.flowControl.maxRecvRate); in FillpHandleConnConfirmAckInput()
[all …]
H A Dfillp_flow_control_alg0.c67 alg->maxRateAllowed = FILLP_GET_SOCKET(pcb)->resConf.flowControl.maxRate; in FillpAlg0FlowControlInit()
214 maxRateAllowed = FILLP_GET_SOCKET(pcb)->resConf.flowControl.maxRate; in FillpAlg0PackStateProcess()
H A Dfillp_timer.c54 if (appFcStastics->periodTimePassed < (FILLP_LLONG)(sock->resConf.common.fcStasticsInterval)) { in FillpCalFcAppStastics()
170 … (curTime - pack->packRttDetectTime) > (FILLP_LLONG)(sock->resConf.common.fcStasticsInterval)) { in FillpPackTimerCb()
H A Dfillp_common.c526 pcb->delayNackTimerNode.interval = (FILLP_UINT32)sock->resConf.common.nackDelayTimeout; in FillpAddNodeAtDelayNackListTail()
749 …sock->resConf.common.nackDelayTimeout = pcb->statistics.pack.packInterval - FILLP_INTERVAL_THRESHO… in FillpCalNackDelayTimeByPackInterval()
751 sock->resConf.common.nackDelayTimeout = UTILS_MAX(sock->resConf.common.nackDelayTimeout, in FillpCalNackDelayTimeByPackInterval()
H A Dfillp_pcb.c664 pcb->keepAliveTimerNode.interval = FILLP_UTILS_MS2US(sock->resConf.common.keepAliveTime); in FillpInitPcbTimeNode()
756 return sock->resConf.flowControl.packInterval; in FillpGetSockPackInterval()
H A Dfillp_input.c63 (((struct FtSocket *)conn->sock)->resConf.common.enlargePackIntervalFlag == FILLP_TRUE && in FillpChangePackInteval()
657 … if (sock->resConf.common.enlargePackIntervalFlag && (pack->flag & FILLP_PACK_FLAG_NO_DATA_SEND)) { in FillpChangePackInterval()
H A Dfillp_output.c466 if (ftSock->resConf.common.enlargePackIntervalFlag) { in FillpSetSimplePack()
/ohos5.0/foundation/communication/dsoftbus/components/nstackx/fillp/src/app_lib/src/
H A Dsocket_opt.c226 sock->resConf.common.recvCache = FILLP_DEFAULT_MSG_RECV_CACHE; in SockSetFcAlg()
227 sock->resConf.common.sendCache = FILLP_DEFAULT_MSG_SEND_CACHE; in SockSetFcAlg()
228 NetconnSetRecvCacheSize(sock->netconn, sock->resConf.common.recvCache); in SockSetFcAlg()
229 NetconnSetSendCacheSize(sock->netconn, sock->resConf.common.sendCache); in SockSetFcAlg()
H A Dfillp_stack_app_config.c54 *resource = &sock->resConf; in FtGetRightAppResourceByIndex()
319 resource = &sock->resConf; in FtSetConfigApp()
435 resource = &sock->resConf; in FtGetSockValue()
H A Dspunge_app.c72 …(void)memcpy_s(&sock->resConf, sizeof(struct GlobalAppResource), &g_appResource, sizeof(struct Glo… in SpungeInitSocket()
H A Depoll_app.c37 FILLP_UINT loopLimit = g_spunge->resConf.maxEpollItemNum; in EpFind()
63 FILLP_UINT loopLimit = g_spunge->resConf.maxEpollItemNum; in EpRbtreeInsert()
H A Dfillp_dfx.c497 FILLP_INT32 isOk = DoShowSockConfigRes(sockIndex, &sock->resConf, data, &len); in FillpDumpShowSockResource()
563 …FILLP_CHAR *data = (FILLP_CHAR *)calloc(1U, g_spunge->resConf.maxSockNum * FILLP_DFX_DUMP_ONE_SOCK… in FillpDumpShowSockList()
H A Dsocket_app.c883 if ((backLog == 0) || (backLog > (FILLP_INT)g_spunge->resConf.maxConnNum)) { in SockListen()
886 backLog, g_spunge->resConf.maxConnNum, sock->index); in SockListen()
888 backLog = (FILLP_INT)g_spunge->resConf.maxConnNum; in SockListen()
H A Dapi.c860 resource = &sock->resConf; in FillpDebugCmdSocketConfigRes()
/ohos5.0/foundation/communication/dsoftbus/components/nstackx/fillp/src/public/include/
H A Dspunge.h130 struct SpungeResConf resConf; member
H A Dsockets.h143 struct GlobalAppResource resConf; /* Total size is 15 * sizeof uint32 */ member