Home
last modified time | relevance | path

Searched refs:communicator (Results 1 – 25 of 72) sorted by relevance

123

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/
H A Dvirtual_communicator_aggregator.cpp64 OfflineDevice(communicator->GetDeviceId()); in ReleaseCommunicator()
69 RefObject::KillAndDecObjRef(communicator); in ReleaseCommunicator()
70 communicator = nullptr; in ReleaseCommunicator()
146 if (communicator == nullptr) { in AllocCommunicator()
154 return communicator; in AllocCommunicator()
163 return communicator; in GetCommunicator()
196 if (!communicator->IsEnabled()) { in DispatchMessageInner()
205 RefObject::IncObjRef(communicator); in DispatchMessageInner()
218 RefObject::DecObjRef(communicator); in DispatchMessageInner()
348 communicator.second->Disable(); in DisableCommunicator()
[all …]
H A Ddistributeddb_mock_sync_module_test.cpp183 MockCommunicator communicator; in StateMachineCheck013() local
382 delete communicator; in TimeSync001()
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
1206 auto communicator = variable
[all …]
H A Dmock_single_ver_data_sync.h50 void SetCommunicatorHandle(ICommunicator *communicator) in SetCommunicatorHandle() argument
52 communicateHandle_ = communicator; in SetCommunicatorHandle()
/ohos5.0/foundation/distributeddatamgr/data_object/interfaces/innerkits/
H A DBUILD.gn23 "../../frameworks/innerkitsimpl/include/communicator",
45 "../../frameworks/innerkitsimpl/src/communicator/app_device_handler.cpp",
46 "../../frameworks/innerkitsimpl/src/communicator/app_pipe_handler.cpp",
47 "../../frameworks/innerkitsimpl/src/communicator/app_pipe_mgr.cpp",
48 "../../frameworks/innerkitsimpl/src/communicator/ark_communication_provider.cpp",
49 "../../frameworks/innerkitsimpl/src/communicator/communication_provider.cpp",
50 "../../frameworks/innerkitsimpl/src/communicator/communication_provider_impl.cpp",
51 "../../frameworks/innerkitsimpl/src/communicator/dev_manager.cpp",
52 "../../frameworks/innerkitsimpl/src/communicator/process_communicator_impl.cpp",
53 "../../frameworks/innerkitsimpl/src/communicator/softbus_adapter_standard.cpp",
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/adapter/communicator/test/
H A DBUILD.gn28 …n/distributeddatamgr/datamgr_service/services/distributeddataservice/adapter/include/communicator",
39 …ibuteddatamgr/datamgr_service/services/distributeddataservice/adapter/communicator:distributeddata…
53 …n/distributeddatamgr/datamgr_service/services/distributeddataservice/adapter/include/communicator",
71 …ibuteddatamgr/datamgr_service/services/distributeddataservice/adapter/communicator:distributeddata…
85 "${data_service_path}/adapter/include/communicator",
103 "${data_service_path}/adapter/communicator:distributeddata_communicator_static",
115 "./unittest/communicator",
116 "./unittest/communicator/include",
119 …n/distributeddatamgr/datamgr_service/services/distributeddataservice/adapter/include/communicator",
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/
H A Dremote_executor.cpp62 communicator_ = communicator; in Initialize()
295 RefObject::DecObjRef(communicator); in ReceiveRemoteExecutorAck()
320 if (communicator == nullptr) { in CheckParamValid()
325 RefObject::DecObjRef(communicator); in CheckParamValid()
533 RefObject::DecObjRef(communicator); in SendRequestMessage()
594 if (communicator == nullptr) { in ResponseStart()
608 RefObject::DecObjRef(communicator); in ResponseStart()
839 RefObject::IncObjRef(communicator); in GetAndIncCommunicator()
840 return communicator; in GetAndIncCommunicator()
912 if (communicator == nullptr) { in GetPacketSize()
[all …]
H A Dsync_engine.cpp374 ScheduleTaskOut(context, communicator); in MessageReciveCallbackTask()
387 ScheduleTaskOut(context, communicator); in RemoteDataChangedTask()
394 RefObject::DecObjRef(communicator); in ScheduleTaskOut()
753 ICommunicator *communicator = nullptr; in SetEqualIdentifier() local
781 communicator->Activate(); in SetEqualIdentifier()
897 if (communicator == nullptr) { in AllocCommunicator()
899 return communicator; in AllocCommunicator()
921 return communicator; in AllocCommunicator()
1157 auto communicator = communicator_; in GetLocalDeviceId() local
1158 RefObject::IncObjRef(communicator); in GetLocalDeviceId()
[all …]
H A Dcommunicator_proxy.cpp228 void CommunicatorProxy::SetMainCommunicator(ICommunicator *communicator) in SetMainCommunicator() argument
230 mainComm_ = communicator; in SetMainCommunicator()
234 void CommunicatorProxy::SetEqualCommunicator(ICommunicator *communicator, const std::string &identi… in SetEqualCommunicator() argument
262 RefObject::IncObjRef(communicator); in SetEqualCommunicator()
263 devCommMap_[target] = {identifier, communicator}; in SetEqualCommunicator()
270 for (const auto &[target, communicator] : devCommMap_) { in Dump()
271 std::string label = DBCommon::TransferStringToHex(communicator.first); in Dump()
H A Ddevice_manager.cpp70 int DeviceManager::Initialize(ICommunicator *communicator, const std::function<void(std::string)> &… in Initialize() argument
73 if (communicator == nullptr) { in Initialize()
76 RefObject::IncObjRef(communicator); in Initialize()
77 communicator_ = communicator; in Initialize()
H A Dcommunicator_proxy.h50 void SetMainCommunicator(ICommunicator *communicator);
53 void SetEqualCommunicator(ICommunicator *communicator, const std::string &identifier,
H A Dsync_engine.h166 …void MessageReciveCallbackTask(ISyncTaskContext *context, const ICommunicator *communicator, Messa…
168 …void RemoteDataChangedTask(ISyncTaskContext *context, const ICommunicator *communicator, Message *…
170 void ScheduleTaskOut(ISyncTaskContext *context, const ICommunicator *communicator);
H A Dsync_state_machine.cpp54 const std::shared_ptr<Metadata> &metadata, ICommunicator *communicator) in Initialize() argument
56 … == nullptr) || (syncInterface == nullptr) || (metadata == nullptr) || (communicator == nullptr)) { in Initialize()
62 RefObject::IncObjRef(communicator); in Initialize()
63 communicator_ = communicator; in Initialize()
H A Dremote_executor.h59 int Initialize(ISyncInterface *syncInterface, ICommunicator *communicator);
139 …int CheckSecurityOption(ISyncInterface *storage, ICommunicator *communicator, const SecurityOption…
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/adapter/communicator/test/fuzztest/softbusadapter_fuzzer/
H A DBUILD.gn23 "${data_service_path}/adapter/include/communicator",
28 "${data_service_path}/adapter/communicator/src",
38 fuzz_config_file = "${data_service_path}/adapter/communicator/test/fuzztest/softbusadapter_fuzzer"
50 "${data_service_path}/adapter/communicator:distributeddata_communicator_static",
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/fuzztest/iprocesscommunicator_fuzzer/
H A Diprocesscommunicator_fuzzer.cpp155 auto communicator = std::make_shared<ProcessCommunicatorFuzzTest>(); in CommunicatorFuzzer() local
156 KvStoreDelegateManager::SetProcessCommunicator(communicator); in CommunicatorFuzzer()
157 RuntimeConfig::SetProcessCommunicator(communicator); in CommunicatorFuzzer()
176 communicator->FuzzOnDataReceive(device, data, size); in CommunicatorFuzzer()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/
H A Ddistributeddb.gni69 "${distributeddb_path}/communicator/src/combine_status.cpp",
70 "${distributeddb_path}/communicator/src/communicator.cpp",
72 "${distributeddb_path}/communicator/src/communicator_linker.cpp",
73 "${distributeddb_path}/communicator/src/db_status_adapter.cpp",
74 "${distributeddb_path}/communicator/src/frame_combiner.cpp",
75 "${distributeddb_path}/communicator/src/frame_retainer.cpp",
76 "${distributeddb_path}/communicator/src/header_converter.cpp",
77 "${distributeddb_path}/communicator/src/message_transform.cpp",
78 "${distributeddb_path}/communicator/src/network_adapter.cpp",
79 "${distributeddb_path}/communicator/src/protocol_proto.cpp",
[all …]
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/multiver/
H A Dmulti_ver_sync_task_context.cpp32 const std::shared_ptr<Metadata> &metadata, ICommunicator *communicator) in Initialize() argument
34 if (deviceId.empty() || (syncInterface == nullptr) || (communicator == nullptr)) { in Initialize()
38 communicator_ = communicator; in Initialize()
54 errCode = stateMachine_->Initialize(this, syncInterface, metadata, communicator); in Initialize()
H A Dmulti_ver_sync_state_machine.cpp62 const std::shared_ptr<Metadata> &metadata, ICommunicator *communicator) in Initialize() argument
64 …if (context == nullptr || syncInterface == nullptr || metadata == nullptr || communicator == nullp… in Initialize()
67 int errCode = SyncStateMachine::Initialize(context, syncInterface, metadata, communicator); in Initialize()
77 errCode = timeSync_->Initialize(communicator, metadata, syncInterface, context->GetDeviceId()); in Initialize()
86 commitHistorySync_->Initialize(multiVerStorage_, communicator); in Initialize()
87 multiVerDataSync_->Initialize(multiVerStorage_, communicator); in Initialize()
88 valueSliceSync_->Initialize(multiVerStorage_, communicator); in Initialize()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/communicator/
H A Ddistributeddb_communicator_common.h146 #define ASSERT_NOT_NULL_AND_ACTIVATE(communicator) \ argument
148 ASSERT_NE(communicator, nullptr); \
149 (communicator)->Activate(); \
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/
H A DBUILD.gn71 "../communicator/include",
72 "../communicator/src",
409 "unittest/common/communicator/adapter_stub.cpp",
410 "unittest/common/communicator/distributeddb_communicator_common.cpp",
411 "unittest/common/communicator/distributeddb_communicator_test.cpp",
417 "unittest/common/communicator/adapter_stub.cpp",
418 "unittest/common/communicator/distributeddb_communicator_common.cpp",
419 "unittest/common/communicator/distributeddb_communicator_send_receive_test.cpp",
425 "unittest/common/communicator/adapter_stub.cpp",
426 "unittest/common/communicator/distributeddb_communicator_common.cpp",
[all …]
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/adapter/test/
H A DBUILD.gn22 "../communicator/test:unittest",
31 deps = [ "../communicator/test/fuzztest:fuzztest" ]
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/adapter/
H A DBUILD.gn33 "include/communicator",
58 "${data_service_path}/adapter/communicator:distributeddata_communicator_static",
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/fuzztest/storage_fuzzer/
H A DBUILD.gn51 "../../../communicator/include",
52 "../../../communicator/src",
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/fuzztest/cloudsync_fuzzer/
H A DBUILD.gn52 "../../../communicator/include",
53 "../../../communicator/src",
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/
H A Dsingle_ver_sync_task_context.cpp43 const std::shared_ptr<Metadata> &metadata, ICommunicator *communicator) in Initialize() argument
46 communicator == nullptr) { in Initialize()
59 int errCode = stateMachine_->Initialize(this, syncInterface, metadata, communicator); in Initialize()
77 communicator_ = communicator; in Initialize()

123