1 /*
2 * Copyright (c) 2022 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 "update_service_ondemand.h"
17
18 namespace OHOS {
19 namespace UpdateEngine {
20 sptr<UpdateServiceOnDemand> UpdateServiceOnDemand::instance_ = nullptr;
21 std::mutex UpdateServiceOnDemand::instanceLock_;
22
GetInstance()23 sptr<UpdateServiceOnDemand> UpdateServiceOnDemand::GetInstance()
24 {
25 instanceLock_.lock();
26 if (instance_ == nullptr) {
27 instance_ = new UpdateServiceOnDemand;
28 }
29 instanceLock_.unlock();
30 return instance_;
31 }
32
TryLoadUpdaterSa()33 bool UpdateServiceOnDemand::TryLoadUpdaterSa()
34 {
35 InitStatus();
36 return LoadUpdaterSa();
37 }
38
OnLoadSystemAbilitySuccess(int32_t systemAbilityId,const sptr<IRemoteObject> & remoteObject)39 void UpdateServiceOnDemand::OnLoadSystemAbilitySuccess(int32_t systemAbilityId, const sptr<IRemoteObject>& remoteObject)
40 {
41 ENGINE_LOGI("OnLoadSystemAbilitySuccess systemAbilityId: %{public}d, IRemoteObject result: %{public}s",
42 systemAbilityId, (remoteObject != nullptr) ? "succeed" : "failed");
43 loadUpdaterSaStatus_ = (remoteObject != nullptr) ? LoadUpdaterSaStatus::SUCCESS : LoadUpdaterSaStatus::FAIL;
44 }
45
OnLoadSystemAbilityFail(int32_t systemAbilityId)46 void UpdateServiceOnDemand::OnLoadSystemAbilityFail(int32_t systemAbilityId)
47 {
48 ENGINE_LOGE("OnLoadSystemAbilityFail systemAbilityId: %{public}d", systemAbilityId);
49 loadUpdaterSaStatus_ = LoadUpdaterSaStatus::FAIL;
50 }
51
InitStatus()52 void UpdateServiceOnDemand::InitStatus()
53 {
54 if (loadUpdaterSaStatus_ != LoadUpdaterSaStatus::WAIT_RESULT) {
55 loadUpdaterSaStatus_ = LoadUpdaterSaStatus::WAIT_RESULT;
56 }
57 }
58
WaitUpdaterSaInit()59 void UpdateServiceOnDemand::WaitUpdaterSaInit()
60 {
61 usleep(UPDATER_SA_INIT_TIME);
62 }
63
CheckUpdaterSaLoaded()64 bool UpdateServiceOnDemand::CheckUpdaterSaLoaded()
65 {
66 int32_t retry = RETRY_TIMES;
67 ENGINE_LOGI("Waiting for CheckUpdaterSaLoaded");
68 while (retry--) {
69 usleep(SLEEP_TIME);
70 LoadUpdaterSaStatus loadUpdaterSaStatus = loadUpdaterSaStatus_;
71 if (loadUpdaterSaStatus != LoadUpdaterSaStatus::WAIT_RESULT) {
72 bool isUpdaterSaLoaded = loadUpdaterSaStatus == LoadUpdaterSaStatus::SUCCESS;
73 ENGINE_LOGI("found OnLoad result: %{public}s", isUpdaterSaLoaded ? "succeed" : "failed");
74 return isUpdaterSaLoaded;
75 }
76 }
77 ENGINE_LOGE("CheckUpdaterSaLoaded didn't get OnLoad result");
78 return false;
79 }
80
LoadUpdaterSa()81 bool UpdateServiceOnDemand::LoadUpdaterSa()
82 {
83 sptr<ISystemAbilityManager> sm = SystemAbilityManagerClient::GetInstance().GetSystemAbilityManager();
84 if (sm == nullptr) {
85 ENGINE_LOGE("GetSystemAbilityManager samgr object null!");
86 return false;
87 }
88 int32_t result = sm->LoadSystemAbility(UPDATE_DISTRIBUTED_SERVICE_ID, this);
89 if (result != ERR_OK) {
90 ENGINE_LOGE("systemAbilityId: %{public}d, load failed, result code: %{public}d", UPDATE_DISTRIBUTED_SERVICE_ID,
91 result);
92 return false;
93 }
94 if (!CheckUpdaterSaLoaded()) {
95 ENGINE_LOGE("systemAbilityId: %{public}d, CheckUpdaterSaLoaded failed", UPDATE_DISTRIBUTED_SERVICE_ID);
96 return false;
97 }
98 WaitUpdaterSaInit();
99 ENGINE_LOGI("systemAbilityId: %{public}d, load succeed", UPDATE_DISTRIBUTED_SERVICE_ID);
100 return true;
101 }
102 } // namespace UpdateEngine
103 } // namespace OHOS
104