| /base/time/time_service/services/timer/src/ |
| H A D | timer_info.cpp | 57 whenElapsed {_whenElapsed},
69 TIME_HILOGD(TIME_MODULE_SERVICE, "Update whenElapsed, id=%{public}" PRId64 "", id); in UpdateWhenElapsedFromNow()
70 auto oldWhenElapsed = whenElapsed; in UpdateWhenElapsedFromNow()
71 whenElapsed = now + offset; in UpdateWhenElapsedFromNow()
73 maxWhenElapsed = whenElapsed + windowLength; in UpdateWhenElapsedFromNow()
83 return (oldWhenElapsed != whenElapsed) || (oldMaxWhenElapsed != maxWhenElapsed); in UpdateWhenElapsedFromNow()
88 auto oldWhenElapsed = whenElapsed; in AdjustTimer()
92 auto oldTimeSec = std::chrono::duration_cast<std::chrono::seconds>(whenElapsed.time_since_epoch()); in AdjustTimer()
94 whenElapsed = std::chrono::steady_clock::time_point(timeSec); in AdjustTimer()
96 maxWhenElapsed = whenElapsed; in AdjustTimer()
[all...] |
| H A D | batch.cpp | 30 : start_ {seed.whenElapsed}, in Batch()
47 bool Batch::CanHold(std::chrono::steady_clock::time_point whenElapsed, in CanHold() argument
50 return (end_ > whenElapsed) && (start_ <= maxWhen); in CanHold()
60 return first->whenElapsed < second->whenElapsed; in Add()
64 if (alarm->whenElapsed > start_) { in Add()
65 start_ = alarm->whenElapsed; in Add()
94 if (alarm->whenElapsed > newStart) { in Remove()
95 newStart = alarm->whenElapsed; in Remove()
|
| H A D | timer_manager.cpp | 356 std::chrono::steady_clock::time_point whenElapsed, in SetHandlerLocked()
368 auto alarm = std::make_shared<TimerInfo>(id, type, when, whenElapsed, windowLength, maxWhen, in SetHandlerLocked()
375 alarm->UpdateWhenElapsedFromNow(whenElapsed, milliseconds(TimerProxy::GetInstance().GetProxyDelayTime())); in SetHandlerLocked()
381 alarm->UpdateWhenElapsedFromNow(whenElapsed, milliseconds(TimerProxy::GetInstance().GetProxyDelayTime())); in SetHandlerLocked()
430 if (pendingTimer->whenElapsed <= GetBootTimeNs()) { in RemoveLocked()
460 alarm->offset = duration_cast<milliseconds>(alarm->whenElapsed - GetBootTimeNs()); in SetHandlerLocked()
502 ", timer originMaxWhenElapsed=%{public}lld, whenElapsed=%{public}lld, now=%{public}lld", in ReAddTimerLocked()
504 timer->whenElapsed.time_since_epoch().count(), GetBootTimeNs().time_since_epoch().count()); in ReAddTimerLocked()
505 auto whenElapsed = ConvertToElapsed(timer->when, timer->type); in ReAddTimerLocked() local
508 maxElapsed = whenElapsed; in ReAddTimerLocked()
354 SetHandlerLocked(uint64_t id, int type, std::chrono::milliseconds when, std::chrono::steady_clock::time_point whenElapsed, std::chrono::milliseconds windowLength, std::chrono::steady_clock::time_point maxWhen, std::chrono::milliseconds interval, std::function<int32_t (const uint64_t)> callback, const std::shared_ptr<OHOS::AbilityRuntime::WantAgent::WantAgent> &wantAgent, uint32_t flags, uint64_t callingUid, uint64_t callingPid, const std::string &bundleName) SetHandlerLocked() argument
773 AttemptCoalesceLocked(std::chrono::steady_clock::time_point whenElapsed, std::chrono::steady_clock::time_point maxWhen) AttemptCoalesceLocked() argument
993 auto whenElapsed = ConvertToElapsed(timer->origWhen, timer->type); ReCalcuOriWhenElapsed() local
[all...] |
| H A D | timer_proxy.cpp | 428 it->second.insert(std::make_pair(alarm->id, alarm->whenElapsed)); in RecordProxyUidTimerMap()
431 std::unordered_map<uint64_t, std::chrono::steady_clock::time_point>{{alarm->id, alarm->whenElapsed}})); in RecordProxyUidTimerMap()
440 it->second.insert(std::make_pair(alarm->id, alarm->whenElapsed)); in RecordProxyPidTimerMap()
443 std::unordered_map<uint64_t, std::chrono::steady_clock::time_point>{{alarm->id, alarm->whenElapsed}})); in RecordProxyPidTimerMap()
544 timePointMap.insert(std::make_pair(itUidTimersMap->first, itUidTimersMap->second->whenElapsed)); in UpdateProxyWhenElapsedForProxyUidMap()
547 "uid= %{public}d, id=%{public}" PRId64 ", timer whenElapsed=%{public}lld, now=%{public}lld", in UpdateProxyWhenElapsedForProxyUidMap()
549 itUidTimersMap->second->whenElapsed.time_since_epoch().count(), in UpdateProxyWhenElapsedForProxyUidMap()
577 timePointMap.insert(std::make_pair(itPidTimersMap->first, itPidTimersMap->second->whenElapsed)); in UpdateProxyWhenElapsedForProxyPidMap()
580 "pid= %{public}d, id=%{public}" PRId64 ", timer whenElapsed=%{public}lld, now=%{public}lld", in UpdateProxyWhenElapsedForProxyPidMap()
582 itPidTimersMap->second->whenElapsed in UpdateProxyWhenElapsedForProxyPidMap()
[all...] |
| /base/time/time_service/services/timer/include/ |
| H A D | timer_info.h | 44 std::chrono::steady_clock::time_point whenElapsed; member in OHOS::MiscServices::TimerInfo
52 std::chrono::steady_clock::time_point whenElapsed,
|
| H A D | batch.h | 37 bool CanHold(std::chrono::steady_clock::time_point whenElapsed,
|
| H A D | timer_manager.h | 89 std::chrono::steady_clock::time_point whenElapsed,
108 int64_t AttemptCoalesceLocked(std::chrono::steady_clock::time_point whenElapsed,
|
| /base/time/time_service/services/dfx/src/ |
| H A D | time_sysevent.cpp | 32 int64_t triggerTime = timer->whenElapsed.time_since_epoch().count(); in StatisticReporter()
|
| /base/time/time_service/test/unittest/service_test/src/ |
| H A D | time_proxy_test.cpp | 377 std::chrono::steady_clock::time_point time = TimerProxy::GetInstance().uidTimersMap_[uid][timerId]->whenElapsed; in HWTEST_F()
398 EXPECT_NE(it4->second->whenElapsed, time); in HWTEST_F()
411 EXPECT_EQ(it6->second->whenElapsed, time); in HWTEST_F()
590 std::chrono::steady_clock::time_point time = TimerProxy::GetInstance().pidTimersMap_[pid][timerId]->whenElapsed; in HWTEST_F()
611 EXPECT_NE(it4->second->whenElapsed, time); in HWTEST_F()
624 EXPECT_EQ(it6->second->whenElapsed, time); in HWTEST_F()
|