1 /*
2 * Copyright (c) 2021-2024 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 "app_lifecycle_deal.h"
17
18 #include "freeze_util.h"
19 #include "hilog_tag_wrapper.h"
20 #include "hitrace_meter.h"
21 #include "time_util.h"
22 #include "app_mgr_service_const.h"
23 #include "app_mgr_service_dump_error_code.h"
24
25 namespace OHOS {
26 using AbilityRuntime::FreezeUtil;
27 namespace AppExecFwk {
AppLifeCycleDeal()28 AppLifeCycleDeal::AppLifeCycleDeal()
29 {}
30
~AppLifeCycleDeal()31 AppLifeCycleDeal::~AppLifeCycleDeal()
32 {
33 TAG_LOGD(AAFwkTag::APPMGR, "called");
34 }
35
LaunchApplication(const AppLaunchData & launchData,const Configuration & config)36 void AppLifeCycleDeal::LaunchApplication(const AppLaunchData &launchData, const Configuration &config)
37 {
38 HITRACE_METER_NAME(HITRACE_TAG_APP, __PRETTY_FUNCTION__);
39 TAG_LOGD(AAFwkTag::APPMGR, "called");
40 auto appThread = GetApplicationClient();
41 if (appThread) {
42 appThread->ScheduleLaunchApplication(launchData, config);
43 }
44 }
45
UpdateApplicationInfoInstalled(const ApplicationInfo & appInfo)46 void AppLifeCycleDeal::UpdateApplicationInfoInstalled(const ApplicationInfo &appInfo)
47 {
48 auto appThread = GetApplicationClient();
49 if (!appThread) {
50 TAG_LOGE(AAFwkTag::APPMGR, "appThread is nullptr");
51 return;
52 }
53
54 appThread->ScheduleUpdateApplicationInfoInstalled(appInfo);
55 }
56
AddAbilityStage(const HapModuleInfo & abilityStage)57 void AppLifeCycleDeal::AddAbilityStage(const HapModuleInfo &abilityStage)
58 {
59 auto appThread = GetApplicationClient();
60 if (!appThread) {
61 TAG_LOGE(AAFwkTag::APPMGR, "appThread is nullptr");
62 return;
63 }
64
65 appThread->ScheduleAbilityStage(abilityStage);
66 }
67
LaunchAbility(const std::shared_ptr<AbilityRunningRecord> & ability)68 void AppLifeCycleDeal::LaunchAbility(const std::shared_ptr<AbilityRunningRecord> &ability)
69 {
70 auto appThread = GetApplicationClient();
71 if (appThread && ability) {
72 auto &abilityInfo = ability->GetAbilityInfo();
73 if (abilityInfo != nullptr && abilityInfo->type == AbilityType::PAGE) {
74 FreezeUtil::LifecycleFlow flow = {ability->GetToken(), FreezeUtil::TimeoutState::LOAD};
75 std::string entry = "AppLifeCycleDeal::LaunchAbility; the LoadAbility lifecycle.";
76 FreezeUtil::GetInstance().AddLifecycleEvent(flow, entry);
77 }
78 TAG_LOGD(AAFwkTag::APPMGR, "Launch");
79 appThread->ScheduleLaunchAbility(*abilityInfo, ability->GetToken(),
80 ability->GetWant(), ability->GetAbilityRecordId());
81 } else {
82 TAG_LOGW(AAFwkTag::APPMGR, "LoadLifecycle.");
83 }
84 }
85
ScheduleTerminate(bool isLastProcess)86 void AppLifeCycleDeal::ScheduleTerminate(bool isLastProcess)
87 {
88 auto appThread = GetApplicationClient();
89 if (!appThread) {
90 TAG_LOGE(AAFwkTag::APPMGR, "appThread is nullptr");
91 return;
92 }
93
94 appThread->ScheduleTerminateApplication(isLastProcess);
95 }
96
ScheduleForegroundRunning()97 bool AppLifeCycleDeal::ScheduleForegroundRunning()
98 {
99 auto appThread = GetApplicationClient();
100 if (!appThread) {
101 TAG_LOGE(AAFwkTag::APPMGR, "appThread is nullptr");
102 return false;
103 }
104
105 HITRACE_METER_NAME(HITRACE_TAG_ABILITY_MANAGER, __PRETTY_FUNCTION__);
106 return appThread->ScheduleForegroundApplication();
107 }
108
ScheduleBackgroundRunning()109 void AppLifeCycleDeal::ScheduleBackgroundRunning()
110 {
111 auto appThread = GetApplicationClient();
112 if (!appThread) {
113 TAG_LOGE(AAFwkTag::APPMGR, "appThread is nullptr");
114 return;
115 }
116
117 appThread->ScheduleBackgroundApplication();
118 }
119
ScheduleTrimMemory(int32_t timeLevel)120 void AppLifeCycleDeal::ScheduleTrimMemory(int32_t timeLevel)
121 {
122 auto appThread = GetApplicationClient();
123 if (!appThread) {
124 TAG_LOGE(AAFwkTag::APPMGR, "appThread is nullptr");
125 return;
126 }
127
128 appThread->ScheduleShrinkMemory(timeLevel);
129 }
130
ScheduleMemoryLevel(int32_t Level)131 void AppLifeCycleDeal::ScheduleMemoryLevel(int32_t Level)
132 {
133 auto appThread = GetApplicationClient();
134 if (!appThread) {
135 TAG_LOGE(AAFwkTag::APPMGR, "appThread is nullptr");
136 return;
137 }
138
139 appThread->ScheduleMemoryLevel(Level);
140 }
141
ScheduleHeapMemory(const int32_t pid,OHOS::AppExecFwk::MallocInfo & mallocInfo)142 void AppLifeCycleDeal::ScheduleHeapMemory(const int32_t pid, OHOS::AppExecFwk::MallocInfo &mallocInfo)
143 {
144 auto appThread = GetApplicationClient();
145 if (!appThread) {
146 TAG_LOGE(AAFwkTag::APPMGR, "appThread is nullptr");
147 return;
148 }
149
150 appThread->ScheduleHeapMemory(pid, mallocInfo);
151 }
152
ScheduleJsHeapMemory(OHOS::AppExecFwk::JsHeapDumpInfo & info)153 void AppLifeCycleDeal::ScheduleJsHeapMemory(OHOS::AppExecFwk::JsHeapDumpInfo &info)
154 {
155 auto appThread = GetApplicationClient();
156 if (!appThread) {
157 TAG_LOGE(AAFwkTag::APPMGR, "appThread is nullptr");
158 return;
159 }
160
161 appThread->ScheduleJsHeapMemory(info);
162 }
163
LowMemoryWarning()164 void AppLifeCycleDeal::LowMemoryWarning()
165 {
166 auto appThread = GetApplicationClient();
167 if (!appThread) {
168 TAG_LOGE(AAFwkTag::APPMGR, "appThread is nullptr");
169 return;
170 }
171
172 appThread->ScheduleLowMemory();
173 }
174
ScheduleCleanAbility(const sptr<IRemoteObject> & token,bool isCacheProcess)175 void AppLifeCycleDeal::ScheduleCleanAbility(const sptr<IRemoteObject> &token, bool isCacheProcess)
176 {
177 auto appThread = GetApplicationClient();
178 if (!appThread) {
179 TAG_LOGE(AAFwkTag::APPMGR, "appThread is nullptr");
180 return;
181 }
182 appThread->ScheduleCleanAbility(token, isCacheProcess);
183 }
184
ScheduleProcessSecurityExit()185 void AppLifeCycleDeal::ScheduleProcessSecurityExit()
186 {
187 auto appThread = GetApplicationClient();
188 if (!appThread) {
189 TAG_LOGE(AAFwkTag::APPMGR, "appThread is nullptr");
190 return;
191 }
192
193 appThread->ScheduleProcessSecurityExit();
194 }
195
ScheduleClearPageStack()196 void AppLifeCycleDeal::ScheduleClearPageStack()
197 {
198 auto appThread = GetApplicationClient();
199 if (!appThread) {
200 TAG_LOGE(AAFwkTag::APPMGR, "appThread is nullptr");
201 return;
202 }
203
204 appThread->ScheduleClearPageStack();
205 }
206
SetApplicationClient(const sptr<IAppScheduler> & thread)207 void AppLifeCycleDeal::SetApplicationClient(const sptr<IAppScheduler> &thread)
208 {
209 std::lock_guard guard(schedulerMutex_);
210 appThread_ = thread;
211 }
212
GetApplicationClient() const213 sptr<IAppScheduler> AppLifeCycleDeal::GetApplicationClient() const
214 {
215 std::lock_guard guard(schedulerMutex_);
216 return appThread_;
217 }
218
ScheduleAcceptWant(const AAFwk::Want & want,const std::string & moduleName)219 void AppLifeCycleDeal::ScheduleAcceptWant(const AAFwk::Want &want, const std::string &moduleName)
220 {
221 auto appThread = GetApplicationClient();
222 if (!appThread) {
223 TAG_LOGE(AAFwkTag::APPMGR, "appThread is nullptr");
224 return;
225 }
226
227 appThread->ScheduleAcceptWant(want, moduleName);
228 }
229
ScheduleNewProcessRequest(const AAFwk::Want & want,const std::string & moduleName)230 void AppLifeCycleDeal::ScheduleNewProcessRequest(const AAFwk::Want &want, const std::string &moduleName)
231 {
232 auto appThread = GetApplicationClient();
233 if (!appThread) {
234 TAG_LOGE(AAFwkTag::APPMGR, "appThread is nullptr");
235 return;
236 }
237
238 appThread->ScheduleNewProcessRequest(want, moduleName);
239 }
240
UpdateConfiguration(const Configuration & config)241 int32_t AppLifeCycleDeal::UpdateConfiguration(const Configuration &config)
242 {
243 HITRACE_METER_NAME(HITRACE_TAG_ABILITY_MANAGER, __PRETTY_FUNCTION__);
244 TAG_LOGD(AAFwkTag::APPMGR, "call");
245 auto appThread = GetApplicationClient();
246 if (!appThread) {
247 TAG_LOGE(AAFwkTag::APPMGR, "appThread is nullptr");
248 return ERR_INVALID_VALUE;
249 }
250 appThread->ScheduleConfigurationUpdated(config);
251 return ERR_OK;
252 }
253
NotifyLoadRepairPatch(const std::string & bundleName,const sptr<IQuickFixCallback> & callback,const int32_t recordId)254 int32_t AppLifeCycleDeal::NotifyLoadRepairPatch(const std::string &bundleName, const sptr<IQuickFixCallback> &callback,
255 const int32_t recordId)
256 {
257 HITRACE_METER_NAME(HITRACE_TAG_ABILITY_MANAGER, __PRETTY_FUNCTION__);
258 TAG_LOGD(AAFwkTag::APPMGR, "call");
259 auto appThread = GetApplicationClient();
260 if (appThread == nullptr) {
261 TAG_LOGE(AAFwkTag::APPMGR, "appThread is nullptr.");
262 return ERR_INVALID_VALUE;
263 }
264 return appThread->ScheduleNotifyLoadRepairPatch(bundleName, callback, recordId);
265 }
266
NotifyHotReloadPage(const sptr<IQuickFixCallback> & callback,const int32_t recordId)267 int32_t AppLifeCycleDeal::NotifyHotReloadPage(const sptr<IQuickFixCallback> &callback, const int32_t recordId)
268 {
269 HITRACE_METER_NAME(HITRACE_TAG_ABILITY_MANAGER, __PRETTY_FUNCTION__);
270 TAG_LOGD(AAFwkTag::APPMGR, "call");
271 auto appThread = GetApplicationClient();
272 if (appThread == nullptr) {
273 TAG_LOGE(AAFwkTag::APPMGR, "appThread is nullptr.");
274 return ERR_INVALID_VALUE;
275 }
276 return appThread->ScheduleNotifyHotReloadPage(callback, recordId);
277 }
278
NotifyUnLoadRepairPatch(const std::string & bundleName,const sptr<IQuickFixCallback> & callback,const int32_t recordId)279 int32_t AppLifeCycleDeal::NotifyUnLoadRepairPatch(const std::string &bundleName,
280 const sptr<IQuickFixCallback> &callback, const int32_t recordId)
281 {
282 HITRACE_METER_NAME(HITRACE_TAG_ABILITY_MANAGER, __PRETTY_FUNCTION__);
283 TAG_LOGD(AAFwkTag::APPMGR, "called");
284 auto appThread = GetApplicationClient();
285 if (appThread == nullptr) {
286 TAG_LOGE(AAFwkTag::APPMGR, "appThread is nullptr.");
287 return ERR_INVALID_VALUE;
288 }
289 return appThread->ScheduleNotifyUnLoadRepairPatch(bundleName, callback, recordId);
290 }
291
NotifyAppFault(const FaultData & faultData)292 int32_t AppLifeCycleDeal::NotifyAppFault(const FaultData &faultData)
293 {
294 TAG_LOGD(AAFwkTag::APPMGR, "called");
295 auto appThread = GetApplicationClient();
296 if (appThread == nullptr) {
297 TAG_LOGE(AAFwkTag::APPMGR, "appThread is nullptr.");
298 return ERR_INVALID_VALUE;
299 }
300 return appThread->ScheduleNotifyAppFault(faultData);
301 }
302
ChangeAppGcState(int32_t state)303 int32_t AppLifeCycleDeal::ChangeAppGcState(int32_t state)
304 {
305 TAG_LOGD(AAFwkTag::APPMGR, "called");
306 auto appThread = GetApplicationClient();
307 if (appThread == nullptr) {
308 TAG_LOGE(AAFwkTag::APPMGR, "appThread is nullptr.");
309 return ERR_INVALID_VALUE;
310 }
311 return appThread->ScheduleChangeAppGcState(state);
312 }
313
AttachAppDebug()314 int32_t AppLifeCycleDeal::AttachAppDebug()
315 {
316 TAG_LOGD(AAFwkTag::APPMGR, "called");
317 auto appThread = GetApplicationClient();
318 if (appThread == nullptr) {
319 TAG_LOGE(AAFwkTag::APPMGR, "appThread is nullptr.");
320 return ERR_INVALID_VALUE;
321 }
322 appThread->AttachAppDebug();
323 return ERR_OK;
324 }
325
DetachAppDebug()326 int32_t AppLifeCycleDeal::DetachAppDebug()
327 {
328 TAG_LOGD(AAFwkTag::APPMGR, "called");
329 auto appThread = GetApplicationClient();
330 if (appThread == nullptr) {
331 TAG_LOGE(AAFwkTag::APPMGR, "appThread is nullptr.");
332 return ERR_INVALID_VALUE;
333 }
334 appThread->DetachAppDebug();
335 return ERR_OK;
336 }
337
DumpIpcStart(std::string & result)338 int AppLifeCycleDeal::DumpIpcStart(std::string& result)
339 {
340 TAG_LOGD(AAFwkTag::APPMGR, "called");
341 auto appThread = GetApplicationClient();
342 if (appThread == nullptr) {
343 result.append(MSG_DUMP_IPC_START_STAT, strlen(MSG_DUMP_IPC_START_STAT))
344 .append(MSG_DUMP_FAIL, strlen(MSG_DUMP_FAIL))
345 .append(MSG_DUMP_FAIL_REASON_INTERNAL, strlen(MSG_DUMP_FAIL_REASON_INTERNAL));
346 TAG_LOGE(AAFwkTag::APPMGR, "appThread is nullptr.");
347 return DumpErrorCode::ERR_INTERNAL_ERROR;
348 }
349 return appThread->ScheduleDumpIpcStart(result);
350 }
351
DumpIpcStop(std::string & result)352 int AppLifeCycleDeal::DumpIpcStop(std::string& result)
353 {
354 TAG_LOGD(AAFwkTag::APPMGR, "called");
355 auto appThread = GetApplicationClient();
356 if (appThread == nullptr) {
357 result.append(MSG_DUMP_IPC_STOP_STAT, strlen(MSG_DUMP_IPC_STOP_STAT))
358 .append(MSG_DUMP_FAIL, strlen(MSG_DUMP_FAIL))
359 .append(MSG_DUMP_FAIL_REASON_INTERNAL, strlen(MSG_DUMP_FAIL_REASON_INTERNAL));
360 TAG_LOGE(AAFwkTag::APPMGR, "appThread is nullptr.");
361 return DumpErrorCode::ERR_INTERNAL_ERROR;
362 }
363 return appThread->ScheduleDumpIpcStop(result);
364 }
365
DumpIpcStat(std::string & result)366 int AppLifeCycleDeal::DumpIpcStat(std::string& result)
367 {
368 TAG_LOGD(AAFwkTag::APPMGR, "called");
369 auto appThread = GetApplicationClient();
370 if (appThread == nullptr) {
371 result.append(MSG_DUMP_IPC_STAT, strlen(MSG_DUMP_IPC_STAT))
372 .append(MSG_DUMP_FAIL, strlen(MSG_DUMP_FAIL))
373 .append(MSG_DUMP_FAIL_REASON_INTERNAL, strlen(MSG_DUMP_FAIL_REASON_INTERNAL));
374 TAG_LOGE(AAFwkTag::APPMGR, "appThread is nullptr.");
375 return DumpErrorCode::ERR_INTERNAL_ERROR;
376 }
377 return appThread->ScheduleDumpIpcStat(result);
378 }
379
ScheduleCacheProcess()380 void AppLifeCycleDeal::ScheduleCacheProcess()
381 {
382 auto appThread = GetApplicationClient();
383 if (!appThread) {
384 TAG_LOGE(AAFwkTag::APPMGR, "appThread is nullptr");
385 return;
386 }
387
388 appThread->ScheduleCacheProcess();
389 }
390
DumpFfrt(std::string & result)391 int AppLifeCycleDeal::DumpFfrt(std::string& result)
392 {
393 TAG_LOGD(AAFwkTag::APPMGR, "called");
394 auto appThread = GetApplicationClient();
395 if (appThread == nullptr) {
396 result.append(MSG_DUMP_FAIL, strlen(MSG_DUMP_FAIL))
397 .append(MSG_DUMP_FAIL_REASON_INTERNAL, strlen(MSG_DUMP_FAIL_REASON_INTERNAL));
398 TAG_LOGE(AAFwkTag::APPMGR, "appThread is nullptr.");
399 return DumpErrorCode::ERR_INTERNAL_ERROR;
400 }
401 return appThread->ScheduleDumpFfrt(result);
402 }
403 } // namespace AppExecFwk
404 } // namespace OHOS
405