Home
last modified time | relevance | path

Searched refs:syncEngine_ (Results 1 – 7 of 7) sorted by relevance

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/
H A Dgeneric_syncer.cpp45 : syncEngine_(nullptr), in GenericSyncer()
63 if (syncEngine_ != nullptr) { in ~GenericSyncer()
64 syncEngine_->OnKill([this]() { this->syncEngine_->Close(); }); in ~GenericSyncer()
73 syncEngine_ = nullptr; in ~GenericSyncer()
213 engine = syncEngine_; in PrepareSync()
327 engine = syncEngine_; in QueryAutoSync()
418 if (syncEngine_ != nullptr && syncEngine_->IsEngineActive()) { in InitSyncEngine()
443 syncEngine_ = nullptr; in InitSyncEngine()
840 engine = syncEngine_; in SyncPreCheck()
892 syncEngine_->Dump(fd); in Dump()
[all …]
H A Dgeneric_syncer.h221 ISyncEngine *syncEngine_; variable
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/
H A Dsingle_ver_kv_syncer.cpp93 ISyncEngine *engine = syncEngine_; in LocalDataChanged()
133 RefObject::IncObjRef(syncEngine_); in RemoteDataChanged()
145 RefObject::DecObjRef(syncEngine_); in RemoteDataChanged()
150 RefObject::DecObjRef(syncEngine_); in RemoteDataChanged()
157 static_cast<SingleVerSyncEngine *>(syncEngine_)->GetLocalSubscribeQueries(device, syncQueries); in RemoteDataChanged()
166 static_cast<SingleVerSyncEngine *>(syncEngine_)->PutUnfinishedSubQueries(device, syncQueries); in RemoteDataChanged()
201 RefObject::IncObjRef(syncEngine_); in TriggerSubscribe()
217 RefObject::DecObjRef(syncEngine_); in TriggerSubscribe()
221 RefObject::DecObjRef(syncEngine_); in TriggerSubscribe()
310 if (syncInterface == nullptr || syncEngine_ == nullptr) { in TriggerAddSubscribeAsync()
[all …]
H A Dsingle_ver_syncer.cpp33 RefObject::IncObjRef(syncEngine_); in RemoteDeviceOffline()
34 ISyncEngine *engine = syncEngine_; in RemoteDeviceOffline()
80 if (syncEngine_ == nullptr) { in SetStaleDataWipePolicy()
86 static_cast<SingleVerSyncEngine *>(syncEngine_)->EnableClearRemoteStaleData(false); in SetStaleDataWipePolicy()
89 static_cast<SingleVerSyncEngine *>(syncEngine_)->EnableClearRemoteStaleData(true); in SetStaleDataWipePolicy()
H A Dsingle_ver_relational_syncer.cpp165 if (syncEngine_ == nullptr) { in SchemaChangeCallback()
168 syncEngine_->SchemaChange(); in SchemaChangeCallback()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/multiver/
H A Dmulti_ver_syncer.cpp45 if (!enable || (syncEngine_ == nullptr)) { in EnableAutoSync()
83 syncEngine_->BroadCastDataChanged(); in LocalDataChanged()
112 GenericSyncer::AddSyncOperation(syncEngine_, operation); in AddSyncOperation()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/
H A Dmock_single_ver_kv_syncer.h36 syncEngine_ = engine; in SetSyncEngine()
46 syncEngine_ = engine; in Init()