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 "distributed_hardware_manager.h"
17
18 #include "anonymous_string.h"
19 #include "capability_info_manager.h"
20 #include "component_loader.h"
21 #include "component_manager.h"
22 #include "dh_context.h"
23 #include "dh_modem_context_ext.h"
24 #include "dh_utils_hisysevent.h"
25 #include "dh_utils_tool.h"
26 #include "distributed_hardware_errno.h"
27 #include "distributed_hardware_log.h"
28 #include "device_param_mgr.h"
29 #include "hidump_helper.h"
30 #include "local_capability_info_manager.h"
31 #include "local_hardware_manager.h"
32 #include "meta_info_manager.h"
33 #include "publisher.h"
34 #include "task_board.h"
35 #include "task_executor.h"
36 #include "task_factory.h"
37 #include "version_info_manager.h"
38 #include "version_manager.h"
39
40 namespace OHOS {
41 namespace DistributedHardware {
42 #undef DH_LOG_TAG
43 #define DH_LOG_TAG "DistributedHardwareManager"
44
45
46 IMPLEMENT_SINGLE_INSTANCE(DistributedHardwareManager);
47
LocalInit()48 int32_t DistributedHardwareManager::LocalInit()
49 {
50 DHLOGI("DHFWK Local Init begin");
51 if (isLocalInit_.load()) {
52 DHLOGI("Local init already finish");
53 return DH_FWK_SUCCESS;
54 }
55 VersionInfoManager::GetInstance()->Init();
56 CapabilityInfoManager::GetInstance()->Init();
57 MetaInfoManager::GetInstance()->Init();
58 LocalCapabilityInfoManager::GetInstance()->Init();
59 ComponentLoader::GetInstance().Init();
60 VersionManager::GetInstance().Init();
61 LocalHardwareManager::GetInstance().Init();
62 DeviceParamMgr::GetInstance().QueryDeviceDataSyncMode();
63 DHLOGI("DHFWK Local Init end");
64 isLocalInit_.store(true);
65 return DH_FWK_SUCCESS;
66 }
67
Initialize()68 int32_t DistributedHardwareManager::Initialize()
69 {
70 DHLOGI("DHFWK Normal Init begin");
71 std::lock_guard<std::mutex> lock(dhInitMgrMutex_);
72 if (isAllInit_.load()) {
73 DHLOGI("DHMgr init already finish");
74 return DH_FWK_SUCCESS;
75 }
76 LocalInit();
77 ComponentManager::GetInstance().Init();
78 DHLOGI("DHFWK Normal Init end");
79 isAllInit_.store(true);
80 return DH_FWK_SUCCESS;
81 }
82
Release()83 int32_t DistributedHardwareManager::Release()
84 {
85 DHLOGI("start");
86 LocalHardwareManager::GetInstance().UnInit();
87 ComponentManager::GetInstance().UnInit();
88 VersionManager::GetInstance().UnInit();
89 ComponentLoader::GetInstance().UnInit();
90 VersionInfoManager::GetInstance()->UnInit();
91 CapabilityInfoManager::GetInstance()->UnInit();
92 MetaInfoManager::GetInstance()->UnInit();
93 LocalCapabilityInfoManager::GetInstance()->UnInit();
94 DHModemContextExt::GetInstance().UnInit();
95 isAllInit_.store(false);
96 isLocalInit_.store(false);
97 return DH_FWK_SUCCESS;
98 }
99
SendOnLineEvent(const std::string & networkId,const std::string & uuid,const std::string & udid,uint16_t deviceType)100 int32_t DistributedHardwareManager::SendOnLineEvent(const std::string &networkId, const std::string &uuid,
101 const std::string &udid, uint16_t deviceType)
102 {
103 if (!IsIdLengthValid(networkId) || !IsIdLengthValid(uuid) || !IsIdLengthValid(udid)) {
104 return ERR_DH_FWK_PARA_INVALID;
105 }
106 (void)deviceType;
107 DHLOGI("SendOnLineEvent networkId = %{public}s, uuid = %{public}s, udid = %{public}s",
108 GetAnonyString(networkId).c_str(), GetAnonyString(uuid).c_str(), GetAnonyString(udid).c_str());
109
110 TaskParam taskParam = {
111 .networkId = networkId,
112 .uuid = uuid,
113 .udid = udid,
114 .dhId = "",
115 .dhType = DHType::UNKNOWN
116 };
117 auto task = TaskFactory::GetInstance().CreateTask(TaskType::ON_LINE, taskParam, nullptr);
118 TaskExecutor::GetInstance().PushTask(task);
119 return DH_FWK_SUCCESS;
120 }
121
SendOffLineEvent(const std::string & networkId,const std::string & uuid,const std::string & udid,uint16_t deviceType)122 int32_t DistributedHardwareManager::SendOffLineEvent(const std::string &networkId, const std::string &uuid,
123 const std::string &udid, uint16_t deviceType)
124 {
125 if (!IsIdLengthValid(networkId) || !IsIdLengthValid(uuid) || !IsIdLengthValid(udid)) {
126 return ERR_DH_FWK_PARA_INVALID;
127 }
128 (void)deviceType;
129 DHLOGI("SendOffLineEvent networkId = %{public}s, uuid = %{public}s, udid = %{public}s",
130 GetAnonyString(networkId).c_str(), GetAnonyString(uuid).c_str(), GetAnonyString(udid).c_str());
131
132 TaskParam taskParam = {
133 .networkId = networkId,
134 .uuid = uuid,
135 .udid = udid,
136 .dhId = "",
137 .dhType = DHType::UNKNOWN
138 };
139 auto task = TaskFactory::GetInstance().CreateTask(TaskType::OFF_LINE, taskParam, nullptr);
140 TaskExecutor::GetInstance().PushTask(task);
141 Publisher::GetInstance().PublishMessage(DHTopic::TOPIC_DEV_OFFLINE, networkId);
142
143 HiSysEventWriteCompOfflineMsg(DHFWK_DEV_OFFLINE, OHOS::HiviewDFX::HiSysEvent::EventType::BEHAVIOR,
144 GetAnonyString(networkId), "dhfwk device offline event.");
145
146 return DH_FWK_SUCCESS;
147 }
148
GetOnLineCount()149 size_t DistributedHardwareManager::GetOnLineCount()
150 {
151 return DHContext::GetInstance().GetOnlineCount();
152 }
153
GetComponentVersion(std::unordered_map<DHType,std::string> & versionMap)154 int32_t DistributedHardwareManager::GetComponentVersion(std::unordered_map<DHType, std::string> &versionMap)
155 {
156 DHLOGI("start");
157 DHVersion dhVersion;
158 int32_t ret = ComponentLoader::GetInstance().GetLocalDHVersion(dhVersion);
159 if (ret != DH_FWK_SUCCESS) {
160 DHLOGE("GetLocalDHVersion fail, errCode = %{public}d", ret);
161 return ret;
162 }
163
164 for (auto iter = dhVersion.compVersions.cbegin(); iter != dhVersion.compVersions.cend(); ++iter) {
165 versionMap.emplace(iter->first, iter->second.sinkVersion);
166 }
167 return DH_FWK_SUCCESS;
168 }
169
Dump(const std::vector<std::string> & argsStr,std::string & result)170 int32_t DistributedHardwareManager::Dump(const std::vector<std::string> &argsStr, std::string &result)
171 {
172 return HidumpHelper::GetInstance().Dump(argsStr, result);
173 }
174 } // namespace DistributedHardware
175 } // namespace OHOS
176