openharmony/communication_ipc
1
0
Fork 0
mirror of https://gitee.com/openharmony/communication_ipc synced 2024-12-02 13:16:50 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

!1136 【IPC/RPC】BrokerDelegator构造和析构中添加锁保护

Browse Source 
Merge pull request !1136 from chenchong_666/master
This commit is contained in:
openharmony_ci 2024-05-27 02:30:38 +00:00 committed by Gitee
commit c2d9edc00e
No known key found for this signature in database
GPG Key ID: 173E9B9CA92EEF8F
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
interfaces/innerkits/ipc_core/include/iremote_broker.h
View File

@ -131,10 +131,12 @@ private:
BrokerDelegator(BrokerDelegator &&) = delete;
BrokerDelegator &operator = (const BrokerDelegator &) = delete;
BrokerDelegator &operator = (BrokerDelegator &&) = delete;
std::mutex regMutex_;
};
template <typename T> BrokerDelegator<T>::BrokerDelegator()
{
std::lock_guard<std::mutex> lockGuard(regMutex_);
const std::u16string descriptor = T::GetDescriptor();
BrokerRegistration &registration = BrokerRegistration::Get();
if (registration.Register(descriptor, BrokerCreator<T>(), this)) {
@ -144,6 +146,7 @@ template <typename T> BrokerDelegator<T>::BrokerDelegator()
template <typename T> BrokerDelegator<T>::~BrokerDelegator()
{
std::lock_guard<std::mutex> lockGuard(regMutex_);
if (!isSoUnloaded && !descriptor_.empty()) {
BrokerRegistration &registration = BrokerRegistration::Get();
registration.Unregister(descriptor_);