Searched refs:communicateHandle_ (Results 1 – 13 of 13) sorted by relevance
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
| H A D | generic_virtual_device.cpp | 24 : communicateHandle_(nullptr), in GenericVirtualDevice()
44 if (communicateHandle_ != nullptr) { in ~GenericVirtualDevice()
45 communicateHandle_->RegOnMessageCallback(nullptr, nullptr); in ~GenericVirtualDevice()
46 communicatorAggregator_->ReleaseCommunicator(communicateHandle_); in ~GenericVirtualDevice()
47 communicateHandle_ = nullptr; in ~GenericVirtualDevice()
85 if (communicateHandle_ == nullptr) { in Initialize()
111 communicateHandle_->RegOnMessageCallback( in Initialize()
121 executor_->Initialize(syncInterface, communicateHandle_); in Initialize()
158 RefObject::IncObjRef(communicateHandle_); in MessageCallback()
160 ICommunicator *communicateHandle = communicateHandle_; in MessageCallback()
[all …]
|
| H A D | mock_single_ver_data_sync.h | 52 communicateHandle_ = communicator; in SetCommunicatorHandle()
|
| H A D | generic_virtual_device.h | 50 ICommunicator *communicateHandle_;
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/multiver/ |
| H A D | value_slice_sync.h | 67 ValueSliceSync() : storagePtr_(nullptr), communicateHandle_(nullptr) {}; in ValueSliceSync()
121 ICommunicator *communicateHandle_; variable
|
| H A D | multi_ver_data_sync.h | 68 MultiVerDataSync() : storagePtr_(nullptr), communicateHandle_(nullptr) {}; in MultiVerDataSync()
130 ICommunicator *communicateHandle_; variable
|
| H A D | value_slice_sync.cpp | 97 communicateHandle_ = nullptr; in ~ValueSliceSync()
175 communicateHandle_ = communicateHandle; in Initialize()
531 int errCode = communicateHandle_->SendMessage(deviceId, inMsg, conf); in Send()
|
| H A D | multi_ver_data_sync.cpp | 97 communicateHandle_ = nullptr; in ~MultiVerDataSync()
175 communicateHandle_ = communicateHandle; in Initialize()
582 int errCode = communicateHandle_->SendMessage(deviceId, inMsg, conf); in Send()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/ |
| H A D | commit_history_sync.h | 87 CommitHistorySync() : storagePtr_(nullptr), communicateHandle_(nullptr) {}; in CommitHistorySync()
141 ICommunicator *communicateHandle_; variable
|
| H A D | time_sync.cpp | 137 : communicateHandle_(nullptr), in TimeSync()
161 communicateHandle_ = nullptr; in ~TimeSync()
191 communicateHandle_ = communicator; in Initialize()
488 int errCode = communicateHandle_->SendMessage(deviceId, message, conf, handler); in SendPacket()
673 int errCode = communicateHandle_->GetRemoteCommunicatorVersion(deviceId_, version); in IsRemoteLowVersion()
|
| H A D | commit_history_sync.cpp | 138 communicateHandle_ = nullptr; in ~CommitHistorySync()
218 communicateHandle_ = communicateHandle; in Initialize()
549 int errCode = communicateHandle_->SendMessage(deviceId, inMsg, conf); in Send()
707 return communicateHandle_->GetLocalIdentity(deviceInfo); in GetLocalDeviceInfo()
|
| H A D | time_sync.h | 152 ICommunicator *communicateHandle_; variable
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/ |
| H A D | single_ver_data_sync.cpp | 36 communicateHandle_(nullptr), in SingleVerDataSync()
44 communicateHandle_ = nullptr; in ~SingleVerDataSync()
55 communicateHandle_ = inCommunicateHandle; in Initialize()
230 if (communicateHandle_ != nullptr) { in GetLocalDeviceName()
231 communicateHandle_->GetLocalIdentity(deviceInfo); in GetLocalDeviceName()
247 …int errCode = communicateHandle_->SendMessage(context->GetDeviceId(), message, sendConfig, handler… in Send()
920 …if (communicateHandle_->GetRemoteCommunicatorVersion(context->GetDeviceId(), remoteCommunicatorVer… in DoAbilitySyncIfNeed()
1339 …mitReceive = SingleVerDataSyncUtils::CheckPermitReceiveData(context, communicateHandle_, storage_); in RunPermissionCheck()
1706 …mtuSize_ = communicateHandle_->GetCommunicatorMtuSize(deviceId_) * 9 / 10; // get the 9/10 of the … in UpdateMtuSize()
1887 …bool permitReceive = SingleVerDataSyncUtils::CheckPermitReceiveData(context, communicateHandle_, s… in ControlCmdStartCheck()
|
| H A D | single_ver_data_sync.h | 256 ICommunicator* communicateHandle_; variable
|