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

修改死锁导致UT卡死

Browse Source 
Signed-off-by: li-tiangang4 <litiangang4@huawei.com>
This commit is contained in:
li-tiangang4
2024-05-10 18:41:11 +08:00
parent 722ef369c5
commit 825320b904
4 changed files with 0 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files
services/sink/sinkmanager/src/distributed_input_sink_manager.cpp
-1
View File
@@ -695,7 +695,6 @@ int32_t DistributedInputSinkManager::RegisterGetSinkScreenInfosCallback(
uint32_t DistributedInputSinkManager::GetSinkScreenInfosCbackSize()
{
std::lock_guard<std::mutex> lock(mutex_);
return getSinkScreenInfosCallbacks_.size();
}
services/transportbase/src/distributed_input_transport_base.cpp
-2
View File
@@ -369,13 +369,11 @@ void DistributedInputTransportBase::RunSessionStateCallback(const std::string &r
int32_t DistributedInputTransportBase::CountSession(const std::string &remoteDevId)
{
std::unique_lock<std::mutex> sessionLock(operationMutex_);
return remoteDevSessionMap_.count(remoteDevId);
}
void DistributedInputTransportBase::EraseSessionId(const std::string &remoteDevId)
{
std::unique_lock<std::mutex> sessionLock(operationMutex_);
remoteDevSessionMap_.erase(remoteDevId);
}
services/transportbase/test/transbaseunittest/distributed_input_transbase_test.cpp
-8
View File
@@ -33,14 +33,6 @@ namespace {
}
void DistributedInputTransbaseTest::SetUp()
{
sourceTransport_ = new DistributedInputSourceTransport();
statusSourceListener_ =
std::make_shared<DistributedInputSourceTransport::DInputTransbaseSourceListener>(sourceTransport_);
DistributedInputTransportBase::GetInstance().RegisterSrcHandleSessionCallback(statusSourceListener_);
sinkTransport_ = new DistributedInputSinkTransport();
statusSinkListener_ = std::make_shared<DistributedInputSinkTransport::DInputTransbaseSinkListener>(sinkTransport_);
DistributedInputTransportBase::GetInstance().RegisterSinkHandleSessionCallback(statusSinkListener_);
}
void DistributedInputTransbaseTest::TearDown()
services/transportbase/test/transbaseunittest/distributed_input_transbase_test.h
-6
View File
@@ -48,12 +48,6 @@ public:
virtual ~TestRegisterSessionStateCallbackStub() = default;
void OnResult(const std::string &devId, const uint32_t status);
};
private:
DistributedInputSourceTransport* sourceTransport_;
std::shared_ptr<DistributedInputSourceTransport::DInputTransbaseSourceListener> statusSourceListener_;
DistributedInputSinkTransport* sinkTransport_;
std::shared_ptr<DistributedInputSinkTransport::DInputTransbaseSinkListener> statusSinkListener_;
};
} // namespace DistributedInput
} // namespace DistributedHardware