Searched refs:syncAbleEngine_ (Results 1 – 4 of 4) sorted by relevance
266 syncAbleEngine_->EraseDeviceWaterMark(deviceHash, false, tableName); in CleanDistributedDeviceTable()301 syncAbleEngine_ = std::make_shared<SyncAbleEngine>(storageEngine_); in Open()304 storageEngine_->SetSyncAbleEngine(syncAbleEngine_); in Open()370 return syncAbleEngine_->Sync(syncParam, connectionId); in Sync()398 syncAbleEngine_->Close(); in DecreaseConnectionCounter()440 syncAbleEngine_->WakeUpSyncer(); in WakeUpSyncer()460 int errCode = syncAbleEngine_->GetLocalIdentity(localIdentity); in CreateDistributedTable()598 int errCode = syncAbleEngine_->GetHashDeviceId(device, hashDeviceId); in RemoveDeviceData()754 return syncAbleEngine_->StopSync(connectionId); in StopSync()772 if (syncAbleEngine_ != nullptr) { in Dump()[all …]
185 std::shared_ptr<SyncAbleEngine> syncAbleEngine_ = nullptr; // For storage operate sync function variable
320 std::shared_ptr<SyncAbleEngine> syncAbleEngine_ = nullptr; variable
55 syncAbleEngine_ = nullptr; in ~RelationalSyncAbleStorage()1423 syncAbleEngine_ = syncAbleEngine; in SetSyncAbleEngine()