openharmony/miscservices_time
1
0
Fork 0
mirror of https://github.com/openharmony/miscservices_time.git synced 2026-07-18 17:34:34 -04:00
Code Issues Packages Projects Releases Wiki Activity

Signed-off-by: zhangjunxi <zhangjunxi1@huawei.com>

Browse Source 
Changes to be committed:
	modified:   timer/src/timer_handler.cpp
	modified:   timer/src/timer_manager.cpp
This commit is contained in:
zhangjunxi
2022-07-02 11:17:19 +08:00
parent d149d1e3ff
commit fde22bc32b
2 changed files with 1 additions and 23 deletions
Download Patch File Download Diff File Expand all files Collapse all files
services/timer/src/timer_handler.cpp
-1
View File
@@ -104,7 +104,6 @@ TimerHandler::~TimerHandler()
int TimerHandler::Set(uint32_t type, std::chrono::nanoseconds when)
{
TIME_HILOGI(TIME_MODULE_SERVICE, "type= %{public}d, when= %{public}lld", type, when.count());
if (static_cast<size_t>(type) > ALARM_TYPE_COUNT) {
errno = EINVAL;
return -1;
services/timer/src/timer_manager.cpp
+1 -22
View File
@@ -361,14 +361,12 @@ void TimerManager::TimerLooper()
do {
result = handler_->WaitForAlarm();
} while (result < 0 && errno == EINTR);
TIME_HILOGI(TIME_MODULE_SERVICE, "result= %{public}d", result);
auto nowRtc = std::chrono::system_clock::now();
auto nowElapsed = std::chrono::steady_clock::now();
triggerList.clear();
if ((result & TIME_CHANGED_MASK) != 0) {
TIME_HILOGI(TIME_MODULE_SERVICE, "time changed");
system_clock::time_point lastTimeChangeClockTime;
system_clock::time_point expectedClockTime;
std::lock_guard<std::mutex> lock(mutex_);
@@ -386,8 +384,7 @@ void TimerManager::TimerLooper()
if (result != TIME_CHANGED_MASK) {
std::lock_guard<std::mutex> lock(mutex_);
auto hasWakeup = TriggerTimersLocked(triggerList, nowElapsed);
TIME_HILOGI(TIME_MODULE_SERVICE, "hasWakeup= %{public}d", hasWakeup);
TriggerTimersLocked(triggerList, nowElapsed);
DeliverTimersLocked(triggerList, nowElapsed);
RescheduleKernelTimerLocked();
} else {
@@ -407,16 +404,10 @@ TimerManager::~TimerManager()
bool TimerManager::TriggerTimersLocked(std::vector<std::shared_ptr<TimerInfo>> &triggerList,
std::chrono::steady_clock::time_point nowElapsed)
{
TIME_HILOGI(TIME_MODULE_SERVICE, "alarmBatches_.size= %{public}d", static_cast<int>(alarmBatches_.size()));
bool hasWakeup = false;
while (!alarmBatches_.empty()) {
auto batch = alarmBatches_.at(0);
TIME_HILOGI(TIME_MODULE_SERVICE, "batch->GetStart()= %{public}lld, nowElapsed= %{public}lld",
time_point_cast<nanoseconds>(batch->GetStart()).time_since_epoch().count(),
time_point_cast<nanoseconds>(nowElapsed).time_since_epoch().count());
if (batch->GetStart() > nowElapsed) {
TIME_HILOGI(TIME_MODULE_SERVICE, "break alarmBatches_.size= %{public}d",
static_cast<int>(alarmBatches_.size()));
break;
}
alarmBatches_.erase(alarmBatches_.begin());
@@ -454,23 +445,16 @@ bool TimerManager::TriggerTimersLocked(std::vector<std::shared_ptr<TimerInfo>> &
void TimerManager::RescheduleKernelTimerLocked()
{
TIME_HILOGI(TIME_MODULE_SERVICE, "start alarmBatches_.size= %{public}d", static_cast<int>(alarmBatches_.size()));
auto nextNonWakeup = std::chrono::steady_clock::time_point::min();
if (!alarmBatches_.empty()) {
auto firstWakeup = FindFirstWakeupBatchLocked();
auto firstBatch = alarmBatches_.front();
if (firstWakeup != nullptr) {
auto alarmPtr = firstWakeup->Get(0);
if (alarmPtr != nullptr) {
TIME_HILOGI(TIME_MODULE_SERVICE, "wake up alarm id :%{public}" PRId64 "", alarmPtr->id);
}
SetLocked(ELAPSED_REALTIME_WAKEUP, firstWakeup->GetStart().time_since_epoch());
}
if (firstBatch != firstWakeup) {
auto alarmPtr = firstBatch->Get(0);
if (alarmPtr != nullptr) {
TIME_HILOGI(TIME_MODULE_SERVICE, "nonwakeup alarm id :%{public}" PRId64 "", alarmPtr->id);
}
nextNonWakeup = firstBatch->GetStart();
}
}
@@ -478,7 +462,6 @@ void TimerManager::RescheduleKernelTimerLocked()
if (nextNonWakeup != std::chrono::steady_clock::time_point::min()) {
SetLocked(ELAPSED_REALTIME, nextNonWakeup.time_since_epoch());
}
TIME_HILOGI(TIME_MODULE_SERVICE, "end");
}
std::shared_ptr<Batch> TimerManager::FindFirstWakeupBatchLocked()
@@ -493,9 +476,7 @@ std::shared_ptr<Batch> TimerManager::FindFirstWakeupBatchLocked()
void TimerManager::SetLocked(int type, std::chrono::nanoseconds when)
{
TIME_HILOGI(TIME_MODULE_SERVICE, "start when.count= %{public}lld", when.count());
handler_->Set(static_cast<uint32_t>(type), when);
TIME_HILOGI(TIME_MODULE_SERVICE, "end");
}
void TimerManager::InsertAndBatchTimerLocked(std::shared_ptr<TimerInfo> alarm)
@@ -532,14 +513,12 @@ int64_t TimerManager::AttemptCoalesceLocked(std::chrono::steady_clock::time_poin
void TimerManager::DeliverTimersLocked(const std::vector<std::shared_ptr<TimerInfo>> &triggerList,
std::chrono::steady_clock::time_point nowElapsed)
{
TIME_HILOGI(TIME_MODULE_SERVICE, "start");
for (const auto &alarm : triggerList) {
if (alarm->callback) {
alarm->callback(alarm->id);
TIME_HILOGI(TIME_MODULE_SERVICE, "Trigger id: %{public}" PRId64 "", alarm->id);
}
}
TIME_HILOGI(TIME_MODULE_SERVICE, "end");
}
bool AddBatchLocked(std::vector<std::shared_ptr<Batch>> &list, const std::shared_ptr<Batch> &newBatch)