| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/ |
| H A D | distributeddb_cloud_db_proxy_test.cpp | 391 int errCode = proxy.HeartBeat(); in HWTEST_F() local [all...] |
| H A D | cloud_db_sync_utils_test.cpp | 340 int errCode; in GetHashKey() local
|
| H A D | distributeddb_cloud_syncer_lock_test.cpp | 198 int errCode = E_OK; in GetRelationalStore() local 237 int errCode; in InsertLocalData() local 404 int errCode = E_OK; in CheckAssetStatusNormal() local 999 int errCode = E_OK; in HWTEST_F() local
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/gaussdb_rd/src/interface/src/ |
| H A D | document_store.cpp | 42 int errCode = E_OK; in CreateCollection() local 88 int errCode = E_OK; DropCollection() local 133 int errCode = E_OK; TranFilter() local 145 int errCode = E_OK; UpdateArgsCheck() local 177 int errCode = resultSet.GetValue(valueGotStr); GetUpDataRePlaceData() local 215 int errCode = executor_->StartTransaction(); UpdateDataIntoDB() local 260 int errCode = UpdateArgsCheck(collection, filter, update, flags); UpdateDocument() local 288 int errCode = E_OK; UpsertArgsCheck() local 308 int errCode = resultSet.GetValue(val); CheckUpsertConflict() local 324 int errCode = resultSet.GetValue(valStr); GetUpsertRePlaceData() local 361 int errCode = E_OK; InsertIdToDocument() local 389 int errCode = executor_->StartTransaction(); UpsertDataIntoDB() local 434 int errCode = E_OK; UpsertDocumentFormatCheck() local 448 int errCode = UpsertArgsCheck(collection, filter, document, flags); UpsertDocument() local 490 int errCode = E_OK; InsertArgsCheck() local 522 int errCode = InsertArgsCheck(collection, document, flags); InsertDocument() local 546 int errCode = E_OK; DeleteArgsCheck() local 569 int errCode = executor_->StartTransaction(); DeleteDataFromDB() local 598 int errCode = DeleteArgsCheck(collection, filter, flags); DeleteDocument() local 670 int errCode = E_OK; JudgeViewType() local 720 int errCode = E_OK; FindArgsCheck() local 738 int errCode = E_OK; FindProjectionInit() local 769 int errCode = E_OK; InitFindResultSet() local 804 int errCode = FindArgsCheck(collection, filter, projection, flags); FindDocument() local 898 IsCollectionExists(const std::string &collectionName, int &errCode) IsCollectionExists() argument [all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/gaussdb_rd/ |
| H A D | rd_single_ver_natural_store.cpp | 34 GenericKvDBConnection *RdSingleVerNaturalStore::NewConnection(int &errCode) in NewConnection() argument 47 int errCode = E_OK; in GetAndInitStorageEngine() local 70 int errCode = RegisterNotificationEventType(*event); RegisterNotification() local 114 int errCode = ClearIncompleteDatabase(kvDBProp); Open() local 254 int errCode = E_OK; Export() local 316 int errCode = E_OK; Import() local 373 GetHandle(bool isWrite, int &errCode, OperatePerm perm) const GetHandle() argument 460 int errCode = storageEngine_->InitRdStorageEngine(poolSize, option, identifier); InitDatabaseContext() local [all...] |
| H A D | rd_single_ver_natural_store_connection.cpp | 72 int errCode = CheckOption(option, type); in GetEntriesInner() local 119 int errCode = tmpResultSet->Open(false); GetResultSet() local 147 int errCode = GetQueryInfo::GetQueryExpression(query).RangeParamCheck(); GetResultSet() local 177 int errCode = tmpResultSet->Close(); ReleaseResultSet() local 204 int errCode = E_OK; TranslateObserverModeToEventTypes() local 218 int errCode = E_OK; ForceCheckPoint() local 247 int errCode = CheckOption(option, dataType); Get() local 302 int errCode = GetQueryInfo::GetQueryExpression(query).RangeParamCheck(); GetEntriesInner() local 404 int errCode = CheckRdMonoStatus(OperatePerm::IMPORT_MONOPOLIZE_PERM); Import() local 435 int errCode = kvDB_->TryToDisableConnection(perm); CheckRdMonoStatus() local 478 int errCode = RollbackInner(); PreClose() local 521 int errCode = naturalStore->CheckDataStatus(entry.key, entry.value, false); CheckSyncEntriesValid() local 543 int errCode = E_OK; SetBatchInner() local 594 int errCode = writeHandle_->SaveSyncDataItem(entry, committedData_, isDelete); SaveEntryNormally() local 640 int errCode = E_OK; StartTransactionNormally() local 674 int errCode = writeHandle_->Commit(); CommitInner() local 686 int errCode = writeHandle_->Rollback(); RollbackInner() local 715 int errCode = naturalStore->CheckDataStatus(key, {}, true); CheckSyncKeysValid() local [all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/ |
| H A D | sqlite_single_ver_natural_store_extend.cpp | 49 int errCode = ResetLifeCycleTimer(); in HeartBeatForLifeCycle() local 63 int errCode = runtimeCxt->SetTimer(autoLifeTime_, in StartLifeCycleTimer() local 106 int errCode = StopLifeCycleTimer(); in ResetLifeCycleTimer() local 159 int errCode = RuntimeContext::GetInstance()->ScheduleTask([this, storageEngine]() { TriggerToMigrateData() local 246 int errCode = CheckValueAndAmendIfNeed(ValueSource::FROM_SYNC, eachItem.value, eachItem.value, useAmendValue); CheckAmendValueContentForSyncProcedure() local 269 int errCode = E_OK; CheckIntegrity() local 283 int errCode = GetDatabaseCreateTimestamp(createDBTime); SaveCreateDBTimeIfNotExisted() local 299 int errCode = E_OK; DeleteMetaDataByPrefixKey() local 339 int errCode = E_OK; CheckAndInitQueryCondition() local 378 int errCode = interceptor(data, sourceID, targetID); InterceptData() local 405 int errCode = E_OK; AddSubscribe() local 463 int errCode = E_OK; RemoveDeviceDataInner() local 512 int errCode = E_OK; RemoveDeviceDataInner() local 541 int errCode = E_OK; RemoveDeviceDataInner() local 592 int errCode = E_OK; GetStorageExecutor() local [all...] |
| H A D | sqlite_utils_extend.cpp | 98 int errCode = newCache->valueParsed.Parse(valueBlob, valueBlob + valueBlobLen, offset); in ParseValueThenCacheOrGetFromCache() local 142 int errCode = SchemaUtils::ParseAndCheckFieldPath(path, outPath); in JsonExtractByPath() local 168 int errCode = inValue.GetFieldTypeByFieldPath(inPath, outType); in JsonExtractInnerFunc() local 237 int errCode = schema.ExtractValue(ValueSource::FROM_DBFILE, inPath, inValue, outExtract, nullptr); FlatBufferExtractInnerFunc() local 269 int errCode = schema.ExtractValue(ValueSource::FROM_DBFILE, inPath, inValue, outExtract, cached); FlatBufferExtractInnerFunc() local 319 int errCode = DBCommon::CalcValueHash(value, hashValue); CalcHashFunc() local 352 int errCode = OS::CalFileSize(dataDir, localDbSize); GetDbSize() local 381 int errCode = SetBusyTimeout(db, BUSY_TIMEOUT_MS); SetDataBaseProperty() local 425 int errCode = SQLiteUtils::ExecuteRawSQL(db, cipherConfig); SetCipherSettings() local 449 int errCode = SQLiteUtils::ExecuteRawSQL(db, dropTriggerSql); DropTriggerByName() local 489 int errCode = SQLiteUtils::GetStatement(db, cntSql, stmt); CheckTableEmpty() local 510 int errCode = sqlite3_file_control(db, "main", SQLITE_FCNTL_PERSIST_WAL, &opCode); SetPersistWalMode() local 549 int errCode = sqlite3_key(db, static_cast<const void *>(passwd.GetData()), static_cast<int>(passwd.GetSize())); SetKeyInner() local 567 int errCode = E_OK; BindDataValueByType() local 614 int errCode = SetKeyInner(db, type, passwd, iterTimes); UpdateCipherShaAlgo() local 661 int errCode = SQLiteUtils::GetStatement(db, isCheckMeta ? CHECK_META_DB_TABLE_CREATED : CHECK_TABLE_CREATED, stmt); CheckTableExists() local 690 int errCode = SQLiteUtils::StepWithRetry(stmt, isMemDb); StepNext() local [all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/ |
| H A D | single_ver_sync_task_context.cpp | 59 int errCode = stateMachine_->Initialize(this, syncInterface, metadata, communicator); in Initialize() local 516 int errCode = static_cast<SingleVerSyncStateMachine *>(stateMachine_)->GetSendQueryWaterMark( GetCorrectedSendWaterMarkForCurrentTask() local 575 int errCode = GetCorrectedSendWaterMarkForCurrentTask(operation, localWaterMark); IsCurrentSyncTaskCanBeSkippedInner() local [all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/common/ |
| H A D | distributeddb_schema_object_test.cpp | 618 int errCode = schemaOri.ParseFromSchemaString(VALID_SCHEMA_FULL_DEFINE); in HWTEST_F() local 639 int errCode = compatibleSchema.ParseFromSchemaString(SCHEMA_COMPARE_BASELINE); in HWTEST_F() local 674 int errCode = compatibleSchema.ParseFromSchemaString(SCHEMA_COMPARE_BASELINE); HWTEST_F() local 709 int errCode = strictSchema.ParseFromSchemaString(SchemaSwitchMode(SCHEMA_COMPARE_BASELINE)); HWTEST_F() local 784 int errCode = schemaStrict.ParseFromSchemaString(VALID_SCHEMA_FULL_DEFINE); HWTEST_F() local 864 int errCode = schemaStrict.ParseFromSchemaString(VALID_SCHEMA_FULL_DEFINE); HWTEST_F() local 905 int errCode = testObject.InsertField(FieldPath{"L1F1", "L2F1", "L3F1", "L4F1"}, FieldType::LEAF_FIELD_STRING, val); HWTEST_F() local 953 int errCode = testObject.InsertField(FieldPath{"L1F1", "L2F1", "L3F1"}, FieldType::LEAF_FIELD_STRING, val); HWTEST_F() local 977 int errCode = externalValueObject.Parse(valueStr); CheckValueLackField() local 1001 int errCode = schema.ParseFromSchemaString(SCHEMA_FOR_TEST_NOTNULL_AND_DEFAULT); HWTEST_F() local 1060 int errCode = schema.ParseFromSchemaString(SCHEMA_FOR_TEST_NOTNULL_AND_DEFAULT); HWTEST_F() local [all...] |
| H A D | distributeddb_relational_schema_object_test.cpp | 297 int errCode = schemaObj.ParseFromSchemaString(schemaStr); in HWTEST_F() local 326 int errCode = schemaObj.ParseFromSchemaString(schemaStr01); in HWTEST_F() local 390 int errCode = E_OK; HWTEST_F() local 443 int errCode = E_OK; HWTEST_F() local 461 int errCode = E_OK; HWTEST_F() local 479 int errCode = E_OK; HWTEST_F() local 498 int errCode = schemaObj.ParseFromSchemaString(NORMAL_SCHEMA); HWTEST_F() local 518 int errCode = schemaObj.ParseFromSchemaString(NORMAL_SCHEMA_V2_1); HWTEST_F() local 538 int errCode = schemaObj.ParseFromSchemaString(NORMAL_SCHEMA_V2_1); HWTEST_F() local 556 int errCode = schemaObj.ParseFromSchemaString(NORMAL_SCHEMA); HWTEST_F() local 574 int errCode = schemaObj.ParseFromSchemaString(NORMAL_SCHEMA_V2_1); HWTEST_F() local 593 int errCode = schemaObj.ParseFromSchemaString(NORMAL_SCHEMA); HWTEST_F() local 641 int errCode = SchemaNegotiate::SerializeData(opinion, writeParcel); HWTEST_F() local [all...] |
| H A D | distributeddb_auto_launch_test.cpp | 169 int errCode = E_OK; in PutSyncData() local 188 int errCode = E_OK; in SetLifeCycleTime() local 215 int errCode = RuntimeContext::GetInstance()->EnableKvStoreAutoLaunch(g_propA, nullptr, option); in HWTEST_F() local 366 int errCode = RuntimeContext::GetInstance()->EnableKvStoreAutoLaunch(g_propA, notifier, option); HWTEST_F() local 437 int errCode = RuntimeContext::GetInstance()->EnableKvStoreAutoLaunch(g_propI, nullptr, option); HWTEST_F() local 516 int errCode = RuntimeContext::GetInstance()->EnableKvStoreAutoLaunch(g_propA, notifier, option); HWTEST_F() local 586 int errCode = RuntimeContext::GetInstance()->EnableKvStoreAutoLaunch(g_propA, notifier, option); HWTEST_F() local 878 int errCode = RuntimeContext::GetInstance()->EnableKvStoreAutoLaunch(g_propA, TestAutoLaunchNotifier, option); HWTEST_F() local [all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/ |
| H A D | distributeddb_storage_query_sync_test.cpp | 1425 int errCode = E_OK; in HWTEST_F() local
|
| H A D | distributeddb_storage_commit_storage_test.cpp | 196 int errCode = E_OK; in TestCommitStorageHeader() local 311 int errCode = g_commitStorage->Open(g_prop); in SetUp() local 754 int errCode = E_OK; in HWTEST_F() local
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/include/store/ |
| H A D | general_value.h | 115 int32_t errCode = 0; member
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/gaussdb_rd/src/oh_adapter/src/ |
| H A D | rd_json_object.cpp | 71 JsonObject JsonObject::Parse(const std::string &jsonStr, int &errCode, bool caseSensitive, bool isFilter) in Parse() argument 272 JsonObject JsonObject::GetObjectItem(const std::string &field, int &errCode) in GetObjectItem() argument 411 void JsonObject::ReplaceItemInObject(const std::string &fieldName, const JsonObject &newItem, int &errCode) in ReplaceItemInObject() argument 426 void JsonObject::ReplaceItemInArray(const int &index, const JsonObject &newItem, int &errCode) in ReplaceItemInArray() argument [all...] |
| /foundation/distributeddatamgr/relational_store/test/native/rdb/unittest/ |
| H A D | rdb_step_result_set_test.cpp | 83 int errCode = E_OK;
in SetUpTestCase() local 1465 int errCode = SqliteSqlBuilder::BuildQueryString(false, "", "", columns, "", "", "", "", 0, 0, outSql);
in HWTEST_F() local 1668 int errCode = 0;
in HWTEST_F() local 1727 int errCode = 0, columnIndex = 0; HWTEST_F() local 1771 int errCode = 0, columnIndex = 0; HWTEST_F() local 1832 int errCode = 0; HWTEST_F() local 1896 int errCode = 0; HWTEST_F() local [all...] |
| H A D | rdb_sqlite_shared_result_set_test.cpp | 76 int errCode = E_OK;
in SetUpTestCase() local
|
| /foundation/distributeddatamgr/relational_store/frameworks/js/napi/relationalstore/src/ |
| H A D | napi_rdb_predicates.cpp | 768 int errCode = predicatesProxy->GetInstance()->GetJoinCount(); in GetJoinCount() local
|
| /foundation/distributeddatamgr/relational_store/frameworks/native/rdb/src/ |
| H A D | sqlite_statement.cpp | 71 int errCode = sqlite3_prepare_v2(dbHandle, newSql.c_str(), newSql.length(), &stmt, nullptr); in Prepare() local 97 void SqliteStatement::PrintInfoForDbError(int errCode, const std::string &sql) in PrintInfoForDbError() argument 168 auto errCode = action(stmt_, index, arg.get().value); BindArgs() local 199 int errCode = Prepare(db, sql); Prepare() local 205 int errCode = slave_->Prepare(sql); Prepare() local 240 int errCode = BindArgs(abindArgs); Bind() local 246 int errCode = slave_->Bind(args); Bind() local 298 auto errCode = sqlite3_step(stmt_); InnerStep() local 313 int errCode = sqlite3_reset(stmt_); Reset() local 329 int errCode = InnerFinalize(); Finalize() local 365 auto errCode = conn_->LimitWalSize(); Execute() local 374 auto errCode = BindArgs(args); Execute() local 385 int errCode = slave_->Execute(args); Execute() local 396 auto errCode = Execute(args); ExecuteForValue() local 587 int32_t errCode = E_OK; FillBlockInfo() local 729 int errCode = sqlite3_finalize(stmt_); InnerFinalize() local [all...] |
| H A D | rdb_security_manager.cpp | 616 auto errCode = stat(keyFile.c_str(), &fileInfo);
in IsKeyFileEmpty() local 687 int32_t errCode;
in Lock() local 703 int32_t errCode;
in Unlock() local [all...] |
| H A D | connection_pool.cpp | 47 std::shared_ptr<ConnPool> ConnPool::Create(const RdbStoreConfig &config, int &errCode) in Create() argument 75 HandleDataCorruption( const RdbStoreConfig &storeConfig, int &errCode) HandleDataCorruption() argument 302 auto errCode = node->Unused(transCount); ReleaseNode() local 350 auto errCode = readers_.ConfigLocale(localeStr); ConfigLocale() local 520 auto errCode = ExtendNode(); Initialize() local [all...] |
| /foundation/distributedhardware/device_manager/interfaces/inner_kits/native_cpp/src/ipc/standard/ |
| H A D | ipc_cmd_parser.cpp | 1741 int32_t errCode = data.ReadInt32(); in ON_IPC_CMD() local
|
| /foundation/distributeddatamgr/relational_store/test/native/relational_store_test/unittest/ |
| H A D | rdb_store_test.cpp | 76 int errCode = RdbHelper::DeleteRdbStore(DATABASE_NAME); in SetUp() local 89 int errCode = RdbHelper::DeleteRdbStore(DATABASE_NAME); in TearDown() local 269 int errCode = E_OK; in HWTEST_F() local 283 int errCode in HWTEST_F() local 297 int errCode = E_OK; HWTEST_F() local 352 int errCode = E_OK; HWTEST_F() local 419 int errCode = E_OK; HWTEST_F() local 450 int errCode = E_OK; HWTEST_F() local 490 int errCode = E_OK; HWTEST_F() local 532 int errCode = E_OK; HWTEST_F() local 576 int errCode = E_OK; HWTEST_F() local 630 int errCode = E_OK; HWTEST_F() local 656 int errCode = E_OK; HWTEST_F() local 694 int errCode = E_OK; HWTEST_F() local 717 int errCode = E_OK; HWTEST_F() local 743 int errCode = E_OK; HWTEST_F() local 770 int errCode = E_OK; HWTEST_F() local 796 int errCode = E_OK; HWTEST_F() local 819 int errCode = E_OK; HWTEST_F() local 841 int errCode = E_OK; HWTEST_F() local [all...] |
| /foundation/distributedhardware/device_manager/radar/include/ |
| H A D | dm_radar_helper.h | 145 int32_t errCode; member [all...] |