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