Home
last modified time | relevance | path

Searched refs:FILLP_UINT32 (Results 1 – 25 of 67) sorted by relevance

123

/ohos5.0/foundation/communication/dsoftbus/components/nstackx/fillp/include/
H A Dfillpinc.h45 IN FILLP_UINT32 msgLength, IN FILLP_UINT32 traceObj, IN FILLP_UINT8 *traceDescript,
728 FILLP_UINT32 periodRtt;
796 FILLP_UINT32 reserve;
835 FILLP_UINT32 maxRate;
862 FILLP_UINT32 reserve;
875 FILLP_UINT32 reserve;
901 FILLP_UINT32 reserve;
918 FILLP_UINT32 sendCache;
950 FILLP_UINT32 maxRate;
994 FILLP_UINT32 reserved;
[all …]
H A Dfillptypes.h131 typedef unsigned int FILLP_UINT32; typedef
243 FILLP_UINT32 u32; /* Indicates 32-bit data. */
251 FILLP_UINT32 events; /* Indicates Epoll events. */
386 FILLP_UINT32 reserve;
495 typedef void (*FillpDebugSendFunc)(IN FILLP_UINT32 debugType, IN FILLP_UINT32 debugLvl,
496 IN FILLP_UINT32 debugId, IN FILLP_CHAR *format, ...);
574 FILLP_UINT32 bitMap;
608 FILLP_UINT32 costTimeStatsCnt[FILLP_FRAME_COST_MAX];
625 FILLP_UINT32 reserved;
675 FILLP_UINT32 u32v;
[all …]
/ohos5.0/foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/include/fillp/
H A Dfillp_pcb.h44 FILLP_UINT32 size;
45 FILLP_UINT32 hashModSize;
57 FILLP_UINT32 startPktNum;
58 FILLP_UINT32 endPktNum;
88 FILLP_UINT32 pktStartNum;
89 FILLP_UINT32 seqStartNum;
139 FILLP_UINT32 retryIndex;
140 FILLP_UINT32 pktNum;
145 FILLP_UINT32 seqNum;
176 FILLP_UINT32 mpSendSize;
[all …]
H A Dfillp.h94 FILLP_UINT32 seqNum;
95 FILLP_UINT32 pktNum;
101 FILLP_UINT32 flags;
149 FILLP_UINT32 pktNum;
150 FILLP_UINT32 seqNum;
168 FILLP_UINT32 jitter;
171 FILLP_UINT32 windowVar;
196 FILLP_UINT32 rate;
200 FILLP_UINT32 lostSeq;
202 FILLP_UINT32 rtt;
[all …]
H A Dfillp_frame.h41 FILLP_UINT32 size; /* size of the fragment */
42 FILLP_UINT32 procSize; /* current size of received data of this fragment,
44 FILLP_UINT32 seqNum; /* fragment sequence number of the frame */
48 FILLP_UINT32 seqNum;
50 FILLP_UINT32 size; /* frame size */
51 FILLP_UINT32 fragCnt; /* fragment count of the frame */
52 FILLP_UINT32 totalItemCnt; /* packet count of the frame */
68 FILLP_UINT32 iFrameCount;
71 FILLP_UINT32 pFrameCount;
91 FILLP_UINT32 fragSize; /* size of the fragment the item belongs to */
[all …]
H A Dfillp_flow_control.h47 FILLP_UINT32 v; /* value measured */
51 FILLP_UINT32 maxCnt;
55 void FillpUpdateRecvRateSample(struct FillpMaxRateSample *maxRateSample, FILLP_UINT32 rateValue, FI…
68 void FillpFcRecvLost(struct FillpPcb *pcb, FILLP_UINT32 ones);
69 FILLP_BOOL FillpAppLimitedStatus(struct FillpPcb *pcb, FILLP_UINT32 beginPktNum, FILLP_UINT32 endPk…
H A Dfillp_common.h53 void FillpSendNack(struct FillpPcb *pcb, FILLP_UINT32 startPktNum, FILLP_UINT32 endPktNum);
56 void FillpMoveUnackToUnrecv(FILLP_UINT32 last_seq, FILLP_UINT32 cur_seq, struct FillpPcb *pcb,
58 void FillpMoveUnackToUnrecvAll(FILLP_UINT32 ackSeq, FILLP_UINT32 lostSeq, struct FillpPcb *pcb,
/ohos5.0/foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/src/
H A Dsha256.c34 FILLP_UINT32 *_arrayPtr = (FILLP_UINT32 *)(_array); \
110 FILLP_UINT32 jdex; in FillpSha256Compile()
111 FILLP_UINT32 index; in FillpSha256Compile()
112 FILLP_UINT32 key0; in FillpSha256Compile()
113 FILLP_UINT32 key1; in FillpSha256Compile()
114 FILLP_UINT32 key2; in FillpSha256Compile()
115 FILLP_UINT32 key3; in FillpSha256Compile()
116 FILLP_UINT32 *buf = ctx->wbuf; in FillpSha256Compile()
181 FILLP_UINT32 offset = (FILLP_UINT32)(ctx->count[0] & FILLP_SHA256_MASK); in FillpSha256Upd()
215 FILLP_UINT32 offset = (FILLP_UINT32)(ctx->count[0] & FILLP_SHA256_MASK); in FillpSha256Fin()
[all …]
H A Dfillp_stack_config_in.c55 FILLP_UINT32 configValue = *(FILLP_UINT32 *)value; in FtConfigSetRecvCachePktNumBufferSize()
152 FILLP_UINT32 configValue = *(FILLP_UINT32 *)value; in FtConfigSetFullCpuUseThresholdRate()
220 FILLP_UINT32 configValue = *(FILLP_UINT32 *)value; in FtConfigSetInitialRate()
265 … if ((*(FILLP_UINT32 *)value != FILLP_NULL) && (*(FILLP_UINT32 *)value <= FILLP_MAX_STACK_RATE) && in FtConfigSetMaxRate()
267 g_resource.flowControl.maxRate = *(FILLP_UINT32 *)value; in FtConfigSetMaxRate()
278 if (*(FILLP_UINT32 *)value <= FILLP_MAX_STACK_RATE) { in FtConfigSetLimitRate()
279 g_resource.flowControl.limitRate = *(FILLP_UINT32 *)value; in FtConfigSetLimitRate()
290 …if ((*(FILLP_UINT32 *)value != FILLP_NULL) && (*(FILLP_UINT32 *)value <= FILLP_MAX_STACK_RECV_RATE… in FtConfigSetMaxRecvRate()
292 g_resource.flowControl.maxRecvRate = *(FILLP_UINT32 *)value; in FtConfigSetMaxRecvRate()
303 FILLP_UINT32 configValue = *(FILLP_UINT32 *)value; in FtConfigSetSendCache()
[all …]
H A Dspunge_core.c52 FILLP_UINT32 i; in SpungeDoRecvCycle()
73 static FILLP_UINT32 SpungeCalExpectedBytes(FILLP_UINT32 *sendPktNum, struct SpungePcb *pcb, in SpungeCalExpectedBytes()
76 FILLP_UINT32 bytesExpected; in SpungeCalExpectedBytes()
113 FILLP_UINT32 sendPktNum; in SpungeDoSendCycle()
114 FILLP_UINT32 sendBytes = 0; in SpungeDoSendCycle()
115 FILLP_UINT32 tmpBytes = 0; in SpungeDoSendCycle()
116 FILLP_UINT32 bytesExpected; in SpungeDoSendCycle()
810 FILLP_UINT32 i; in SpungZeroInstance()
811 FILLP_UINT32 instAllBit = (FILLP_UINT32)((1U << g_spunge->insNum) - 1); in SpungZeroInstance()
1281 FILLP_UINT32 tokens; in SpungeTokenTimerCb()
[all …]
H A Dfillp_stack_config.c230 *(FILLP_UINT32 *)value = g_resource.flowControl.initialRate; in FtGetConfigStackHalf2()
233 *(FILLP_UINT32 *)value = g_resource.flowControl.maxRate; in FtGetConfigStackHalf2()
237 *(FILLP_UINT32 *)value = g_resource.flowControl.maxRecvRate; in FtGetConfigStackHalf2()
254 *(FILLP_UINT32 *)value = g_resource.flowControl.limitRate; in FtGetConfigStackHalf2()
258 *(FILLP_UINT32 *)value = g_resource.common.sendCache; in FtGetConfigStackHalf2()
262 *(FILLP_UINT32 *)value = g_resource.common.recvCache; in FtGetConfigStackHalf2()
291 IN FILLP_UINT32 name, in FtGetConfigStack()
315 IN FILLP_UINT32 name, in FtSetConfigStackHalf1()
368 IN FILLP_UINT32 name, in FtSetConfigStackHalf2()
419 IN FILLP_UINT32 name, in FtSetConfigStack()
[all …]
/ohos5.0/foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/include/
H A Dfillp_cookie.h39 FILLP_UINT32 lifeTime; /* life time in milliseconds */
40 FILLP_UINT32 localPacketSeqNumber; /* local packet sequence number */
42 FILLP_UINT32 remotePacketSeqNumber; /* remote packet sequence number */
44 FILLP_UINT32 localMessageSeqNumber; /* local Message sequence number */
46 FILLP_UINT32 remoteMessageSeqNumber; /* remote Message sequence number */
49 FILLP_UINT32 remoteRecvCache; /* client recv from server cache, same as server send cache */
61 FILLP_UINT32 lifeTime; /* life time in milliseconds */
64 FILLP_UINT32 remotePacketSeqNumber; /* remote packet sequence number */
66 FILLP_UINT32 localMessageSeqNumber; /* local Message sequence number */
68 FILLP_UINT32 remoteMessageSeqNumber; /* remote Message sequence number */
[all …]
H A Dres.h39 FILLP_UINT32 recvCachePktNumBufferSize;
50 FILLP_UINT32 padd;
54 FILLP_UINT32 maxRate;
55 FILLP_UINT32 maxRecvRate;
56 FILLP_UINT32 initialRate;
63 FILLP_UINT32 limitRate;
73 FILLP_UINT32 maximalAckNumLimit;
74 FILLP_UINT32 sendOneAckNum;
82 FILLP_UINT32 instUnsendBoxSize;
89 FILLP_UINT32 fullCpuUseThresholdRate;
[all …]
H A Dnet.h65 FILLP_UINT32 closeSet : 1; /* Application calls close() function */
66 FILLP_UINT32 shutdownRdSet : 1; /* Application called shutdown(sock, RD) */
70 FILLP_UINT32 sendBufRunOut : 1; /* Send buffer has run out */
71 FILLP_UINT32 flagsReverse : 26;
76 FILLP_UINT32 peerCharacters;
79 FILLP_UINT32 peerPktSize;
101 void NetconnSetSendCacheSize(struct FtNetconn *conn, FILLP_UINT32 cacheSize);
102 void NetconnSetRecvCacheSize(struct FtNetconn *conn, FILLP_UINT32 cacheSize);
103 void NetconnSetPktSize(struct FtNetconn *conn, FILLP_UINT32 pktSize);
104 void NetconnSetOpersiteRate(struct FtNetconn *conn, FILLP_UINT32 rate);
[all …]
H A Dpcb.h33 FILLP_UINT32 curMaxRateLimitation;
84 void SpungePcbSetSendCacheSize(struct SpungePcb *pcb, FILLP_UINT32 cahceSize);
85 void SpungePcbSetRecvCacheSize(struct SpungePcb *pcb, FILLP_UINT32 cahceSize);
86 void SpungePcbSetPktSize(struct SpungePcb *pcb, FILLP_UINT32 pktSize);
87 void SpungePcbSetOppositeRate(struct SpungePcb *pcb, FILLP_UINT32 rate);
89 void SpungePcbSetPackInterval(struct SpungePcb *pcb, FILLP_UINT32 interval);
H A Dsha256.h29 FILLP_UINT32 count[2];
30 FILLP_UINT32 hash[8];
31 FILLP_UINT32 wbuf[16];
65 void FillpSha256Fin(FillpSha256Ctx ctx[1], FILLP_UINT8 hashVal[], FILLP_UINT32 hashValLen);
/ohos5.0/foundation/communication/dsoftbus/components/nstackx/fillp/src/public/include/
H A Dsockets.h47 FILLP_UINT32 reserve;
52 FILLP_UINT32 keepAliveTime; /* ms */
53 FILLP_UINT32 maxServerAllowSendCache;
54 FILLP_UINT32 maxServerAllowRecvCache;
55 FILLP_UINT32 udpSendBufSize;
56 FILLP_UINT32 recvBufSize;
68 FILLP_UINT32 fcStasticsInterval;
73 FILLP_UINT32 maxRecvRate;
111 FILLP_UINT32 errEvent;
123 FILLP_UINT32 offset;
[all …]
/ohos5.0/foundation/communication/dsoftbus/components/nstackx/fillp/src/app_lib/src/
H A Dfillp_stack_app_config_in.c208 FILLP_UINT32 timerValue; in FtAppTimerConfigSet()
229 FILLP_UINT32 timerValue; in FtAppSetKeepAliveTime()
289 FILLP_UINT32 timerValue; in FtAppSetDisconnectRetryTimeout()
338 FILLP_UINT32 configValue; in FtAppConfigSetSendCache()
365 FILLP_UINT32 configValue; in FtAppConfigSetRecvCache()
392 FILLP_UINT32 configValue; in FtAppSetMaxServerSendCache()
410 FILLP_UINT32 configValue; in FtAppSetMaxServeRecvCache()
429 FILLP_UINT32 configValue; in FtAppConfigSetOppositeSetRate()
785 FILLP_UINT32 val = *(FILLP_UINT32 *)value; in FtAppConfigSetPackInterval()
813 IN FILLP_UINT32 name, in FtInnerAppConfigSetHelper()
[all …]
H A Dfillp_dfx.c43 FILLP_UINT32 dropCnt;
49 FILLP_UINT32 sockIdx;
53 FILLP_UINT32 sockIdx;
57 FILLP_UINT32 dropCnt;
60 FILLP_UINT32 sockIdx;
61 FILLP_UINT32 rtt;
225 *(FILLP_UINT32 *)dstVal = *(FILLP_UINT32 *)srcVal; in DfxEvtParamValCpy()
406 FILLP_UINT32 len = 0; in FillpDumpShowHelp()
423 FILLP_UINT32 len = 0; in FillpDumpShowVer()
440 FILLP_UINT32 len = 0; in FillpDumpShowLogLevel()
[all …]
/ohos5.0/foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/src/fillp/
H A Dfillp_common.c44 FILLP_UINT32 hashIndex = (FILLP_UINT32)(pktNum & mapList->hashModSize); in FillpDelPktSeqHashItem()
66 void FillpMoveUnackToUnrecv(FILLP_UINT32 ackSeq, FILLP_UINT32 lostSeq, struct FillpPcb *pcb, in FillpMoveUnackToUnrecv()
133 FILLP_UINT32 i; in FillpMoveUnackToUnrecvAll()
134 FILLP_UINT32 ackSeqIndex; in FillpMoveUnackToUnrecvAll()
135 FILLP_UINT32 lostSeqIndex; in FillpMoveUnackToUnrecvAll()
136 FILLP_UINT32 loopCount; in FillpMoveUnackToUnrecvAll()
137 FILLP_UINT32 unackListSize; in FillpMoveUnackToUnrecvAll()
138 FILLP_UINT32 hashModSize; in FillpMoveUnackToUnrecvAll()
156 FILLP_UINT32 hashIndex = (FILLP_UINT32)((i + ackSeqIndex) & hashModSize); in FillpMoveUnackToUnrecvAll()
289 FILLP_UINT32 i, loopCount; in FillpAckUnackList()
[all …]
H A Dfillp_flow_control.c47 FILLP_UINT32 indexK) in FillpRecvRateIsBigger()
49 FILLP_UINT32 indexN = indexK - 1; in FillpRecvRateIsBigger()
64 FILLP_UINT32 index; in FillpUpdateRecvRateSample()
65 FILLP_UINT32 indexK; in FillpUpdateRecvRateSample()
97 FILLP_UINT32 indexN = indexK + 1; in FillpUpdateRecvRateSample()
124 FILLP_BOOL FillpAppLimitedStatus(struct FillpPcb *pcb, FILLP_UINT32 beginPktNum, FILLP_UINT32 endPk… in FillpAppLimitedStatus()
130 FILLP_UINT32 i, j; in FillpAppLimitedStatus()
131 FILLP_UINT32 mapLevel; in FillpAppLimitedStatus()
195 FILLP_UINT32 infBytes = 0; in FillpFcTailProtected()
196 FILLP_UINT32 infCap = 0; in FillpFcTailProtected()
[all …]
H A Dfillp_flow_control_alg0.c34 FILLP_UINT32 minRate = FILLP_FC0_DEFAULT_RATE; in FillpAlg0CalSendInterval()
45 static void FillpAlg0UpdateMaxRecvRate(struct FillpFlowControlAlg0 *alg, FILLP_UINT32 recvRate) in FillpAlg0UpdateMaxRecvRate()
54 FILLP_UINT32 i; in FillpAlg0FlowControlInit()
138 FILLP_UINT32 packInterval = FillpGetSockPackInterval(pcb); in FillpAlg0CalPackInterval()
143 FILLP_UINT32 periodSendRate) in FillpAlg0CalMaxPackRcvInterval()
160 FILLP_UINT32 baseSendRate; in FillpAlg0FcHandleInit()
194 FILLP_UINT32 baseSendRate; in FillpAlg0FcHandleBwProbe()
195 FILLP_UINT32 recvRate = pack->rate; in FillpAlg0FcHandleBwProbe()
210 FILLP_UINT32 maxRateAllowed; in FillpAlg0PackStateProcess()
241 FILLP_UINT32 periodSendRate; /* Kbps */ in FillpAlg0AnalysePack()
[all …]
H A Dfillp_output.c64 sendPcb->seqNum = sendPcb->seqNum + (FILLP_UINT32)item->dataLen; in FillpGetSendItem()
83 if (sendPcb->unackList.count < (FILLP_UINT32)DYMP_GET_CUR_SIZE(sendPcb->itemPool)) { in FillpIsAskMoreBuf()
98 sendPcb->curItemCount = (FILLP_UINT32)DYMP_GET_CUR_SIZE(sendPcb->itemPool); in FillpIsAskMoreBuf()
104 FILLP_UINT32 sentBytes, FILLP_UINT32 sendPktNum) in FillpDoneSendAllData()
133 FILLP_UINT32 sentBytes, FILLP_UINT32 totalBytes) in FillpBeforeSendItem()
145 sentBytes = (sentBytes + (FILLP_UINT32)item->dataLen); in FillpBeforeSendItem()
161 FILLP_UINT32 FillpSendOne(struct FillpPcb *pcb, FILLP_UINT32 totalBytes, FILLP_UINT32 sendPktNum) in FillpSendOne()
166 FILLP_UINT32 sentBytes = FILLP_NULL; in FillpSendOne()
328 FILLP_UINT32 unackIndex = FILLP_UNACKLIST_HASHINDEX(item->seqNum, pcb); in FillpAddToUnackList()
397 UpdateStatisticsWhenSendOne(stats, (FILLP_UINT32)item->dataLen); in FillpSendItem()
[all …]
H A Dfillp_frame.c78 FILLP_UINT32 size, FILLP_BOOL newFrame) in FillpFrameAddItemStats()
123 const struct FrameInfo *info, FILLP_UINT32 fragSize, FILLP_BOOL firstPkt) in FillpFrameTxInitItem()
129 … if (h->curFrame.info.size == 0 || (FILLP_UINT32)info->seqNum != h->curFrame.info.seqNum) { in FillpFrameTxInitItem()
133 h->curFrame.info.seqNum = (FILLP_UINT32)info->seqNum; in FillpFrameTxInitItem()
152 FILLP_UINT32 FillpFrameGetPktDataOptLen(FILLP_UINT32 flag, FILLP_UINT32 pktDataOptLen) in FillpFrameGetPktDataOptLen()
154 FILLP_UINT32 optLen = pktDataOptLen; in FillpFrameGetPktDataOptLen()
181 frameOpt->txTimestamp = FILLP_HTONL((FILLP_UINT32)info->timestamp); in FillpFrameBuildOption()
224 UTILS_FLAGS_SET(item->flags, (FILLP_UINT32)frameOpt->bitMap | FILLP_ITEM_FLAGS_FIRST_PKT); in FillpFrameParseOption()
238 frame->info.seqNum = (FILLP_UINT32)item->frame->info.seqNum; in FillpFrameRxNewFrag()
240 frame->info.txTimestamp = (FILLP_UINT32)item->frame->info.timestamp; in FillpFrameRxNewFrag()
[all …]
/ohos5.0/foundation/communication/dsoftbus/components/nstackx/fillp/src/public/src/
H A Dspunge_mem.c30 FILLP_UINT32 totalSize = (FILLP_UINT32)(blockSize * blockNum); in SpungeAlloc()
35 return FILLP_MALLOC((FILLP_UINT32)totalSize); in SpungeAlloc()
41 return FILLP_CALLOC((FILLP_UINT32)blockNum, (FILLP_UINT32)blockSize); in SpungeAlloc()

123