Home
last modified time | relevance | path

Searched refs:FILLP_TRUE (Results 1 – 25 of 33) sorted by relevance

12

/ohos5.0/foundation/communication/dsoftbus/components/nstackx/fillp/src/public/include/
H A Dpdt_fc_miracast.h47 #define FILLP_DEFAULT_APP_SLOW_START FILLP_TRUE /* slow start */
54 #define FILLP_ADHOC_PACK_ENABLE FILLP_TRUE
60 #define FILLP_DEFAULT_SEND_HISTORY_NACK FILLP_TRUE
85 #define FILLP_DEFAULT_DESTROY_STACK_WITHOUT_WAIT_SOCKET_CLOSE FILLP_TRUE
H A Dpdt_fc_ut.h59 #define FILLP_DEFAULT_APP_SLOW_START FILLP_TRUE /* slow start */
73 #define FILLP_DELAY_NACK_ENABLE FILLP_TRUE
75 #define FILLP_DEFAULT_ENLARGE_PACK_INTERVAL FILLP_TRUE
77 #define FILLP_DEFAULT_SEND_HISTORY_NACK FILLP_TRUE
H A Dpdt_fc.h84 #define FILLP_DEFAULT_APP_SLOW_START FILLP_TRUE /* slow start */
108 #define FILLP_DEFAULT_BFULL_CPU FILLP_TRUE
136 #define FILLP_DELAY_NACK_ENABLE FILLP_TRUE
231 #define FILLP_DEFAULT_ENLARGE_PACK_INTERVAL FILLP_TRUE
H A Dhlist.h55 … ((_pos) = HLIST_FIRST(list); ((_pos) != FILLP_NULL_PTR) && ((_next) = (_pos)->next, FILLP_TRUE); \
59 for (; ((_pos) != FILLP_NULL_PTR) && ((_next) = (_pos)->next, FILLP_TRUE); (_pos) = (_next))
H A Dutils.h90 return FILLP_TRUE; in UtilsIpv6AddrMatch()
/ohos5.0/foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/src/fillp/
H A Dfillp_output.c36 if (SkipListInsert(&sendPcb->unrecvList, item, &item->skipListNode, FILLP_TRUE) != ERR_OK) { in FillpMoveRedundantItemToUnrecvList()
100 return FILLP_TRUE; in FillpIsAskMoreBuf()
118 sendPcb->appLimited = FILLP_TRUE; in FillpDoneSendAllData()
122 sendPcb->flowControl.lastCycleNoEnoughData = FILLP_TRUE; in FillpDoneSendAllData()
124 sendPcb->flowControl.sendOneNoData = FILLP_TRUE; in FillpDoneSendAllData()
126 if (g_gsoSupport == FILLP_TRUE && pcb->sendmsgEio == FILLP_FALSE) { in FillpDoneSendAllData()
154 pcb->isLast = FILLP_TRUE; in FillpBeforeSendItem()
184 if (FillpIsAskMoreBuf(sendPcb, pcb) == FILLP_TRUE) { in FillpSendOne()
404 if (g_gsoSupport == FILLP_FALSE || fpcb->sendmsgEio == FILLP_TRUE) { in FillpSendItem()
494 return FILLP_TRUE; in FillpSendPack()
[all …]
H A Dfillp_conn.c745 return FILLP_TRUE; in FillpConfirmCheckState()
888 return FILLP_TRUE; in FillpCheckConfirmAckInfoIsValid()
934 if (match == FILLP_TRUE) { in FillpCheckandcopyConfirmAckAddr()
996 return FILLP_TRUE; in FillpCheckConfirmAckPar()
1851 flags.wrSet = FILLP_TRUE; in FillpSendRstWithVersionImcompatible()
1852 flags.rdSet = FILLP_TRUE; in FillpSendRstWithVersionImcompatible()
1853 flags.ackSet = FILLP_TRUE; in FillpSendRstWithVersionImcompatible()
1854 flags.verSet = FILLP_TRUE; in FillpSendRstWithVersionImcompatible()
1867 wrSet = FILLP_TRUE; in FillpSendFin()
1870 rdSet = FILLP_TRUE; in FillpSendFin()
[all …]
H A Dfillp_flow_control.c54 return FILLP_TRUE; in FillpRecvRateIsBigger()
150 appLimited = FILLP_TRUE; in FillpAppLimitedStatus()
156 if (appLimited == FILLP_TRUE) { in FillpAppLimitedStatus()
208 …tedEmpty = (unsendSize == 0) && (SpungeConnCheckUnsendBoxEmpty(FILLP_GET_CONN(pcb)) == FILLP_TRUE); in FillpFcTailProtected()
292 pcb->send.flowControl.sendOneNoData = FILLP_TRUE; in FillpFcInit()
H A Dfillp_input.c63 (((struct FtSocket *)conn->sock)->resConf.common.enlargePackIntervalFlag == FILLP_TRUE && in FillpChangePackInteval()
168 …f (SkipListInsert(&pcb->recv.recvBoxPlaceInOrder, (void *)item, &item->skipListNode, FILLP_TRUE)) { in FillpProcessItemData()
413 … if (SkipListInsert(&pcb->send.unrecvList, unackItem, &unackItem->skipListNode, FILLP_TRUE)) { in ProtectLongLoopRun()
506 return FILLP_TRUE; in FillpCheckPackInput()
590 return FILLP_TRUE; in FillpCheckPackNumber()
610 pcb->adhocPackReplied = FILLP_TRUE; in FillpHandleAdhocpackFlag()
675 pcb->statistics.pack.peerRtt = FILLP_TRUE; in FillpHandlePackFlag()
699 FillpMoveUnackToUnrecv(ackSeqNum, lostSeqNum, pcb, FILLP_TRUE); in MoveUnackToUnrecvByPackInfo()
707 FillpMoveUnackToUnrecv(ackSeqNum, lostSeqNum, pcb, FILLP_TRUE); in MoveUnackToUnrecvByPackInfo()
795 FILLP_BOOL validPkt = FILLP_TRUE; in FillpHdlConnect()
[all …]
H A Dfillp_common.c85 if (FillpNumIsbigger(item->seqNum, lostSeq) == FILLP_TRUE) { in FillpMoveOneNode()
104 if (SkipListInsert(&pcb->send.unrecvList, (void *)item, &item->skipListNode, FILLP_TRUE) != in FillpMoveOneNode()
122 pktFound = FILLP_TRUE; in FillpMoveOneNode()
160 if (pktFound == FILLP_TRUE) { in FillpMoveUnackToUnrecvAll()
330 if (FillpNumIsbigger(item->seqNum, curSeq) == FILLP_TRUE) { in FillpAckUnackList()
387 FILLP_BOOL needLoopRun = FILLP_TRUE; in FillpUploadRecvBox()
671 if (SkipListInsert(&pcb->recv.recvList, (void *)item, &item->skipListNode, FILLP_TRUE)) { in FillpDataToStack()
H A Dfillp_frame.c231 frame->rxStarted = FILLP_TRUE; in FillpFrameRxNewFrag()
252 frame->lastFragRecvd = FILLP_TRUE; in FillpFrameRxNewFrag()
H A Dfillp_pcb.c242 FillbufItemPoolSetConflictSafe(pcb->itemPool, FILLP_TRUE, FILLP_FALSE); in InitItemPool()
306 FillbufItemPoolSetConflictSafe(pcb->itemPool, FILLP_FALSE, FILLP_TRUE); in FillpInitRecvPcbBox()
716 pcb->resInited = FILLP_TRUE; in FillpInitPcb()
/ohos5.0/foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/src/
H A Dspunge_core.c281 DympSetConsSafe(inst->msgPool, FILLP_TRUE); in SpungeInstMsgBoxInit()
282 DympSetProdSafe(inst->msgPool, FILLP_TRUE); in SpungeInstMsgBoxInit()
304 inst->thresdSemInited = FILLP_TRUE; in SpungeInstSendInit()
357 inst->hasInited = FILLP_TRUE; in SpungeThreadInit()
491 g_spunge->hasDeinitBlked = FILLP_TRUE; in SpungeAllocInstRes()
788 g_spunge->hasInited = FILLP_TRUE; in FtInit()
886 FtDestroyInner(FILLP_TRUE); in FtDestroy()
971 return FILLP_TRUE; in SpungeDelay()
976 FILLP_BOOL isTimeout = FILLP_TRUE; in SpungeMainDelay()
1179 return FILLP_TRUE; in FillpKillCore()
[all …]
H A Dfillp_stack_config_in.c71 if ((val != FILLP_TRUE) && (val != FILLP_FALSE)) { in FtConfigSetOutOfOrderCacheFeature()
83 if ((g_spunge != FILLP_NULL_PTR) && (g_spunge->hasInited == FILLP_TRUE)) { in FtConfigSetCpuCoreUse()
97 if ((g_spunge != FILLP_NULL_PTR) && (g_spunge->hasInited == FILLP_TRUE)) { in FtConfigSetMaxSockNum()
119 if ((g_spunge != FILLP_NULL_PTR) && (g_spunge->hasInited == FILLP_TRUE)) { in FtConfigSetMaxConnectionNum()
140 if ((val != FILLP_TRUE) && (val != FILLP_FALSE)) { in FtConfigSetFullCpu()
376 if ((resource->common.fullCpu != FILLP_FALSE) && (resource->common.fullCpu != FILLP_TRUE)) { in FtValidateCommonConfigParamsInner()
388 if ((resource->common.outOfOrderCacheFeature != FILLP_TRUE) && in FtValidateCommonConfigParamsInner()
H A Dspunge_stack.c293 if (sock->isListenSock == FILLP_TRUE) { in SpungeFreeSock()
325 if (sock->isListenSock == FILLP_TRUE) { in SpungeShutdownSock()
346 return FILLP_TRUE; in SpungeConnCheckUnsendBoxEmpty()
351 return FILLP_TRUE; in SpungeConnCheckUnsendBoxEmpty()
372 return FILLP_TRUE; in SpungeConnCheckUnsendBoxEmpty()
381 if (pcb->pcbInst->waitTobeCoreKilled == FILLP_TRUE) { in SpungeDestroyNoWait()
434 conn->sendBufRunOut = FILLP_TRUE; in SpungeCheckDisconn()
443 if (pcb->isFinAckReceived != FILLP_TRUE) { in SpungeCheckDisconn()
H A Dpcb.c36 …FillpErrorType err = FillpQueuePush(conn->pcb->fpcb.recv.recvBox, buf, FILLP_TRUE, (FILLP_UINT)cou… in SpungePcbRecv()
147 spcb->fpcb.sendmsgEio = FILLP_TRUE; in SpungePcbSendmsgInner()
182 send = FILLP_TRUE; in SpungePcbSendmsg()
H A Dfillp_stack_config.c28 if ((g_spunge != FILLP_NULL_PTR) && (g_spunge->hasInited == FILLP_TRUE)) { in FtSetCopyPreinitConfigs()
81 if ((g_spunge != FILLP_NULL_PTR) && (g_spunge->hasInited == FILLP_TRUE)) { in FtInitConfigSet()
/ohos5.0/foundation/communication/dsoftbus/components/nstackx/fillp/src/public/src/
H A Dcheck_gso_support.c77 return (err == (IOV_CNT * CFG_MSS)) ? FILLP_TRUE : FILLP_FALSE; in SendUdpSegment()
89 g_gsoSupport = FILLP_TRUE; in RecvUdpSegment()
133 if (SendUdpSegment(&sa) != FILLP_TRUE) { in CheckGSOSupport()
139 chked = FILLP_TRUE; in CheckGSOSupport()
H A Dsocket_common.c208 if (FillpQueuePush(table->freeQueqe, (void *)&sock, FILLP_TRUE, 1)) { in SpungeInitSocket()
233 while (FILLP_TRUE) { in SpungeAllocFtSock()
334 return FILLP_TRUE; in SockCanSendData()
350 return FILLP_TRUE; in SockCanRecvData()
H A Dspunge_message.c215 FillpQueueSetConsSafe(sock->acceptBox, FILLP_TRUE); in SpungeHandleMsgListen()
216 FillpQueueSetProdSafe(sock->acceptBox, FILLP_TRUE); in SpungeHandleMsgListen()
227 sock->isListenSock = FILLP_TRUE; in SpungeHandleMsgListen()
472 sock->isSockBind = FILLP_TRUE; in SpungeHandleMsgBind()
574 readShut = FILLP_TRUE; in SpungeHandleMsgDoShutdown()
578 writeShut = FILLP_TRUE; in SpungeHandleMsgDoShutdown()
901 return DympCreatePool(initSize, maxSize, sizeof(struct SpungeMsg), FILLP_TRUE, in SpungeMsgCreatePool()
H A Dlf_ring.c82 ring->consSafe = FILLP_TRUE; in FillpLfRingInit()
83 ring->prodSafe = FILLP_TRUE; in FillpLfRingInit()
/ohos5.0/foundation/communication/dsoftbus/components/nstackx/fillp/src/app_lib/src/
H A Dfillp_stack_app_config_in.c46 if ((globalResource->flowControl.slowStart != FILLP_TRUE) && in FtAppValidateFlowConfig()
52 if ((globalResource->flowControl.constRateEnbale != FILLP_TRUE) && in FtAppValidateFlowConfig()
119 if ((globalResource->common.enableNackDelay != FILLP_TRUE) && in FtAppValidateCommParams()
247 … FillpErrorType ret = SpungePostMsg(sock->inst, (void *)sock, MSG_TYPE_SET_KEEP_ALIVE, FILLP_TRUE); in FtAppSetKeepAliveTime()
512 ret = SpungePostMsg(sock->inst, (void *)sock, MSG_TYPE_SET_SEND_BUF, FILLP_TRUE); in FtAppConfigSetSendBufSize()
547 ret = SpungePostMsg(sock->inst, (void *)sock, MSG_TYPE_SET_RECV_BUF, FILLP_TRUE); in FtAppConfigSetRecvBufSize()
573 if ((val == FILLP_FALSE) || (val == FILLP_TRUE)) { in FtAppConfigSetSlowStart()
623 if ((val != FILLP_FALSE) && (val != FILLP_TRUE)) { in FtAppConfigSetConstRate()
663 if ((configValue != FILLP_TRUE) && (configValue != FILLP_FALSE)) { in FtAppEnlargePackInterval()
691 … ret = SpungePostMsg(SPUNGE_GET_CUR_INSTANCE(), (void *)cfg, MSG_TYPE_SET_NACK_DELAY, FILLP_TRUE); in FtAppConfigInitNackDelayCfg()
[all …]
H A Dsocket_app.c133 err = SpungePostMsg(sock->inst, &sockMsg, MSG_TYPE_ALLOC_SOCK, FILLP_TRUE); in SockSocket()
288 if (sock->isListenSock == FILLP_TRUE) { in SocketGetForDataTrans()
850 if (sock->isListenSock == FILLP_TRUE) { in SockApiGetAndCheckListenState()
893 err = SpungePostMsg(sock->inst, sock, MSG_TYPE_DO_LISTEN, FILLP_TRUE); in SockListen()
1069 err = SpungePostMsg(sock->inst, (void *)&acceptMsg, MSG_TYPE_NETCONN_ACCPETED, FILLP_TRUE); in SockAccept()
1140 sock->lingering = FILLP_TRUE; in SockClose()
1145 err = SpungePostMsg(sock->inst, sock, MSG_TYPE_DO_CLOSE, FILLP_TRUE); in SockClose()
1219 err = SpungePostMsg(sock->inst, (void *)&shutdownMsg, MSG_TYPE_DO_SHUTDOWN, FILLP_TRUE); in SockShutdown()
1347 err = SpungePostMsg(sock->inst, &connectMsg, MSG_TYPE_DO_CONNECT, FILLP_TRUE); in SockConnect()
1404 err = SpungePostMsg(sock->inst, &bindMsg, MSG_TYPE_DO_BIND, FILLP_TRUE); in SockBind()
[all …]
H A Dapi.c363 g_traceInfo.cmdTraceFlag = FILLP_TRUE; in FtInnerStartTrace()
380 g_traceInfo.cmdTraceFlag = FILLP_TRUE; in FtInnerStartTrace()
454 ret = (isStart == FILLP_TRUE) ? in FtStartStopTraceSock()
478 ret = (isStart == FILLP_TRUE) ? in FtStartStopTrace()
542 return FtStartStopTrace(traceObjType, traceObj, traceHandle, FILLP_TRUE); in FtStartTrace()
/ohos5.0/foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/include/fillp/
H A Dfillp_pcb.h246 return (pcb->send.directlySend == 0) ? FILLP_FALSE : FILLP_TRUE; in FillpPcbGetDirectlySend()

12