diff --git a/services/sink/sinkmanager/src/distributed_input_sink_manager.cpp b/services/sink/sinkmanager/src/distributed_input_sink_manager.cpp index 80faa00..27b157f 100644 --- a/services/sink/sinkmanager/src/distributed_input_sink_manager.cpp +++ b/services/sink/sinkmanager/src/distributed_input_sink_manager.cpp @@ -695,7 +695,6 @@ int32_t DistributedInputSinkManager::RegisterGetSinkScreenInfosCallback( uint32_t DistributedInputSinkManager::GetSinkScreenInfosCbackSize() { - std::lock_guard lock(mutex_); return getSinkScreenInfosCallbacks_.size(); } diff --git a/services/transportbase/src/distributed_input_transport_base.cpp b/services/transportbase/src/distributed_input_transport_base.cpp index 1721633..ad8a335 100644 --- a/services/transportbase/src/distributed_input_transport_base.cpp +++ b/services/transportbase/src/distributed_input_transport_base.cpp @@ -369,13 +369,11 @@ void DistributedInputTransportBase::RunSessionStateCallback(const std::string &r int32_t DistributedInputTransportBase::CountSession(const std::string &remoteDevId) { - std::unique_lock sessionLock(operationMutex_); return remoteDevSessionMap_.count(remoteDevId); } void DistributedInputTransportBase::EraseSessionId(const std::string &remoteDevId) { - std::unique_lock sessionLock(operationMutex_); remoteDevSessionMap_.erase(remoteDevId); } diff --git a/services/transportbase/test/transbaseunittest/distributed_input_transbase_test.cpp b/services/transportbase/test/transbaseunittest/distributed_input_transbase_test.cpp index d5d55fb..74e6dd8 100644 --- a/services/transportbase/test/transbaseunittest/distributed_input_transbase_test.cpp +++ b/services/transportbase/test/transbaseunittest/distributed_input_transbase_test.cpp @@ -33,14 +33,6 @@ namespace { } void DistributedInputTransbaseTest::SetUp() { - sourceTransport_ = new DistributedInputSourceTransport(); - statusSourceListener_ = - std::make_shared(sourceTransport_); - DistributedInputTransportBase::GetInstance().RegisterSrcHandleSessionCallback(statusSourceListener_); - - sinkTransport_ = new DistributedInputSinkTransport(); - statusSinkListener_ = std::make_shared(sinkTransport_); - DistributedInputTransportBase::GetInstance().RegisterSinkHandleSessionCallback(statusSinkListener_); } void DistributedInputTransbaseTest::TearDown() diff --git a/services/transportbase/test/transbaseunittest/distributed_input_transbase_test.h b/services/transportbase/test/transbaseunittest/distributed_input_transbase_test.h index 56bb089..d87cb3d 100644 --- a/services/transportbase/test/transbaseunittest/distributed_input_transbase_test.h +++ b/services/transportbase/test/transbaseunittest/distributed_input_transbase_test.h @@ -48,12 +48,6 @@ public: virtual ~TestRegisterSessionStateCallbackStub() = default; void OnResult(const std::string &devId, const uint32_t status); }; - -private: - DistributedInputSourceTransport* sourceTransport_; - std::shared_ptr statusSourceListener_; - DistributedInputSinkTransport* sinkTransport_; - std::shared_ptr statusSinkListener_; }; } // namespace DistributedInput } // namespace DistributedHardware