Home
last modified time | relevance | path

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

/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()
301 fpcb->connRetryTimeoutTimerNode.interval = (FILLP_UINT32)FILLP_UTILS_MS2US(sock->resConf.common.connRetryTimeout); in SpungeStartConnRetryTimer()
330 NetconnSetConnectTimeout(sock->netconn, FILLP_UTILS_MS2US((FILLP_LLONG)sock->resConf.common.connectTimeout)); in SpungeHandleMsgConnect()
516 sock->resConf in SpungeHandleMsgConnAccepted()
[all...]
/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()
266 inst->msgBox = FillpQueueCreate("spunge_msg_box", g_spunge->resConf.maxMsgItemNum, SPUNGE_ALLOC_TYPE_MALLOC); in SpungeInstMsgBoxInit()
275 inst->msgPool = SpungeMsgCreatePool(FILLP_MSG_ITEM_INIT_NUM, (int)g_spunge->resConf.maxMsgItemNum); in SpungeInstMsgBoxInit()
451 g_spunge->epitemPool = DympCreatePool(FILLP_EPOLL_ITEM_INIT_NUM, (int)g_spunge->resConf.maxEpollEventNum, in FtAllocateEpollResource()
460 g_spunge->eventpollPool = DympCreatePool(FILLP_EPOLL_ITEM_INIT_NUM, (int)g_spunge->resConf.maxEpollEventNum, in FtAllocateEpollResource()
561 static void FtGetSpungeRes(struct SpungeResConf *resConf) in FtGetSpungeRes() argument
563 (void)memset_s(resConf, sizeof(struct SpungeResConf), 0, sizeof(struct SpungeResConf)); in FtGetSpungeRes()
565 resConf in FtGetSpungeRes()
[all...]
H A Dspunge_stack.c438 (FILLP_UINT32)FILLP_UTILS_MS2US((FILLP_LLONG)sock->resConf.common.disconnectRetryTimeout); in SpungeCheckDisconn()
/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.c495 newConn->pcb->fpcb.pktSize = UTILS_MIN(sock->resConf.flowControl.pktSize, newConn->peerPktSize); in FillpInitNewPcbByNewConn()
551 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()
555 FILLP_LOGDBG("Set pack interval:%u", 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 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_THRESHOLD; 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()
/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 GlobalAppResource)); 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_BUF); 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()
/foundation/communication/dsoftbus/components/nstackx/fillp/src/public/include/
H A Dspunge.h130 struct SpungeResConf resConf; member
H A Dsockets.h144 struct GlobalAppResource resConf; /* Total size is 15 * sizeof uint32 */ member

Completed in 22 milliseconds