Searched refs:wakeUpTime (Results 1 – 2 of 2) sorted by relevance
1226 wakeUpTime = nextServerHandleTime; in PrepareNext()1230 nextServerHandleTime, wakeUpTime); in PrepareNext()1338 int64_t wakeUpTime = ClockTime::GetCurNano(); in RecordProcessCallbackFuc() local1356 wakeUpTime = curTime; in RecordProcessCallbackFuc()1371 if (wakeUpTime > curTime && wakeUpTime - curTime < static_cast<int64_t>(spanSizeInMs_) * in RecordProcessCallbackFuc()1614 ClockTime::AbsoluteSleep(wakeUpTime); in ProcessCallbackFuc()1636 wakeUpTime = curTime; in ProcessCallbackFucIndependent()1667 ClockTime::AbsoluteSleep(wakeUpTime); in ProcessCallbackFucIndependent()1697 wakeUpTime = nextServerHandleTime; in PrepareNextIndependent()1718 int64_t wakeupCost = curTime - wakeUpTime; in CheckIfWakeUpTooLate()[all …]
194 bool PrepareNextLoop(uint64_t curWritePos, int64_t &wakeUpTime);1706 wakeUpTime = predictWakeupTime; in RecordPrepareNextLoop()1727 wakeUpTime = predictWakeupTime; in PrepareNextLoop()2016 int64_t wakeUpTime = ClockTime::GetCurNano(); in RecordEndpointWorkLoopFuc() local2025 wakeUpTime = ClockTime::GetCurNano(); in RecordEndpointWorkLoopFuc()2047 ClockTime::AbsoluteSleep(wakeUpTime); in RecordEndpointWorkLoopFuc()2056 int64_t wakeUpTime = ClockTime::GetCurNano(); in EndpointWorkLoopFuc() local2069 wakeUpTime = curTime; in EndpointWorkLoopFuc()2082 if (!CheckAllBufferReady(wakeUpTime, curWritePos)) { in EndpointWorkLoopFuc()2093 if (!PrepareNextLoop(curWritePos, wakeUpTime)) { in EndpointWorkLoopFuc()[all …]