| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/evloop/src/ |
| H A D | event_loop_epoll.cpp | 46 int errCode; in Initialize() local
96 int errCode = -errno; Poll() local
127 int errCode = -errno; WakeUp() local
159 int errCode = -errno; EpollWokenUp() local
222 int errCode = epoll_ctl(epollFd_, operation, fd, &epollEvent); EpollCtl() local
237 int errCode = EpollCtl(EPOLL_CTL_ADD, event, events); AddEvent() local
254 int errCode = EpollCtl(EPOLL_CTL_DEL, event, events); RemoveEvent() local
277 int errCode = EpollCtl(EPOLL_CTL_MOD, event, newEvents); ModifyEvent() local
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/ |
| H A D | task_pool_impl.cpp | 56 int errCode = SpawnThreads(true); in Start() local
|
| H A D | time_tick_monitor.cpp | 45 int errCode = PrepareNotifierChain(); in StartTimeTickMonitor() local
83 RegisterTimeChangedLister(const TimeChangedAction &action, const TimeFinalizeAction &finalize, int &errCode) RegisterTimeChangedLister() argument
111 int errCode = timeChangedNotifier_->RegisterEventType(TIME_CHANGE_EVENT); PrepareNotifierChain() local
161 int errCode = OS::GetCurrentSysTimeInMicrosecond(curTime); GetSysCurrentTime() local
172 int errCode = OS::GetMonotonicRelativeTimeInMicrosecond(time); GetMonotonicTime() local
[all...] |
| H A D | runtime_context_impl.cpp | 128 int errCode = communicatorAggregator_->Initialize(adapter_, statusAdapter); in GetCommunicatorAggregator() local
168 int errCode = SetTimerByThreadPool(milliSeconds, action, finalizer, true, timerId); in SetTimer() local
222 int errCode = ModifyTimerByThreadPool(timerId, milliSeconds); ModifyTimer() local
268 int errCode = PrepareTaskPool(); ScheduleTask() local
292 int errCode = PrepareTaskPool(); ScheduleQueuedTask() local
[all...] |
| H A D | schema_negotiate.cpp | 57 int errCode = remoteSchemaObj.ParseFromSchemaString(remoteSchema); in MakeLocalSyncOpinion() local
108 int errCode = it.second.CompareWithTable(remoteSchema.GetTable(it.first), localSchema.GetSchemaVersion()); in MakeOpinionEachTable() local
148 int errCode = remoteSchemaObj.ParseFromSchemaString(remoteSchema); MakeLocalSyncOpinion() local
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/src/ |
| H A D | communicator.cpp | 46 int errCode = RegCallBack(onConnect, onConnectHandle_, inOper, onConnectFinalizer_); in RegOnConnectCallback() local
125 int errCode = ProtocolProto::SetDivergeHeader(buffer, commLabel_); in SendMessage() local
222 int errCode = E_OK; TriggerVersionNegotiation() local
253 int errCode = E_OK; TriggerUnknownMessageFeedback() local
[all...] |
| H A D | frame_combiner.cpp | 35 int errCode = context->SetTimer(COMBINER_SURVAIL_PERIOD_IN_MILLISECOND, action, finalizer, timerId_); in Initialize() local
69 int errCode = ContinueExistCombineWork(bytes, length, inPacketInfo); in AssembleFrameFragment() local
87 int errCode in AssembleFrameFragment() local
138 int errCode = ProtocolProto::CombinePacketIntoFrame(oriWork.buffer, bytes, length, fragOffset, fragLength); ContinueExistCombineWork() local
154 int errCode = ProtocolProto::AnalyzeSplitStructure(inPacketInfo, fragLen, lastFragLen); CreateNewCombineWork() local
247 int errCode = buffer->AllocBufferByTotalLength(inInfo.GetFrameLen(), frameHeaderLength); CreateNewFrameBuffer() local
[all...] |
| H A D | send_task_scheduler.cpp | 56 int errCode = ScheduleOutSendTask(task, taskInfo, totalLength); in Finalize() local
95 int errCode = ScheduleOutSendTask(outTask, taskInfo, totalLength); in ScheduleOutSendTask() local
112 int errCode = ScheduleDelayTask(outTask, outTaskInfo); in ScheduleOutSendTask() local
123 int errCode = ScheduleNoDelayTask(outTask, outTaskInfo); in ScheduleOutSendTask() local
[all...] |
| H A D | frame_retainer.cpp | 47 int errCode = context->SetTimer(RETAIN_SURVAIL_PERIOD_IN_MILLISECOND, action, nullptr, timerId_); in Initialize() local
95 int errCode = work.buffer->ConvertForCrossThread(); in RetainFrame() local
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/gaussdb_rd/ |
| H A D | rd_single_ver_storage_engine.cpp | 95 int errCode = Init(true); in InitRdStorageEngine() local
142 int errCode = OpenGrdDb(optionTemp, db); in TryToOpenMainDatabase() local
155 int errCode = TryToOpenMainDatabase(isWrite, dbHandle); GetDbHandle() local
197 int errCode = RdDbOpen(option.uri.c_str(), option.rdConfig.c_str(), flag, db); OpenGrdDb() local
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/operation/ |
| H A D | multi_ver_database_oper.cpp | 65 bool MultiVerDatabaseOper::RekeyPreHandle(const CipherPassword &passwd, int &errCode) in RekeyPreHandle() argument
82 int errCode = GetCtrlFilePrefix(multiVerNaturalStore_->GetDbProperties(), filePrefix); in BackupDb() local
108 int errCode = RekeyRecover(multiVerNaturalStore_->GetDbProperties()); in CloseStorages() local
122 int errCode in RekeyPostHandle() local
132 int errCode = DBCommon::CreateDirectory(dbDir); ExportAllDatabases() local
172 int errCode = OS::CreateFileByFileName(info.curValidFile); BackupCurrentDatabase() local
224 int errCode = DBCommon::RemoveAllFilesOfDirectory(info.currentDir, false); ImportUnpackedDatabase() local
277 int errCode = multiVerData_->ImportDatabase(multiVerProp, dir, passwd); ImportDatabase() local
[all...] |
| H A D | local_database_oper.cpp | 54 bool LocalDatabaseOper::RekeyPreHandle(const CipherPassword &passwd, int &errCode) in RekeyPreHandle() argument
77 int errCode = GetCtrlFilePrefix(localKvDb_->GetDbProperties(), filePrefix); in BackupDb() local
102 int errCode = RekeyRecover(localKvDb_->GetDbProperties()); CloseStorages() local
131 int errCode = SQLiteUtils::ExportDatabase(currentDb, cipherType, currPasswd, backupDbName, passwd); ExportAllDatabases() local
142 int errCode = OS::CreateFileByFileName(info.curValidFile); BackupCurrentDatabase() local
176 int errCode = DBCommon::RemoveAllFilesOfDirectory(info.currentDir, false); ImportUnpackedDatabase() local
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/common/ |
| H A D | evloop_timer_unit_test.cpp | 56 int errCode = OS::GetCurrentSysTimeInMicrosecond(now); in GetCurrentTime() local
83 int errCode = E_OK; in SetUp() local
115 int errCode = E_OK; in HWTEST_F() local
177 int errCode = E_OK; in HWTEST_F() local
233 int errCode = E_OK; HWTEST_F() local
286 int errCode = E_OK; HWTEST_F() local
346 int errCode = E_OK; HWTEST_F() local
403 int errCode = E_OK; HWTEST_F() local
489 int errCode = E_OK; HWTEST_F() local
547 int errCode = E_OK; HWTEST_F() local
573 int errCode = E_OK; HWTEST_F() local
611 int errCode = E_OK; HWTEST_F() local
678 int errCode = E_OK; HWTEST_F() local
709 int errCode = E_OK; HWTEST_F() local
744 int errCode = E_OK; HWTEST_F() local
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/ |
| H A D | distributeddb_storage_transaction_record_test.cpp | 65 int errCode = g_transaction->Initialize(g_storeDir, false, CipherType::AES_256_GCM, passwd); in SetUp() local
|
| H A D | distributeddb_storage_sqlite_single_ver_storage_engine_test.cpp | 49 int errCode; in GetStorageEngine() local
184 int errCode = E_OK; in HWTEST_F() local
190 errCode); in HWTEST_F() local
[all...] |
| H A D | distributeddb_storage_resultset_and_json_optimize.cpp | 93 int errCode = E_OK; in SetUp() local
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
| H A D | virtual_time_sync_communicator.cpp | 99 int errCode; in SendMessage() local
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/relational/ |
| H A D | tracker_table.cpp | 268 int errCode = SQLiteUtils::GetStatement(db, "SELECT 1 FROM sqlite_temp_master where name='" + in ReBuildTempTrigger() local
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/ |
| H A D | single_ver_utils.cpp | 62 int errCode = DBCommon::RemoveAllFilesOfDirectory(dbSubDir); in ClearIncompleteDatabase() local
105 int errCode = RuntimeContext::GetInstance()->SetSecurityOption(option.subdir + "/" + item, secOption); in CreateNewDirsAndSetSecOption() local
126 int errCode; in GetExistedSecOpt() local
176 int errCode = SQLiteUtils::OpenDatabase(checkOpt, db); CheckStoreStatus() local
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/ |
| H A D | sqlite_local_storage_executor.cpp | 50 int errCode = SQLiteUtils::GetStatement(dbHandle_, SELECT_SQL, statement); in Get() local
77 int errCode = SQLiteUtils::ExecuteRawSQL(dbHandle_, CLEAR_SQL); Clear() local
85 int errCode = SQLiteUtils::GetStatement(dbHandle_, SELECT_BATCH_SQL, statement); GetEntries() local
138 int errCode = Put(entry.key, entry.value); PutBatch() local
157 int errCode = Delete(key); DeleteBatch() local
175 int errCode = SQLiteUtils::BeginTransaction(dbHandle_); StartTransaction() local
181 int errCode = SQLiteUtils::CommitTransaction(dbHandle_); Commit() local
187 int errCode = SQLiteUtils::RollbackTransaction(dbHandle_); RollBack() local
194 int errCode = SQLiteUtils::GetStatement(dbHandle_, INSERT_SQL, statement); Put() local
226 int errCode = SQLiteUtils::GetStatement(dbHandle_, DELETE_SQL, statement); Delete() local
[all...] |
| H A D | sqlite_single_ver_storage_executor.h | 222 int errCode = E_OK; member
|
| H A D | sqlite_single_ver_schema_database_upgrader.cpp | 31 int errCode = SQLiteUtils::GetSchema(db_, dbSchema); in GetDatabaseSchema() local
41 int errCode = SQLiteUtils::SaveSchema(db_, dbSchema); in SetDatabaseSchema() local
52 int errCode member
72 int errCode = valueObj.Parse(inValue.first, inValue.first + inValue.second, context.schema.GetSkipSize()); CheckGetForJsonSchema() local
118 int errCode = context.schema.VerifyValue(ValueSource::FROM_DBFILE, inValue); CheckGetForFlatBufferSchema() local
179 int errCode = sqlite3_create_function_v2(db_, FUNC_NAME_CHECK_AMEND_VALUE.c_str(), UpgradeValues() local
210 int errCode = SQLiteUtils::DecreaseIndex(db_, entry); UpgradeIndexes() local
217 int errCode = SQLiteUtils::ChangeIndex(db_, entry.first, entry.second, theType, skipSize); UpgradeIndexes() local
224 int errCode = SQLiteUtils::IncreaseIndex(db_, entry.first, entry.second, theType, skipSize); UpgradeIndexes() local
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/communicator/ |
| H A D | distributeddb_communicator_common.cpp | 45 int errCode = inEnv.commAggrHandle->Initialize(inEnv.adapterHandle, adapter); in SetUpEnv() local
195 int errCode = outMsg->SetExternalObject(obj); BuildRegedTinyMessage() local
223 int errCode = outMsg->SetExternalObject(obj); BuildRegedHugeMessage() local
265 int errCode = outMsg->SetExternalObject(obj); BuildRegedGiantMessage() local
293 int errCode = outMsg->SetExternalObject(obj); BuildRegedOverSizeMessage() local
321 int errCode = outMsg->SetExternalObject(obj); BuildUnRegedTinyMessage() local
[all...] |
| /foundation/deviceprofile/device_info_manager/services/core/test/unittest/ |
| H A D | subscribe_profile_manager_test.cpp | 51 int32_t errCode = SubscribeProfileManager::GetInstance().Init(); in SetUpTestCase() local
57 int32_t errCode = SubscribeProfileManager::GetInstance().UnInit(); in TearDownTestCase() local
156 int32_t errCode = SubscribeProfileManager::GetInstance().SubscribeDeviceProfile(subscribeInfo); in HWTEST_F() local
170 int32_t errCode = SubscribeProfileManager::GetInstance(). in HWTEST_F() local
185 int32_t errCode = SubscribeProfileManager::GetInstance(). in HWTEST_F() local
199 int32_t errCode = SubscribeProfileManager::GetInstance().NotifyTrustDeviceProfileAdd(profile); HWTEST_F() local
212 int32_t errCode = SubscribeProfileManager::GetInstance().NotifyTrustDeviceProfileDelete(profile); HWTEST_F() local
226 int32_t errCode = SubscribeProfileManager::GetInstance().NotifyTrustDeviceProfileUpdate(oldProfile, newProfile); HWTEST_F() local
240 int32_t errCode = SubscribeProfileManager::GetInstance().NotifyDeviceProfileAdd(dbKey, dbValue); HWTEST_F() local
254 int32_t errCode = SubscribeProfileManager::GetInstance().NotifyDeviceProfileUpdate(dbKey, dbValue); HWTEST_F() local
268 int32_t errCode = SubscribeProfileManager::GetInstance().NotifyDeviceProfileDelete(dbKey, dbValue); HWTEST_F() local
282 int32_t errCode = SubscribeProfileManager::GetInstance().NotifyServiceProfileAdd(dbKey, dbValue); HWTEST_F() local
296 int32_t errCode = SubscribeProfileManager::GetInstance().NotifyServiceProfileUpdate(dbKey, dbValue); HWTEST_F() local
310 int32_t errCode = SubscribeProfileManager::GetInstance().NotifyServiceProfileDelete(dbKey, dbValue); HWTEST_F() local
324 int32_t errCode = SubscribeProfileManager::GetInstance().NotifyCharProfileAdd(dbKey, dbValue); HWTEST_F() local
338 int32_t errCode = SubscribeProfileManager::GetInstance().NotifyCharProfileUpdate(dbKey, dbValue); HWTEST_F() local
352 int32_t errCode = SubscribeProfileManager::GetInstance().NotifyCharProfileDelete(dbKey, dbValue); HWTEST_F() local
385 int32_t errCode = SubscribeProfileManager::GetInstance().UnSubscribeDeviceProfile(subscribeInfo); HWTEST_F() local
402 int32_t errCode = SubscribeProfileManager::GetInstance().SubscribeDeviceProfile(subscribeInfo); HWTEST_F() local
415 int32_t errCode = SubscribeProfileManager::GetInstance().NotifyTrustDeviceProfileAdd(profile); HWTEST_F() local
428 int32_t errCode = SubscribeProfileManager::GetInstance().NotifyTrustDeviceProfileDelete(profile); HWTEST_F() local
442 int32_t errCode = SubscribeProfileManager::GetInstance().NotifyTrustDeviceProfileUpdate(oldProfile, newProfile); HWTEST_F() local
456 int32_t errCode = SubscribeProfileManager::GetInstance().NotifyDeviceProfileAdd(dbKey, dbValue); HWTEST_F() local
470 int32_t errCode = SubscribeProfileManager::GetInstance().NotifyDeviceProfileUpdate(dbKey, dbValue); HWTEST_F() local
484 int32_t errCode = SubscribeProfileManager::GetInstance().NotifyDeviceProfileDelete(dbKey, dbValue); HWTEST_F() local
498 int32_t errCode = SubscribeProfileManager::GetInstance().NotifyServiceProfileAdd(dbKey, dbValue); HWTEST_F() local
512 int32_t errCode = SubscribeProfileManager::GetInstance().NotifyServiceProfileUpdate(dbKey, dbValue); HWTEST_F() local
526 int32_t errCode = SubscribeProfileManager::GetInstance().NotifyServiceProfileDelete(dbKey, dbValue); HWTEST_F() local
540 int32_t errCode = SubscribeProfileManager::GetInstance().NotifyCharProfileAdd(dbKey, dbValue); HWTEST_F() local
554 int32_t errCode = SubscribeProfileManager::GetInstance().NotifyCharProfileUpdate(dbKey, dbValue); HWTEST_F() local
568 int32_t errCode = SubscribeProfileManager::GetInstance().NotifyCharProfileDelete(dbKey, dbValue); HWTEST_F() local
586 int32_t errCode = SubscribeProfileManager::GetInstance().UnSubscribeDeviceProfile(subscribeInfo); HWTEST_F() local
606 int32_t errCode = SubscribeProfileManager::GetInstance().SubscribeDeviceProfile(subscribeInfo); HWTEST_F() local
619 int32_t errCode = SubscribeProfileManager::GetInstance().NotifyTrustDeviceProfileAdd(profile); HWTEST_F() local
632 int32_t errCode = SubscribeProfileManager::GetInstance().NotifyTrustDeviceProfileDelete(profile); HWTEST_F() local
646 int32_t errCode = SubscribeProfileManager::GetInstance().NotifyTrustDeviceProfileUpdate(oldProfile, newProfile); HWTEST_F() local
660 int32_t errCode = SubscribeProfileManager::GetInstance().NotifyDeviceProfileAdd(dbKey, dbValue); HWTEST_F() local
674 int32_t errCode = SubscribeProfileManager::GetInstance().NotifyDeviceProfileUpdate(dbKey, dbValue); HWTEST_F() local
688 int32_t errCode = SubscribeProfileManager::GetInstance().NotifyDeviceProfileDelete(dbKey, dbValue); HWTEST_F() local
702 int32_t errCode = SubscribeProfileManager::GetInstance().NotifyServiceProfileAdd(dbKey, dbValue); HWTEST_F() local
716 int32_t errCode = SubscribeProfileManager::GetInstance().NotifyServiceProfileUpdate(dbKey, dbValue); HWTEST_F() local
730 int32_t errCode = SubscribeProfileManager::GetInstance().NotifyServiceProfileDelete(dbKey, dbValue); HWTEST_F() local
744 int32_t errCode = SubscribeProfileManager::GetInstance().NotifyCharProfileAdd(dbKey, dbValue); HWTEST_F() local
758 int32_t errCode = SubscribeProfileManager::GetInstance().NotifyCharProfileUpdate(dbKey, dbValue); HWTEST_F() local
772 int32_t errCode = SubscribeProfileManager::GetInstance().NotifyCharProfileDelete(dbKey, dbValue); HWTEST_F() local
786 int32_t errCode = SubscribeProfileManager::GetInstance(). HWTEST_F() local
801 int32_t errCode = SubscribeProfileManager::GetInstance(). HWTEST_F() local
816 int32_t errCode = SubscribeProfileManager::GetInstance(). HWTEST_F() local
831 int32_t errCode = SubscribeProfileManager::GetInstance(). HWTEST_F() local
846 int32_t errCode = SubscribeProfileManager::GetInstance(). HWTEST_F() local
861 int32_t errCode = SubscribeProfileManager::GetInstance(). HWTEST_F() local
876 int32_t errCode = SubscribeProfileManager::GetInstance(). HWTEST_F() local
891 int32_t errCode = SubscribeProfileManager::GetInstance(). HWTEST_F() local
906 int32_t errCode = SubscribeProfileManager::GetInstance(). HWTEST_F() local
921 int32_t errCode = SubscribeProfileManager::GetInstance(). HWTEST_F() local
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/ |
| H A D | intercepted_data_impl.cpp | 46 int errCode = checkSchema(value); in CheckValue() local
133 int errCode = DBCommon::CalcValueHash(newKey, hashKey); in ModifyKey() local
|