| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/ |
| H A D | distributeddb_relational_encrypted_db_test.cpp | 76 int errCode = E_OK; in GetRelationalStore() local
|
| H A D | distributeddb_file_package_test.cpp | 51 int errCode = OS::GetFileAttrFromPath(path, files); in RemovePath() local 79 int errCode = OS::GetFileAttrFromPath(path1, files1); in ComparePath() local 147 int errCode = calc.Initialize(); in SetUpTestCase() local 185 int errCode = PackageFile::PackageFiles(g_sourcePath, g_packageResultPath + PACKAGE_RESULT_FILE_NAME, g_fileInfo); HWTEST_F() local 203 int errCode = PackageFile::PackageFiles(g_sourcePath + NON_EXIST_PATH, HWTEST_F() local 217 int errCode = PackageFile::PackageFiles(g_sourcePath, HWTEST_F() local 235 int errCode = PackageFile::PackageFiles(g_sourcePath, g_packageResultPath + PACKAGE_RESULT_FILE_NAME, g_fileInfo); HWTEST_F() local 258 int errCode = PackageFile::UnpackFile(g_packageResultPath + PACKAGE_RESULT_FILE_NAME, g_unpackResultPath, fileInfo); HWTEST_F() local 271 int errCode = PackageFile::PackageFiles(g_sourcePath, g_packageResultPath + PACKAGE_RESULT_FILE_NAME, g_fileInfo); HWTEST_F() local 288 int errCode = PackageFile::PackageFiles(g_sourcePath, g_packageResultPath + PACKAGE_RESULT_FILE_NAME, g_fileInfo); HWTEST_F() local 312 int errCode = PackageFile::PackageFiles(g_sourcePath, g_packageResultPath + PACKAGE_RESULT_FILE_NAME, g_fileInfo); HWTEST_F() local [all...] |
| H A D | distributeddb_query_object_helper_test.cpp | 55 int errCode = E_OK; in GetQuerySql() local 175 int errCode = E_OK; in HWTEST_F() local [all...] |
| H A D | distributeddb_storage_rd_single_ver_natural_executor_test.cpp | 284 int errCode = E_OK; in HWTEST_F() local 417 int errCode = E_OK; in HWTEST_F() local
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
| H A D | distributeddb_anti_dos_sync_test.cpp | 189 int errCode = message->SetExternalObject(packet); in HWTEST_F() local 241 int errCode = message->SetExternalObject(packet); in HWTEST_F() local 307 int errCode = message->SetExternalObject(packet); in HWTEST_F() local
|
| /foundation/distributeddatamgr/data_share/frameworks/native/consumer/src/ |
| H A D | datashare_proxy.cpp | 301 int32_t errCode = -1; in InsertEx() local 333 int32_t errCode = -1; in UpdateEx() local 364 int32_t errCode = -1; in DeleteEx() local [all...] |
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/rdb/ |
| H A D | rdb_cloud.cpp | 341 auto errCode = Traits::get_if<int64_t>(&(errorField->second)); in ConvertErrorField() local
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/ |
| H A D | platform_specific.cpp | 62 int errCode = rename(oldFilePath.c_str(), newFilePath.c_str()); in RenameFilePath() local 76 int errCode = remove(filePath.c_str()); in RemoveFile() local 89 int errCode = (errno == ENOENT) ? -E_NOT_FOUND : -E_INVALID_DB; in CalFileSize() local 118 int errCode = mkdir(directory.c_str()); in MakeDBDirectory() local 245 int errCode in GetFilePathAttr() local 297 int errCode = _stat64(fileName.c_str(), &fileStat); GetFilePermissions() local 312 int errCode = _chmod(fileName.c_str(), _S_IREAD | _S_IWRITE); SetFilePermissions() local [all...] |
| H A D | parcel.cpp | 89 errno_t errCode = memcpy_s(bufPtr_, totalLen_ - parcelLen_, &inData, sizeof(double)); in WriteDouble() local 171 errno_t errCode = memcpy_s(bufPtr_, totalLen_ - parcelLen_, &len, sizeof(uint32_t)); in WriteString() local 233 int errCode = WriteVectorChar(commit.commitId); in WriteMultiVerCommit() local 292 int errCode = WriteUInt64(len); WriteMultiVerCommits() local 392 int errCode = memcpy_s(bufPtr_, leftLen, buffer, bufLen); WriteBlob() local 419 int errCode = memcpy_s(buffer, bufLen, bufPtr_, bufLen); ReadBlob() local [all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/multiver/ |
| H A D | multi_ver_natural_store_connection.cpp | 43 int errCode = CheckDataStatus(key, {}, false); in Get() local 73 int errCode in Put() local 104 int errCode = CheckDataStatus(key, {}, true); Delete() local 136 int errCode = StartTransactionInner(isAuto); Clear() local 168 int errCode = E_OK; GetEntries() local 194 int errCode = StartTransactionInner(isAuto); PutBatch() local 229 int errCode = StartTransactionInner(isAuto); DeleteBatch() local 268 int errCode = E_OK; GetSnapshot() local 374 int errCode = writeHandle_->CommitTransaction(); CommitTransactionInner() local 390 int errCode = writeHandle_->RollBackTransaction(); RollBackTransactionInner() local 406 int errCode = E_OK; StartTransactionInner() local 443 int errCode = kvDB_->TryToDisableConnection(OperatePerm::REKEY_MONOPOLIZE_PERM); Rekey() local 476 int errCode = kvDB_->TryToDisableConnection(OperatePerm::IMPORT_MONOPOLIZE_PERM); Import() local [all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/ |
| H A D | sqlite_relational_utils.cpp | 31 int errCode = E_OK; in GetDataValueByType() local 106 int errCode = SQLiteUtils::GetColumnBlobValue(statement, cid, blobValue); in GetCloudValueByType() local 117 int errCode = SQLiteUtils::GetColumnBlobValue(statement, cid, blobValue); GetCloudValueByType() local 164 int errCode = E_OK; BindStatementByType() local 200 int errCode = E_OK; BindExtendStatementByType() local 245 int errCode = GetTypeValByStatement(stmt, cid, typeVal); GetSelectVBucket() local 275 int errCode = E_OK; GetTypeValByStatement() local 319 int errCode = E_OK; GetBlobByStatement() local 367 int errCode = SQLiteUtils::GetStatement(db, sql, stmt); SelectServerObserver() local 397 int errCode = SQLiteUtils::AnalysisSchema(db, trackerTable.GetTableName(), tableInfo, true); AnalysisTrackerTable() local 414 int errCode = SQLiteUtils::GetStatement(db, sql, stmt); QueryCount() local [all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/multiver/ |
| H A D | multi_ver_sync_state_machine.cpp | 67 int errCode = SyncStateMachine::Initialize(context, syncInterface, metadata, communicator); in Initialize() local 104 int errCode = RuntimeContext::GetInstance()->ScheduleTask([this] { SyncStepInnerLocked(); }); in SyncStep() local 132 int errCode in MessageCallbackCheck() local 153 int errCode = MessageCallbackCheck(inMsg); ReceiveMessageCallback() local 199 int errCode = commitHistorySync_->SyncStart(context_); CommitHistorySyncStepInner() local 223 int errCode; SyncStepInnerLocked() local 279 int errCode = StartWatchDog(); StartSyncInner() local 322 int errCode; TimeSyncPacketRecvCallback() local 347 int errCode; CommitHistorySyncPktRecvCallback() local 376 int errCode; MultiVerDataPktRecvCallback() local 403 int errCode; ValueSlicePktRecvCallback() local 437 int errCode = multiVerDataSync_->MergeSyncCommit(commit, commits); Finish() local 454 int errCode = E_OK; OneCommitSyncFinish() local 550 int errCode = RuntimeContext::GetInstance()->SetTimer( SyncResponseBegin() local [all...] |
| H A D | multi_ver_sync_task_context.cpp | 43 int errCode = timeHelper_->Initialize(syncInterface, metadata); in Initialize() local
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/ |
| H A D | single_ver_data_message_schedule.cpp | 135 int errCode = UpdateMsgMapIfNeed(msg); in UpdateMsgMapInner() local 232 int errCode = RuntimeContext::GetInstance()->SetTimer(IDLE_TIME_OUT, timeOutCallback, in StartTimer() local [all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/moduletest/common/distributeddb/src/ |
| H A D | distributed_rdb_tools.cpp | 127 int errCode = sqlite3_open(dbName, &db);
in InitSqlite3Store() local 144 int errCode = sqlite3_exec(db, sql, nullptr, nullptr, &errMsg);
in SqliteExecSql() local 185 int errCode = sqlite3_exec(db, SQL_ADD_FIELD_TABLE1, nullptr, nullptr, &errMsg);
in AlterTableAttributes() local 230 int errCode = sqlite3_exec(db, sql_name, 0, 0, 0);
in Sqlite3ExecOpration() local
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/interfaces/ |
| H A D | distributeddb_cloud_interfaces_reference_test.cpp | 410 int errCode = RelationalTestUtils::ExecSql(db, sql, bindCallback, [&count] (sqlite3_stmt *stmt) { in CheckResult() local
|
| H A D | distributeddb_interfaces_database_rd_kernel_test.cpp | 652 int errCode = E_OK; in HWTEST_F() local
|
| H A D | distributeddb_interfaces_device_identifier_test.cpp | 339 int errCode; in HWTEST_F() local 512 int errCode = E_OK; in HWTEST_F() local 582 int errCode = E_OK; in HWTEST_F() local 626 int errCode = E_OK; in HWTEST_F() local 647 int errCode = E_OK; HWTEST_F() local 700 int errCode = E_OK; HWTEST_F() local 741 int errCode = E_OK; HWTEST_F() local [all...] |
| H A D | distributeddb_interfaces_encrypt_delegate_test.cpp | 65 void GetSnapshotAndValueCheck(const Key &testKey, const Value &testValue, DBStatus errCode) in GetSnapshotAndValueCheck() argument 114 int errCode = g_passwd1.SetValue(passwdBuffer1.data(), passwdBuffer1.size()); in SetUpTestCase() local 467 DBStatus errCode = INVALID_ARGS; HWTEST_F() local [all...] |
| H A D | distributeddb_interfaces_database_corrupt_test.cpp | 152 int errCode = passwd.SetValue(randomPassword.data(), randomPassword.size()); in HWTEST_F() local 196 int errCode = passwd.SetValue(randomPassword.data(), randomPassword.size()); in HWTEST_F() local 268 int errCode = passwd.SetValue(randomPassword.data(), randomPassword.size()); in HWTEST_F() local 341 int errCode = passwd.SetValue(randomPassword.data(), randomPassword.size()); in HWTEST_F() local 401 int errCode = passwd.SetValue(randomPassword.data(), randomPassword.size()); in HWTEST_F() local 611 int errCode = passwd.SetValue(randomPassword.data(), randomPassword.size()); HWTEST_F() local [all...] |
| /foundation/distributeddatamgr/data_share/frameworks/native/proxy/src/ |
| H A D | data_share_service_proxy.cpp | 85 int32_t errCode = -1; InsertEx() local 117 int32_t errCode = -1; UpdateEx() local 149 int32_t errCode = -1; DeleteEx() local [all...] |
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/ |
| H A D | data_share_service_impl_test.cpp | 224 int errCode = 0;
in HWTEST_F() local 248 int errCode = 0;
in HWTEST_F() local
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/ |
| H A D | data_transformer.cpp | 32 int errCode = SerializeDataItem(data, fieldInfoList, dataItem); in TransformTableData() local 49 int errCode = DeSerializeDataItem(dataItem, dataWithLog, remoteFieldInfo); in TransformDataItem() local 61 int errCode = SerializeValue(dataItem.value, data.rowData, fieldInfo); in SerializeDataItem() local 80 int errCode in DeSerializeDataItem() local 187 int errCode = parcel.WriteUInt32(size); SerializeBlobValue() local 217 int errCode = -E_NOT_SUPPORT; DeSerializeBlobByType() local 303 int errCode = SerializeDataValue(dataValue, parcel); SerializeValue() local 323 int errCode = DeserializeDataValue(dataValue, parcel); DeSerializeValue() local [all...] |
| H A D | single_ver_natural_store_commit_notify_data.cpp | 52 int errCode; in IsChangedDataEmpty() local 137 FilterEntriesByKey( const std::list<Entry> &entries, const Key &filterKey, int &errCode) FilterEntriesByKey() argument [all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/ |
| H A D | sqlite_single_ver_result_set.cpp | 87 int errCode = window_->Init(rawCursor_, windowSize, scale); in OpenForCacheFullEntryMode() local 105 int errCode = E_OK; in OpenForCacheEntryIdMode() local 290 int errCode; MoveToForCacheEntryIdMode() local 331 int errCode = handle_->GetEntryByRowId(cachedRowIds_[cacheIndex], entry); GetEntry() local [all...] |