Home
last modified time | relevance | path

Searched defs:errCode (Results 926 - 950 of 1737) sorted by relevance

1...<<31323334353637383940>>...70

/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/src/
H A Ddb_status_adapter.cpp110 int errCode = RuntimeContext::GetInstance()->ScheduleTask([triggerLocal, remoteDBInfos, remote, local]() { in SetDBStatusChangeCallback() local
125 int errCode = RuntimeContext::GetInstance()->ScheduleTask([this, devInfos, dbInfos]() { in NotifyDBInfos() local
200 int errCode = RuntimeContext::GetInstance()->ScheduleTask([this, dev]() { in SetRemoteOptimizeCommunication() local
327 int errCode = RuntimeContext::GetInstance()->GetCommunicatorAggregator(communicatorAggregator); GetLocalDeviceId() local
[all...]
H A Dnetwork_adapter.cpp59 DBStatus errCode = processCommunicator_->Start(processLabel_); in StartAdapter() local
109 DBStatus errCode = processCommunicator_->RegOnDeviceChange(nullptr); StopAdapter() local
227 DBStatus errCode = processCommunicator_->SendData(dstDevInfo, bytes, length, SendBytes() local
272 DBStatus errCode = processCommunicator_->CheckAndGetDataHeadInfo(data, length, headLength, userId); OnDataReceiveHandler() local
355 int errCode = RuntimeContext::GetInstance()->ScheduleQueuedTask(SCHEDULE_QUEUE_TAG, callbackTask); SearchOnlineRemoteDeviceAtStartup() local
408 int errCode = RuntimeContext::GetInstance()->ScheduleQueuedTask(SCHEDULE_QUEUE_TAG, callbackTask); CheckDeviceOfflineAfterSendFail() local
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/gaussdb_rd/
H A Drd_utils.cpp206 int errCode = TransferGrdErrno(GRD_KVGetSize(resultSet, &keyLen, &valueLen)); in RdKvFetch() local
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/common/
H A Ddistributeddb_thread_pool_test.cpp103 int errCode = RuntimeContext::GetInstance()->ScheduleTask([]() { in CallScheduleTaskOnce() local
138 int errCode = RuntimeContext::GetInstance()->SetTimer(timeOut, [&timerCount](TimerId timerId) { in SetTimer() local
154 int errCode = RuntimeContext::GetInstance()->SetTimer(ONE_HUNDRED_MILLISECONDS, [&timerCount](TimerId timerId) { in SetTimer() local
415 int errCode = RuntimeContext::GetInstance()->SetTimer(1, [&dataMutex, &removeSet, &checkSet](TimerId timerId) { in HWTEST_F() local
450 int errCode = RuntimeContext::GetInstance()->ScheduleTask([&finishedTaskCount, &dataMutex, &cv]() { in HWTEST_F() local
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/gaussdb_rd/src/oh_adapter/src/
H A Dsqlite_store_executor_impl.cpp33 int errCode = RDSQLiteUtils::CreateDataBase(path, 0, db); in CreateDatabase() local
79 int errCode = GetDataByKey("grd_meta", dbConfigKey, dbConfigVal); GetDBConfig() local
116 int errCode = RDSQLiteUtils::ExecSql( PutData() local
145 int errCode = RDSQLiteUtils::ExecSql( InsertData() local
172 int errCode = RDSQLiteUtils::ExecSql( GetDataByKey() local
199 int errCode = RDSQLiteUtils::ExecSql( GetDataById() local
253 int errCode = RDSQLiteUtils::ExecSql( GetDataByFilter() local
297 int errCode = 0; DelData() local
326 int errCode = E_OK; CreateCollection() local
359 int errCode = E_OK; DropCollection() local
371 int errCode = RDSQLiteUtils::ExecSql(dbHandle_, sql); DropCollection() local
378 IsCollectionExists(const std::string &name, int &errCode) IsCollectionExists() argument
[all...]
H A Drd_sqlite_utils.cpp31 int MapSqliteError(int errCode) in MapSqliteError() argument
69 int errCode = sqlite3_open_v2(path.c_str(), &db, SQLITE_OPEN_READWRITE | SQLITE_OPEN_CREATE, nullptr); in CreateDataBase() local
97 int errCode = sqlite3_prepare_v2(db, sql.c_str(), -1, &statement, nullptr); GetStatement() local
117 int errCode = sqlite3_step(statement); StepWithRetry() local
131 int errCode = E_OK; ResetStatement() local
158 int errCode; BindBlobToStatement() local
198 int errCode = sqlite3_bind_text(statement, index, value.c_str(), value.length(), SQLITE_TRANSIENT); BindTextToStatement() local
233 int errCode = sqlite3_exec(db, sql.c_str(), nullptr, nullptr, &errMsg); ExecSql() local
251 int errCode = RDSQLiteUtils::GetStatement(db, sql, stmt); ExecSql() local
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/kv/
H A Dsqlite_local_kvdb_connection.cpp52 int errCode = E_OK; in Get() local
65 int errCode = CheckDataStatus(key, value, false); in Put() local
98 int errCode = CheckDataStatus(key, {}, true); Delete() local
133 int errCode = StartTransactionInner(isAuto); Clear() local
174 int errCode = E_OK; GetEntries() local
197 int errCode = StartTransactionInner(isAuto); PutBatch() local
240 int errCode = StartTransactionInner(isAuto); DeleteBatch() local
273 int errCode = E_OK; GetSnapshot() local
374 int errCode = E_OK; StartTransactionInner() local
399 int errCode = writeHandle_->Commit(); CommitInner() local
414 int errCode = writeHandle_->RollBack(); RollBackInner() local
434 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/
H A Dsqlite_single_ver_storage_executor_extend.cpp42 int errCode = E_OK; in CloudExcuteRemoveOrUpdate() local
87 int errCode = E_OK; CloudCheckDataExist() local
140 int errCode = CloudExcuteRemoveOrUpdate(REMOVE_CLOUD_ALL_HWM_DATA_SQL, "", "", true); RemoveDeviceDataInner() local
164 int errCode = CloudExcuteRemoveOrUpdate(REMOVE_CLOUD_ALL_HWM_DATA_SQL, "", "", true); RemoveDeviceDataInner() local
185 int errCode = CloudExcuteRemoveOrUpdate(REMOVE_CLOUD_HWM_DATA_BY_USERID_SQL, "", RemoveDeviceDataWithUserInner() local
213 int errCode = CloudExcuteRemoveOrUpdate(REMOVE_CLOUD_HWM_DATA_BY_USERID_SQL, "", RemoveDeviceDataWithUserInner() local
242 int errCode = CloudCheckDataExist(SELECT_CLOUD_LOG_DATA_BY_DEVID_SQL, deviceName, "", isDataExist); RemoveDeviceData() local
257 int errCode = E_OK; RemoveDeviceData() local
277 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, stmt); GetEntries() local
314 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, statement); PrepareForUnSyncTotalByTime() local
333 int errCode = SQLiteUtils::StepWithRetry(countStatement, isMemDb_); GetCountValue() local
355 int errCode = PrepareForUnSyncTotalByTime(begin, end, countStatement); GetUnSyncTotalByTimestamp() local
366 int errCode = PrepareForUnSyncTotalByTime(begin, end, countStatement, true); GetDeletedSyncTotalByTimestamp() local
376 int errCode = E_OK; GetSyncTotalWithQuery() local
394 int errCode = SQLiteUtils::CheckTableExists(dbHandle_, tableName, isCreate); RemoveCloudUploadFlag() local
[all...]
H A Dsqlite_multi_ver_data_storage.cpp62 int errCode = GetVersion(property, dbVer, isDbExist); in CheckVersion() local
105 int errCode = SQLiteUtils::OpenDatabase(option, db); in Open() local
156 int errCode = static_cast<SQLiteMultiVerTransaction *>(transaction)->Initialize(uri_, false, StartWrite() local
188 int errCode = transaction->CommitTransaction(); CommitWritePhaseOne() local
210 int errCode = sqliteTransaction->ClearEntriesByVersion(versionInfo); RollbackWritePhaseOne() local
228 int errCode = static_cast<SQLiteMultiVerTransaction *>(transaction)->RollBackTransaction(); RollbackWrite() local
244 StartRead(KvDataType dataType, const Version &versionInfo, int &errCode) StartRead() argument
333 int errCode = SQLiteUtils::OpenDatabase(option, db); RunRekeyLogic() local
357 int errCode = SQLiteUtils::OpenDatabase(option, db); RunExportLogic() local
381 int errCode = DBCommon::CopyFile(currentDb, dstDb); BackupCurrentDatabase() local
394 int errCode = SQLiteUtils::ExportDatabase(srcDb, property.cipherType, passwd, currentDb, property.passwd); ImportDatabase() local
[all...]
H A Dsqlite_single_ver_continue_token.cpp151 int &errCode = res.first; in GetCloudQueryStmt() local
171 int errCode = E_OK; in ReleaseCloudQueryStmt() local
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/
H A Dremote_executor_packet.cpp288 int errCode = rowDataSet_.DeSerialize(parcel); in DeSerialization() local
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/fuzztest/common/
H A Ddistributeddb_tools_test.cpp210 int errCode = sqlite3_exec(db, sql.c_str(), nullptr, nullptr, &errMsg); in ExecSql() local
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/communicator/
H A Ddistributeddb_communicator_deep_test.cpp59 bool errCode = SetUpEnv(g_envDeviceA, DEVICE_NAME_A); in SetUpTestCase() local
173 int errCode = g_commAB->SendMessage(DEVICE_NAME_B, msgForAB, conf); in HWTEST_F() local
206 int errCode = eachBuff->AllocBufferByTotalLength(100, 0); // 100 totallen without header CreateBufferThenAddIntoScheduler() local
238 int errCode = CreateBufferThenAddIntoScheduler(scheduler, DEVICE_NAME_A, Priority::LOW); HWTEST_F() local
349 int errCode = g_commAB->SendMessage(DEVICE_NAME_B, sendMsgForAB, conf); HWTEST_F() local
410 int errCode = g_commBC->SendMessage(DEVICE_NAME_C, sendMsgForBC, conf); HWTEST_F() local
481 int errCode = g_commAB->SendMessage(DEVICE_NAME_B, sendMsgForAB, conf); HWTEST_F() local
539 int errCode = g_commAB->SendMessage(DEVICE_NAME_B, sendMsg, conf); HWTEST_F() local
[all...]
H A Ddistributeddb_communicator_send_receive_test.cpp55 bool errCode = SetUpEnv(g_envDeviceA, DEVICE_NAME_A); in SetUpTestCase() local
162 int errCode = g_commAA->SendMessage(DEVICE_NAME_B, msgForAA, conf); in HWTEST_F() local
213 int errCode = g_commAA->SendMessage(DEVICE_NAME_B, msgForAA, conf); in HWTEST_F() local
243 int errCode = g_commAA->SendMessage(DEVICE_NAME_B, msgForAA, conf); HWTEST_F() local
290 int errCode = g_commBA->SendMessage(DEVICE_NAME_A, msgForBA, conf); HWTEST_F() local
475 int errCode = g_commBA->SendMessage(DEVICE_NAME_A, msgForBA, conf); HWTEST_F() local
536 int errCode = g_commBA->SendMessage(DEVICE_NAME_A, msgForBA, conf); HWTEST_F() local
597 int errCode = g_commAA->SendMessage(DEVICE_NAME_B, msgForAA, conf, sendResultNotifier); HWTEST_F() local
657 int errCode = g_commBB->SendMessage(DEVICE_NAME_A, msgForBB, conf); HWTEST_F() local
738 int errCode = g_commAA->SendMessage(DEVICE_NAME_B, msgForAA, conf); HWTEST_F() local
[all...]
H A Ddistributeddb_communicator_common.h106 auto errCode = memcpy_s(data, totalLen, &info, sizeof(ExtendHeadInfo)); variable
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/
H A Dkv_store_delegate_impl.cpp59 int errCode = conn_->Put(option, key, value); in Put() local
76 int errCode = conn_->PutBatch(option, entries); in PutBatch() local
93 int errCode = conn_->Delete(option, key); in Delete() local
110 int errCode = conn_->DeleteBatch(option, keys); DeleteBatch() local
127 int errCode = conn_->Clear(option); Clear() local
161 int errCode = conn_->GetSnapshot(snapshot); GetKvStoreSnapshot() local
223 int errCode = E_OK; RegisterObserver() local
262 int errCode = conn_->UnRegisterObserver(observerHandle); UnRegisterObserver() local
278 int errCode = conn_->StartTransaction(); StartTransaction() local
293 int errCode = conn_->Commit(); Commit() local
308 int errCode = conn_->RollBack(); Rollback() local
333 int errCode = conn_->Rekey(password); Rekey() local
368 int errCode = conn_->Export(canonicalUrl, passwd); Export() local
398 int errCode = conn_->Import(canonicalUrl, passwd); Import() local
418 int errCode = KvDBManager::ReleaseDatabaseConnection(conn_); Close() local
436 int errCode; Pragma() local
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/kv/
H A Dsync_able_kvdb_connection.cpp94 int errCode = PragmaParamCheck(cmd, parameter); Pragma() local
170 int errCode = kvDB->Sync(syncParam, GetConnectionId()); PragmaSyncAction() local
197 int errCode = kvDB->CancelSync(syncId); CancelDeviceSync() local
327 int errCode = E_OK; SetRemotePushFinishedNotify() local
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/multiver/
H A Dmulti_ver_vacuum.cpp276 int errCode = SearchVacuumTaskToExecute(nextDatabase); in VacuumTaskExecutor() local
299 int errCode = inTask.databaseHandle->GetVacuumAbleCommits(inTask.leftBranchCommits, inTask.rightBranchCommits); in ExecuteSpecificVacuumTask() local
310 int errCode = DealWithLeftBranchCommit(inTask); in ExecuteSpecificVacuumTask() local
319 int errCode = DealWithRightBranchCommit(inTask); in ExecuteSpecificVacuumTask() local
327 int errCode = CommitTransactionIfNeed(inTask); ExecuteSpecificVacuumTask() local
352 int errCode = DoCommitAndQuitIfWaitStatusObserved(inTask); DealWithLeftBranchVacuumNeedRecord() local
421 int errCode = DoCommitAndQuitIfWaitStatusObserved(inTask); DoDealCommitOfLeftOrRight() local
473 int errCode = DoCommitAndQuitIfWaitStatusObserved(inTask); DoDeleteRecordOfLeftShadowOrRightVacuumNeed() local
520 int errCode = CommitTransactionIfNeed(inTask); DoCommitAndQuitIfWaitStatusObserved() local
542 int errCode = inTask.databaseHandle->StartTransactionForVacuum(); StartTransactionIfNotYet() local
557 int errCode = inTask.databaseHandle->CommitTransactionForVacuum(); CommitTransactionIfNeed() local
571 int errCode = inTask.databaseHandle->RollBackTransactionForVacuum(); RollBackTransactionIfNeed() local
646 int errCode = RuntimeContext::GetInstance()->ScheduleTask(backgroundTask); ActivateBackgroundVacuumTaskExecution() local
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/
H A Dicloud_syncer.h36 int errCode = 0; member
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/interfaces/
H A Ddistributeddb_interfaces_single_version_result_set_test.cpp113 int errCode = E_OK; in SetUp() local
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/
H A Ddistributeddb_relational_encrypted_db_test.cpp76 int errCode = E_OK; in GetRelationalStore() local
H A Ddistributeddb_file_package_test.cpp51 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 Ddistributeddb_query_object_helper_test.cpp55 int errCode = E_OK; in GetQuerySql() local
175 int errCode = E_OK; in HWTEST_F() local
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/
H A Ddistributeddb_anti_dos_sync_test.cpp189 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 Ddatashare_proxy.cpp301 int32_t errCode = -1; in InsertEx() local
333 int32_t errCode = -1; in UpdateEx() local
364 int32_t errCode = -1; in DeleteEx() local
[all...]

Completed in 28 milliseconds

1...<<31323334353637383940>>...70