1 /*
2 * Copyright (c) 2021 Huawei Device Co., Ltd.
3 * Licensed under the Apache License, Version 2.0 (the "License");
4 * you may not use this file except in compliance with the License.
5 * You may obtain a copy of the License at
6 *
7 * http://www.apache.org/licenses/LICENSE-2.0
8 *
9 * Unless required by applicable law or agreed to in writing, software
10 * distributed under the License is distributed on an "AS IS" BASIS,
11 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12 * See the License for the specific language governing permissions and
13 * limitations under the License.
14 */
15
16 #include "timer_call_back.h"
17 #include "timer_notify_call_back.h"
18
19 namespace OHOS {
20 namespace MiscServices {
21 std::mutex TimerCallback::instanceLock_;
22 sptr<TimerCallback> TimerCallback::instance_;
23
24 std::map<uint64_t, std::shared_ptr<ITimerInfo>> TimerCallback::timerInfoMap_;
25 std::mutex TimerCallback::timerInfoMutex_;
26
TimerCallback()27 TimerCallback::TimerCallback()
28 {
29 }
30
~TimerCallback()31 TimerCallback::~TimerCallback()
32 {
33 timerInfoMap_.clear();
34 }
35
GetInstance()36 sptr<TimerCallback> TimerCallback::GetInstance()
37 {
38 if (instance_ == nullptr) {
39 std::lock_guard<std::mutex> autoLock(instanceLock_);
40 if (instance_ == nullptr) {
41 instance_ = new TimerCallback;
42 }
43 }
44 return instance_;
45 }
46
InsertTimerCallbackInfo(const uint64_t timerId,const std::shared_ptr<ITimerInfo> & timerInfo)47 bool TimerCallback::InsertTimerCallbackInfo(const uint64_t timerId, const std::shared_ptr<ITimerInfo> &timerInfo)
48 {
49 TIME_HILOGD(TIME_MODULE_SERVICE, "start.");
50 if (timerInfo == nullptr) {
51 return false;
52 }
53
54 std::lock_guard<std::mutex> lock(timerInfoMutex_);
55 auto info = timerInfoMap_.find(timerId);
56 if (info != timerInfoMap_.end()) {
57 TIME_HILOGE(TIME_MODULE_CLIENT, "timer info already insert.");
58 return false;
59 } else {
60 timerInfoMap_[timerId] = timerInfo;
61 }
62 TIME_HILOGD(TIME_MODULE_SERVICE, "end.");
63 return true;
64 }
65
RemoveTimerCallbackInfo(const uint64_t timerId)66 bool TimerCallback::RemoveTimerCallbackInfo(const uint64_t timerId)
67 {
68 TIME_HILOGD(TIME_MODULE_SERVICE, "start.");
69 std::lock_guard<std::mutex> lock(timerInfoMutex_);
70 auto info = timerInfoMap_.find(timerId);
71 if (info != timerInfoMap_.end()) {
72 timerInfoMap_.erase(info);
73 TIME_HILOGD(TIME_MODULE_SERVICE, "end.");
74 return true;
75 }
76 TIME_HILOGD(TIME_MODULE_SERVICE, "end.");
77 return false;
78 }
79
NotifyTimer(const uint64_t timerId,const sptr<IRemoteObject> & timerCallback)80 void TimerCallback::NotifyTimer(const uint64_t timerId, const sptr<IRemoteObject> &timerCallback)
81 {
82 TIME_HILOGD(TIME_MODULE_SERVICE, "start.");
83 std::shared_ptr<ITimerInfo> timerInfo;
84 {
85 std::lock_guard<std::mutex> lock(timerInfoMutex_);
86 auto it = timerInfoMap_.find(timerId);
87 if (it != timerInfoMap_.end()) {
88 TIME_HILOGD(TIME_MODULE_SERVICE, "ontrigger.");
89 timerInfo = it->second;
90 }
91 }
92 if (timerInfo != nullptr) {
93 timerInfo->OnTrigger();
94 }
95 if (timerCallback == nullptr) {
96 TIME_HILOGE(TIME_MODULE_SERVICE, "timerCallback nullptr timerId:%{public}" PRId64 "", timerId);
97 return;
98 }
99 sptr<ITimerNotifyCallback> timerNotifyCallback = iface_cast<ITimerNotifyCallback>(timerCallback);
100 if (timerNotifyCallback == nullptr) {
101 TIME_HILOGE(TIME_MODULE_SERVICE, "timerNotifyCallback nullptr timerId:%{public}" PRId64 "", timerId);
102 return;
103 }
104 timerNotifyCallback->Finish(timerId);
105 TIME_HILOGD(TIME_MODULE_SERVICE, "end.");
106 }
107 } // namespace MiscServices
108 } // namespace OHOS
109