1 /*
2 * Copyright (c) 2022-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 "plugin_listener_impl.h"
17
18 #include "anonymous_string.h"
19 #include "capability_info.h"
20 #include "capability_info_manager.h"
21 #include "constants.h"
22 #include "dh_context.h"
23 #include "dh_utils_tool.h"
24 #include "distributed_hardware_errno.h"
25 #include "distributed_hardware_log.h"
26 #include "publisher.h"
27
28 namespace OHOS {
29 namespace DistributedHardware {
30 #undef DH_LOG_TAG
31 #define DH_LOG_TAG "PluginListenerImpl"
32
PluginHardware(const std::string & dhId,const std::string & attrs,const std::string & subtype)33 void PluginListenerImpl::PluginHardware(const std::string &dhId, const std::string &attrs, const std::string &subtype)
34 {
35 if (!IsIdLengthValid(dhId) || !IsMessageLengthValid(attrs)) {
36 return;
37 }
38 DHLOGI("plugin start, dhId: %{public}s", GetAnonyString(dhId).c_str());
39 if (DHContext::GetInstance().IsSleeping()) {
40 DHLOGI("System is in sleeping, drop it");
41 return;
42 }
43 std::vector<std::shared_ptr<CapabilityInfo>> capabilityInfos;
44 std::string deviceId = DHContext::GetInstance().GetDeviceInfo().deviceId;
45 std::string devName = DHContext::GetInstance().GetDeviceInfo().deviceName;
46 uint16_t devType = DHContext::GetInstance().GetDeviceInfo().deviceType;
47 std::shared_ptr<CapabilityInfo> dhCapabilityInfo =
48 std::make_shared<CapabilityInfo>(dhId, deviceId, devName, devType, dhType_, attrs, subtype);
49 capabilityInfos.push_back(dhCapabilityInfo);
50
51 CapabilityInfoManager::GetInstance()->AddCapability(capabilityInfos);
52 Publisher::GetInstance().PublishMessage(DHTopic::TOPIC_PHY_DEV_PLUGIN, dhId);
53 DHLOGI("plugin end, dhId: %{public}s", GetAnonyString(dhId).c_str());
54 }
55
UnPluginHardware(const std::string & dhId)56 void PluginListenerImpl::UnPluginHardware(const std::string &dhId)
57 {
58 if (!IsIdLengthValid(dhId)) {
59 return;
60 }
61 DHLOGI("unplugin start, dhId: %{public}s", GetAnonyString(dhId).c_str());
62 if (DHContext::GetInstance().IsSleeping()) {
63 DHLOGI("System is in sleeping, drop it");
64 return;
65 }
66 std::string deviceId = DHContext::GetInstance().GetDeviceInfo().deviceId;
67 std::shared_ptr<CapabilityInfo> capability = nullptr;
68 auto ret = CapabilityInfoManager::GetInstance()->GetCapability(deviceId, dhId, capability);
69 if ((ret != DH_FWK_SUCCESS) || (capability == nullptr)) {
70 DHLOGE("GetCapability failed, deviceId =%{public}s, dhId = %{public}s, errCode = %{public}d",
71 GetAnonyString(deviceId).c_str(), GetAnonyString(dhId).c_str(), ret);
72 return;
73 }
74 CapabilityInfoManager::GetInstance()->RemoveCapabilityInfoByKey(capability->GetKey());
75 DHLOGI("unplugin end, dhId: %{public}s", GetAnonyString(dhId).c_str());
76 }
77 } // namespace DistributedHardware
78 } // namespace OHOS
79