• Home
  • Line#
  • Scopes#
  • Navigate#
  • Raw
  • Download
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,const std::string & moduleName)46 void AppLifeCycleDeal::UpdateApplicationInfoInstalled(const ApplicationInfo &appInfo, const std::string &moduleName)
47 {
48     auto appThread = GetApplicationClient();
49     if (!appThread) {
50         TAG_LOGE(AAFwkTag::APPMGR, "null appThread");
51         return;
52     }
53 
54     appThread->ScheduleUpdateApplicationInfoInstalled(appInfo, moduleName);
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, "null appThread");
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) {
74             TAG_LOGW(AAFwkTag::APPMGR, "null abilityInfo");
75             return;
76         }
77         if (abilityInfo->type == AbilityType::PAGE) {
78             std::string entry = "AppLifeCycleDeal::LaunchAbility";
79             FreezeUtil::GetInstance().AddLifecycleEvent(ability->GetToken(), entry);
80         }
81         TAG_LOGD(AAFwkTag::APPMGR, "Launch");
82         appThread->ScheduleLaunchAbility(*abilityInfo, ability->GetToken(),
83             ability->GetWant(), ability->GetAbilityRecordId());
84     } else {
85         TAG_LOGW(AAFwkTag::APPMGR, "null appThread or ability");
86     }
87 }
88 
ScheduleTerminate(bool isLastProcess)89 void AppLifeCycleDeal::ScheduleTerminate(bool isLastProcess)
90 {
91     auto appThread = GetApplicationClient();
92     if (!appThread) {
93         TAG_LOGE(AAFwkTag::APPMGR, "null appThread");
94         return;
95     }
96 
97     appThread->ScheduleTerminateApplication(isLastProcess);
98 }
99 
ScheduleForegroundRunning()100 bool AppLifeCycleDeal::ScheduleForegroundRunning()
101 {
102     auto appThread = GetApplicationClient();
103     if (!appThread) {
104         TAG_LOGE(AAFwkTag::APPMGR, "null appThread");
105         return false;
106     }
107 
108     HITRACE_METER_NAME(HITRACE_TAG_ABILITY_MANAGER, __PRETTY_FUNCTION__);
109     return appThread->ScheduleForegroundApplication();
110 }
111 
ScheduleBackgroundRunning()112 void AppLifeCycleDeal::ScheduleBackgroundRunning()
113 {
114     auto appThread = GetApplicationClient();
115     if (!appThread) {
116         TAG_LOGE(AAFwkTag::APPMGR, "null appThread");
117         return;
118     }
119 
120     appThread->ScheduleBackgroundApplication();
121 }
122 
ScheduleTrimMemory(int32_t timeLevel)123 void AppLifeCycleDeal::ScheduleTrimMemory(int32_t timeLevel)
124 {
125     auto appThread = GetApplicationClient();
126     if (!appThread) {
127         TAG_LOGE(AAFwkTag::APPMGR, "null appThread");
128         return;
129     }
130 
131     appThread->ScheduleShrinkMemory(timeLevel);
132 }
133 
ScheduleMemoryLevel(int32_t Level)134 void AppLifeCycleDeal::ScheduleMemoryLevel(int32_t Level)
135 {
136     auto appThread = GetApplicationClient();
137     if (!appThread) {
138         TAG_LOGE(AAFwkTag::APPMGR, "null appThread");
139         return;
140     }
141 
142     appThread->ScheduleMemoryLevel(Level);
143 }
144 
ScheduleHeapMemory(const int32_t pid,OHOS::AppExecFwk::MallocInfo & mallocInfo)145 void AppLifeCycleDeal::ScheduleHeapMemory(const int32_t pid, OHOS::AppExecFwk::MallocInfo &mallocInfo)
146 {
147     auto appThread = GetApplicationClient();
148     if (!appThread) {
149         TAG_LOGE(AAFwkTag::APPMGR, "null appThread");
150         return;
151     }
152 
153     appThread->ScheduleHeapMemory(pid, mallocInfo);
154 }
155 
ScheduleJsHeapMemory(OHOS::AppExecFwk::JsHeapDumpInfo & info)156 void AppLifeCycleDeal::ScheduleJsHeapMemory(OHOS::AppExecFwk::JsHeapDumpInfo &info)
157 {
158     auto appThread = GetApplicationClient();
159     if (!appThread) {
160         TAG_LOGE(AAFwkTag::APPMGR, "null appThread");
161         return;
162     }
163 
164     appThread->ScheduleJsHeapMemory(info);
165 }
166 
LowMemoryWarning()167 void AppLifeCycleDeal::LowMemoryWarning()
168 {
169     auto appThread = GetApplicationClient();
170     if (!appThread) {
171         TAG_LOGE(AAFwkTag::APPMGR, "null appThread");
172         return;
173     }
174 
175     appThread->ScheduleLowMemory();
176 }
177 
ScheduleCleanAbility(const sptr<IRemoteObject> & token,bool isCacheProcess)178 void AppLifeCycleDeal::ScheduleCleanAbility(const sptr<IRemoteObject> &token, bool isCacheProcess)
179 {
180     auto appThread = GetApplicationClient();
181     if (!appThread) {
182         TAG_LOGE(AAFwkTag::APPMGR, "null appThread");
183         return;
184     }
185     appThread->ScheduleCleanAbility(token, isCacheProcess);
186 }
187 
ScheduleProcessSecurityExit()188 void AppLifeCycleDeal::ScheduleProcessSecurityExit()
189 {
190     auto appThread = GetApplicationClient();
191     if (!appThread) {
192         TAG_LOGE(AAFwkTag::APPMGR, "null appThread");
193         return;
194     }
195 
196     appThread->ScheduleProcessSecurityExit();
197 }
198 
ScheduleClearPageStack()199 void AppLifeCycleDeal::ScheduleClearPageStack()
200 {
201     auto appThread = GetApplicationClient();
202     if (!appThread) {
203         TAG_LOGE(AAFwkTag::APPMGR, "null appThread");
204         return;
205     }
206 
207     appThread->ScheduleClearPageStack();
208 }
209 
SetApplicationClient(const sptr<IAppScheduler> & thread)210 void AppLifeCycleDeal::SetApplicationClient(const sptr<IAppScheduler> &thread)
211 {
212     std::lock_guard guard(schedulerMutex_);
213     appThread_ = thread;
214 }
215 
GetApplicationClient() const216 sptr<IAppScheduler> AppLifeCycleDeal::GetApplicationClient() const
217 {
218     std::lock_guard guard(schedulerMutex_);
219     return appThread_;
220 }
221 
ScheduleAcceptWant(const AAFwk::Want & want,const std::string & moduleName)222 void AppLifeCycleDeal::ScheduleAcceptWant(const AAFwk::Want &want, const std::string &moduleName)
223 {
224     auto appThread = GetApplicationClient();
225     if (!appThread) {
226         TAG_LOGE(AAFwkTag::APPMGR, "null appThread");
227         return;
228     }
229 
230     appThread->ScheduleAcceptWant(want, moduleName);
231 }
232 
SchedulePrepareTerminate(const std::string & moduleName)233 void AppLifeCycleDeal::SchedulePrepareTerminate(const std::string &moduleName)
234 {
235     TAG_LOGD(AAFwkTag::APPKIT, "called");
236     auto appThread = GetApplicationClient();
237     if (!appThread) {
238         TAG_LOGE(AAFwkTag::APPMGR, "null appThread");
239         return;
240     }
241     appThread->SchedulePrepareTerminate(moduleName);
242 }
243 
ScheduleNewProcessRequest(const AAFwk::Want & want,const std::string & moduleName)244 void AppLifeCycleDeal::ScheduleNewProcessRequest(const AAFwk::Want &want, const std::string &moduleName)
245 {
246     auto appThread = GetApplicationClient();
247     if (!appThread) {
248         TAG_LOGE(AAFwkTag::APPMGR, "null appThread");
249         return;
250     }
251 
252     appThread->ScheduleNewProcessRequest(want, moduleName);
253 }
254 
UpdateConfiguration(const Configuration & config)255 int32_t AppLifeCycleDeal::UpdateConfiguration(const Configuration &config)
256 {
257     HITRACE_METER_NAME(HITRACE_TAG_ABILITY_MANAGER, __PRETTY_FUNCTION__);
258     TAG_LOGD(AAFwkTag::APPMGR, "call");
259     auto appThread = GetApplicationClient();
260     if (!appThread) {
261         TAG_LOGE(AAFwkTag::APPMGR, "null appThread");
262         return ERR_INVALID_VALUE;
263     }
264     appThread->ScheduleConfigurationUpdated(config);
265     return ERR_OK;
266 }
267 
NotifyLoadRepairPatch(const std::string & bundleName,const sptr<IQuickFixCallback> & callback,const int32_t recordId)268 int32_t AppLifeCycleDeal::NotifyLoadRepairPatch(const std::string &bundleName, const sptr<IQuickFixCallback> &callback,
269     const int32_t recordId)
270 {
271     HITRACE_METER_NAME(HITRACE_TAG_ABILITY_MANAGER, __PRETTY_FUNCTION__);
272     TAG_LOGD(AAFwkTag::APPMGR, "call");
273     auto appThread = GetApplicationClient();
274     if (appThread == nullptr) {
275         TAG_LOGE(AAFwkTag::APPMGR, "null appThread");
276         return ERR_INVALID_VALUE;
277     }
278     return appThread->ScheduleNotifyLoadRepairPatch(bundleName, callback, recordId);
279 }
280 
NotifyHotReloadPage(const sptr<IQuickFixCallback> & callback,const int32_t recordId)281 int32_t AppLifeCycleDeal::NotifyHotReloadPage(const sptr<IQuickFixCallback> &callback, const int32_t recordId)
282 {
283     HITRACE_METER_NAME(HITRACE_TAG_ABILITY_MANAGER, __PRETTY_FUNCTION__);
284     TAG_LOGD(AAFwkTag::APPMGR, "call");
285     auto appThread = GetApplicationClient();
286     if (appThread == nullptr) {
287         TAG_LOGE(AAFwkTag::APPMGR, "null appThread");
288         return ERR_INVALID_VALUE;
289     }
290     return appThread->ScheduleNotifyHotReloadPage(callback, recordId);
291 }
292 
NotifyUnLoadRepairPatch(const std::string & bundleName,const sptr<IQuickFixCallback> & callback,const int32_t recordId)293 int32_t AppLifeCycleDeal::NotifyUnLoadRepairPatch(const std::string &bundleName,
294     const sptr<IQuickFixCallback> &callback, const int32_t recordId)
295 {
296     HITRACE_METER_NAME(HITRACE_TAG_ABILITY_MANAGER, __PRETTY_FUNCTION__);
297     TAG_LOGD(AAFwkTag::APPMGR, "called");
298     auto appThread = GetApplicationClient();
299     if (appThread == nullptr) {
300         TAG_LOGE(AAFwkTag::APPMGR, "null appThread");
301         return ERR_INVALID_VALUE;
302     }
303     return appThread->ScheduleNotifyUnLoadRepairPatch(bundleName, callback, recordId);
304 }
305 
NotifyAppFault(const FaultData & faultData)306 int32_t AppLifeCycleDeal::NotifyAppFault(const FaultData &faultData)
307 {
308     TAG_LOGD(AAFwkTag::APPMGR, "called");
309     auto appThread = GetApplicationClient();
310     if (appThread == nullptr) {
311         TAG_LOGE(AAFwkTag::APPMGR, "null appThread");
312         return ERR_INVALID_VALUE;
313     }
314     return appThread->ScheduleNotifyAppFault(faultData);
315 }
316 
ChangeAppGcState(int32_t state)317 int32_t AppLifeCycleDeal::ChangeAppGcState(int32_t state)
318 {
319     TAG_LOGD(AAFwkTag::APPMGR, "called");
320     auto appThread = GetApplicationClient();
321     if (appThread == nullptr) {
322         TAG_LOGE(AAFwkTag::APPMGR, "null appThread");
323         return ERR_INVALID_VALUE;
324     }
325     return appThread->ScheduleChangeAppGcState(state);
326 }
327 
AttachAppDebug(bool isDebugFromLocal)328 int32_t AppLifeCycleDeal::AttachAppDebug(bool isDebugFromLocal)
329 {
330     TAG_LOGD(AAFwkTag::APPMGR, "called");
331     auto appThread = GetApplicationClient();
332     if (appThread == nullptr) {
333         TAG_LOGE(AAFwkTag::APPMGR, "null appThread");
334         return ERR_INVALID_VALUE;
335     }
336     appThread->AttachAppDebug(isDebugFromLocal);
337     return ERR_OK;
338 }
339 
DetachAppDebug()340 int32_t AppLifeCycleDeal::DetachAppDebug()
341 {
342     TAG_LOGD(AAFwkTag::APPMGR, "called");
343     auto appThread = GetApplicationClient();
344     if (appThread == nullptr) {
345         TAG_LOGE(AAFwkTag::APPMGR, "null appThread");
346         return ERR_INVALID_VALUE;
347     }
348     appThread->DetachAppDebug();
349     return ERR_OK;
350 }
351 
DumpIpcStart(std::string & result)352 int AppLifeCycleDeal::DumpIpcStart(std::string& result)
353 {
354     TAG_LOGD(AAFwkTag::APPMGR, "called");
355     auto appThread = GetApplicationClient();
356     if (appThread == nullptr) {
357         result.append(MSG_DUMP_IPC_START_STAT, strlen(MSG_DUMP_IPC_START_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, "null appThread");
361         return DumpErrorCode::ERR_INTERNAL_ERROR;
362     }
363     return appThread->ScheduleDumpIpcStart(result);
364 }
365 
DumpIpcStop(std::string & result)366 int AppLifeCycleDeal::DumpIpcStop(std::string& result)
367 {
368     TAG_LOGD(AAFwkTag::APPMGR, "called");
369     auto appThread = GetApplicationClient();
370     if (appThread == nullptr) {
371         result.append(MSG_DUMP_IPC_STOP_STAT, strlen(MSG_DUMP_IPC_STOP_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, "null appThread");
375         return DumpErrorCode::ERR_INTERNAL_ERROR;
376     }
377     return appThread->ScheduleDumpIpcStop(result);
378 }
379 
DumpIpcStat(std::string & result)380 int AppLifeCycleDeal::DumpIpcStat(std::string& result)
381 {
382     TAG_LOGD(AAFwkTag::APPMGR, "called");
383     auto appThread = GetApplicationClient();
384     if (appThread == nullptr) {
385         result.append(MSG_DUMP_IPC_STAT, strlen(MSG_DUMP_IPC_STAT))
386             .append(MSG_DUMP_FAIL, strlen(MSG_DUMP_FAIL))
387             .append(MSG_DUMP_FAIL_REASON_INTERNAL, strlen(MSG_DUMP_FAIL_REASON_INTERNAL));
388         TAG_LOGE(AAFwkTag::APPMGR, "null appThread");
389         return DumpErrorCode::ERR_INTERNAL_ERROR;
390     }
391     return appThread->ScheduleDumpIpcStat(result);
392 }
393 
ScheduleCacheProcess()394 void AppLifeCycleDeal::ScheduleCacheProcess()
395 {
396     auto appThread = GetApplicationClient();
397     if (!appThread) {
398         TAG_LOGE(AAFwkTag::APPMGR, "null appThread");
399         return;
400     }
401 
402     appThread->ScheduleCacheProcess();
403 }
404 
DumpFfrt(std::string & result)405 int AppLifeCycleDeal::DumpFfrt(std::string& result)
406 {
407     TAG_LOGD(AAFwkTag::APPMGR, "called");
408     auto appThread = GetApplicationClient();
409     if (appThread == nullptr) {
410         result.append(MSG_DUMP_FAIL, strlen(MSG_DUMP_FAIL))
411             .append(MSG_DUMP_FAIL_REASON_INTERNAL, strlen(MSG_DUMP_FAIL_REASON_INTERNAL));
412         TAG_LOGE(AAFwkTag::APPMGR, "null appThread");
413         return DumpErrorCode::ERR_INTERNAL_ERROR;
414     }
415     return appThread->ScheduleDumpFfrt(result);
416 }
417 
SetWatchdogBackgroundStatusRunning(bool status)418 void AppLifeCycleDeal::SetWatchdogBackgroundStatusRunning(bool status)
419 {
420     auto appThread = GetApplicationClient();
421     if (!appThread) {
422         TAG_LOGE(AAFwkTag::APPMGR, "null appThread");
423         return;
424     }
425     appThread->SetWatchdogBackgroundStatus(status);
426 }
427 }  // namespace AppExecFwk
428 }  // namespace OHOS
429