diff --git a/services/sink/sinkmanager/src/distributed_input_sink_manager.cpp b/services/sink/sinkmanager/src/distributed_input_sink_manager.cpp index 80faa009bd024f93d35067420eccae81fd3fc2f9..27b157f112bb559b41a36570b8e6f95d7d59ef30 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 17216331417562e2583b734d58c103bd59e80a97..ad8a335471226f235cfdfdb62effb286879e57e3 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 d5d55fb814230aa33d961a5004000c81eeabe045..74e6dd840a7e1f3fcda69b26ec558519518e5fdd 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 56bb08943146b29b1e8c723cf5cc270c2bfb3fc9..d87cb3d824071a54a71893b99b38f9325cc6fe3b 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