/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/kv/ |
H A D | kvdb_windowed_result_set.cpp | 85 int KvDBWindowedResultSet::GetEntry(Entry &entry) const in GetEntry()
|
H A D | kvdb_windowed_result_set.h | 57 // Get the entry of current position. 58 int GetEntry(Entry &entry) const override;
|
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/ |
H A D | result_entries_window.h | 32 int GetEntry(Entry &entry) const;
|
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/ |
H A D | sqlite_single_ver_forward_cursor.h | 48 // Get next entry, return errCode if it fails. 49 int GetNext(Entry &entry, bool isCopy) const override;
|
/foundation/graphic/graphic_2d/frameworks/opengl_wrapper/src/EGL/ |
H A D | egl_wrapper_loader.h | 38 void *LoadGl(const char *libName, char const * const *glName, FunctionPointerType *entry);
|
/foundation/bundlemanager/distributed_bundle_framework/services/dbms/src/ |
H A D | distributed_data_storage.cpp | 241 for (auto entry : allEntries) { in GetDistributedBundleName() 242 std::string key = entry.key.ToString(); in GetDistributedBundleName() 243 std::string value = entry.value.ToString(); in GetDistributedBundleName() 491 for (const auto &entry : allEntries) { in GetAllOldDistributionBundleInfo() 492 std::string key = entry.key.ToString(); in GetAllOldDistributionBundleInfo() 496 std::string value = entry.value.ToString(); in GetAllOldDistributionBundleInfo() 502 if (kvStorePtr_->Delete(entry.key) != Status::SUCCESS) { in GetAllOldDistributionBundleInfo()
|
/foundation/graphic/graphic_2d/rosen/modules/render_service_profiler/ |
H A D | rs_profiler_utils.cpp | 309 for (auto const& entry : std::filesystem::recursive_directory_iterator(path)) { in IterateDirectory() 310 if (entry.is_directory()) { in IterateDirectory() 311 IterateDirectory(entry.path().string(), files); in IterateDirectory() 313 files.push_back(entry.path().string()); in IterateDirectory() 322 while (struct dirent* entry = readdir(directory)) { in IterateDirectory() 323 const std::string entryName(entry->d_name); in IterateDirectory() 328 if (entry->d_type == DT_DIR) { in IterateDirectory()
|
/foundation/communication/netmanager_base/frameworks/native/netconnclient/src/ |
H A D | network_security_config.cpp | 105 struct dirent *entry = readdir(dir); in GetCAFilesFromPath() local 106 while (entry != nullptr) { in GetCAFilesFromPath() 107 if (IsCACertFileName(entry->d_name)) { in GetCAFilesFromPath() 109 caFiles.push_back(caPath + OS_PATH_SEPARATOR + entry->d_name); in GetCAFilesFromPath() 111 caFiles.push_back(caPath + entry->d_name); in GetCAFilesFromPath() 113 NETMGR_LOG_D("Read CA File [%{public}s] from CA Path", entry->d_name); in GetCAFilesFromPath() 115 entry = readdir(dir); in GetCAFilesFromPath()
|
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/multiver/ |
H A D | multi_ver_data_sync.cpp | 273 MultiVerKvEntry *entry = nullptr; in AckRecvCallback() local 288 entry = entries[0]; in AckRecvCallback() 289 errCode = entry->GetValueHash(valueHashes); in AckRecvCallback() 313 void MultiVerDataSync::ReleaseKvEntry(const MultiVerKvEntry *entry) in ReleaseKvEntry() argument 315 return storagePtr_->ReleaseKvEntry(entry); in ReleaseKvEntry() 688 MultiVerKvEntry *MultiVerDataSync::CreateKvEntry(const std::vector<uint8_t> &entry) in CreateKvEntry() argument 690 return storagePtr_->CreateKvEntry(entry); in CreateKvEntry()
|
H A D | multi_ver_sync_task_context.cpp | 164 void MultiVerSyncTaskContext::GetEntry(int index, MultiVerKvEntry *&entry) in GetEntry() argument 166 entry = entries_[index]; in GetEntry()
|
/foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/kvdb/include/ |
H A D | store_result_set.h | 43 Status GetEntry(Entry &entry) const override;
|
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/include/store/ |
H A D | cursor.h | 42 virtual int32_t GetEntry(VBucket &entry) = 0;
|
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/rdb/ |
H A D | rdb_service_impl.cpp | 156 for (const auto& entry : entries) { in ResolveAutoLaunch() 157 if (entry.storeType != RDB_DEVICE_COLLABORATION) { in ResolveAutoLaunch() 162 entry.user, entry.appId, entry.storeId); in ResolveAutoLaunch() 164 entry.user.c_str(), entry.appId.c_str(), Anonymous::Change(entry.storeId).c_str()); in ResolveAutoLaunch() 168 ZLOGI("find identifier %{public}s", Anonymous::Change(entry.storeId).c_str()); in ResolveAutoLaunch() 169 param.userId = entry in ResolveAutoLaunch() [all...] |
H A D | rdb_cursor.cpp | 75 int32_t RdbCursor::GetEntry(VBucket &entry) in GetEntry() argument 77 return GetRow(entry); in GetEntry()
|
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/moduletest/src/ |
H A D | distributeddb_nb_schema_upgrade_test.cpp | 833 Entry entry; in HWTEST_F() local 835 EXPECT_EQ(resultSet->GetEntry(entry), OK); in HWTEST_F() 836 EXPECT_EQ(entry.value, value1); in HWTEST_F() 838 EXPECT_EQ(resultSet->GetEntry(entry), OK); in HWTEST_F() 839 EXPECT_EQ(entry.value, value2); in HWTEST_F() 911 Entry entry; in HWTEST_F() local 913 EXPECT_EQ(resultSet->GetEntry(entry), OK); in HWTEST_F() 914 EXPECT_EQ(entry.value, value1); in HWTEST_F() 916 EXPECT_EQ(resultSet->GetEntry(entry), OK); in HWTEST_F() 917 EXPECT_EQ(entry in HWTEST_F() 1043 Entry entry; CheckAddNewFieldSucceed() local [all...] |
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/metadata/ |
H A D | meta_data_manager.cpp | 100 for (const auto &entry : *value) { in OnChange() 101 std::string key(entry.key.begin(), entry.key.end()); in OnChange() 105 observer_(key, { entry.value.begin(), entry.value.end() }, action); in OnChange()
|
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/fuzztest/nbdelegate_fuzzer/ |
H A D | nbdelegate_fuzzer.cpp | 114 Entry entry; in CreateEntries() local 115 entry.key = std::vector<uint8_t>(data, data + i); in CreateEntries() 116 keys.push_back(entry.key); in CreateEntries() 117 entry.value = std::vector<uint8_t>(data, data + size); in CreateEntries() 118 entries.push_back(entry); in CreateEntries() 305 /* Fuzzer entry point */
|
/foundation/filemanagement/app_file_service/utils/src/b_filesystem/ |
H A D | b_dir.cpp | 49 struct dirent *entry = nullptr; in IsEmptyDirectory() local 50 while ((entry = readdir(dir)) != nullptr) { in IsEmptyDirectory() 51 if (entry->d_type != DT_DIR || (strcmp(entry->d_name, ".") != 0 && strcmp(entry->d_name, "..") != 0)) { in IsEmptyDirectory()
|
/foundation/ability/ability_lite/frameworks/ability_lite/src/ |
H A D | ability.cpp | 147 void Ability::SetMainRoute(const std::string &entry) in SetMainRoute() argument 154 abilitySliceManager_->SetMainRoute(entry); in SetMainRoute()
|
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/mock/ |
H A D | general_store_mock.cpp | 148 void GeneralStoreMock::MakeCursor(const std::map<std::string, Value> &entry) in MakeCursor() argument 150 auto resultSet = std::make_shared<CursorMock::ResultSet>(1, entry); in MakeCursor()
|
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/gaussdb_rd/ |
H A D | rd_single_ver_natural_store_connection.h | 137 int SaveEntry(const Entry &entry, bool isDelete, Timestamp timestamp = 0); 139 int SaveEntryNormally(const Entry &entry, bool isDelete);
|
/foundation/distributeddatamgr/udmf/interfaces/ndk/data/ |
H A D | udmf.h | 326 * @param entry Represents custom data.
335 const unsigned char* entry, unsigned int count);
455 * @brief Get one entry data from the {@link OH_UdmfRecord} record.
459 * @param entry Represents a pointer to entry data that is a output param.
460 * @param count Represents the entry data length that is a output param.
468 unsigned char** entry, unsigned int* count);
|
/foundation/communication/dsoftbus/components/nstackx/nstackx_util/platform/unix/ |
H A D | sys_util.c | 179 int32_t PthreadCreate(pthread_t *tid, const pthread_attr_t *attr, void *(*entry)(void *), void *arg) in PthreadCreate() 181 return pthread_create(tid, attr, entry, arg); in PthreadCreate()
|
/foundation/ability/ability_runtime/frameworks/native/ability/native/ |
H A D | ui_ability_thread.cpp | 171 std::string entry = "AbilityThread::Attach start; the load lifecycle."; in AttachInner() local 172 FreezeUtil::GetInstance().AddLifecycleEvent(flow, entry); in AttachInner() 175 entry = std::string("AbilityThread::Attach failed ipc error: ") + std::to_string(err); in AttachInner() 176 FreezeUtil::GetInstance().AddLifecycleEvent(flow, entry); in AttachInner() 254 std::string entry = "AbilityThread::" + methodName + "; the foreground lifecycle."; in AddLifecycleEvent() local 255 FreezeUtil::GetInstance().AddLifecycleEvent(flow, entry); in AddLifecycleEvent() 259 std::string entry = "AbilityThread::" + methodName + "; the background lifecycle."; in AddLifecycleEvent() local 260 FreezeUtil::GetInstance().AddLifecycleEvent(flow, entry); in AddLifecycleEvent()
|
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/moduletest/common/distributeddb/src/ |
H A D | distributeddb_nb_test_tools.cpp | 398 for (auto entry : entries) { in PutLocalBatch() 399 status = kvStoreNbDelegate.PutLocal(entry.key, entry.value); in PutLocalBatch() 560 Entry entry; in MoveToNextFromBegin() local 580 result = result && (resultSet.GetEntry(entry) == OK); in MoveToNextFromBegin() 585 result = result && (entry.key == entries[positionGot].key) && (entry.value == entries[positionGot].value); in MoveToNextFromBegin() 587 MST_LOG("entry != entries[positionGot]"); in MoveToNextFromBegin() 591 result = result && (resultSet.GetEntry(entry) == NOT_FOUND); in MoveToNextFromBegin()
|