Home
last modified time | relevance | path

Searched defs:errCode (Results 701 - 725 of 1383) sorted by relevance

1...<<21222324252627282930>>...56

/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/communicator/src/
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/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...]
H A Dmulti_ver_natural_store_connection.cpp43 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/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...]
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/rdb/
H A Drdb_cloud.cpp341 auto errCode = Traits::get_if<int64_t>(&(errorField->second)); in ConvertErrorField() local
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/
H A Dplatform_specific.cpp62 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 Dparcel.cpp89 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/sqlite/relational/
H A Dsqlite_relational_utils.cpp31 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 Dmulti_ver_sync_state_machine.cpp67 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...]

Completed in 15 milliseconds

1...<<21222324252627282930>>...56