Home
last modified time | relevance | path

Searched refs:dataSizeInfo (Results 1 – 13 of 13) sorted by relevance

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/include/
H A Dsync_generic_interface.h31 ContinueToken &continueStmtToken, const DataSizeSpecInfo &dataSizeInfo) const in GetSyncData() argument
41 ContinueToken &continueStmtToken, const DataSizeSpecInfo &dataSizeInfo) const in GetSyncData() argument
49 const DataSizeSpecInfo &dataSizeInfo, ContinueToken &continueStmtToken, in GetSyncData() argument
56 const DataSizeSpecInfo &dataSizeInfo) const in GetSyncDataNext() argument
62 const DataSizeSpecInfo &dataSizeInfo) const in GetSyncDataNext() argument
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/
H A Dvirtual_single_ver_sync_db_Interface.h66 ContinueToken &continueStmtToken, const DataSizeSpecInfo &dataSizeInfo) const override;
69 const DataSizeSpecInfo &dataSizeInfo) const override;
84 ContinueToken &continueStmtToken, const DataSizeSpecInfo &dataSizeInfo) const override;
86 …tSyncData(QueryObject &query, const SyncTimeRange &timeRange, const DataSizeSpecInfo &dataSizeInfo,
90 const DataSizeSpecInfo &dataSizeInfo) const override;
153 int GetSyncData(Timestamp begin, Timestamp end, const DataSizeSpecInfo &dataSizeInfo,
164 const DataSizeSpecInfo &dataSizeInfo, std::vector<VirtualDataItem> &dataItems) const;
H A Dvirtual_single_ver_sync_db_Interface.cpp133 ContinueToken &continueStmtToken, const DataSizeSpecInfo &dataSizeInfo) const in GetSyncData()
139 const DataSizeSpecInfo &dataSizeInfo) const in GetSyncDataNext()
228 const DataSizeSpecInfo &dataSizeInfo) const in GetSyncData()
231 int errCode = GetSyncData(begin, end, dataSizeInfo, dataItems, continueStmtToken); in GetSyncData()
244 ContinueToken &continueStmtToken, const DataSizeSpecInfo &dataSizeInfo) const in GetSyncDataNext()
256 …bool isFinished = GetDataInner(token->begin, token->end, currentWaterMark, dataSizeInfo, dataItems… in GetSyncDataNext()
282 bool isFinished = GetDataInner(begin, end, currentWaterMark, dataSizeInfo, dataItems); in GetSyncData()
403 const DataSizeSpecInfo &dataSizeInfo, ContinueToken &continueStmtToken, in GetSyncData() argument
589 const DataSizeSpecInfo &dataSizeInfo, std::vector<VirtualDataItem> &dataItems) const in GetDataInner() argument
594 if (dataItems.size() >= dataSizeInfo.packetSize) { in GetDataInner()
[all …]
H A Dvirtual_relational_ver_sync_db_interface.h58 const DataSizeSpecInfo &dataSizeInfo, ContinueToken &continueStmtToken,
H A Dvirtual_relational_ver_sync_db_interface.cpp125 const SyncTimeRange &timeRange, const DataSizeSpecInfo &dataSizeInfo, in GetSyncData() argument
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/
H A Dsqlite_single_ver_natural_store.h78 const DataSizeSpecInfo &dataSizeInfo) const override;
81 ContinueToken &continueStmtToken, const DataSizeSpecInfo &dataSizeInfo) const override;
83 …tSyncData(QueryObject &query, const SyncTimeRange &timeRange, const DataSizeSpecInfo &dataSizeInfo,
87 const DataSizeSpecInfo &dataSizeInfo) const override;
90 const DataSizeSpecInfo &dataSizeInfo) const override;
295 const DataSizeSpecInfo &dataSizeInfo) const;
H A Dsqlite_single_ver_natural_store.cpp620 ContinueToken &continueStmtToken, const DataSizeSpecInfo &dataSizeInfo) const in GetSyncData()
655 ContinueToken &continueStmtToken, const DataSizeSpecInfo &dataSizeInfo) const in GetSyncData()
690 const DataSizeSpecInfo &dataSizeInfo, ContinueToken &continueStmtToken, in GetSyncData() argument
711 errCode = GetSyncDataForQuerySync(dataItems, token, dataSizeInfo); in GetSyncData()
762 if (CanHoldDeletedData(dataItems, dataSizeInfo, GetAppendedLen())) { in GetSyncDataForQuerySync()
786 ContinueToken &continueStmtToken, const DataSizeSpecInfo &dataSizeInfo) const in GetSyncDataNext()
797 errCode = GetSyncDataForQuerySync(dataItems, token, dataSizeInfo); in GetSyncDataNext()
800 errCode = GetSyncDataNext(dataItems, continueStmtToken, dataSizeInfo); in GetSyncDataNext()
817 const DataSizeSpecInfo &dataSizeInfo) const in GetSyncDataNext()
819 if (dataSizeInfo.blockSize > DBConstant::MAX_SYNC_BLOCK_SIZE) { in GetSyncDataNext()
[all …]
H A Dsqlite_single_ver_storage_executor.h80 Timestamp end, const DataSizeSpecInfo &dataSizeInfo) const;
82 Timestamp end, const DataSizeSpecInfo &dataSizeInfo) const;
179 …cDataWithQuery(const QueryObject &query, size_t appendLength, const DataSizeSpecInfo &dataSizeInfo,
329 size_t appendLength, const DataSizeSpecInfo &dataSizeInfo) const;
332 …size_t appendLength, const DataSizeSpecInfo &dataSizeInfo, std::vector<DataItem> &dataItems) const;
H A Dsqlite_single_ver_storage_executor.cpp501 size_t appendLength, const DataSizeSpecInfo &dataSizeInfo) const in GetSyncDataItems()
526 if ((dataTotalSize > dataSizeInfo.blockSize && !dataItems.empty()) || in GetSyncDataItems()
527 dataItems.size() >= dataSizeInfo.packetSize) { in GetSyncDataItems()
538 Timestamp begin, Timestamp end, const DataSizeSpecInfo &dataSizeInfo) const in GetSyncDataByTimestamp()
546 errCode = GetSyncDataItems(dataItems, statement, appendLength, dataSizeInfo); in GetSyncDataByTimestamp()
552 Timestamp begin, Timestamp end, const DataSizeSpecInfo &dataSizeInfo) const in GetDeletedSyncDataByTimestamp()
560 errCode = GetSyncDataItems(dataItems, statement, appendLength, dataSizeInfo); in GetDeletedSyncDataByTimestamp()
567 const DataSizeSpecInfo &dataSizeInfo) in AppendDataItem() argument
571 …if ((appendSize > dataSizeInfo.blockSize && !dataItems.empty()) || dataItems.size() >= dataSizeInf… in AppendDataItem()
624 const DataSizeSpecInfo &dataSizeInfo, const std::pair<Timestamp, Timestamp> &timeRange, in GetSyncDataWithQuery() argument
[all …]
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/gaussdb_rd/
H A Drd_single_ver_storage_executor.h98 Timestamp end, const DataSizeSpecInfo &dataSizeInfo) const;
101 Timestamp end, const DataSizeSpecInfo &dataSizeInfo) const;
188 …cDataWithQuery(const QueryObject &query, size_t appendLength, const DataSizeSpecInfo &dataSizeInfo,
H A Drd_single_ver_storage_executor.cpp507 Timestamp begin, Timestamp end, const DataSizeSpecInfo &dataSizeInfo) const in GetSyncDataByTimestamp()
513 Timestamp begin, Timestamp end, const DataSizeSpecInfo &dataSizeInfo) const in GetDeletedSyncDataByTimestamp()
689 const DataSizeSpecInfo &dataSizeInfo, const std::pair<Timestamp, Timestamp> &timeRange, in GetSyncDataWithQuery() argument
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/relational/
H A Drelational_sync_able_storage.h80 const DataSizeSpecInfo &dataSizeInfo, ContinueToken &continueStmtToken,
84 const DataSizeSpecInfo &dataSizeInfo) const override;
260 const DataSizeSpecInfo &dataSizeInfo) const;
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/relational/
H A Drelational_sync_able_storage.cpp368 …ol CanHoldDeletedData(const std::vector<DataItem> &dataItems, const DataSizeSpecInfo &dataSizeInfo, in CanHoldDeletedData() argument
371 bool reachThreshold = (dataItems.size() >= dataSizeInfo.packetSize); in CanHoldDeletedData()
374 reachThreshold = (blockSize >= dataSizeInfo.blockSize * DBConstant::QUERY_SYNC_THRESHOLD); in CanHoldDeletedData()
404 SQLiteSingleVerRelationalContinueToken *&token, const DataSizeSpecInfo &dataSizeInfo) const in GetSyncDataForQuerySync()
420 dataSizeInfo, in GetSyncDataForQuerySync()
428 …} while (errCode == -E_UNFINISHED && CanHoldDeletedData(dataItems, dataSizeInfo, Parcel::GetAppend… in GetSyncDataForQuerySync()
442 const DataSizeSpecInfo &dataSizeInfo, ContinueToken &continueStmtToken, in GetSyncData() argument
456 return GetSyncDataNext(entries, continueStmtToken, dataSizeInfo); in GetSyncData()
460 ContinueToken &continueStmtToken, const DataSizeSpecInfo &dataSizeInfo) const in GetSyncDataNext()
476 int errCode = GetSyncDataForQuerySync(dataItems, token, dataSizeInfo); in GetSyncDataNext()