| /ohos5.0/foundation/communication/dsoftbus/components/nstackx/fillp/src/public/include/ |
| H A D | timing_wheel.h | 49 FILLP_LLONG curSlotTime;
61 FILLP_LLONG curTime;
63 FILLP_LLONG tickTime;
64 FILLP_LLONG accuracy;
71 FILLP_LLONG nextMinimalExpireTime;
88 FILLP_LLONG expireTime;
135 void FillpTimingWheelInit(struct FillpTimingWheel *ftWheel, FILLP_LLONG accuracy);
137 void FillpTimingWheelAddTimer(struct FillpTimingWheel *ftWheel, FILLP_LLONG expireTime,
140 void FillpTimingWheelLoopCheck(struct FillpTimingWheel *ftWheel, FILLP_LLONG curTime);
|
| H A D | spunge.h | 72 FILLP_LLONG lastControlTime;
80 FILLP_LLONG lastTime;
92 FILLP_LLONG curTime;
93 FILLP_LLONG minSendInterval;
|
| H A D | sockets.h | 67 FILLP_LLONG nackDelayTimeout;
126 FILLP_LLONG jitter;
127 FILLP_LLONG transmit;
238 FILLP_LLONG nackDelayTimeout;
|
| H A D | callbacks.h | 167 FILLP_LLONG FillpSysArchGetCurTimeLonglong(IN void);
438 FILLP_LLONG FillpSysAdaptArchGetCurTimeLonglong();
|
| /ohos5.0/foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/include/fillp/ |
| H A D | fillp_pcb.h | 56 FILLP_LLONG timestamp;
71 FILLP_LLONG maxOwd; /* max owd value */
72 FILLP_LLONG minOwd; /* min owd value */
100 FILLP_LLONG sendTime; /* pre send time */
102 FILLP_LLONG sendInterval; /* Real itnerval(us) * 8 */
164 FILLP_LLONG lastSendTs;
179 FILLP_LLONG connTimestamp;
180 FILLP_LLONG dataNullTimestamp;
209 FILLP_LLONG connReqInputTimestamp;
223 FILLP_LLONG lastCalcTime;
|
| H A D | fillp_flow_control_alg0.h | 38 FILLP_LLONG t; /* rtt time */
39 FILLP_LLONG v; /* rtt value */
|
| H A D | fillp_frame.h | 54 FILLP_LLONG firstPktRxTime; /* rx time of the first pkt of the frame */
55 FILLP_LLONG lastPktRxTime; /* rx time of the last pkt of the frame */
|
| H A D | fillp.h | 103 FILLP_LLONG firstSendTimestamp;
104 FILLP_LLONG lastSendTimestamp;
105 FILLP_LLONG appSendTimestamp;
108 FILLP_LLONG rxTimeStamp;
|
| H A D | fillp_common.h | 48 void FillpAjustTlpParameterByRtt(struct FillpPcb *pcb, FILLP_LLONG rtt);
|
| /ohos5.0/foundation/communication/dsoftbus/components/nstackx/fillp/include/ |
| H A D | fillpinc.h | 742 FILLP_LLONG jitter;
938 FILLP_LLONG nackDelayTimeout;
1099 FILLP_LLONG packTimePassed; /* Indicates the packet time passed. */
1100 FILLP_LLONG packSendTime; /* Indicates the packet send time. */
1128 FILLP_LLONG nackSendTime; /* Indicates the NACK send time. */
1137 FILLP_LLONG lastRecvTime; /* Indicates the last receive time. */
1139 FILLP_LLONG lastSendTime; /* Indicates the last send time. */
1147 FILLP_LLONG curPackDeltaUs;
1211 FILLP_LLONG timestamp;
1227 FILLP_LLONG periodTimePassed;
[all …]
|
| /ohos5.0/foundation/communication/dsoftbus/components/nstackx/fillp/src/public/src/ |
| H A D | timing_wheel.c | 25 static void FillpTimingWheelAddTimerInner(struct FillpTimingWheel *ftWheel, FILLP_LLONG expireTime,
35 static void FillpTimingWheelHandHourTick(struct FillpTimingWheel *wheel, FILLP_LLONG tickDiff) in FillpTimingWheelHandHourTick()
84 static void FillpTimingWheelHandMinTick(struct FillpTimingWheel *wheel, FILLP_LLONG tickDiff) in FillpTimingWheelHandMinTick()
185 void FillpTimingWheelInit(struct FillpTimingWheel *ftWheel, FILLP_LLONG accuracy) in FillpTimingWheelInit()
202 static void FillpTimingWheelAddTimerInner(struct FillpTimingWheel *ftWheel, FILLP_LLONG expireTime, in FillpTimingWheelAddTimerInner()
205 FILLP_LLONG timeDiff; in FillpTimingWheelAddTimerInner()
248 void FillpTimingWheelAddTimer(struct FillpTimingWheel *ftWheel, FILLP_LLONG expireTime, in FillpTimingWheelAddTimer()
287 void FillpTimingWheelLoopCheck(struct FillpTimingWheel *ftWheel, FILLP_LLONG curTime) in FillpTimingWheelLoopCheck()
289 FILLP_LLONG timeDiff = curTime - ftWheel->curTime; in FillpTimingWheelLoopCheck()
|
| H A D | callbacks.c | 433 FILLP_LLONG FillpSysArchTimeToLonglong(FILLP_CONST FillpSysArchTime *time) in FillpSysArchTimeToLonglong()
438 …FILLP_LLONG l_time = (((*time) * g_macTimeBaseInfo.numer) / (g_macTimeBaseInfo.denom * FILLP_CONST… in FillpSysArchTimeToLonglong()
446 FILLP_LLONG FillpSysArchTimeToLonglong(FILLP_CONST FillpSysArchTime *ptime) in FillpSysArchTimeToLonglong()
448 …FILLP_LLONG l_time = ((FILLP_LLONG)ptime->tv_sec) * FILLP_CONST_1M + (ptime->tv_nsec / FILLP_CONST… in FillpSysArchTimeToLonglong()
467 FILLP_LLONG FillpSysArchTimeToLonglong(FILLP_CONST FillpSysArchTime *timeValue) in FillpSysArchTimeToLonglong()
479 FILLP_LLONG FillpSysAdaptArchGetCurTimeLonglong() in FillpSysAdaptArchGetCurTimeLonglong()
510 FILLP_LLONG FillpSysArchGetCurTimeLonglong(IN void) in FillpSysArchGetCurTimeLonglong()
587 return (FILLP_INT)__sync_bool_compare_and_swap(sem, (FILLP_LLONG)(FILLP_ULLONG)oldValue, in FillpSysArchCompAndWwap()
588 (FILLP_LLONG)(FILLP_ULLONG)exchange); in FillpSysArchCompAndWwap()
1258 FILLP_LLONG start; in FillpAdaptSysArchSemWaitTimeout()
[all …]
|
| /ohos5.0/foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/src/fillp/ |
| H A D | fillp_timer.c | 51 appFcStastics->periodRecvBits += (FILLP_LLONG)packStastics->periodRecvBits; in FillpCalFcAppStastics()
54 if (appFcStastics->periodTimePassed < (FILLP_LLONG)(sock->resConf.common.fcStasticsInterval)) { in FillpCalFcAppStastics()
154 FILLP_LLONG curTime = SYS_ARCH_GET_CUR_TIME_LONGLONG(); in FillpPackTimerCb()
170 … (curTime - pack->packRttDetectTime) > (FILLP_LLONG)(sock->resConf.common.fcStasticsInterval)) { in FillpPackTimerCb()
183 FILLP_LLONG detaTime = (FILLP_LLONG)(pcb->pcbInst->curTime - flowControl->sendTime); in FillpSendTimerCb()
184 FILLP_LLONG realDetaTime = (FILLP_LLONG)((FILLP_ULLONG)detaTime << FILLP_TIME_PRECISION); in FillpSendTimerCb()
|
| H A D | fillp_flow_control.c | 179 flowControl->sendInterval = (FILLP_LLONG)(pcb->pktSize * FILLP_FC_IN_KBPS * FILLP_FC_IN_BIT); in FillpCalSendInterval()
181 …flowControl->sendInterval = FILLP_DIV_ROUND_UP(flowControl->sendInterval, (FILLP_LLONG)flowControl… in FillpCalSendInterval()
193 FILLP_LLONG deltaUs; in FillpFcTailProtected()
364 FILLP_LLONG detaTime; in FillpFcCycle()
377 … if (detaTime >= (FILLP_LLONG)FILLP_UTILS_MS2US((FILLP_LLONG)sock->resConf.common.keepAliveTime)) { in FillpFcCycle()
390 … (FILLP_UINT32)(FILLP_UTILS_MS2US((FILLP_LLONG)sock->resConf.common.keepAliveTime) - detaTime); in FillpFcCycle()
|
| H A D | fillp_output.c | 73 … (SYS_ARCH_GET_CUR_TIME_LONGLONG() - (FILLP_LLONG)item->appSendTimestamp), item->appSendSize); in FillpGetSendItem()
76 … (SYS_ARCH_GET_CUR_TIME_LONGLONG() - (FILLP_LLONG)item->appSendTimestamp), item->appSendSize); in FillpGetSendItem()
206 FILLP_LLONG curTime = SYS_ARCH_GET_CUR_TIME_LONGLONG(); in FillpBuildTimestamp()
207 curTime = (FILLP_LLONG)FILLP_HTONLL((FILLP_ULLONG)curTime); in FillpBuildTimestamp()
211 err = memcpy_s(&(dataOption->value[0]), sizeof(FILLP_LLONG), &curTime, sizeof(FILLP_LLONG)); in FillpBuildTimestamp()
438 FILLP_LLONG curTime = SYS_ARCH_GET_CUR_TIME_LONGLONG(); in FillpSendAdhocpackToDetectRtt()
|
| H A D | fillp_input.c | 35 static void FillpCalRecvJitter(struct FtSocket *sock, FILLP_LLONG arrival, FILLP_LLONG receiveTrans… in FillpCalRecvJitter()
37 FILLP_LLONG transmit = arrival - receiveTransmit; in FillpCalRecvJitter()
38 FILLP_LLONG delta = transmit - sock->transmit; in FillpCalRecvJitter()
55 sock->jitter = (FILLP_LLONG)(factor + factorJitter); in FillpCalRecvJitter()
82 FILLP_LLONG sendTimestamp = 0; in FillpProcessDataOptions()
83 FILLP_LLONG recvTimestamp = SYS_ARCH_GET_CUR_TIME_LONGLONG(); in FillpProcessDataOptions()
84 … err = memcpy_s(&sendTimestamp, sizeof(FILLP_LLONG), &(dataOption->value[0]), sizeof(FILLP_LLONG)); in FillpProcessDataOptions()
90 sendTimestamp = (FILLP_LLONG)FILLP_NTOHLL((FILLP_ULLONG)sendTimestamp); in FillpProcessDataOptions()
615 FILLP_LLONG curTime = SYS_ARCH_GET_CUR_TIME_LONGLONG(); in FillpHandleAdhocpackFlag()
|
| H A D | fillp_common.c | 77 FILLP_LLONG cmpGap; in FillpMoveOneNode()
79 cmpGap = (FILLP_LLONG)pcb->send.retramistRto; in FillpMoveOneNode()
89 FILLP_LLONG gap = pcb->pcbInst->curTime - item->lastSendTimestamp; in FillpMoveOneNode()
174 … (SYS_ARCH_GET_CUR_TIME_LONGLONG() - (FILLP_LLONG)item->appSendTimestamp), item->appSendSize); in LogForMsgRTT()
683 void FillpAjustTlpParameterByRtt(struct FillpPcb *pcb, FILLP_LLONG rtt) in FillpAjustTlpParameterByRtt()
760 FillpAjustTlpParameterByRtt(pcb, (FILLP_LLONG)pcb->rtt); in FillpAdjustFcParamsByRtt()
|
| H A D | fillp_conn.c | 456 FILLP_LLONG curTime = SYS_ARCH_GET_CUR_TIME_LONGLONG(); in FillpConnReqAckInput()
457 FILLP_LLONG rttTime = curTime - (FILLP_LLONG)reqAck.timestamp; in FillpConnReqAckInput()
1338 static void FillpSendConnReqBuild(struct FillpPcb *pcb, struct FillpPktConnReq *req, FILLP_LLONG cu… in FillpSendConnReqBuild()
1378 FILLP_LLONG curTime; in FillpSendConnReq()
1910 FILLP_LLONG *cookieTime = (FILLP_LLONG *)(void *)(stateCookie->arr); in FillpGenerateCookie()
1911 *cookieTime = (FILLP_LLONG)SYS_ARCH_GET_CUR_TIME_LONGLONG(); in FillpGenerateCookie()
1998 FILLP_LLONG timeDiffVal; in FillpValidateCookie()
1999 FILLP_LLONG curTime; in FillpValidateCookie()
2028 curTime = (FILLP_LLONG)SYS_ARCH_GET_CUR_TIME_LONGLONG(); in FillpValidateCookie()
2030 timeDiffVal = (FILLP_LLONG)((FILLP_ULLONG)curTime - (*cookieTime)); in FillpValidateCookie()
|
| H A D | fillp_flow_control_alg0.c | 142 static void FillpAlg0CalMaxPackRcvInterval(struct FillpPcb *pcb, FILLP_LLONG detaUs, FILLP_UINT32 p… in FillpAlg0CalMaxPackRcvInterval()
239 FILLP_LLONG detaUs; in FillpAlg0AnalysePack()
|
| H A D | fillp_pcb.c | 516 FILLP_LLONG detaTime = (FILLP_LLONG)(fpcb->pcbInst->curTime - flowControl->sendTime); in FillpPcbSendFc()
517 FILLP_LLONG realDetaTime = (FILLP_LLONG)((FILLP_ULLONG)detaTime << FILLP_TIME_PRECISION); in FillpPcbSendFc()
|
| /ohos5.0/foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/include/ |
| H A D | net.h | 63 FILLP_LLONG connTimeout;
110 void NetconnSetConnectTimeout(struct FtNetconn *conn, FILLP_LLONG timeoutUs);
|
| H A D | spunge_stack.h | 28 void SpungeDoSendCycle(struct SpungePcb *pcb, struct SpungeInstance *inst, FILLP_LLONG detaTime);
|
| H A D | fillp_cookie.h | 88 void FillpMacTimerExpire(FillpMacInfo *macInfo, FILLP_LLONG curTime);
|
| /ohos5.0/foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/src/ |
| H A D | spunge_core.c | 74 struct FtSocket *sock, struct FillpFlowControl *flowControl, FILLP_LLONG detaTime) in SpungeCalExpectedBytes()
111 void SpungeDoSendCycle(struct SpungePcb *pcb, struct SpungeInstance *inst, FILLP_LLONG detaTime) in SpungeDoSendCycle()
949 static FILLP_BOOL SpungeDelay(struct SpungeInstance *inst, FILLP_LLONG curTime) in SpungeDelay()
951 FILLP_LLONG timePass = curTime - inst->curTime; in SpungeDelay()
953 …FILLP_LLONG minSendInterval = (FILLP_LLONG)((FILLP_ULLONG)inst->minSendInterval >> FILLP_TIME_PREC… in SpungeDelay()
977 FILLP_LLONG curTime = SYS_ARCH_GET_CUR_TIME_LONGLONG(); in SpungeMainDelay()
1186 FILLP_LLONG curTime; in FillpCheckPcbNackListToSend()
1204 FILLP_LLONG timestamp = nackNode->timestamp; in FillpCheckPcbNackListToSend()
1236 if (((inst->curTime - (FILLP_LLONG)inst->macInfo.switchOverTime) > FILLP_KEY_REFRESH_TIME)) { in SpinstLoopMacTimerChecker()
|
| H A D | fillp_cookie.c | 38 FILLP_LLONG curTime) in FillpMacTimerExpire()
|