openharmony/distributedhardware_distributed_input
1
0
Fork 0
mirror of https://github.com/openharmony/distributedhardware_distributed_input.git synced 2026-07-21 13:55:22 -04:00
Code Issues Packages Projects Releases Wiki Activity

input死亡监听

Browse Source 
Signed-off-by: “ry521” <renyi50@huawei.com>
This commit is contained in:
“ry521”
2023-10-07 19:51:43 +08:00
parent 670c517f46
commit cdcfe6a04b
4 changed files with 104 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
sourcehandler/src/distributed_input_source_handler.cpp
+43 -1
View File
@@ -63,9 +63,19 @@ int32_t DistributedInputSourceHandler::InitSource(const std::string &params)
void DistributedInputSourceHandler::FinishStartSA(const std::string &params, const sptr<IRemoteObject> &remoteObject)
{
DHLOGD("FinishStartSA");
DHLOGI("DInputSourceHandle FinishStartSA");
std::unique_lock<std::mutex> lock(proxyMutex_);
if (sourceSvrRecipient_ == nullptr) {
DHLOGE("sourceSvrRecipient is nullptr.");
return;
}
remoteObject -> AddDeathRecipient(sourceSvrRecipient_);
dInputSourceProxy_ = iface_cast<IDistributedSourceInput>(remoteObject);
DInputSAManager::GetInstance().SetDInputSourceProxy(remoteObject);
if ((dInputSourceProxy_ == nullptr) || (dInputSourceProxy_ ->AsObject() == nullptr)) {
DHLOGE("Faild to get input source proxy.");
return;
}
DistributedInputClient::GetInstance().InitSource();
proxyConVar_.notify_all();
}
@@ -107,6 +117,38 @@ void DistributedInputSourceHandler::SALoadSourceCb::OnLoadSystemAbilityFail(int3
DHLOGE("DistributedInputSourceHandler OnLoadSystemAbilityFail. systemAbilityId=%d", systemAbilityId);
}
void DistributedInputSourceHandler::DInputSourceSvrRecipient::OnRemoteDied(const wptr<IRemoteObject> &remote)
{
if (remote == nullptr) {
DHLOGI("OnRemoteDied remote is nullptr.");
return;
}
DHLOGI("DInputSourceSvrRecipient OnRemoteDied.");
DistributedInputSourceHandler::GetInstance().OnRemoteSourceSvrDied(remote);
}
void DistributedInputSourceHandler::OnRemoteSourceSvrDied(const wptr<IRemoteObject> &remote)
{
DHLOGI("OnRemoteSourceSvrDied.");
std::lock_guard<std::mutex> lock(proxyMutex_);
if (dInputSourceProxy_ == nullptr) {
DHLOGE("dInputSourceProxy is nullptr.");
return;
}
sptr<IRemoteObject> remoteObject = remote.promote();
if (remoteObject == nullptr) {
DHLOGE("OnRemoteDied remote promoted failed");
return;
}
if (dInputSourceProxy_ ->AsObject() != remoteObject) {
DHLOGE("OnRemoteSourceSvrDied not found remote object.");
return;
}
dInputSourceProxy_->AsObject()->RemoveDeathRecipient(sourceSvrRecipient_);
dInputSourceProxy_ = nullptr;
}
IDistributedHardwareSource *GetSourceHardwareHandler()
{
return &DistributedInputSourceHandler::GetInstance();