| /foundation/communication/wifi/wifi/services/wifi_standard/wifi_framework/wifi_manage/wifi_sta_sa/ |
| H A D | wifi_device_service_impl.cpp | 119 ErrCode errCode = CheckCanEnableWifi(); in EnableWifi() local
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/kvdb/ |
| H A D | kvdb_service_impl.cpp | 889 int errCode = AccessTokenKit::GetHapTokenInfo(tokenId, tokenInfo); in GetInstIndex() local
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/ |
| H A D | db_common.cpp | 51 int errCode = OS::RemoveFile(item.fileName); in RemoveFiles() local
64 int errCode = OS::RemoveDBDirectory(item->fileName); in RemoveDirectories() local
80 int errCode = OS::MakeDBDirectory(directory); in CreateDirectory() local
150 int errCode = CalcValueHash(devVect, hashVect); in TransferHashString() local
176 int errCode in CalcValueHash() local
215 int errCode = DBCommon::CreateDirectory(newDir); CreateStoreDirectory() local
228 int errCode; CopyFile() local
283 int errCode = OS::GetFileAttrFromPath(dir, fileList, true); RemoveAllFilesOfDirectory() local
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/relational/ |
| H A D | relational_store_sqlite_ext.cpp | 90 int errCode = SHA256_Init(context_); in Initialize() local
102 int errCode = SHA256_Update(context_, value.data(), value.size()); in Update() local
116 int errCode = SHA256_Final(value.data(), context_); in GetResult() local
151 int errCode = GetCurrentSysTimeInMicrosecond(curTime); in GetSysCurrentRawTime() local
261 int errCode in GetSysCurrentTime() local
284 int errCode = gettimeofday(&rawTime, nullptr); GetCurrentSysTimeInMicrosecond() local
416 int errCode = hashCalc.Initialize(); CalcValueHash() local
448 int errCode; CalcHashKey() local
504 int errCode = GetStatement(db, "SELECT value FROM naturalbase_rdb_aux_metadata WHERE key = ?", stmt); GetLocalTimeOffsetFromMeta() local
584 int errCode = TimeHelper::GetSysCurrentRawTime(curTime); GetRawSysTime() local
614 int errCode = CalcValueHash(strVec, hashVec); GetHashString() local
694 int errCode = GetStatement(db, checkPrimaryKeySql, checkPrimaryKeyStmt); JudgeIfGetRowid() local
772 int errCode = JudgeIfGetRowid(db, tableName, type, isRowid); DataChangedObserver() local
850 int errCode = GetStatement(db, sql, stmt); GetPrimaryKeyName() local
872 int errCode = GetPrimaryKeyName(db, tableInfo.first, primaryKey); GetTriggerSqls() local
967 int errCode = GetTriggerSqls(db, tableInfos, triggerSqls); StoreObserverCallback() local
989 int errCode = GetHashString(fileName, hashFileName); LogCommitHookCallback() local
1006 int errCode = GetHashString(fileName, hashFileName); RollbackHookCallback() local
1070 int errCode = sqlite3_prepare_v2(db, sql.c_str(), -1, &stmt, nullptr); GetStatement() local
1085 int errCode = sqlite3_exec(db, sql.c_str(), nullptr, nullptr, &errMsg); ExecuteRawSQL() local
1102 int errCode = sqlite3_step(stmt); StepWithRetry() local
1114 int errCode; BindBlobToStatement() local
1166 int errCode = GetStatement(db, checkTableSql, checkTableStmt); GetCurrentMaxTimestamp() local
1222 int errCode = sqlite3_prepare_v2(db, selectSql, -1, &statement, nullptr); GetTableSyncType() local
1263 int errCode = sqlite3_prepare_v2(db, sql.c_str(), -1, &statement, nullptr); HandleDropCloudSyncTable() local
1285 int errCode = sqlite3_exec(db, sql.c_str(), nullptr, nullptr, nullptr); HandleDropLogicDeleteData() local
1322 int errCode = sqlite3_prepare_v2(db, sql.c_str(), -1, &statement, nullptr); SaveDeleteFlagToDB() local
1412 int errCode = GetStatement(db, sql, stmt); HandleDataStatus() local
1453 int errCode = SQLiteUtils::BeginTransaction(db, TransactType::IMMEDIATE); HandleDataLock() local
1513 int errCode = GetStatement(db, sql, stmt); GetTableInfos() local
1542 int errCode = GetTableInfos(db, tableInfos); CreateTempTrigger() local
1603 int errCode = GetHashString(fileName, hashFileName); RegisterClientObserver() local
1621 int errCode = GetHashString(fileName, hashFileName); UnRegisterClientObserver() local
1648 int errCode = GetHashString(fileName, hashFileName); RegisterStoreObserver() local
1684 int errCode = GetHashString(fileName, hashFileName); UnregisterStoreObserver() local
1711 int errCode = GetHashString(fileName, hashFileName); UnregisterStoreObserver() local
1734 int errCode = SQLiteUtils::BeginTransaction(db, TransactType::IMMEDIATE); DropLogicDeletedData() local
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/ |
| H A D | cloud_syncer.cpp | 72 int errCode = CloudSyncUtils::CheckParamValid(taskInfo.devices, taskInfo.mode); in Sync() local
165 int errCode = RuntimeContext::GetInstance()->ScheduleTask([this]() { in TriggerSync() local
209 int errCode = E_OK; DoSyncIfNeed() local
245 int errCode = E_OK; DoSync() local
283 int errCode = CheckTaskIdValid(taskInfo.taskId); PrepareAndUpload() local
314 int errCode = storageProxy_->StartTransaction(); DoUploadInNeed() local
364 int errCode = E_OK; SyncMachineDoDownload() local
398 int errCode = DoUploadInNeed(taskInfo, needUpload); SyncMachineDoUpload() local
427 int errCode; SyncMachineDoFinished() local
467 DoFinished(TaskId taskId, int errCode) DoFinished() argument
566 TagAssetsInSingleRecord(VBucket &coveredData, VBucket &beCoveredData, bool setNormalStatus, int &errCode) TagAssetsInSingleRecord() argument
614 int errCode = storageProxy_->StartTransaction(TransactType::IMMEDIATE); HandleDownloadResult() local
741 int errCode = TagStatusByStrategy(isExist, param, dataInfo, strategyOpResult); TagStatus() local
1043 int errCode = storageProxy_->IsSharedTable(param.tableName, isSharedTable); DoDownloadAssets() local
1121 int errCode = GetSyncParamForDownload(taskId, param); DoDownload() local
1198 int errCode = E_OK; SaveUploadData() local
1228 int errCode = storageProxy_->FillCloudLogAndAsset(OpType::SET_UPLOADING, uploadData); DoBatchUpload() local
1257 int errCode = E_OK; PutWaterMarkAfterBatchUpload() local
1353 int errCode = storageProxy_->SetCloudWaterMark(tableName, cloudWaterMark); SaveCloudWaterMark() local
1537 int errCode = StartHeartBeatTimer(period, taskId); LockCloud() local
1557 int errCode = RuntimeContext::GetInstance()->SetTimer(period, [this, taskId](TimerId timerId) { StartHeartBeatTimer() local
1589 int errCode = RuntimeContext::GetInstance()->ScheduleTask([this, taskId]() { HeartBeat() local
1626 HeartBeatFailed(TaskId taskId, int errCode) HeartBeatFailed() argument
1637 SetTaskFailed(TaskId taskId, int errCode) SetTaskFailed() argument
1669 int errCode = storageProxy_->StartTransaction(TransactType::IMMEDIATE); CleanCloudData() local
1717 CommitDownloadResult(const DownloadItem &downloadItem, InnerProcessInfo &info, DownloadCommitList &commitList, int errCode) CommitDownloadResult() argument
1770 int errCode = storageProxy_->GetInfoByPrimaryKeyOrGid(param.tableName, param.downloadData.data[index], GetLocalInfo() local
1828 SetCurrentTaskFailedWithoutLock(int errCode) SetCurrentTaskFailedWithoutLock() argument
1846 int errCode = CloudLocker::BuildCloudLock([taskId, this]() { LockCloudIfNeed() local
1894 ClearContextAndNotify(TaskId taskId, int errCode) ClearContextAndNotify() argument
[all...] |
| H A D | cloud_syncer_extend.cpp | 80 int errCode = GetCloudGid(taskId, tableName, obj); in FillDownloadExtend() local
105 int errCode = storageProxy_->GetCloudGid(obj, isCloudForcePush, IsCompensatedTask(taskId), cloudGid); in GetCloudGid() local
136 NotifyUploadFailed(int errCode, InnerProcessInfo &info) NotifyUploadFailed() argument
149 int errCode = cloudDB_.BatchInsert(uploadData.tableName, uploadData.insData.record, BatchInsert() local
194 int errCode = cloudDB_.BatchUpdate(uploadData.tableName, uploadData.updData.record, BatchUpdate() local
240 int errCode = storageProxy_->IsSharedTable(info.tableName, isSharedTable); DownloadAssetsOneByOne() local
268 auto &errCode = res.first; GetDBAssets() local
329 IsNeedSkipDownload(bool isSharedTable, int &errCode, const InnerProcessInfo &info, const DownloadItem &downloadItem, VBucket &dbAssets) IsNeedSkipDownload() argument
350 CheckDownloadOrDeleteCode(int &errCode, int downloadCode, int deleteCode, DownloadItem &downloadItem) CheckDownloadOrDeleteCode() argument
368 int errCode = E_OK; DownloadAssetsOneByOneInner() local
435 int errCode = storageProxy_->SetLogTriggerStatus(false); CommitDownloadAssets() local
486 int errCode = storageProxy_->GetCompensatedSyncQuery(syncQuery, users); GenerateCompensatedSync() local
531 int errCode = storageProxy_->GetCloudWaterMark(tableName, cursor); SaveCursorIfNeed() local
558 int errCode = RuntimeContext::GetInstance()->GetLocalIdentity(hashDev); PrepareAndDownload() local
600 int errCode = cloudDB_.BatchDelete(uploadData.tableName, uploadData.delData.record, BatchDelete() local
721 int errCode = PrepareAndDownload(table, taskInfo, isFirstDownload); DoDownloadInNeed() local
767 int errCode = storageProxy_->GetCloudDbSchema(cloudSchema); TryToAddSyncTask() local
987 int errCode = E_OK; DoUploadInner() local
1075 SetCurrentTaskFailedInMachine(int errCode) SetCurrentTaskFailedInMachine() argument
1156 int errCode = storageProxy_->ReviseLocalModTime(tableName, revisedData); DoUploadByMode() local
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/cloud/ |
| H A D | distributeddb_cloud_interfaces_relational_sync_test.cpp | 139 int errCode; in InsertUserTableRecord() local
240 int errCode = g_virtualCloudDb->BatchInsert(g_tableName3, std::move(record1), extend1); in InsertRecordWithoutPk2LocalAndCloud() local
299 int errCode; in UpdateAssetForTest() local
356 int errCode; in UpdateAssetsForTest() local
364 int errCode; in UpdateLocalAssets() local
432 int errCode; CheckDiffTypeAsset() local
483 int errCode; CheckFillAssetForTest10() local
520 int errCode; CheckFillAssetsForTest10() local
906 int errCode; CheckAssetsAfterDownload() local
939 int errCode; CheckAssetAfterDownload() local
979 int errCode; CheckAssetForDownloadAssetTest003() local
1003 int errCode; CheckAssetAfterDownload2() local
2459 int errCode; HWTEST_F() local
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/cj/src/ |
| H A D | distributed_kv_store_impl.cpp | 207 uint64_t CJKVManager::GetKVStore(const char* cStoreId, const CJOptions cjOptions, int32_t& errCode) in GetKVStore() argument
291 CArrStr CJKVManager::GetAllKVStoreId(const char* appId, int32_t& errCode) in GetAllKVStoreId() argument
446 ValueType CJSingleKVStore::Get(const std::string &key, int32_t& errCode) in Get() argument
458 GetEntries(OHOS::sptr<CQuery> query, int32_t& errCode) GetEntries() argument
467 GetEntries(const std::string &keyPrefix, int32_t& errCode) GetEntries() argument
477 GetResultSetByString(const std::string &keyPrefix, int32_t& errCode) GetResultSetByString() argument
491 GetResultSetByQuery(OHOS::sptr<CQuery> query, int32_t& errCode) GetResultSetByQuery() argument
511 GetResultSize(OHOS::sptr<CQuery> query, int32_t& errCode) GetResultSize() argument
565 DeleteBackup(const CArrStr &cArrStr, int32_t& errCode) DeleteBackup() argument
647 int32_t errCode = ConvertCJErrCode(status); OnDataChange() local
661 int32_t errCode = 0; OffDataChange() local
684 int32_t errCode = ConvertCJErrCode(status); OffAllDataChange() local
702 int32_t errCode = ConvertCJErrCode(status); OnSyncComplete() local
714 int32_t errCode = ConvertCJErrCode(status); OffAllSyncComplete() local
721 GetSecurityLevel(int32_t& errCode) GetSecurityLevel() argument
746 Get(const std::string &deviceId, const std::string &key, int32_t& errCode) Get() argument
759 GetEntriesByDataQuery(DistributedKVStore::DataQuery dataQuery, int32_t& errCode) GetEntriesByDataQuery() argument
779 GetEntries(const std::string &deviceId, const std::string &keyPrefix, int32_t& errCode) GetEntries() argument
788 GetEntries(const std::string &deviceId, OHOS::sptr<CQuery> query, int32_t& errCode) GetEntries() argument
796 GetResultSet(const std::string &deviceId, const std::string &keyPrefix, int32_t& errCode) GetResultSet() argument
816 GetResultSetQuery(const std::string &deviceId, OHOS::sptr<CQuery> query, int32_t& errCode) GetResultSetQuery() argument
835 GetResultSize(const std::string &deviceId, OHOS::sptr<CQuery> query, int32_t& errCode) GetResultSize() argument
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/ |
| H A D | sqlite_single_ver_relational_storage_executor.cpp | 126 int errCode = CloudStorageUtils::ConstraintsCheckForCloud(table, trimedSql); in CheckTableConstraint() local
150 int errCode = SQLiteUtils::GetStatement(db, sql, stmt); in GetExistedDataTimeOffset() local
168 int errCode = GetExistedDataTimeOffset(db, tableName, isMemDb_, timeOffset); GeneLogInfoForExistedData() local
216 int errCode = SQLiteUtils::AnalysisSchema(dbHandle_, tableName, table); CreateDistributedTable() local
274 int errCode = SQLiteUtils::AnalysisSchema(dbHandle_, tableName, newTableInfo); UpgradeDistributedTable() local
324 int errCode = SQLiteUtils::GetStatement(handle, checkSql, stmt); GetDeviceTableName() local
377 int errCode = E_OK; UpgradeFields() local
438 int errCode = E_OK; UpgradeIndexes() local
480 int errCode = GetDeviceTableName(dbHandle_, oldTableInfo.GetTableName(), {}, deviceTables); AlterAuxTableForUpgrade() local
508 int errCode = SQLiteUtils::BeginTransaction(dbHandle_, type); StartTransaction() local
529 int errCode = SQLiteUtils::RollbackTransaction(dbHandle_); Rollback() local
546 int errCode = SQLiteUtils::GetColumnBlobValue(logStatement, 1, dev); // 1 means dev index GetLogData() local
653 int errCode = SQLiteUtils::GetStatement(dbHandle_, SELECT_META_VALUE_SQL, statement); GetKvData() local
682 int errCode = SQLiteUtils::GetStatement(dbHandle_, INSERT_META_SQL, statement); PutKvData() local
712 int errCode = SQLiteUtils::GetStatement(dbHandle_, REMOVE_META_VALUE_SQL, statement); DeleteMetaData() local
739 int errCode = SQLiteUtils::GetStatement(dbHandle_, REMOVE_META_VALUE_BY_KEY_PREFIX_SQL, statement); DeleteMetaDataByPrefixKey() local
759 int errCode = SQLiteUtils::GetStatement(dbHandle_, SELECT_ALL_META_KEYS, statement); GetAllMetaKeys() local
775 int errCode = SQLiteUtils::BindBlobToStatement(queryStmt, 1, dataItem.hashKey); // 1 means hashkey index. GetLogInfoPre() local
799 int errCode = GetLogInfoPre(queryStmt, dataItem, logInfoGet); SaveSyncLog() local
835 int errCode = inserter.GetDeleteSyncDataStmt(dbHandle_, stmt); DeleteSyncDataItem() local
842 int errCode = SQLiteUtils::BindBlobToStatement(stmt, 1, dataItem.hashKey); // 1 means hash_key index DeleteSyncDataItem() local
873 int errCode = DeleteSyncDataItem(dataItem, inserter, saveStmt.rmDataStmt); SaveSyncDataItem() local
880 int errCode = inserter.BindInsertStatement(saveStmt.saveDataStmt, dataItem); SaveSyncDataItem() local
897 int errCode = inserter.GetDeleteLogStmt(dbHandle_, stmt); DeleteSyncLog() local
904 int errCode = SQLiteUtils::BindBlobToStatement(stmt, 1, dataItem.hashKey); // 1 means hashkey index DeleteSyncLog() local
927 int errCode = DeleteSyncDataItem(item, inserter, rmDataStmt); ProcessMissQueryData() local
938 int errCode = GetLogInfoPre(queryStmt, dataItem, logInfoGet); GetSyncDataPre() local
954 int errCode = GetSyncDataPre(dataItem, queryStmt, itemGet); CheckDataConflictDefeated() local
967 int errCode = CheckDataConflictDefeated(item, saveStmt.queryStmt, isDefeated); SaveSyncDataItem() local
991 int errCode = inserter.PrepareStatement(dbHandle_, saveStmt); SaveSyncDataItems() local
1017 int errCode = StartTransaction(TransactType::IMMEDIATE); SaveSyncItems() local
1023 int errCode = SetLogTriggerStatus(false); SaveSyncItems() local
1050 int errCode = GetLogData(stmt, data.logInfo); GetDataItemForSync() local
1078 int errCode = GetDataItemForSync(fullStmt, item, false); GetMissQueryData() local
1093 int errCode = SQLiteUtils::StepWithRetry(stmt, isMemDB); StepNext() local
1127 int errCode = GetDataItemForSync(queryStmt, item, isGettingDeletedData); GetQueryDataAndStepNext() local
1138 int errCode = GetMissQueryData(fullStmt, item); GetMissQueryDataAndStepNext() local
1154 int errCode = getStmt(dbHandle_, queryStmt, fullStmt, isGettingDeletedData); GetSyncDataByQuery() local
1203 int errCode = SQLiteUtils::GetJournalMode(dbHandle_, journalMode); CheckDBModeForRelational() local
1220 int errCode = GetDeviceTableName(dbHandle_, tableName, device, deviceTables); DeleteDistributedDeviceTable() local
1251 int errCode = SQLiteUtils::GetStatement(dbHandle_, deleteLogSql, deleteLogStmt); DeleteDistributedDeviceTableLog() local
1282 int errCode = SQLiteUtils::ExecuteRawSQL(dbHandle_, deleteSql); DeleteDistributedLogTable() local
1301 int errCode = GetKvData(key, value); IsTableOnceDropped() local
1320 int errCode = DeleteDistributedDeviceTable({}, tableName); // Clean the auxiliary tables for the dropped table CleanResourceForDroppedTable() local
1346 int errCode = SQLiteUtils::GetStatement(dbHandle_, checkSql, stmt); CheckAndCleanDistributedTable() local
1390 int errCode = SQLiteUtils::CreateSameStuTable(dbHandle_, baseTbl, deviceTableName); CreateDistributedDeviceTable() local
1411 int errCode = SQLiteUtils::AnalysisSchema(dbHandle_, table.GetTableName(), newTable); CheckQueryObjectLegal() local
1454 int errCode = SQLiteUtils::AnalysisSchema(dbHandle_, query.GetTableName(), newTable); CheckQueryObjectLegal() local
1468 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, stmt); GetMaxTimestamp() local
1492 int errCode = SQLiteUtils::ExecuteRawSQL(dbHandle_, sql); SetLogTriggerStatus() local
1505 int errCode = SQLiteUtils::StepWithRetry(stmt, isMemDb); GetRowDatas() local
1547 int errCode = SQLiteUtils::SetAuthorizer(dbHandle_, &PermitSelect); ExecuteQueryBySqlStmt() local
1577 int errCode = SQLiteUtils::ExecuteRawSQL(dbHandle_, "SELECT count(*) FROM sqlite_master;"); CheckEncryptedOrCorrupted() local
1595 int errCode = E_OK; GetSyncCloudGid() local
1637 int errCode = CloudStorageUtils::GetValueFromVBucket(CloudDbConstant::FLAG, extraLog, flag); GetCloudDataForSync() local
1682 int errCode = SQLiteUtils::ExecuteRawSQL(dbHandle_, cleanLogSql); CleanCloudDataOnLogTable() local
1718 int errCode = SQLiteUtils::ExecuteRawSQL(dbHandle_, sql); CleanCloudDataAndLogOnUserTable() local
1747 int errCode = SQLiteUtils::ExecuteRawSQL(dbHandle_, cleanLogSql); ChangeCloudDataFlagOnLogTable() local
1761 int errCode = CreateFuncUpdateCursor(context, &UpdateCursor); SetDataOnUserTableWithLogicDelete() local
1803 int errCode = CreateFuncUpdateCursor(context, &UpdateCursor); SetDataOnShareTableWithLogicDelete() local
1846 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, selectStmt); GetCleanCloudDataKeys() local
1902 int errCode = AppendUpdateLogRecordWhereSqlCondition(tableSchema, vBucket, updateLogSql); GetUpdateLogRecordStatement() local
[all...] |
| H A D | sqlite_single_ver_relational_storage_extend_executor.cpp | 42 int errCode = CloudStorageUtils::GetValueFromVBucket(CloudDbConstant::GID_FIELD, vBucket, gid); in GetQueryInfoSql() local
80 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, stmt); in GetFillDownloadAssetStatement() local
100 int errCode = CloudStorageUtils::GetValueFromVBucket(CloudDbConstant::GID_FIELD, vBucket, cloudGid); FillCloudAssetForDownload() local
154 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, statement); IncreaseCursorOnAssetData() local
194 int errCode = E_OK; FillCloudAssetForUpload() local
258 int errCode = E_OK; BindUpdateVersionStatement() local
292 int errCode; InitFillUploadAssetStatement() local
334 int errCode = AnalysisTrackerTable(trackerTable, table); CreateTrackerTable() local
389 int errCode = GetKvData(schemaKey, schemaVal); // save schema to meta_data GetOrInitTrackerSchemaFromMeta() local
408 int errCode = SQLiteUtils::GetStatement(dbHandle_, condition.sql, statement); ExecuteSql() local
451 int errCode = SQLiteUtils::CheckTableExists(dbHandle_, logTableName, isExists); GetClearWaterMarkTables() local
495 int errCode = SetLogTriggerStatus(false); UpgradedLogForExistedData() local
514 int errCode = E_OK; CreateTempSyncTrigger() local
556 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, stmt); ClearAllTempSyncTrigger() local
586 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, statement); CleanTrackerData() local
641 int errCode = SQLiteUtils::ExecuteRawSQL(dbHandle_, createTableSql); CreateSharedTable() local
652 int errCode = SQLiteUtils::ExecuteRawSQL(dbHandle_, deleteTableSql); DeleteTable() local
664 int errCode = E_OK; UpdateSharedTable() local
699 int errCode = SQLiteUtils::ExecuteRawSQL(dbHandle_, alterTableSql); AlterTableName() local
712 int errCode = CloudStorageUtils::GetValueFromVBucket(CloudDbConstant::GID_FIELD, vBucket, gidStr); AppendUpdateLogRecordWhereSqlCondition() local
734 int errCode = E_OK; DoCleanShareTableDataAndLog() local
754 int errCode = E_OK; CleanShareTable() local
793 int errCode = E_OK; GetReferenceGid() local
819 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, statement); GetReferenceGidInner() local
876 int errCode = E_OK; GetReferenceGidByStmt() local
941 int errCode = E_OK; BindStmtWithCloudGid() local
987 int errCode = SQLiteUtils::ExecuteRawSQL(dbHandle_, sql); CleanExtendAndCursorForDeleteData() local
998 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, statement); CheckIfExistUserTable() local
1033 int errCode = SetCursor(table, cursor + 1); GetCloudDeleteSql() local
1045 int errCode = E_OK; RemoveDataAndLog() local
1075 int errCode = SQLiteUtils::BindTextToStatement(stmt, 1, gid); // 1 means the gid index BindStmtWithCloudGidInner() local
1106 int errCode = GetCleanCloudDataKeys(logTableName, dataKeys, false); DoCleanAssetId() local
1122 int errCode = E_OK; CleanAssetId() local
1153 int errCode = E_OK; UpdateAssetIdOnUserTable() local
1198 int errCode = E_OK; GetAssetsAndUpdateAssetsId() local
1247 int errCode = SQLiteUtils::GetStatement(dbHandle_, cleanAssetIdSql, stmt); CleanAssetsIdOnUserTable() local
1323 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, stmt); InitGetAssetStmt() local
1348 int errCode = E_OK; FillHandleWithOpType() local
1399 int errCode = SQLiteUtils::StepWithRetry(selectStmt); GetAssetsByRowId() local
1428 int errCode = SQLiteUtils::BindTextToStatement(stmt, beginIndex, cloudGid); ExecuteFillDownloadAssetStatement() local
1475 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, statement); GetAndBindFillUploadAssetStatement() local
1506 int errCode = UpdateAssetId(tableSchema, dataKey, vBucket); OnlyUpdateAssetId() local
1537 int errCode = RuntimeContext::GetInstance()->AssetToBlob(asset, blobValue); BindAssetToBlobStatement() local
1553 int errCode = RuntimeContext::GetInstance()->AssetsToBlob(assets, blobValue); BindAssetsToBlobStatement() local
1575 int errCode = BindAssetToBlobStatement(assetOfOneRecord[assetIndex], assetIndex + assetsIndex + 1, stmt); BindAssetFiledToBlobStatement() local
1585 int errCode = BindAssetsToBlobStatement(assetsOfOneRecord[assetsIndex], assetIndex + assetsIndex + 1, stmt); BindAssetFiledToBlobStatement() local
1599 int errCode = E_OK; UpdateAssetsIdForOneRecord() local
1626 int errCode = E_OK; UpdateAssetId() local
1739 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, stmt); UpdateRecordFlag() local
1779 int errCode = SQLiteUtils::GetStatement(dbHandle_, CloudStorageUtils::GetUpdateUploadFinishedSql(tableName), MarkFlagAsUploadFinished() local
1822 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, stmt); GetWaitCompensatedSyncDataPk() local
1856 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, stmt); ClearUnLockingStatus() local
1875 int errCode = E_OK; GetRecordFromStmt() local
1894 int errCode = E_OK; BindShareValueToInsertLogStatement() local
[all...] |
| H A D | sqlite_single_ver_relational_storage_executor_extend.cpp | 40 int errCode = GetQueryInfoSql(tableSchema.name, vBucket, pkSet, assetFields, querySql); in GetInfoByPrimaryKeyOrGid() local
115 int errCode = E_OK; GetInfoByStatement() local
166 int errCode = E_OK; GetPrimaryKeyHashValue() local
190 int errCode = SQLiteUtils::GetStatement(dbHandle_, querySql, selectStmt); GetQueryLogStatement() local
229 int errCode = CloudStorageUtils::GetValueFromVBucket(CloudDbConstant::GID_FIELD, vBucket, cloudGid); GetQueryLogSql() local
255 int errCode = E_OK; ExecutePutCloudData() local
298 int errCode = SetLogTriggerStatus(false); DoCleanInner() local
336 int errCode = E_OK; DoCleanLogs() local
376 int errCode = sqlite3_create_function_v2(dbHandle_, sql.c_str(), 0, SQLITE_UTF8 | SQLITE_DIRECTONLY, CreateFuncUpdateCursor() local
390 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, stmt); GetCursor() local
420 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, stmt); SetCursor() local
455 int errCode = E_OK; DoCleanLogAndData() local
489 int errCode = E_OK; GetAssetOnTable() local
535 int errCode = E_OK; GetCloudAssetsOnTable() local
575 int errCode = E_OK; GetCloudAssets() local
604 int errCode = SQLiteUtils::ExecuteRawSQL(dbHandle_, sql); SetCursorIncFlag() local
620 int errCode = SetLogTriggerStatus(false); PutCloudSyncData() local
646 int errCode = E_OK; InsertCloudData() local
688 int errCode = CloudStorageUtils::GetValueFromVBucket(CloudDbConstant::GID_FIELD, vBucket, gidStr); InsertLogRecord() local
707 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, insertLogStmt); InsertLogRecord() local
744 int errCode = E_OK; BindValueToUpsertStatement() local
759 int errCode = SQLiteUtils::BindBlobToStatement(insertLogStmt, 12, hashKey); // 12 is hash_key BindStatusSubQueryHashKeyStatement() local
777 int errCode = GetPrimaryKeyHashValue(vBucket, tableSchema, hashKey); BindHashKeyAndGidToInsertLogStatement() local
824 int errCode = SQLiteUtils::BindInt64ToStatement(insertLogStmt, 1, rowid); BindValueToInsertLogStatement() local
928 int errCode = CloudStorageUtils::GetValueFromVBucket(CloudDbConstant::GID_FIELD, vBucket, gidStr); GetUpdateDataTableStatement() local
971 int errCode = GetUpdateDataTableStatement(vBucket, tableSchema, updateStmt); UpdateCloudData() local
1007 int errCode = GetUpdateLogRecordStatement(tableSchema, vBucket, opType, updateColName, updateLogStmt); UpdateLogRecord() local
1036 int errCode = CloudStorageUtils::BindUpdateLogStmtFromVBucket(vBucket, tableSchema, colNames, updateLogStmt); BindValueToUpdateLogStatement() local
1057 int errCode = CloudStorageUtils::GetValueFromVBucket(CloudDbConstant::GID_FIELD, vBucket, gidStr); GetDeleteStatementForCloudSync() local
1096 int errCode = GetDeleteStatementForCloudSync(tableSchema, pkSet, vBucket, deleteStmt); DeleteCloudData() local
1136 int errCode = SQLiteUtils::ExecuteRawSQL(dbHandle_, deleteSql); DeleteTableTrigger() local
1155 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, stmt); UpdateRecordStatus() local
1187 int errCode = SQLiteUtils::ExecuteRawSQL(dbHandle_, CloudStorageUtils::GetCursorIncSql(tableName)); LogicDeleteCloudData() local
1206 int errCode = GetKvData(key, cursor); InitCursorToMeta() local
1232 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, stmt); ReviseLocalModTime() local
1336 int errCode = SQLiteUtils::GetStatement(dbHandle_, queryAssetsSql, selectStmt); IsNeedUpdateAssetId() local
1372 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, stmt); MarkFlagAsConsistent() local
1407 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, stmt); FillCloudVersionForUpload() local
1432 int errCode = SQLiteRelationalUtils::QueryCount(dbHandle_, tableName, dataCount); CheckInventoryData() local
1444 int errCode = helper.GetCloudQueryStatement(false, dbHandle_, sql, stmt); GetUploadCountInner() local
1463 int errCode; GetUploadCount() local
1480 int errCode; GetAllUploadCount() local
1509 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, stmt); UpdateCloudLogGid() local
1525 int errCode = token.GetCloudStatement(dbHandle_, cloudDataResult, queryStmt, isStepNext); GetSyncCloudData() local
1553 int errCode = RuntimeContext::GetInstance()->BlobToAsset(std::get<Bytes>(cloudValue), asset); PutVBucketByType() local
1563 int errCode = RuntimeContext::GetInstance()->BlobToAssets(std::get<Bytes>(cloudValue), assets); PutVBucketByType() local
1580 int errCode = SQLiteUtils::StepWithRetry(stmt); GetAssetInfoOnTable() local
[all...] |
| H A D | sqlite_relational_store.cpp | 49 RelationalStoreConnection *SQLiteRelationalStore::GetDBConnection(int &errCode) in GetDBConnection() argument
80 int errCode = sqliteStorageEngine_->InitSQLiteStorageEngine(poolSize, option, identifier); in InitStorageEngine() local
103 int errCode = E_OK; in CheckDBMode() local
122 int errCode = storageEngine_->GetMetaData(schemaKey, schemaVal); GetSchemaFromMeta() local
147 int errCode = storageEngine_->GetMetaData(modeKey, modeVal); CheckTableModeFromMeta() local
171 int errCode = GetSchemaFromMeta(schema); CheckProperties() local
211 int errCode = storageEngine_->PutMetaData(modeKey, modeVal); SaveTableModeToMeta() local
223 int errCode = storageEngine_->GetMetaData(logVersionKey, logVersion); SaveLogTableVersionToMeta() local
245 int errCode = sqliteStorageEngine_->CleanDistributedDeviceTable(missingTables); CleanDistributedDeviceTable() local
269 int errCode = InitSQLiteStorageEngine(properties); Open() local
447 int errCode = syncAbleEngine_->GetLocalIdentity(localIdentity); CreateDistributedTable() local
455 int errCode = sqliteStorageEngine_->CreateDistributedTable(tableName, DBCommon::TransferStringToHex(localIdentity), CreateDistributedTable() local
504 int errCode = cloudSyncer_->CleanCloudData(mode, cloudTableNameList, localSchema); CleanCloudData() local
526 int errCode = EraseAllDeviceWatermark(tableNameList); RemoveDeviceData() local
585 int errCode = syncAbleEngine_->GetHashDeviceId(device, hashDeviceId); RemoveDeviceData() local
642 int errCode = runtimeCxt->SetTimer( StartLifeCycleTimer() local
681 int errCode; RegisterLifeCycleCallback() local
709 int errCode = ResetLifeCycleTimer(); HeartBeat() local
722 int errCode = StopLifeCycleTimer(); ResetLifeCycleTimer() local
788 int errCode = E_OK; RemoteQuery() local
805 int errCode = GetExistDevices(devices); EraseAllDeviceWatermark() local
834 int errCode = E_OK; GetHandleAndStartTransaction() local
867 int errCode = syncAbleEngine_->EraseDeviceWaterMark(hashDev, false, tableName); RemoveDeviceDataInner() local
908 int errCode = E_OK; GetExistDevices() local
1051 int errCode = CheckCloudSchema(schema); PrepareAndSetCloudDbSchema() local
1089 int errCode = CheckBeforeSync(option); Sync() local
1124 int errCode = CheckQueryValid(option); CheckBeforeSync() local
1145 int errCode = syncObject.GetValidStatus(); CheckQueryValid() local
1183 int errCode = storageEngine_->CheckQueryValid(item); CheckObjectValid() local
1214 int errCode = ChkSchema(table); CheckTableName() local
1262 int errCode = sqliteStorageEngine_->CheckAndCacheTrackerSchema(trackerSchema, tableInfo, isFirstCreate); SetTrackerTable() local
1285 int errCode = E_OK; CleanWaterMark() local
1315 int errCode = GetHandleAndStartTransaction(handle); SetReference() local
1356 int errCode = sqliteStorageEngine_->GetOrInitTrackerSchemaFromMeta(); InitTrackerSchemaFromMeta() local
1383 int errCode = sqliteStorageEngine_->UpgradeSharedTable(schema, deleteTableNames, updateTableNames, alterTableNames); ExecuteCreateSharedTable() local
1437 int errCode = CheckParamForUpsertData(status, tableName, records); UpsertData() local
1482 int errCode = ChkTable(table); CheckSchemaForUpsertData() local
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/common/ |
| H A D | distributeddb_tools_unit_test.cpp | 99 int errCode = DBCommon::CreateStoreDirectory(dbInfo.dir, identifierName, DBConstant::SINGLE_SUB_DIR, true); in CreateMockSingleDb() local
135 int errCode = SQLiteUtils::SetUserVer(properties, dbInfo.dbUserVersion); CreatMockMultiDb() local
164 int errCode = CreatMockMultiDb(properties, dbInfo); OpenMockMultiDb() local
194 int errCode = DBCommon::CreateStoreDirectory(dbInfo.dir, identifierName, DBConstant::MULTI_SUB_DIR, true); CreateMockMultiDb() local
213 int errCode = GetCurrentDir(dir); GetResourceDir() local
580 int errCode = store->GetSyncData(syncInputArg.begin_, syncInputArg.end_, entries, GetSyncDataTest() local
592 int errCode = store->GetSyncDataNext(entries, continueStmtToken, syncDataSizeInfo); GetSyncDataNextTest() local
621 int errCode = store->PutSyncDataWithQuery(query, entries, deviceName); PutSyncDataTest() local
1133 int errCode = sqlite3_exec(db, sql.c_str(), nullptr, nullptr, &errMsg); ExecSql() local
1150 int errCode = SQLiteUtils::GetStatement(db, sql, stmt); ExecSql() local
1204 int errCode = SQLiteUtils::GetStatement(db, sql, stmt); CheckSqlResult() local
1231 int errCode = SQLiteUtils::GetStatement(db, sql, stmt); CheckTableRecords() local
1253 int errCode = SQLiteUtils::GetStatement(db, sql, stmt); GetMetaData() local
1279 int errCode = SQLiteUtils::GetStatement(db, sql, stmt); SetMetaData() local
1335 int errCode = E_OK; SelectData() local
1491 int errCode = E_OK; DeleteRecord() local
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/interfaces/ |
| H A D | distributeddb_interfaces_nb_delegate_test.cpp | 137 void CheckResultSetValue(KvStoreResultSet *readResultSet, DBStatus errCode, int position) in CheckResultSetValue() argument
1896 int errCode = g_kvNbDelegatePtr->GetEntries(query, entriesRes); in HWTEST_F() local
2542 int errCode in HWTEST_F() local
2954 int errCode = RuntimeContext::GetInstance()->SetTimer(1, [&triggerTimer, &triggerCv, &triggerMutex](TimerId id) { HWTEST_F() local
3022 int errCode; HWTEST_F() local
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/cloud/ |
| H A D | cloud_storage_utils.cpp | 30 int errCode = GetValueFromVBucket<int64_t>(field.colName, vBucket, val); in BindInt64() local
51 int errCode in BindBool() local
72 int errCode = GetValueFromVBucket<double>(field.colName, vBucket, val); BindDouble() local
93 int errCode = GetValueFromVBucket<std::string>(field.colName, vBucket, str); BindText() local
113 int errCode = E_OK; BindBlob() local
152 int errCode; BindAsset() local
269 int errCode = RuntimeContext::GetInstance()->AssetToBlob(val, value); BlobToVector() local
279 int errCode = RuntimeContext::GetInstance()->AssetsToBlob(val, value); BlobToVector() local
426 int errCode = GetValueFromType(value, assetVal); GetAssetFromAssets() local
598 int errCode = fillAsset(cacheItem, dbItem, opType); FillAssetFromVBucketFinish() local
660 int errCode = it->second(vBucket, field, collateType, value); CalculateHashKeyForOneField() local
862 ChkFillCloudAssetParam(const CloudSyncBatch &data, int errCode) ChkFillCloudAssetParam() argument
994 int errCode = E_OK; GetHashValueWithPrimaryKeyMap() local
1081 int errCode = E_OK; BindUpdateLogStmtFromVBucket() local
1210 int errCode = CloudStorageUtils::GetValueFromVBucket(CloudDbConstant::GID_FIELD, data, gidStr); BindStepConsistentFlagStmt() local
1393 int errCode = GetValueFromVBucket(field, data, blobStr); GetBytesFromCloudData() local
1404 int errCode = GetValueFromVBucket(field, data, str); GetStringFromCloudData() local
1415 int errCode = GetValueFromVBucket(field, data, intNum); GetUInt64FromCloudData() local
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/ |
| H A D | sqlite_single_ver_storage_executor.cpp | 37 int errCode = E_OK; in ResetOrRegetStmt() local
54 int errCode in GetEntryFromStatement() local
126 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, statement); GetKvData() local
161 int errCode = SQLiteUtils::BindBlobToStatement(statement, BIND_KV_KEY_INDEX, key, false); BindPutKvData() local
200 int errCode = SQLiteUtils::GetStatement(dbHandle_, SELECT_SYNC_HASH_SQL, statement); GetKvDataByHashKey() local
259 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, statement); SaveKvData() local
299 int errCode = SaveKvData(type, key, value, timestamp); PutKvData() local
325 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, statement); GetEntries() local
345 int errCode = E_OK; GetEntries() local
367 int errCode = E_OK; GetCount() local
421 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, statement); InitCurrentMaxStamp() local
441 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, statement); PrepareForSyncDataByTime() local
466 int errCode = E_OK; ReleaseContinueStatement() local
482 int errCode = SQLiteUtils::GetColumnBlobValue(statement, SYNC_RES_ORI_DEV_INDEX, devVect); GetDataItemForSync() local
503 int errCode; GetSyncDataItems() local
541 int errCode = PrepareForSyncDataByTime(begin, end, statement); GetSyncDataByTimestamp() local
555 int errCode = PrepareForSyncDataByTime(begin, end, statement, true); GetDeletedSyncDataByTimestamp() local
581 int errCode = SQLiteUtils::GetStatement(db, SELECT_SYNC_MODIFY_SQL, stmt); GetFullDataStatement() local
605 int errCode = E_OK; GetQueryDataStatement() local
615 int errCode = SQLiteUtils::StepWithRetry(stmt, isMemDB); GetNextDataItem() local
629 int errCode = GetQueryDataStatement(dbHandle_, query, timeRange, queryStmt); GetSyncDataWithQuery() local
657 int errCode = E_OK; GetSyncDataWithQuery() local
709 int errCode = StartTransaction(TransactType::DEFERRED); OpenResultSet() local
742 int errCode = InitResultSet(queryObj, countStatement); OpenResultSet() local
797 int errCode = SQLiteUtils::GetStatement(dbHandle_, SELECT_SYNC_ROWID_PREFIX_SQL, getResultRowIdStatement_); OpenResultSetForCacheRowIdMode() local
822 int errCode = E_OK; OpenResultSetForCacheRowIdMode() local
849 int errCode = ResetOrRegetStmt(dbHandle_, getResultRowIdStatement_, SELECT_SYNC_ROWID_PREFIX_SQL); ReloadResultSet() local
865 int errCode = E_OK; ReloadResultSet() local
899 int errCode = ReloadResultSet(keyPrefix); // Reuse this function(A convenience) ReloadResultSetForCacheRowIdMode() local
915 int errCode = ReloadResultSet(queryObj); // Reuse this function(A convenience) ReloadResultSetForCacheRowIdMode() local
934 int errCode = SQLiteUtils::StepWithRetry(getResultRowIdStatement_, isMemDb_); GetNextEntryFromResultSet() local
978 int errCode = E_OK; GetEntryByRowId() local
1006 int errCode = E_OK; CloseResultSet() local
1027 int errCode = SQLiteUtils::BeginTransaction(dbHandle_, type); StartTransaction() local
1041 int errCode = SQLiteUtils::CommitTransaction(dbHandle_); Commit() local
1054 int errCode = SQLiteUtils::RollbackTransaction(dbHandle_); Rollback() local
1071 int errCode = GetKvData(SingleVerDataType::LOCAL_TYPE_SQLITE, key, value, timestamp); CheckIfKeyExisted() local
1089 int errCode = SQLiteUtils::GetStatement(dbHandle_, SELECT_ENTRY_DEVICE, statement); GetDeviceIdentifier() local
1122 int errCode; PutIntoCommittedData() local
1142 int errCode = SQLiteUtils::GetStatement(dbHandle_, readSql, statements.queryStatement); PrepareForSavingData() local
1167 int errCode = -E_NOT_SUPPORT; PrepareForSavingData() local
1179 int errCode = E_OK; ResetForSavingData() local
1214 int errCode = BindSavedSyncData(statement, dataItem, hashKey, {origDev, devName}, isUpdate); SaveSyncDataToDatabase() local
1266 int errCode = SQLiteUtils::GetColumnBlobValue(statement, SYNC_RES_KEY_INDEX, itemGet.key); GetSyncDataItemExt() local
1279 ResetSaveSyncStatements(int errCode) ResetSaveSyncStatements() argument
1301 int errCode = GetSyncDataItemPre(dataItem, notify.getData, notify.hashKey); PrepareForNotifyConflictAndObserver() local
1360 int errCode = PrepareForNotifyConflictAndObserver(dataItem, deviceInfo, notify, isPermitForceWrite); SaveSyncDataItem() local
1390 int errCode = SQLiteUtils::GetStatement(dbHandle_, sqlStr, statement); GetAllMetaKeys() local
1404 int errCode = E_OK; GetAllSyncedEntries() local
1443 int errCode; GetAllEntries() local
1474 int errCode = SQLiteUtils::BindBlobToStatement(statement, hashKeyIndex, hashKey, false); BindSavedSyncData() local
1552 int errCode = ResetForSavingData(SingleVerDataType::SYNC_TYPE); Reset() local
1573 int errCode = DBCommon::CalcValueHash(itemPut.key, hashKey); GetSyncDataItemPre() local
1585 int errCode = SQLiteUtils::BindBlobToStatement(statement, 1, hashKey, false); // 1st arg. GetSyncDataPreByHashKey() local
1635 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, statement); DeleteLocalDataInner() local
1667 int errCode = GetKvData(SingleVerDataType::LOCAL_TYPE_SQLITE, key, value, timestamp); DeleteLocalKvData() local
1680 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, stmt); EraseSyncData() local
1705 int errCode = E_OK; RemoveDeviceData() local
1728 int errCode = E_OK; StepForResultEntries() local
1756 int errCode = SQLiteUtils::BindInt64ToStatement(statement, BIND_SYNC_FLAG_INDEX, BindDevForSavedSyncData() local
1796 int errCode = SQLiteUtils::GetStatement(dbHandle_, SELECT_COUNT_SYNC_PREFIX_SQL, countStmt); InitResultSet() local
1840 int errCode = E_OK; InitResultSetCount() local
1856 int errCode = E_OK; InitResultSetContent() local
1883 int errCode = E_OK; InitResultSet() local
1909 int errCode = SQLiteUtils::ExecuteRawSQL(dbHandle_, sql); UpdateLocalDataTimestamp() local
1921 int errCode = SQLiteUtils::GetColumnBlobValue(statement, SYNC_RES_KEY_INDEX, dataItem.key); GetOneRawDataItem() local
1968 int errCode; GetAllDataItems() local
1992 int errCode = SQLiteUtils::GetStatement(dbHandle_, SELECT_SYNC_DATA_BY_ROWID_SQL, getResultEntryStatement_); OpenResultSetForCacheRowIdModeCommon() local
2019 int errCode = SQLiteUtils::StepWithRetry(getResultRowIdStatement_, isMemDb_); ResultSetLoadRowIdCache() local
2042 int errCode = E_OK; ResetStatement() local
2062 int errCode = saveLocalStatements_.ResetStatement(); FinalizeAllStatements() local
2148 int errCode = CreateFuncUpdateKey(context, &Translate, &CalHashKey); UpdateKey() local
2171 int errCode = sqlite3_create_function_v2(dbHandle_, FUNC_NAME_TRANSLATE_KEY, 1, SQLITE_UTF8 | SQLITE_DETERMINISTIC, CreateFuncUpdateKey() local
2248 int errCode = SQLiteUtils::BindInt64ToStatement(statement, BIND_SYNC_STAMP_INDEX, dataItem.timestamp); BindSyncDataTime() local
[all...] |
| H A D | sqlite_single_ver_natural_store.cpp | 52 void ProcessContinueToken(const DeviceID &deviceID, const std::vector<DataItem> &dataItems, int &errCode, in ProcessContinueToken() argument
78 void ProcessContinueToken(const std::vector<DataItem> &dataItems, int &errCode, in ProcessContinueToken() argument
87 void ProcessContinueTokenForQuerySync(const std::vector<DataItem> &dataItems, int &errCode, in ProcessContinueTokenForQuerySync() argument
137 int errCode = E_OK; in GetKvEntriesByDataItems() local
196 int errCode = SQLiteUtils::SetUserVer(properties, version); SetUserVer() local
205 int errCode = InitStorageEngine(kvDBProp, isNeedUpdateSecOpt); InitDatabaseContext() local
215 int errCode; RegisterLifeCycleCallback() local
251 int errCode = runtimeCxt->ModifyTimer(lifeTimerId_, time); SetAutoLifeCycleTime() local
279 OriValueCanBeUse(int errCode) OriValueCanBeUse() argument
284 AmendValueShouldBeUse(int errCode) AmendValueShouldBeUse() argument
289 IsValueMismatched(int errCode) IsValueMismatched() argument
311 int errCode = valueObj.Parse(oriValue.data(), oriValue.data() + oriValue.size(), schemaObjRef.GetSkipSize()); CheckValueAndAmendIfNeed() local
335 int errCode = schemaObjRef.VerifyValue(sourceType, oriValue); CheckValueAndAmendIfNeed() local
352 int errCode = operation->RekeyRecover(kvDBProp); CheckDatabaseRecovery() local
385 int errCode = E_OK; GetAndInitStorageEngine() local
414 int errCode = CheckDatabaseRecovery(kvDBProp); Open() local
476 NewConnection(int &errCode) NewConnection() argument
535 int errCode = E_OK; GetMetaData() local
555 int errCode = SQLiteSingleVerNaturalStore::CheckDataStatus(key, value, false); PutMetaData() local
583 int errCode = E_OK; DeleteMetaData() local
608 int errCode = E_OK; GetAllMetaKeys() local
622 int errCode = CheckReadDataControlled(); GetSyncData() local
667 int errCode = E_OK; GetSyncData() local
696 int errCode = CheckReadDataControlled(); GetSyncData() local
735 int errCode = E_OK; GetSyncDataForQuerySync() local
788 int errCode = CheckReadDataControlled(); GetSyncDataNext() local
829 int errCode = E_OK; GetSyncDataNext() local
855 int errCode = E_OK; GetUnSyncTotal() local
872 int errCode = CheckReadDataControlled(); GetUnSyncTotal() local
942 int errCode = SaveSyncDataItems(query, dataItems, deviceInfo, true); // Current is true to check value content PutSyncDataWithQuery() local
955 int errCode = E_OK; GetMaxTimestamp() local
977 int errCode = E_OK; GetExistsDeviceList() local
1001 int errCode = GetHashDeviceId(deviceName, hashDeviceId); RemoveDeviceData() local
1035 int errCode = E_OK; RemoveDeviceDataInCacheMode() local
1053 int errCode = E_OK; RemoveDeviceDataNormally() local
1117 GetHandle(bool isWrite, int &errCode, OperatePerm perm) const GetHandle() argument
1170 int errCode = RegisterNotificationEventType(*event); RegisterNotification() local
1246 int errCode = E_OK; SaveSyncDataItems() local
1286 int errCode = SaveSyncItems(query, dataItems, deviceInfo, maxTimestamp, committedData); SaveSyncDataToMain() local
1301 int errCode = E_OK; SaveSyncItems() local
1353 int errCode = E_OK; SaveSyncDataToCacheDB() local
1376 int errCode = GetMetaData(key, timeOffset); GetTimestampFromDB() local
1431 int errCode = storageEngine_->InitSQLiteStorageEngine(poolSize, option, identifier); InitStorageEngine() local
1458 int errCode = storageEngine_->TryToDisable(false, OperatePerm::REKEY_MONOPOLIZE_PERM); Rekey() local
1511 int errCode = E_OK; Export() local
1551 int errCode = GetLocalIdentity(localDev); Import() local
1632 int errCode = remoteSchema.ParseFromSchemaString(schema); CheckCompatible() local
1725 int errCode = E_OK; GetSchema() local
1757 int errCode = GetSchema(savedSchemaObj); DecideReadOnlyBaseOnSchema() local
1776 int errCode = E_OK; InitialLocalDataTimestamp() local
1804 int errCode = -E_NOT_FOUND; GetKvDBSize() local
1839 int errCode = handle->StartTransaction(TransactType::IMMEDIATE); SaveSyncItemsInCacheMode() local
1889 int errCode = GetMetaData(key, value); GetDatabaseCreateTimestamp() local
1919 int errCode = PutMetaData(key, value, false); SaveCreateDBTime() local
1933 int errCode = E_OK; RemoveSubscribe() local
1970 int errCode = E_OK; RemoveAllSubscribe() local
2013 int errCode = GetLocalIdentity(outTarget); GetAndResizeLocalIdentity() local
[all...] |
| H A D | sqlite_single_ver_natural_store_connection.cpp | 95 int errCode = CheckReadDataControlled(); in Get() local
148 int errCode = CheckReadDataControlled(); GetEntries() local
193 int errCode = CheckReadDataControlled(); GetCount() local
280 int errCode = StartTransactionInner(); StartTransaction() local
295 int errCode = CommitInner(); Commit() local
310 int errCode = RollbackInner(); RollBack() local
324 int errCode = E_OK; Pragma() local
372 int errCode = E_OK; TranslateObserverModeToEventTypes() local
457 int errCode = E_OK; SetConflictNotifier() local
485 int errCode = CheckMonoStatus(OperatePerm::REKEY_MONOPOLIZE_PERM); Rekey() local
520 int errCode = CheckMonoStatus(OperatePerm::IMPORT_MONOPOLIZE_PERM); Import() local
550 int errCode = CheckReadDataControlled(); GetResultSet() local
594 int errCode = CheckReadDataControlled(); GetResultSet() local
667 int errCode = RollbackInner(); PreClose() local
686 int errCode = E_OK; CheckIntegrity() local
716 int errCode = E_OK; ForceCheckPoint() local
734 int errCode = DisableManualSync(); CheckMonoStatus() local
792 int errCode = E_OK; GetDeviceIdentifier() local
814 int errCode = E_OK; PutBatchInner() local
861 int errCode = E_OK; DeleteBatchInner() local
900 int errCode = E_OK; SaveSyncEntries() local
912 int errCode = E_OK; SaveLocalEntries() local
924 int errCode = E_OK; DeleteSyncEntries() local
939 int errCode = E_OK; DeleteLocalEntries() local
968 int errCode = CheckAmendValueContentForLocalProcedure(dataItem.value, dataItem.value); SaveEntry() local
1009 int errCode = E_OK; SaveLocalItem() local
1028 int errCode = writeHandle_->PutLocalDataToCacheDB(dataItem); SaveLocalItemInCacheMode() local
1037 int errCode = writeHandle_->PrepareForSavingData(SingleVerDataType::SYNC_TYPE); SaveEntryNormally() local
1058 int errCode = writeHandle_->PrepareForSavingCacheData(SingleVerDataType::SYNC_TYPE); SaveEntryInCacheMode() local
1118 int errCode = naturalStore->CheckDataStatus(entry.key, entry.value, false); CheckSyncEntriesValid() local
1142 int errCode = naturalStore->CheckDataStatus(key, {}, true); CheckSyncKeysValid() local
1167 int errCode = naturalStore->GenericKvDB::CheckDataStatus(entry.key, entry.value, false); CheckLocalEntriesValid() local
1191 int errCode = naturalStore->GenericKvDB::CheckDataStatus(key, {}, true); CheckLocalKeysValid() local
1229 int errCode = E_OK; StartTransactionInCacheMode() local
1252 int errCode = E_OK; StartTransactionNormally() local
1320 int errCode = writeHandle_->Commit(); CommitInner() local
1343 int errCode = writeHandle_->Rollback(); RollbackInner() local
1401 int errCode = CheckWritePermission(); PublishLocal() local
1475 int errCode = DBCommon::CalcValueHash(localRecord.key, hashKey); PublishInner() local
1526 int errCode = CheckWritePermission(); UnpublishToLocal() local
1582 int errCode = E_OK; UnpublishInner() local
1629 int errCode = E_OK; UnpublishOper() local
1781 int errCode = GetEntriesInner(false, option, keyPrefix, entries); GetKeys() local
1808 int errCode = CheckReadDataControlled(); GetEntriesInner() local
1844 int errCode = E_OK; UpdateKey() local
1867 int errCode = E_OK; SetCloudDbSchema() local
1992 int errCode = CheckReadDataControlled(); GetEntries() local
[all...] |
| H A D | sqlite_utils.cpp | 163 int errCode = sqlite3_open_v2(fileUrl.c_str(), &dbTemp, flag, nullptr); in CreateDataBase() local
197 int errCode = CreateDataBase(properties, dbTemp, setWal); OpenDatabase() local
241 int errCode = sqlite3_prepare_v2(db, sql.c_str(), NO_SIZE_LIMIT, &statement, nullptr); GetStatement() local
262 int errCode = sqlite3_bind_text(statement, index, str.c_str(), str.length(), SQLITE_TRANSIENT); BindTextToStatement() local
274 int errCode = sqlite3_bind_int64(statement, index, value); BindInt64ToStatement() local
296 int errCode; BindBlobToStatement() local
312 ResetStatement(sqlite3_stmt *&statement, bool isNeedFinalize, int &errCode) ResetStatement() argument
351 int errCode = E_OK; StepWithRetry() local
378 int errCode = BindBlobToStatement(statement, index, keyPrefix, true); BindPrefixKey() local
435 int errCode = SQLiteUtils::GetStatement(db, sql, stmt); ExecuteRawSQL() local
465 int errCode = SetKeyInner(db, type, passwd, iterTimes); SetKey() local
486 int errCode = SQLiteUtils::ExecuteRawSQL(db, USER_VERSION_SQL); SetKey() local
560 int errCode = SQLiteUtils::ExecuteRawSQL(db, SHA256_ALGO_ATTACH_SQL); AttachNewDatabase() local
595 int errCode = SQLiteUtils::GetStatement(db, attachSql, statement); AttachNewDatabaseInner() local
634 int errCode = SQLiteUtils::OpenDatabase(metaProperties, db); CreateMetaDatabase() local
647 int errCode = SQLiteUtils::GetStatement(db, sql, statement); CheckIntegrity() local
691 int errCode = SQLiteUtils::GetStatement(db, sql, statement); AnalysisSchemaSqlAndTrigger() local
732 int errCode = SQLiteUtils::GetStatement(db, sql, statement); GetSchemaIndexList() local
766 int errCode = SQLiteUtils::GetStatement(db, sql, statement); AnalysisSchemaIndexDefine() local
795 int errCode = GetSchemaIndexList(db, tableName, indexList, uniqueList); AnalysisSchemaIndex() local
874 int errCode = SQLiteUtils::GetStatement(db, sql, statement); AnalysisSchemaFieldDefine() local
915 int errCode = AnalysisSchemaSqlAndTrigger(db, tableName, table, caseSensitive); AnalysisSchema() local
945 int errCode = AttachNewDatabase(db, type, passwd, newDbName); ExportDatabase() local
971 int errCode = sqlite3_rekey(db, static_cast<const void *>(passwd.GetData()), static_cast<int>(passwd.GetSize())); Rekey() local
1007 int errCode = sqlite3_open_v2(fileUrl.c_str(), &dbTemp, SQLITE_OPEN_URI | SQLITE_OPEN_READONLY, nullptr); GetVersion() local
1041 int errCode = sqlite3_prepare(db, strSql.c_str(), -1, &statement, nullptr); GetVersion() local
1068 int errCode = SQLiteUtils::GetStatement(db, sql, statement); GetJournalMode() local
1092 int errCode = SQLiteUtils::OpenDatabase(properties, db); SetUserVer() local
1122 MapSQLiteErrno(int errCode) MapSQLiteErrno() argument
1162 int errCode = sqlite3_busy_timeout(db, timeout); SetBusyTimeout() local
1177 int errCode = SQLiteUtils::OpenDatabase(option, db); ExportDatabase() local
1211 int errCode = GetStatement(db, sql, statement); SaveSchema() local
1250 int errCode = CheckTableExists(db, "meta_data", isExists); GetSchema() local
1324 int errCode = DecreaseIndex(db, name); ChangeIndex() local
1358 int errCode = sqlite3_create_function_v2(db, "calc_hash_key", 1, SQLITE_UTF8 | SQLITE_DETERMINISTIC, RegisterJsonFunctions() local
1409 int errCode = TimeHelper::GetSysCurrentRawTime(curTime); GetRawSysTime() local
1547 int errCode = SQLiteUtils::ExecuteRawSQL(db, sql); CreateSameStuTable() local
1566 int errCode = SQLiteUtils::GetStatement(db, sql, stmt); CloneIndexes() local
1609 int errCode = GetStatement(db, sql, statement); GetRelationalSchema() local
1650 int errCode = GetStatement(db, sql, statement); GetLogTableVersion() local
1690 int errCode = sqlite3_create_function_v2(db, funcName.c_str(), nArg, SQLITE_UTF8 | SQLITE_DETERMINISTIC, uData, RegisterFunction() local
1709 int errCode = heapSchemaObj->ParseFromSchemaString(inSchema); RegisterFlatBufferFunction() local
1757 int errCode = SQLiteUtils::GetStatement(handle, UPDATE_META_SQL, stmt); UpdateMetaDataWithinTrigger() local
1790 int errCode = sqlite3_create_function_v2(db, DBConstant::UPDATE_META_FUNC.c_str(), RegisterMetaDataUpdateFunction() local
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
| H A D | distributeddb_relational_ver_p2p_sync_test.cpp | 635 int errCode = SQLiteUtils::GetStatement(db, sql, stmt); in GetCount() local
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/src/ |
| H A D | protocol_proto.cpp | 107 int errCode = CalculateDataSerializeLength(inMsg, serializeLen); in ToSerialBuffer() local
114 int errCode = GetExtendHeadDataSize(extendHandle, headSize); in ToSerialBuffer() local
166 int errCode = DeSerializeMessage(inBuff, outMsg, onlyMsgHeader); ToMessage() local
188 int errCode = buffer->AllocBufferByPayloadLength(0, GetCommLayerFrameHeaderLength()); BuildEmptyFrameForVersionNegotiate() local
209 int errCode = ProtocolProto::SetDivergeHeader(buffer, inLabel); BuildFeedbackMessageFrame() local
237 int errCode = buffer->AllocBufferByPayloadLength(static_cast<uint32_t>(payloadLen), BuildLabelExchange() local
276 int errCode = buffer->AllocBufferByPayloadLength(payloadLen, GetCommLayerFrameHeaderLength()); BuildLabelExchangeAck() local
375 errno_t errCode = memcpy_s(dstByteHead, dstLeftLen, srcByteHead, fragLength); CombinePacketIntoFrame() local
424 errno_t errCode = memcpy_s(headerByteLen.first + sizeof(CommPhyHeader), SetDivergeHeader() local
480 int errCode = CalculateXorSum(bufferByteLen.first + LENGTH_BEFORE_SUM_RANGE, SetPhyHeader() local
498 int errCode = ParseCommPhyHeader(srcTarget, bytes, length, outResult); CheckAndParsePacket() local
534 int errCode = ParseCommLayerPayload(frameBytesLen.first, frameBytesLen.second, outResult); CheckAndParseFrame() local
540 int errCode = ParseCommDivergeHeader(frameBytesLen.first, frameBytesLen.second, outResult); CheckAndParseFrame() local
759 int errCode = CalculateXorSum(bytes + LENGTH_BEFORE_SUM_RANGE, length - LENGTH_BEFORE_SUM_RANGE, sumResult); ParseCommPhyHeaderCheckField() local
775 int errCode = ParseCommPhyHeaderCheckMagicAndVersion(bytes, length); ParseCommPhyHeader() local
861 int errCode = ParseLabelExchangeAck(bytes, length, inResult); ParseCommLayerPayload() local
867 int errCode = ParseLabelExchange(bytes, length, inResult); ParseCommLayerPayload() local
1064 int errCode = CalculateXorSum(outPacket.ptrPacket + LENGTH_BEFORE_SUM_RANGE, FillFragmentPacket() local
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/include/ |
| H A D | store_types.h | 188 DBStatus errCode = OK; member
207 DBStatus errCode = OK; member
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/cloud/ |
| H A D | cloud_service_impl.cpp | 1221 int errCode = AccessTokenKit::GetHapTokenInfo(tokenId, tokenInfo); in GetHapInfo() local
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/ |
| H A D | single_ver_data_sync.cpp | 69 int errCode = CheckPermitSendData(mode, context); in SyncStart() local
107 int errCode = CheckPermitSendData(mode_, context); InnerSyncStart() local
187 int errCode = metadata_->GetLastQueryTime(context->GetQuerySyncId(), context->GetDeviceId(), dbLastQueryTime); TryContinueSync() local
248 int errCode = communicateHandle_->SendMessage(context->GetDeviceId(), message, sendConfig, handler); Send() local
268 int errCode = GetData(context, packetSize, outData); GetDataWithPerformanceRecord() local
281 int errCode; GetData() local
316 int errCode = GetDataWithPerformanceRecord(context, syncOutData.entries, packetSize); GetMatchData() local
355 int errCode = metadata_->GetLastQueryTime(context->GetQuerySyncId(), context->GetDeviceId(), GetUnsyncData() local
375 int errCode; GetUnsyncData() local
396 int errCode = storage_->GetSyncDataNext(outData, token, syncDataSizeInfo); GetNextUnsyncData() local
419 int errCode = storage_->InterceptData(copyData, GetDeviceId(), localDeviceName, false); SaveData() local
469 int errCode = E_OK; SaveLocalWaterMark() local
570 int errCode = E_OK; RemoveDeviceDataHandle() local
619 int errCode = storage_->RemoveDeviceData(context->GetDeviceId(), true); DealRemoveDeviceDataByAck() local
714 int errCode = QuerySyncCheck(context); RequestStart() local
789 int errCode = QuerySyncCheck(context); PullRequestStart() local
839 int errCode = GetMatchData(context, syncData); PullResponseStart() local
896 int errCode = E_OK; UpdatePeerWaterMark() local
966 int errCode = RunPermissionCheck(context, message, packet); DataRequestRecvPre() local
990 int errCode = DataRequestRecvPre(context, message); DataRequestRecv() local
1054 int errCode = message->SetExternalObject(packet); SendDataPacket() local
1107 int errCode = message->SetExternalObject(packet); SendPullResponseDataPkt() local
1146 int errCode = ackMessage->SetCopiedObject(ack); SendDataAck() local
1193 int errCode = SingleVerDataSyncUtils::AckMsgErrnoCheck(context, message); AckRecv() local
1262 int errCode = ackMessage->SetCopiedObject(ack); SendSaveDataNotifyPacket() local
1311 int errCode = SaveLocalWaterMark(curType, context, DealWaterMarkException() local
1333 int errCode = SingleVerDataSyncUtils::RunPermissionCheck(context, storage_, label_, packet); RunPermissionCheck() local
1381 int errCode = ackMessage->SetCopiedObject(ack); SendResetWatchDogPacket() local
1408 int errCode = RemoveDeviceDataIfNeed(context); ReSend() local
1459 int errCode = message->SetExternalObject(packet); SendReSendPacket() local
1644 int errCode; GetReSendData() local
1697 int errCode = E_OK; RemoveDeviceDataIfNeed() local
1812 int errCode = ControlCmdStartCheck(context); ControlCmdStart() local
1846 int errCode = ControlCmdRequestRecvPre(context, message); ControlCmdRequestRecv() local
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/moduletest/common/distributeddb/src/ |
| H A D | distributed_test_tools.cpp | 1371 int errCode = 0; local
1390 int errCode = sqlite3_key(db, static_cast<const void *>(passwd.data()), local
1424 int errCode = sqlite3_open_v2(dbOpenName.c_str(), &db, flag, nullptr); global() local
1491 int errCode = sqlite3_step(statement); global() local
[all...] |