| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
| H A D | distributeddb_mock_sync_module_test.cpp | 183 MockCommunicator communicator; in StateMachineCheck013() local
421 MockCommunicator communicator; variable
444 MockCommunicator communicator; variable
467 MockCommunicator communicator; variable
498 MockCommunicator communicator; variable
523 MockCommunicator communicator; variable
551 MockCommunicator communicator; variable
608 MockCommunicator communicator; variable
626 MockCommunicator communicator; variable
645 MockCommunicator communicator; variable
[all …]
|
| H A D | virtual_communicator_aggregator.cpp | 63 VirtualCommunicator *communicator = static_cast<VirtualCommunicator *>(inCommunicator); in ReleaseCommunicator() local
145 VirtualCommunicator *communicator = new (std::nothrow) VirtualCommunicator(deviceId, this); in AllocCommunicator() local
162 VirtualCommunicator *communicator = static_cast<VirtualCommunicator *>(iter->second); in GetCommunicator() local
195 VirtualCommunicator *communicator = static_cast<VirtualCommunicator *>(iter->second); in DispatchMessageInner() local
347 for (const auto &communicator: communicators_) { in DisableCommunicator() local
355 for (const auto &communicator: communicators_) { in EnableCommunicator() local
|
| H A D | mock_single_ver_data_sync.h | 50 void SetCommunicatorHandle(ICommunicator *communicator) in SetCommunicatorHandle()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/ |
| H A D | remote_executor.cpp | 54 int RemoteExecutor::Initialize(ISyncInterface *syncInterface, ICommunicator *communicator) in Initialize()
290 auto communicator = GetAndIncCommunicator(); in ReceiveRemoteExecutorAck() local
319 ICommunicator *communicator = GetAndIncCommunicator(); in CheckParamValid() local
509 auto communicator = GetAndIncCommunicator(); in SendRequestMessage() local
593 auto *communicator = GetAndIncCommunicator(); in ResponseStart() local
838 ICommunicator *communicator = communicator_; in GetAndIncCommunicator() local
911 auto *communicator = GetAndIncCommunicator(); in GetPacketSize() local
979 int RemoteExecutor::CheckSecurityOption(ISyncInterface *storage, ICommunicator *communicator, in CheckSecurityOption()
|
| H A D | communicator_proxy.cpp | 228 void CommunicatorProxy::SetMainCommunicator(ICommunicator *communicator) in SetMainCommunicator()
234 void CommunicatorProxy::SetEqualCommunicator(ICommunicator *communicator, const std::string &identi… in SetEqualCommunicator()
|
| H A D | sync_engine.cpp | 352 …SyncEngine::MessageReciveCallbackTask(ISyncTaskContext *context, const ICommunicator *communicator, in MessageReciveCallbackTask()
377 void SyncEngine::RemoteDataChangedTask(ISyncTaskContext *context, const ICommunicator *communicator… in RemoteDataChangedTask()
390 void SyncEngine::ScheduleTaskOut(ISyncTaskContext *context, const ICommunicator *communicator) in ScheduleTaskOut()
753 ICommunicator *communicator = nullptr; in SetEqualIdentifier() local
896 auto communicator = communicatorAggregator->AllocCommunicator(identifierVect, errCode); in AllocCommunicator() local
1157 auto communicator = communicator_; in GetLocalDeviceId() local
|
| H A D | device_manager.cpp | 70 int DeviceManager::Initialize(ICommunicator *communicator, const std::function<void(std::string)> &… in Initialize()
|
| H A D | sync_state_machine.cpp | 54 const std::shared_ptr<Metadata> &metadata, ICommunicator *communicator) in Initialize()
|
| H A D | time_sync.cpp | 181 int TimeSync::Initialize(ICommunicator *communicator, const std::shared_ptr<Metadata> &metadata, in Initialize()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/multiver/ |
| H A D | multi_ver_sync_task_context.cpp | 32 const std::shared_ptr<Metadata> &metadata, ICommunicator *communicator) in Initialize()
|
| H A D | multi_ver_sync_state_machine.cpp | 62 const std::shared_ptr<Metadata> &metadata, ICommunicator *communicator) in Initialize()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/communicator/ |
| H A D | distributeddb_communicator_common.h | 146 #define ASSERT_NOT_NULL_AND_ACTIVATE(communicator) \ argument
|
| H A D | distributeddb_communicator_test.cpp | 261 #define REG_CONNECT_CALLBACK(communicator, online) \ argument
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/distributeddatafwk/src/ |
| H A D | distributed_kv_data_manager.cpp | 209 auto communicator = std::make_shared<ProcessCommunicationImpl>(endpoint); in SetEndpoint() local
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/fuzztest/iprocesscommunicator_fuzzer/ |
| H A D | iprocesscommunicator_fuzzer.cpp | 155 auto communicator = std::make_shared<ProcessCommunicatorFuzzTest>(); in CommunicatorFuzzer() local
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/ |
| H A D | distributeddb_relational_encrypted_db_test.cpp | 115 auto communicator = new (std::nothrow) VirtualCommunicatorAggregator(); in SetUpTestCase() local
|
| H A D | distributeddb_relational_remote_query_test.cpp | 138 auto communicator = new (std::nothrow) VirtualCommunicatorAggregator(); in SetUpTestCase() local
|
| H A D | distributeddb_relational_get_data_test.cpp | 296 auto communicator = new (std::nothrow) VirtualCommunicatorAggregator(); in SetUpTestCase() local
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/interfaces/ |
| H A D | distributeddb_interfaces_encrypt_database_test.cpp | 539 auto communicator = new(std::nothrow) VirtualCommunicatorAggregator(); variable
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/moduletest/src/ |
| H A D | distributeddb_nb_autolaunch_test.cpp | 657 …std::shared_ptr<ProcessCommunicatorTestStub> communicator = std::make_shared<ProcessCommunicatorTe… variable
|
| H A D | distributeddb_nb_enable_sync_by_closed_db_test.cpp | 645 …std::shared_ptr<ProcessCommunicatorTestStub> communicator = std::make_shared<ProcessCommunicatorTe… variable
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/ |
| H A D | single_ver_sync_task_context.cpp | 43 const std::shared_ptr<Metadata> &metadata, ICommunicator *communicator) in Initialize()
|
| H A D | single_ver_data_sync_utils.cpp | 214 const ICommunicator *communicator, const SyncGenericInterface *storage) in CheckPermitReceiveData()
|
| H A D | single_ver_sync_state_machine.cpp | 120 const std::shared_ptr<Metadata> &metaData, ICommunicator *communicator) in Initialize()
|
| /ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/app/src/ |
| H A D | kvstore_data_service.cpp | 118 …auto communicator = std::make_shared<AppDistributedKv::ProcessCommunicatorImpl>(RouteHeadHandlerIm… in Initialize() local
|