1 /*
2 * Copyright (c) 2024-2025 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 "background_sensitive_task_overlapping_scene_recognizer.h"
17 #include "continuous_app_install_recognizer.h"
18 #include "slide_recognizer.h"
19 #include "res_sched_log.h"
20 #include "scene_recognizer_mgr.h"
21 #include "system_upgrade_scene_recognizer.h"
22
23 namespace OHOS {
24 namespace ResourceSchedule {
25 IMPLEMENT_SINGLE_INSTANCE(SceneRecognizerMgr);
26
SceneRecognizerMgr()27 SceneRecognizerMgr::SceneRecognizerMgr()
28 {
29 sceneRecognizers_ = {
30 { RecognizeType::CONTINUOUS_APP_INSTALL_RECOGNIZER, std::make_shared<ContinuousAppInstallRecognizer>() },
31 { RecognizeType::SYSTEM_UPGRADE_SCENE_RECOGNIZER, std::make_shared<SystemUpgradeSceneRecognizer>() },
32 { RecognizeType::BACKGROUND_SENSITIVE_TASK_OVERLAPPING_SCENE_RECOGNIZER,
33 std::make_shared<BackgroundSensitiveTaskOverlappingSceneRecognizer>() },
34 { RecognizeType::SLIDE_RECOGNIZER, std::make_shared<SlideRecognizer>()},
35 };
36 ffrtQueue_ = std::make_shared<ffrt::queue>("scene_recognizers_queue",
37 ffrt::queue_attr().qos(ffrt::qos_user_interactive));
38 }
39
~SceneRecognizerMgr()40 SceneRecognizerMgr::~SceneRecognizerMgr()
41 {
42 sceneRecognizers_.clear();
43 if (ffrtQueue_ != nullptr) {
44 ffrtQueue_.reset();
45 }
46 RESSCHED_LOGI("~SceneRecognizerMgr");
47 }
48
DispatchResource(const std::shared_ptr<ResData> & resData)49 void SceneRecognizerMgr::DispatchResource(const std::shared_ptr<ResData>& resData)
50 {
51 if (ffrtQueue_ == nullptr) {
52 return;
53 }
54 if (!resData) {
55 RESSCHED_LOGE("%{public}s, failed, null res data.", __func__);
56 return;
57 }
58 for (auto recognizerItem : sceneRecognizers_) {
59 auto recognizer = recognizerItem.second;
60 if (!recognizer->Accept(resData->resType)) {
61 continue;
62 }
63 ffrtQueue_->submit([resData, recognizer]() {
64 recognizer->OnDispatchResource(resData->resType, resData->value, resData->payload);
65 });
66 }
67 }
68
SubmitTask(const std::function<void ()> & task)69 void SceneRecognizerMgr::SubmitTask(const std::function<void()>& task)
70 {
71 if (ffrtQueue_ == nullptr) {
72 return;
73 }
74 ffrtQueue_->submit(task);
75 }
76
SetListFlingTimeoutTime(int64_t value)77 void SceneRecognizerMgr::SetListFlingTimeoutTime(int64_t value)
78 {
79 std::static_pointer_cast<SlideRecognizer>(sceneRecognizers_[RecognizeType::SLIDE_RECOGNIZER])->
80 SetListFlingTimeoutTime(value);
81 }
82
SetListFlingEndTime(int64_t value)83 void SceneRecognizerMgr::SetListFlingEndTime(int64_t value)
84 {
85 std::static_pointer_cast<SlideRecognizer>(sceneRecognizers_[RecognizeType::SLIDE_RECOGNIZER])->
86 SetListFlingEndTime(value);
87 }
SetListFlingSpeedLimit(float value)88 void SceneRecognizerMgr::SetListFlingSpeedLimit(float value)
89 {
90 std::static_pointer_cast<SlideRecognizer>(sceneRecognizers_[RecognizeType::SLIDE_RECOGNIZER])->
91 SetListFlingSpeedLimit(value);
92 }
93
94 extern "C" {
SetListFlingTimeoutTime(int64_t value)95 void SetListFlingTimeoutTime(int64_t value)
96 {
97 SceneRecognizerMgr::GetInstance().SetListFlingTimeoutTime(value);
98 }
SetListFlingEndTime(int64_t value)99 void SetListFlingEndTime(int64_t value)
100 {
101 SceneRecognizerMgr::GetInstance().SetListFlingEndTime(value);
102 }
SetListFlingSpeedLimit(float value)103 void SetListFlingSpeedLimit(float value)
104 {
105 SceneRecognizerMgr::GetInstance().SetListFlingSpeedLimit(value);
106 }
107 }
108 } // namespace ResourceSchedule
109 } // namespace OHOS