Home
last modified time | relevance | path

Searched defs:errCode (Results 1351 - 1375 of 1747) sorted by relevance

1...<<51525354555657585960>>...70

/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/cloud/
H A Ddistributeddb_cloud_save_cloud_data_test.cpp188 int errCode = E_OK; in PrepareDataBaseForAsset() local
211 int errCode = E_OK; in GetRelationalStore() local
873 int errCode = RelationalTestUtils::ExecSql(db, sql, nullptr, [] (sqlite3_stmt *stmt) { in HWTEST_F() local
1113 int errCode = RelationalTestUtils::ExecSql(db, sql, nullptr, [&count] (sqlite3_stmt *stmt) { in HWTEST_F() local
1208 int errCode in HWTEST_F() local
1276 int errCode = RelationalTestUtils::ExecSql(db, sql, nullptr, [&count] (sqlite3_stmt *stmt) { DeleteWithPkTest() local
1346 int errCode = RelationalTestUtils::ExecSql(db, sql, nullptr, [&count] (sqlite3_stmt *stmt) { HWTEST_F() local
1388 int errCode = storageProxy->StartTransaction(); HWTEST_F() local
1504 int errCode = RelationalTestUtils::ExecSql(db, sql, nullptr, [] (sqlite3_stmt *stmt) { HWTEST_F() local
[all...]
H A Ddistributeddb_cloud_assets_operation_sync_test.cpp210 int errCode; in InsertUserTableRecord() local
451 int errCode; in HWTEST_F() local
541 int errCode; in HWTEST_F() local
643 int errCode; in InsertLocalAssetData() local
H A Ddistributeddb_cloud_reference_sync_test.cpp388 int errCode; in CheckDistributedSharedData() local
407 int errCode; in CheckSharedDataAfterUpdated() local
893 int errCode; in HWTEST_F() local
949 int errCode; in HWTEST_F() local
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/
H A Dtime_sync.cpp196 int errCode = timeHelper_->Initialize(storage, metadata_); in Initialize() local
247 int errCode = message->SetCopiedObject<>(packet); in SyncStart() local
291 int errCode = parcel.WriteUInt32(TIME_SYNC_VERSION_V1); Serialization() local
397 int errCode = SaveOffsetWithAck(packetData); AckRecv() local
434 int errCode = ackMessage->SetCopiedObject<>(ackPacket); RequestRecv() local
488 int errCode = communicateHandle_->SendMessage(deviceId, message, conf, handler); SendPacket() local
504 int errCode = RuntimeContext::GetInstance()->ScheduleTask([this]() { TimeSyncDriver() local
527 int errCode = SyncStart(handler, sessionId); GetTimeOffset() local
563 CommErrHandlerFunc(int errCode, TimeSync *timeSync) CommErrHandlerFunc() argument
594 int errCode = RuntimeContext::GetInstance()->SetTimer( ResetTimer() local
635 handler(errCode); SendMessageWithSendEnd() variable
[all...]
H A Dremote_executor.cpp75 int errCode = E_OK; in RemoteQuery() local
109 int errCode = RuntimeContext::GetInstance()->ScheduleTask([this, targetDev, inMsg]() { in ReceiveMessage() local
206 int errCode = CheckPermissions(device, inMsg); in ParseOneRequestMessage() local
229 int errCode = RuntimeContext::GetInstance()->RunPermissionCheck( CheckPermissions() local
269 int errCode = ResponseRemoteQueryRequest(storage, requestPacket->GetPreparedStmt(), device, inMsg->GetSessionId()); SendRemoteExecutorData() local
281 int errCode = packet->GetAckCode(); ReceiveRemoteExecutorAck() local
324 int errCode = communicator->GetLocalIdentity(localId); CheckParamValid() local
406 int errCode = RuntimeContext::GetInstance()->ScheduleTask([this, device]() { RemoteQueryInner() local
442 int errCode = RequestStart(sessionId); TryExecuteTaskInLock() local
492 int errCode = FillRequestPacket(packet, sessionId, target); RequestStart() local
522 int errCode = communicator->SendMessage(target, message, sendConfig, [this, sessionId](int errCode) { SendRequestMessage() local
537 ResponseFailed(int errCode, uint32_t sessionId, uint32_t sequenceId, const std::string &device) ResponseFailed() argument
585 int errCode = message->SetExternalObject(exObj); ResponseStart() local
621 int errCode = RuntimeContext::GetInstance()->SetTimer(timeout, timeoutCallBack, [this]() { StartTimer() local
653 int errCode = RuntimeContext::GetInstance()->ScheduleTask([this, timerId]() { TimeoutCallBack() local
678 DoSendFailed(uint32_t sessionId, int errCode) DoSendFailed() argument
684 DoFinished(uint32_t sessionId, int errCode) DoFinished() argument
747 int errCode = storage->GetSecurityOption(localOption); FillRequestPacket() local
778 int errCode = E_OK; ReceiveMessageInner() local
867 RemoveAllTask(int errCode) RemoveAllTask() argument
942 int errCode = GetPacketSize(device, packetSize); ResponseRemoteQueryRequest() local
990 int errCode = storage->GetSecurityOption(localOption); CheckSecurityOption() local
1009 int errCode = storage->GetSecurityOption(localOption); CheckRemoteRecvData() local
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/
H A Ddistributeddb_storage_transaction_data_test.cpp76 int errCode = g_transaction->Initialize(dir, true, CipherType::AES_256_GCM, passwd); in GetReadTransaction() local
103 int errCode = g_naturalStore->PutCommitData(multiVerCommit, entries, "deviceB"); in RunSyncMergeForOneCommit() local
138 int errCode = commitStorage->Open(property); in GetCommitTimestamp() local
220 int errCode = g_naturalStoreConnection->Get(option, key, valueRead); ValueEqualByKey() local
266 int errCode = 0; SetUp() local
1374 int errCode = g_naturalStore->PutCommitData(multiVerCommit, entries, "deviceB"); PutFirstSyncCommitData() local
1403 int errCode = g_naturalStore->PutCommitData(newCommit, entries, "deviceB"); PutSecondSyncCommitData() local
[all...]
H A Ddistributeddb_storage_single_ver_upgrade_test.cpp226 int errCode = RuntimeContext::GetInstance()->GetSecurityOption(g_maindbPath, checkSecOpt); in CheckSecOpt() local
289 int errCode = g_passwd.SetValue(passwdBuffer1.data(), passwdBuffer1.size()); in SetUpTestCase() local
H A Ddistributeddb_storage_single_ver_natural_store_testcase.cpp206 int errCode = DistributedDBToolsUnitTest::GetSyncDataNextTest(store, 30 * 1024, dataItems, token); // 30k block in GetSyncData004() local
1663 int errCode = E_OK; in TestMetaDataPutAndGet() local
H A Ddistributeddb_storage_register_observer_test.cpp87 int errCode; in TestFunc() local
305 int errCode = g_singleVerNaturaStore->Open(property); in SetUp() local
[all...]
H A Ddistributeddb_relational_get_data_test.cpp56 int errCode = sqlite3_open(g_storePath.c_str(), &db); in CreateDBAndTable() local
78 int errCode = sqlite3_open(g_storePath.c_str(), &db); in AddOrUpdateRecord() local
99 int errCode = sqlite3_open(g_storePath.c_str(), &db); GetLogData() local
144 int errCode = E_OK; GetRelationalStore() local
156 int errCode = SQLiteUtils::GetStatement(db, sql, stmt); GetCount() local
180 int errCode = SQLiteUtils::GetStatement(db, sql, stmt); GetOneText() local
197 int errCode = sqlite3_open(g_storePath.c_str(), &db); PutBatchData() local
388 int errCode = store->GetSyncData(query, SyncTimeRange {}, sizeInfo, token, entries); HWTEST_F() local
575 int errCode = store->GetSyncData(query, SyncTimeRange {}, DataSizeSpecInfo {}, token, entries); HWTEST_F() local
1279 int errCode = store->GetSyncData(query, {}, sizeInfo, token, entries); HWTEST_F() local
1640 int errCode = E_OK; HWTEST_F() local
1703 int errCode = E_OK; HWTEST_F() local
1762 int errCode = sqliteStorageEngine->InitSQLiteStorageEngine(poolSize, option, hashIdentifier); HWTEST_F() local
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/
H A Dvirtual_single_ver_sync_db_Interface.cpp35 int errCode = E_OK; in GetEntriesFromItems() local
157 int errCode = DataControl(); in GetUnSyncTotal() local
282 int errCode = GetSyncData(begin, end, dataSizeInfo, dataItems, continueStmtToken); in GetSyncData() local
300 int errCode = DataControl(); GetSyncDataNext() local
328 int errCode = DataControl(); GetSyncData() local
460 int errCode = DataControl(); GetSyncData() local
609 SetGetDataErrCode(int whichTime, int errCode, bool isGetDataControl) SetGetDataErrCode() argument
[all...]
H A Dvirtual_relational_ver_sync_db_interface.cpp28 int errCode = E_OK; in GetEntriesFromItems() local
93 int errCode = DataTransformer::TransformDataItem(dataItems, localFieldInfo_, optTableDataWithLog); in PutSyncDataWithQuery() local
150 int errCode in GetSyncData() local
376 int errCode = RuntimeContext::GetInstance()->GetSecurityOption("", option); GetSecurityOption() local
[all...]
H A Ddistributeddb_single_ver_p2p_query_sync_test.cpp746 int errCode = SingleVerSerializeManager::Serialization(buffer, len, &msg); in HWTEST_F() local
787 int errCode = meta.Initialize(&storage); in HWTEST_F() local
868 int errCode = meta.Initialize(&storage); in HWTEST_F() local
910 int errCode = meta.Initialize(&storage); in HWTEST_F() local
941 int errCode = meta.Initialize(&storage); HWTEST_F() local
986 int errCode = meta.Initialize(&storage); HWTEST_F() local
1042 int errCode = meta.Initialize(&storage); HWTEST_F() local
1092 int errCode = meta.Initialize(&storage); HWTEST_F() local
1123 int errCode = meta.Initialize(&storage); HWTEST_F() local
1195 int errCode = meta.Initialize(&storage); HWTEST_F() local
1276 int errCode = meta.Initialize(&storage); HWTEST_F() local
1322 int errCode = meta.Initialize(&storage); HWTEST_F() local
1378 int errCode = meta.Initialize(&storage); HWTEST_F() local
1626 int errCode = meta.Initialize(&storage); HWTEST_F() local
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/
H A Dsqlite_single_ver_storage_engine.cpp65 int errCode = kvStore->EraseDeviceWaterMark(devId, isNeedHash); in EraseDeviceWaterMark() local
85 int errCode = handle->GetExistsDevicesFromMeta(removeDevices); in GetRemoveDataDevices() local
102 int errCode = E_OK; in EraseDeviceWaterMark() local
152 int errCode = handle->GetMinVersionCacheData(dataItems, minVerIncurCacheDb); MigrateSyncDataByVersion() local
195 int errCode = ReleaseExecutor(handle); ReleaseHandleTransiently() local
219 int errCode = E_OK; AddSubscribeToMainDBInMigrate() local
245 int errCode = E_OK; MigrateSyncData() local
294 int errCode = E_OK; AttachMainDbAndCacheDb() local
326 int errCode = E_OK; AttachMainDbAndCacheDb() local
372 int errCode; FinishMigrateData() local
432 int errCode = E_OK; InitExecuteMigrate() local
469 int errCode = E_OK; ExecuteMigrate() local
517 EndMigrate(SQLiteSingleVerStorageExecutor *&handle, EngineState stateBeforeMigrate, int errCode, bool isNeedTriggerSync) EndMigrate() argument
560 int errCode = executor->CreateCloudLogTable(); NewSQLiteStorageExecutor() local
587 int errCode = SQLiteUtils::OpenDatabase(optionTemp, db); TryToOpenMainDatabase() local
618 int errCode = TryToOpenMainDatabase(isWrite, dbHandle); GetDbHandle() local
691 int errCode = SQLiteUtils::OpenDatabase(option, db); GetCacheDbHandle() local
740 int errCode = CheckStoreStatus(option_); PreCreateExecutor() local
783 int errCode = SQLiteSingleVerDatabaseUpgrader::SetSecOption(option_.subdir, option_.securityOpt, EndCreateExecutor() local
819 int errCode = AttachMetaDatabase(dbHandle, option_); TryAttachMetaDb() local
834 int errCode = PreCreateExecutor(isWrite, existedSecOpt); CreateNewExecutor() local
894 int errCode = schema.ParseFromSchemaString(option_.schema); Upgrade() local
906 int errCode = E_OK; Upgrade() local
942 int errCode = SQLiteUtils::GetSchema(dbHandle, schemaStr); RegisterFunctionIfNeed() local
949 int errCode = SQLiteUtils::RegisterFlatBufferFunction(dbHandle, schemaStr); RegisterFunctionIfNeed() local
957 int errCode = SQLiteUtils::RegisterMetaDataUpdateFunction(dbHandle); RegisterFunctionIfNeed() local
965 int errCode; AttachMetaDatabase() local
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/communicator/
H A Dadapter_stub.cpp87 int errCode = onSendBytes_(); in SendBytes() local
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/interfaces/
H A Ddistributeddb_interfaces_relational_sync_test.cpp227 int errCode = delegate->Sync(devices, SyncMode::SYNC_MODE_PUSH_ONLY, query, in HWTEST_F() local
246 int errCode = delegate->Sync(devices, SyncMode::SYNC_MODE_PUSH_ONLY, query, in HWTEST_F() local
265 int errCode = delegate->Sync(devices, SyncMode::SYNC_MODE_PUSH_ONLY, query, in HWTEST_F() local
284 int errCode = delegate->Sync(devices, SyncMode::SYNC_MODE_PUSH_ONLY, query, in HWTEST_F() local
306 int errCode = delegate->Sync(devices, SyncMode::SYNC_MODE_PUSH_ONLY, query, in HWTEST_F() local
325 int errCode = delegate->Sync(devices, SyncMode::SYNC_MODE_PUSH_ONLY, query, HWTEST_F() local
350 int errCode = delegate->Sync(devices, SyncMode::SYNC_MODE_PUSH_ONLY, query, HWTEST_F() local
380 int errCode = delegate->Sync(devices, SyncMode::SYNC_MODE_PUSH_ONLY, query, HWTEST_F() local
465 int errCode = delegate->Sync(devices, SyncMode::SYNC_MODE_PUSH_ONLY, query, HWTEST_F() local
538 int errCode = RelationalTestUtils::ExecSql(db, "SELECT sql FROM sqlite_master WHERE type = ? AND name = ?", HWTEST_F() local
622 int errCode = delegate->Sync(devices, SyncMode::SYNC_MODE_PUSH_ONLY, query, HWTEST_F() local
648 int errCode = delegate->Sync(devices, SyncMode::SYNC_MODE_PUSH_ONLY, query, HWTEST_F() local
674 int errCode = delegate->Sync(devices, SyncMode::SYNC_MODE_PUSH_ONLY, query, HWTEST_F() local
700 int errCode = delegate->Sync(devices, SyncMode::SYNC_MODE_PUSH_ONLY, query, HWTEST_F() local
920 int errCode = delegate->Sync(devices, SyncMode::SYNC_MODE_PUSH_ONLY, query, HWTEST_F() local
1013 int errCode = delegate->Sync(devices, SyncMode::SYNC_MODE_PULL_ONLY, query, HWTEST_F() local
1087 int errCode = delegate->Sync(devices, SyncMode::SYNC_MODE_PUSH_ONLY, query, HWTEST_F() local
[all...]
H A Ddistributeddb_interfaces_data_operation_test.cpp1258 int errCode = g_kvNbDelegatePtrForQuery->GetEntries(query, entries); in HWTEST_F() local
1313 int errCode = g_kvNbDelegatePtrForQuery->GetEntries(query, entriesRes); in HWTEST_F() local
1394 int errCode = g_kvNbDelegatePtrForQuery->GetEntries(query, entriesRes); HWTEST_F() local
1456 int errCode = g_kvNbDelegatePtrForQuery->GetEntries(query, entriesRes); HWTEST_F() local
1513 int errCode = g_kvNbDelegatePtrForQuery->GetEntries(query, entries); HWTEST_F() local
1592 int errCode = g_kvNbDelegatePtrForQuery->GetEntries(query, entries); HWTEST_F() local
1658 int errCode = g_kvNbDelegatePtrForQuery->GetEntries(query, entries); HWTEST_F() local
1696 int errCode = g_kvNbDelegatePtrForQuery->GetEntries(query, entries); HWTEST_F() local
1741 int errCode = g_kvNbDelegatePtrForQuery->GetEntries(query, entriesRes); HWTEST_F() local
1792 int errCode = g_kvNbDelegatePtrForQuery->GetEntries(query1, entriesRes); HWTEST_F() local
1955 int errCode = g_kvNbDelegatePtrForQuery->GetEntries(query1, entriesRes); HWTEST_F() local
2019 int errCode = g_kvNbDelegatePtrForQuery->GetEntries(query, entriesRes); HWTEST_F() local
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/kv/
H A Dsync_able_kvdb.cpp89 int errCode = StartSyncer(); in Sync() local
168 int errCode = E_OK; in StartSyncer() local
189 int errCode = syncer_.Initialize(syncInterface, isNeedActive); in StartSyncerWithNoLock() local
334 int errCode = StartSyncer(); in EraseDeviceWaterMark() local
386 int errCode = notifyChain_->RegisterEventType(type); RegisterEventType() local
398 AddRemotePushFinishedNotify(const RemotePushFinishedNotifier &notifier, int &errCode) AddRemotePushFinishedNotify() argument
494 int errCode = StartSyncer(); GetHashDeviceId() local
614 int errCode = CheckSyncOption(option, *syncer); Sync() local
633 int errCode = syncer->SetCloudDB(cloudDBs); SetCloudDB() local
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/
H A Dsingle_ver_serialize_manager.cpp149 int errCode; in CalculateDataLen() local
174 int errCode; in CalculateControlLen() local
233 int errCode = parcel.WriteUInt32(packet->GetVersion()); DataPacketSerialization() local
273 int errCode = parcel.WriteUInt64(packet->GetDeletedWaterMark()); DataPacketQuerySyncSerialization() local
383 int errCode = DataPacketSyncerPartDeSerialization(parcel, packet, packLen, length, version); DataPacketDeSerialization() local
419 int errCode = E_OK; DataPacketQuerySyncDeSerialization() local
440 int errCode = GenericSingleVerKvEntry::DeSerializeCompressedDatas(originalData, parcel); DataPacketCompressDataDeSerialization() local
512 int errCode = AckPacketSyncerPartDeSerializationV1(parcel, packet); AckPacketDeSerialization() local
523 int32_t errCode; AckPacketSyncerPartDeSerializationV1() local
569 int errCode = ControlRequestDeSerialization(parcel, packet); ControlPacketDeSerialization() local
624 int errCode; AckControlPacketDeSerialization() local
698 int errCode = ControlRequestSerialization(parcel, inMsg); SubscribeSerialization() local
720 int errCode = QuerySyncObject::DeSerializeData(parcel, querySyncObj); SubscribeDeSerialization() local
752 int errCode = E_OK; RegisterCommunicatorTransformFunc() local
797 int errCode = E_OK; ISyncPacketSerialization() local
813 int errCode = BuildISyncPacket(inMsg, packet); ISyncPacketDeSerialization() local
909 int errCode = E_OK; DataPacketInnerDeSerialization() local
958 int errCode = DataPacketExtraConditionsSerialization(parcel, packet); DataPacketInnerSerialization() local
[all...]
H A Dsingle_ver_data_sync_utils.cpp102 int errCode = storage->CheckAndInitQueryCondition(syncQuery); in RequestQueryCheck() local
126 int errCode = storage->GetSecurityOption(localSecOption); in IsPermitRemoteDeviceRecvData() local
191 void SingleVerDataSyncUtils::TranslateErrCodeIfNeed(int mode, uint32_t version, int &errCode) in TranslateErrCodeIfNeed() argument
234 int errCode = storage->GetSecurityOption(localOption); CheckPermitReceiveData() local
386 IsGetDataSuccessfully(int errCode) IsGetDataSuccessfully() argument
499 int errCode = RuntimeContext::GetInstance()->RunPermissionCheck(param, flag); RunPermissionCheckInner() local
532 int errCode = metadata->SaveClientId(context.GetDeviceId(), clientId); RecordClientId() local
597 int errCode; GetUnsyncTotal() local
[all...]
H A Dsingle_ver_data_packet.cpp86 void DataRequestPacket::SetSendCode(int32_t errCode) in SetSendCode() argument
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/gaussdb_rd/test/unittest/api/
H A Ddocumentdb_find_test.cpp95 int errCode; in CompareValue() local
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/multiver/
H A Dmulti_ver_natural_store_commit_storage.cpp60 int errCode = GetVersion(property, dbVer, isDbExist); in CheckVersion() local
92 int errCode = localKvdb->GetVersion(dbProperties, version, isDbExisted); in GetVersion() local
108 int errCode = E_OK; in Open() local
170 int errCode = KvDBUtils::RemoveKvDB(dataDir, DBConstant::MULTI_VER_COMMIT_STORE); Remove() local
253 int errCode = GetAllCommits(commitsTable, headerId); GetAllCommitsInTree() local
302 int errCode = CheckAddedCommit(commitEntry); AddCommit() local
344 int errCode = commitStorageDBConnection_->StartTransaction(); RemoveCommit() local
403 int errCode = E_OK; SetHeader() local
493 int errCode = GetAllCommits(commits, headerId); GetLatestCommits() local
586 int errCode = GetAllCommits(allCommits, header); GetCommitTree() local
633 int errCode = static_cast<SQLiteLocalKvDB *>(commitStorageDatabase_)->RunRekeyLogic(type, passwd); RunRekeyLogic() local
645 int errCode = static_cast<SQLiteLocalKvDB *>(commitStorageDatabase_)->RunExportLogic(type, passwd, newDbName); RunExportLogic() local
671 int errCode = parcel.WriteUInt64(commit.GetTimestamp()); TransferCommitToValue() local
779 int errCode = commitStorageDBConnection_->GetEntries(option, keyPrefix, entries); GetAllCommits() local
823 int errCode = commitStorageDBConnection_->Put(option, key, value); SetHeaderInner() local
841 int errCode = E_OK; CheckAddedCommit() local
896 int errCode = SQLiteLocalKvDB::BackupCurrentDatabase(dbProperties, dir); BackupCurrentDatabase() local
910 int errCode = SQLiteLocalKvDB::ImportDatabase(dbProperties, dir, passwd); ImportDatabase() local
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/
H A Dsqlite_single_relational_storage_engine.cpp44 int errCode = CreateRelationalMetaTable(db); in Upgrade() local
56 int errCode = SQLiteUtils::RegisterCalcHash(db); in RegisterFunction() local
96 int errCode = SQLiteUtils::OpenDatabase(option_, db, false); CreateNewExecutor() local
158 int errCode = handle->PutKvData(schemaKey, schemaVal); // save schema to meta_data SaveSchemaToMetaTable() local
172 int errCode = handle->PutKvData(schemaKey, schemaVal); // save schema to meta_data SaveTrackerSchemaToMetaTable() local
186 int errCode = handle->PutKvData(key, value); SaveSyncTableTypeAndDropFlagToMeta() local
214 int errCode = UpgradeDistributedTable(tableName, schemaChanged, syncType); CreateDistributedTable() local
227 int errCode = CreateDistributedTable(tableName, isUpgraded, identity, schema, syncType); CreateDistributedTable() local
254 int errCode = CreateDistributedTable(handle, isUpgraded, "", table, schema); CreateDistributedSharedTable() local
268 int errCode = E_OK; CreateDistributedTable() local
312 int errCode = handle->CreateDistributedTable(mode, isUpgraded, identity, table, tableSyncType); CreateDistributedTable() local
341 int errCode = E_OK; UpgradeDistributedTable() local
382 int errCode = E_OK; CleanDistributedDeviceTable() local
448 int errCode = SQLiteUtils::ExecuteRawSQL(db, sql); CreateRelationalMetaTable() local
457 int errCode = E_OK; SetTrackerTable() local
512 int errCode = E_OK; CheckAndCacheTrackerSchema() local
546 int errCode = E_OK; GetOrInitTrackerSchemaFromMeta() local
582 int errCode = E_OK; SaveTrackerSchema() local
601 int errCode = E_OK; ExecuteSql() local
656 int errCode = CheckReference(tableReferenceProperty, schema); SetReference() local
695 int errCode = E_OK; CleanTrackerData() local
710 int errCode = E_OK; UpgradeSharedTable() local
743 int errCode = DoDeleteSharedTable(handle, deleteTableNames, schema); UpgradeSharedTableInner() local
779 int errCode = handle->DeleteTable(deleteTableNames); DoDeleteSharedTable() local
813 int errCode = handle->UpdateSharedTable(updateTableNames); DoUpdateSharedTable() local
837 int errCode = handle->AlterTableName(alterTableNames); DoAlterSharedTableName() local
892 int errCode = handle->CreateSharedTable(tableSchema); DoCreateSharedTable() local
928 int errCode = handle->DeleteMetaData(keys); UpdateKvData() local
947 int errCode = handle->CheckIfExistUserTable(tableSchema.sharedTableName); CheckIfExistUserTable() local
994 int errCode = handle->CheckAndCleanDistributedTable(tableNames, missingTrackerTables); CleanTrackerDeviceTable() local
1017 int errCode = E_OK; GenLogInfoForUpgrade() local
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/
H A Dcloud_db_proxy.cpp77 int errCode = CloudStorageUtils::GetValueFromVBucket<int64_t>(CloudDbConstant::MODIFY_FIELD, data[0], first); in RecordSyncDataTimeStampLog() local
106 int errCode = InnerAction(context, cloudDb, INSERT); in BatchInsert() local
123 int errCode = InnerAction(context, cloudDb, UPDATE); in BatchUpdate() local
140 int errCode = InnerAction(context, cloudDb, DELETE); BatchDelete() local
156 int errCode = InnerAction(context, cloudDb, QUERY); Query() local
180 int errCode = InnerAction(context, cloudDb, LOCK); Lock() local
314 int errCode = InnerAction(context, cloudDb, GET_EMPTY_CURSOR); GetEmptyCursor() local
[all...]

Completed in 38 milliseconds

1...<<51525354555657585960>>...70