/* * Copyright (c) 2022-2023 Huawei Device Co., Ltd. * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ #include "bridge/common/utils/engine_helper.h" #include "base/log/ace_checker.h" #include "base/subwindow/subwindow_manager.h" namespace OHOS::Ace { std::shared_mutex EngineHelper::mutex_; std::unordered_map> EngineHelper::engineWeakMap_; std::function EngineHelper::removeUIContextFunc_; ScopedDelegate::ScopedDelegate(const RefPtr& delegate, int32_t id) : delegate_(delegate), scope_(new ContainerScope(id)) {} ScopedDelegate::~ScopedDelegate() { delete scope_; scope_ = nullptr; } void EngineHelper::AddEngine(int32_t id, WeakPtr engine) { std::unique_lock lock(mutex_); engineWeakMap_.emplace(id, engine); } RefPtr EngineHelper::GetEngine(int32_t id) { std::shared_lock lock(mutex_); if (id >= MIN_SUBCONTAINER_ID && id < MIN_PLUGIN_SUBCONTAINER_ID) { id = SubwindowManager::GetInstance()->GetParentContainerId(id); } auto iter = engineWeakMap_.find(id); if (iter != engineWeakMap_.end()) { return iter->second.Upgrade(); } return nullptr; } void EngineHelper::RemoveEngine(int32_t id) { std::unique_lock lock(mutex_); engineWeakMap_.erase(id); if (removeUIContextFunc_) { removeUIContextFunc_(id); } } RefPtr EngineHelper::GetCurrentEngine() { return GetEngine(Container::CurrentId()); } RefPtr EngineHelper::GetCurrentEngineSafely() { return GetEngine(Container::CurrentIdSafely()); } ScopedDelegate EngineHelper::GetCurrentDelegate() { auto engine = GetCurrentEngine(); if (engine) { return { engine->GetFrontend(), Container::CurrentId() }; } auto container = Container::GetActive(); return GetDelegateByContainer(container); } ScopedDelegate EngineHelper::GetCurrentDelegateSafely() { auto engine = GetCurrentEngineSafely(); if (engine) { return { engine->GetFrontend(), Container::CurrentIdSafely() }; } auto container = Container::CurrentSafely(); return GetDelegateByContainer(container); } ScopedDelegate EngineHelper::GetDefaultDelegate() { auto engine = GetCurrentEngine(); if (engine) { return { engine->GetFrontend(), Container::CurrentId() }; } auto container = Container::GetDefault(); return GetDelegateByContainer(container); } ScopedDelegate EngineHelper::GetDelegateByContainer(RefPtr container) { if (!container) { return { nullptr, -1 }; } auto engine = GetEngine(container->GetInstanceId()); return { engine ? engine->GetFrontend() : nullptr, container->GetInstanceId() }; } std::pair EngineHelper::StringToPair(const std::string& match) { std::vector arr; std::pair res; StringUtils::SplitStr(match, ":", arr); res.first = StringUtils::StringToInt(arr[0]); res.second = StringUtils::StringToInt(arr[1]); return res; } std::pair EngineHelper::GetPositionOnJsCode() { if (!AceChecker::IsPerformanceCheckEnabled()) { return { 0, 0 }; } auto jsEngine = GetCurrentEngine(); std::string stack; CHECK_NULL_RETURN(jsEngine, std::make_pair(0, 0)); jsEngine->GetStackTrace(stack); std::regex reg("\\d+:\\d+"); std::smatch match; if (std::regex_search(stack, match, reg)) { return StringToPair(match[0].str()); } return { 0, 0 }; } void EngineHelper::RegisterRemoveUIContextFunc(const std::function& removeUIContextFunc) { if (!removeUIContextFunc_) { removeUIContextFunc_ = removeUIContextFunc; } } } // namespace OHOS::Ace