Searched refs:syncObject (Results 1 – 7 of 7) sorted by relevance
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/ |
| H A D | distributeddb_cloud_kv_syncer_test.cpp | 498 QuerySyncObject syncObject; variable
504 ASSERT_EQ(CloudStorageUtils::GetSyncQueryByPk(tableName, syncDataPk, true, syncObject), E_OK);
507 bytes.resize(syncObject.CalculateParcelLen(SOFTWARE_VERSION_CURRENT));
509 ASSERT_EQ(syncObject.SerializeData(parcel, SOFTWARE_VERSION_CURRENT), E_OK);
516 syncObject.ParserQueryNodes(bytes, queryNodes);
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/ |
| H A D | sqlite_cloud_kv_store.cpp | 607 QuerySyncObject syncObject; in GetCompensatedSyncQuery() local
608 errCode = CloudStorageUtils::GetSyncQueryByPk(table.name, syncDataPk, true, syncObject); in GetCompensatedSyncQuery()
613 syncQuery.push_back(syncObject); in GetCompensatedSyncQuery()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/ |
| H A D | sqlite_relational_store.cpp | 1170 QuerySyncObject syncObject(option.query); in CheckQueryValid() local
1171 int errCode = syncObject.GetValidStatus(); in CheckQueryValid()
1182 const auto tableNames = syncObject.GetRelationTableNames(); in CheckQueryValid()
1252 auto syncObject = QuerySyncObject::GetQuerySyncObject(option.query); in FillSyncInfo() local
1253 if (syncObject.empty()) { in FillSyncInfo()
1262 for (auto &item : syncObject) { in FillSyncInfo()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/ |
| H A D | sync_engine.cpp | 363 QuerySyncObject syncObject; in MessageReciveCallbackTask() local
364 if (errCode == E_OK && context->IsNeedTriggerQueryAutoSync(inMsg, syncObject)) { in MessageReciveCallbackTask()
366 GetQueryAutoSyncParam(deviceId, syncObject, param); in MessageReciveCallbackTask()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/ |
| H A D | db_common.cpp | 494 QuerySyncObject syncObject(query); in CheckQueryWithoutMultiTable() local
495 if (!syncObject.GetRelationTableNames().empty()) { in CheckQueryWithoutMultiTable()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/relational/ |
| H A D | relational_sync_able_storage.cpp | 2030 QuerySyncObject syncObject; in GetCompensatedSyncQueryInner() local
2031 errCode = CloudStorageUtils::GetSyncQueryByPk(table.name, syncDataPk, false, syncObject); in GetCompensatedSyncQueryInner()
2037 syncQuery.push_back(syncObject); in GetCompensatedSyncQueryInner()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/ |
| H A D | cloud_syncer.cpp | 63 QuerySyncObject syncObject; in Sync() local
64 syncObject.SetTableName(item); in Sync()
65 taskInfo.queryList.push_back(syncObject); in Sync()
|