1 /*
2 * Copyright (c) 2021-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 "core/common/plugin_manager.h"
17
18 #include "base/log/log_wrapper.h"
19 #include "base/log/log.h"
20 #include "base/utils/utils.h"
21
22 namespace OHOS::Ace {
PluginManager()23 PluginManager::PluginManager() {}
24
~PluginManager()25 PluginManager::~PluginManager()
26 {
27 pluginSubContainerMap_.clear();
28 nonmatchedContainerMap_.clear();
29 }
30
AddPluginSubContainer(int64_t pluginId,const RefPtr<PluginSubContainer> & pluginSubContainer)31 void PluginManager::AddPluginSubContainer(int64_t pluginId, const RefPtr<PluginSubContainer>& pluginSubContainer)
32 {
33 std::lock_guard<std::mutex> lock(mutex_);
34 pluginSubContainerMap_.try_emplace(pluginId, pluginSubContainer);
35 }
36
RemovePluginSubContainer(int64_t pluginId)37 void PluginManager::RemovePluginSubContainer(int64_t pluginId)
38 {
39 std::lock_guard<std::mutex> lock(mutex_);
40 pluginSubContainerMap_.erase(pluginId);
41 }
42
GetPluginSubContainer(int64_t pluginId)43 RefPtr<PluginSubContainer> PluginManager::GetPluginSubContainer(int64_t pluginId)
44 {
45 std::lock_guard<std::mutex> lock(mutex_);
46 auto pluginSubContainer = pluginSubContainerMap_.find(pluginId);
47 if (pluginSubContainer != pluginSubContainerMap_.end()) {
48 return pluginSubContainer->second;
49 } else {
50 return nullptr;
51 }
52 }
53
UpdateConfigurationInPlugin(const ResourceConfiguration & resConfig,const RefPtr<TaskExecutor> & taskExecutor)54 void PluginManager::UpdateConfigurationInPlugin(
55 const ResourceConfiguration& resConfig, const RefPtr<TaskExecutor>& taskExecutor)
56 {
57 std::lock_guard<std::mutex> lock(mutex_);
58 for (const auto& pluginSubContainerMap : pluginSubContainerMap_) {
59 auto pluginSubContainer = pluginSubContainerMap.second;
60 auto pluginPipeline = pluginSubContainer->GetPipelineContext();
61 if (!pluginPipeline) {
62 continue;
63 }
64 auto pluginThemeManager = pluginPipeline->GetThemeManager();
65 pluginThemeManager->UpdateConfig(resConfig);
66 pluginThemeManager->LoadResourceThemes();
67 CHECK_NULL_VOID(taskExecutor);
68 taskExecutor->PostTask(
69 [instanceId = pluginSubContainerMap.first,
70 weak = AceType::WeakClaim(AceType::RawPtr(pluginSubContainer))]() {
71 ContainerScope scope(instanceId);
72 auto pluginSubContainer = weak.Upgrade();
73 CHECK_NULL_VOID(pluginSubContainer);
74 pluginSubContainer->FlushReload();
75 },
76 TaskExecutor::TaskType::JS);
77 }
78 }
79
AddNonmatchedContainer(const std::string & pluginKey,const RefPtr<PluginSubContainer> & pluginSubContainer)80 void PluginManager::AddNonmatchedContainer(
81 const std::string& pluginKey, const RefPtr<PluginSubContainer>& pluginSubContainer)
82 {
83 std::lock_guard<std::mutex> lock(nonmatchedContainerMutex_);
84 nonmatchedContainerMap_.try_emplace(pluginKey, pluginSubContainer);
85 }
86
MatchPluginSubContainerWithPluginId(int64_t pluginId,const std::string & pluginKey)87 RefPtr<PluginSubContainer> PluginManager::MatchPluginSubContainerWithPluginId(
88 int64_t pluginId, const std::string& pluginKey)
89 {
90 std::lock_guard<std::mutex> lock(nonmatchedContainerMutex_);
91 auto iter = nonmatchedContainerMap_.find(pluginKey);
92 if (iter == nonmatchedContainerMap_.end()) {
93 TAG_LOGI(AceLogTag::ACE_PLUGIN_COMPONENT, "no subcontainer of key: %{private}s", pluginKey.c_str());
94 return nullptr;
95 }
96 auto pluginSubContainer = iter->second;
97 AddPluginSubContainer(pluginId, pluginSubContainer);
98 nonmatchedContainerMap_.erase(iter);
99 return pluginSubContainer;
100 }
101
GetPluginSubContainerId()102 int64_t PluginManager::GetPluginSubContainerId()
103 {
104 std::lock_guard<std::mutex> lock(mutex_);
105 if (pluginSubContainerMap_.empty()) {
106 return MIN_PLUGIN_SUBCONTAINER_ID;
107 }
108 return pluginSubContainerMap_.rbegin()->first + 1;
109 }
110
StartAbility(const std::string & bundleName,const std::string & abilityName,const std::string & params)111 int32_t PluginManager::StartAbility(
112 const std::string& bundleName, const std::string& abilityName, const std::string& params)
113 {
114 CHECK_NULL_RETURN(pluginUtils_, -1);
115 return pluginUtils_->StartAbility(bundleName, abilityName, params);
116 }
117
AddPluginParentContainer(int64_t pluginId,int32_t pluginParentContainerId)118 void PluginManager::AddPluginParentContainer(int64_t pluginId, int32_t pluginParentContainerId)
119 {
120 std::lock_guard<std::mutex> lock(parentContainerMutex_);
121 parentContainerMap_.try_emplace(pluginId, pluginParentContainerId);
122 }
123
RemovePluginParentContainer(int64_t pluginId)124 void PluginManager::RemovePluginParentContainer(int64_t pluginId)
125 {
126 std::lock_guard<std::mutex> lock(parentContainerMutex_);
127 parentContainerMap_.erase(pluginId);
128 }
129
GetPluginParentContainerId(int64_t pluginId)130 int32_t PluginManager::GetPluginParentContainerId(int64_t pluginId)
131 {
132 std::lock_guard<std::mutex> lock(parentContainerMutex_);
133 auto result = parentContainerMap_.find(pluginId);
134 if (result != parentContainerMap_.end()) {
135 return result->second;
136 } else {
137 return 0;
138 }
139 }
140 } // namespace OHOS::Ace
141