Home
last modified time | relevance | path

Searched refs:inCommunicator (Results 1 – 14 of 14) sorted by relevance

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/
H A Druntime_config.cpp52 … RuntimeConfig::SetProcessCommunicator(const std::shared_ptr<IProcessCommunicator> &inCommunicator) in SetProcessCommunicator() argument
66 auto *adapter = new (std::nothrow) NetworkAdapter(processLabel, inCommunicator); in SetProcessCommunicator()
71 processCommunicator_ = inCommunicator; in SetProcessCommunicator()
H A Dkv_store_delegate_manager.cpp451 …elegateManager::SetProcessCommunicator(const std::shared_ptr<IProcessCommunicator> &inCommunicator) in SetProcessCommunicator() argument
465 NetworkAdapter *adapter = new (std::nothrow) NetworkAdapter(processLabel, inCommunicator); in SetProcessCommunicator()
470 processCommunicator_ = inCommunicator; in SetProcessCommunicator()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/include/
H A Dicommunicator_aggregator.h47 virtual void ReleaseCommunicator(ICommunicator *inCommunicator) = 0;
H A Dnetwork_adapter.h33 …er(const std::string &inProcessLabel, const std::shared_ptr<IProcessCommunicator> &inCommunicator);
H A Dcommunicator_aggregator.h65 void ReleaseCommunicator(ICommunicator *inCommunicator) override;
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/include/
H A Druntime_config.h42 …tatic DBStatus SetProcessCommunicator(const std::shared_ptr<IProcessCommunicator> &inCommunicator);
H A Dkv_store_delegate_manager.h74 …tatic DBStatus SetProcessCommunicator(const std::shared_ptr<IProcessCommunicator> &inCommunicator);
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/src/
H A Dnetwork_adapter.cpp40 const std::shared_ptr<IProcessCommunicator> &inCommunicator) in NetworkAdapter() argument
41 : processLabel_(inProcessLabel), processCommunicator_(inCommunicator) in NetworkAdapter()
H A Dcommunicator_aggregator.cpp171 void CommunicatorAggregator::ReleaseCommunicator(ICommunicator *inCommunicator) in ReleaseCommunicator() argument
173 if (inCommunicator == nullptr) { in ReleaseCommunicator()
176 Communicator *commPtr = static_cast<Communicator *>(inCommunicator); in ReleaseCommunicator()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/
H A Dvirtual_communicator_aggregator.cpp60 void VirtualCommunicatorAggregator::ReleaseCommunicator(ICommunicator *inCommunicator) in ReleaseCommunicator() argument
63 VirtualCommunicator *communicator = static_cast<VirtualCommunicator *>(inCommunicator); in ReleaseCommunicator()
H A Dvirtual_communicator_aggregator.h39 void ReleaseCommunicator(ICommunicator *inCommunicator) override;
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/
H A Dability_sync.h161 int Initialize(ICommunicator *inCommunicator, ISyncInterface *inStorage,
H A Dability_sync.cpp367 int AbilitySync::Initialize(ICommunicator *inCommunicator, ISyncInterface *inStorage, in Initialize() argument
370 …if (inCommunicator == nullptr || inStorage == nullptr || deviceId.empty() || inMetadata == nullptr… in Initialize()
373 communicator_ = inCommunicator; in Initialize()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/interfaces/
H A Ddistributeddb_interfaces_auto_launch_test.cpp88 void ReleaseCommunicator(ICommunicator *inCommunicator) override in ReleaseCommunicator() argument