/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/ |
H A D | runtime_config.cpp | 52 … 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 D | kv_store_delegate_manager.cpp | 451 …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 D | icommunicator_aggregator.h | 47 virtual void ReleaseCommunicator(ICommunicator *inCommunicator) = 0;
|
H A D | network_adapter.h | 33 …er(const std::string &inProcessLabel, const std::shared_ptr<IProcessCommunicator> &inCommunicator);
|
H A D | communicator_aggregator.h | 65 void ReleaseCommunicator(ICommunicator *inCommunicator) override;
|
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/include/ |
H A D | runtime_config.h | 42 …tatic DBStatus SetProcessCommunicator(const std::shared_ptr<IProcessCommunicator> &inCommunicator);
|
H A D | kv_store_delegate_manager.h | 74 …tatic DBStatus SetProcessCommunicator(const std::shared_ptr<IProcessCommunicator> &inCommunicator);
|
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/src/ |
H A D | network_adapter.cpp | 40 const std::shared_ptr<IProcessCommunicator> &inCommunicator) in NetworkAdapter() argument 41 : processLabel_(inProcessLabel), processCommunicator_(inCommunicator) in NetworkAdapter()
|
H A D | communicator_aggregator.cpp | 171 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 D | virtual_communicator_aggregator.cpp | 60 void VirtualCommunicatorAggregator::ReleaseCommunicator(ICommunicator *inCommunicator) in ReleaseCommunicator() argument 63 VirtualCommunicator *communicator = static_cast<VirtualCommunicator *>(inCommunicator); in ReleaseCommunicator()
|
H A D | virtual_communicator_aggregator.h | 39 void ReleaseCommunicator(ICommunicator *inCommunicator) override;
|
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/ |
H A D | ability_sync.h | 161 int Initialize(ICommunicator *inCommunicator, ISyncInterface *inStorage,
|
H A D | ability_sync.cpp | 367 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 D | distributeddb_interfaces_auto_launch_test.cpp | 88 void ReleaseCommunicator(ICommunicator *inCommunicator) override in ReleaseCommunicator() argument
|