Searched refs:communicator_ (Results 1 – 16 of 16) sorted by relevance
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/ |
| H A D | device_manager.cpp | 29 DeviceManager::DeviceManager() : communicator_(nullptr) in DeviceManager()
35 if (communicator_ != nullptr) { in ~DeviceManager()
36 RefObject::DecObjRef(communicator_); in ~DeviceManager()
37 communicator_ = nullptr; in ~DeviceManager()
77 communicator_ = communicator; in Initialize()
154 int errCode = communicator_->SendMessage(deviceId, msg, conf); in SendLocalDataChanged()
|
| H A D | sync_engine.cpp | 49 communicator_(nullptr), in SyncEngine()
208 if (communicator_ == nullptr) { in StartCommunicator()
221 communicator_->Activate(); in StartCommunicator()
293 if (communicator_ == nullptr) { in InitComunicator()
303 communicator_ = nullptr; in InitComunicator()
311 communicator_ = nullptr; in InitComunicator()
926 if (communicator_ != nullptr) { in UnRegCommunicatorsCallback()
953 if (communicator_ != nullptr) { in ReleaseCommunicators()
955 communicator_ = nullptr; in ReleaseCommunicators()
1014 communicator_ = nullptr; in ClearInnerResource()
[all …]
|
| H A D | sync_state_machine.cpp | 27 communicator_(nullptr), in SyncStateMachine()
47 if (communicator_ != nullptr) { in ~SyncStateMachine()
48 RefObject::DecObjRef(communicator_); in ~SyncStateMachine()
49 communicator_ = nullptr; in ~SyncStateMachine()
63 communicator_ = communicator; in Initialize()
|
| H A D | sync_task_context.cpp | 48 communicator_(nullptr), in SyncTaskContext()
74 communicator_ = nullptr; in ~SyncTaskContext()
239 param.timeout = communicator_->GetTimeout(deviceId_); in MoveToNextTarget()
437 (void)communicator_->GetRemoteCommunicatorVersion(deviceId_, remoteVersion); in ReceiveMessageCallback()
|
| H A D | device_manager.h | 71 ICommunicator *communicator_; variable
|
| H A D | sync_state_machine.h | 163 ICommunicator *communicator_; variable
|
| H A D | ability_sync.cpp | 353 : communicator_(nullptr), in AbilitySync()
362 communicator_ = nullptr; in ~AbilitySync()
373 communicator_ = inCommunicator; in Initialize()
405 errCode = communicator_->SendMessage(deviceId_, message, conf, handler); in SyncStart()
1203 errCode = communicator_->SendMessage(deviceId_, ackMessage, conf); in SendAck()
|
| H A D | remote_executor.cpp | 47 communicator_(nullptr), in RemoteExecutor()
62 communicator_ = communicator; in Initialize()
729 communicator_ = nullptr; in ClearInnerSource()
838 ICommunicator *communicator = communicator_; in GetAndIncCommunicator()
|
| H A D | sync_task_context.h | 265 ICommunicator *communicator_; variable
|
| H A D | remote_executor.h | 165 ICommunicator *communicator_; variable
|
| H A D | sync_engine.h | 223 ICommunicator *communicator_; variable
|
| H A D | ability_sync.h | 265 ICommunicator *communicator_; variable
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/multiver/ |
| H A D | multi_ver_sync_state_machine.cpp | 103 RefObject::IncObjRef(communicator_); in SyncStep()
107 RefObject::DecObjRef(communicator_); in SyncStep()
263 RefObject::DecObjRef(communicator_); in SyncStepInnerLocked()
|
| H A D | multi_ver_sync_task_context.cpp | 38 communicator_ = communicator; in Initialize()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/ |
| H A D | single_ver_sync_state_machine.cpp | 171 RefObject::IncObjRef(communicator_); in SyncStep()
175 RefObject::DecObjRef(communicator_); in SyncStep()
219 RefObject::DecObjRef(communicator_); in SyncStepInnerLocked()
499 …int errCode = communicator_->GetRemoteCommunicatorVersion(context_->GetDeviceId(), remoteCommunica… in DoAbilitySync()
636 uint32_t timeout = communicator_->GetTimeout(context_->GetDeviceId()); in HandleDataRequestRecv()
|
| H A D | single_ver_sync_task_context.cpp | 77 communicator_ = communicator; in Initialize()
|