/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/ |
H A D | distributeddb_cloud_syncer_upload_test.cpp | 105 uploadData.insData.record = std::vector<VBucket>(COUNT, tmp); in PrepareUploadDataInsData() 113 uploadData.updData.record = std::vector<VBucket>(COUNT, tmp); in PrepareUploadDataUpdData() 123 uploadData.insData.record = std::vector<VBucket>(COUNT, tmp); in PrepareUploadDataForUploadModeCheck012() 126 uploadData.delData.record = std::vector<VBucket>(COUNT, tmp); in PrepareUploadDataForUploadModeCheck012() 405 uploadData.insData.record = std::vector<VBucket>(1001, tmp); in HWTEST_F() 471 uploadData3.insData.record = std::vector<VBucket>(1001, tmp); in HWTEST_F() 527 uploadData2.insData.record = std::vector<VBucket>(100); in HWTEST_F() 588 // CloudSyncData format error: record does not match extend length in HWTEST_F() 590 uploadData.insData.record = std::vector<VBucket>(1000, tmp); in HWTEST_F() 641 uploadData2.insData.record in HWTEST_F() [all...] |
H A D | cloud_db_sync_utils_test.cpp | 83 std::vector<VBucket> record; in InsertCloudTableRecord() local 96 record.push_back(data); in InsertCloudTableRecord() 105 ASSERT_EQ(virtualCloudDb->BatchInsert(TABLE_NAME, std::move(record), extend), DBStatus::OK); in InsertCloudTableRecord() 106 LOGD("insert cloud record worker[primary key]:[cloud%" PRId64 " - cloud%" PRId64")", begin, count); in InsertCloudTableRecord() 114 std::vector<VBucket> record; in UpdateCloudTableRecord() local 127 record.push_back(data); in UpdateCloudTableRecord() 137 ASSERT_EQ(virtualCloudDb->BatchUpdate(TABLE_NAME, std::move(record), extend), DBStatus::OK); in UpdateCloudTableRecord() 138 LOGD("update cloud record worker[primary key]:[cloud%" PRId64 " - cloud%" PRId64")", begin, count); in UpdateCloudTableRecord() 150 LOGD("delete cloud record worker[primary key]:[cloud%" PRId64 " - cloud%" PRId64")", begin, count); in DeleteCloudTableRecordByGid()
|
/foundation/bundlemanager/bundle_framework_lite/services/bundlemgr_lite/src/ |
H A D | gt_bundle_installer.cpp | 216 // if third system bundle, it need to record bundleName in THIRD_SYSTEM_BUNDLE_JSON in Install() 224 // record app info event when install app in Install() 299 // rename install path and record install infomation in ProcessBundleInstall() 449 uint8_t GtBundleInstaller::HandleFileAndBackUpRecord(const InstallRecord &record, const char *tmpPath, in HandleFileAndBackUpRecord() argument 456 GtManagerService::GetInstance().RemoveBundleResList(record.bundleName); in HandleFileAndBackUpRecord() 458 if (!BundleUtil::RenameDir(tmpPath, record.codePath)) { in HandleFileAndBackUpRecord() 464 const_cast<char *>(JSON_PATH), const_cast<char *>(record.bundleName), const_cast<char *>(randStr), in HandleFileAndBackUpRecord() 473 if (!BackUpInstallRecord(record, bundleTmpJsonPath)) { in HandleFileAndBackUpRecord() 490 uint8_t GtBundleInstaller::TransformJsToBc(const char *codePath, InstallRecord &record) in TransformJsToBc() argument 516 record in TransformJsToBc() 740 BackUpInstallRecord(const InstallRecord &record, const char *jsonPath) BackUpInstallRecord() argument [all...] |
/foundation/resourceschedule/qos_manager/services/src/ |
H A D | concurrent_task_controller.cpp | 149 ForegroundAppRecord* record = GetRecordOfPid(pid); in QueryUi() local 150 if (!record) { in QueryUi() 154 int grpId = record->GetGrpId(); in QueryUi() 167 ForegroundAppRecord* record = GetRecordOfPid(pid); in QueryRender() local 168 if (!record) { in QueryRender() 172 int grpId = record->GetGrpId(); in QueryRender() 312 ForegroundAppRecord* record = GetRecordOfPid(pid); in QueryHwc() local 313 if (!record) { in QueryHwc() 317 int grpId = record->GetGrpId(); in QueryHwc() 553 CONCUR_LOGE("pid %{public}d create app record faile in NewForegroundAppRecord() [all...] |
/foundation/communication/netmanager_base/services/netmanagernative/src/netsys/dnsresolv/ |
H A D | dns_param_cache.cpp | 630 sptr<NetManagerStandard::InterceptRecord> record = new (std::nothrow) NetManagerStandard::InterceptRecord(); in NotifyDomianIntercept() local 631 record->time = (int32_t)time(NULL); in NotifyDomianIntercept() 632 record->appUid = appUid; in NotifyDomianIntercept() 633 record->domain = host; in NotifyDomianIntercept() 635 if (oldRecord_ != nullptr && (record->time - oldRecord_->time) < INTERCEPT_BUFF_INTERVAL_SEC) { in NotifyDomianIntercept() 636 if (record->appUid == oldRecord_->appUid && record->domain == oldRecord_->domain) { in NotifyDomianIntercept() 640 oldRecord_ = record; in NotifyDomianIntercept() 642 callback->OnIntercept(record); in NotifyDomianIntercept()
|
/foundation/communication/netmanager_ext/test/netfirewallmanager/unittest/netfirewallmanager_test/ |
H A D | netfirewall_service_test.cpp | 669 sptr<InterceptRecord> record = (std::make_unique<InterceptRecord>()).release();
in HWTEST_F() local 674 record->time = time;
in HWTEST_F() 675 record->localIp = "192.168.1.2";
in HWTEST_F() 676 record->remoteIp = "192.168.1.3";
in HWTEST_F() 677 record->localPort = sourcePort;
in HWTEST_F() 678 record->remotePort = destPort;
in HWTEST_F() 679 record->protocol = 1;
in HWTEST_F() 680 record->appUid = uid;
in HWTEST_F() 682 int32_t ret = NetFirewallInterceptRecorder::GetInstance()->callback_->OnIntercept(record);
in HWTEST_F()
|
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/udmf/store/ |
H A D | runtime_store.cpp | 122 // add unified record
in Put() 123 for (const auto &record : unifiedData.GetRecords()) {
in Put() 126 if (!TLVUtil::Writing(record, recordTlv, TAG::TAG_UNIFIED_RECORD)) {
in Put() 127 ZLOGI("Marshall unified record failed.");
in Put() 130 std::string recordKey = unifiedKey + "/" + record->GetUid();
in Put() 203 for (const auto &record : unifiedData.GetRecords()) {
in GetSummary() 204 int64_t recordSize = record->GetSize();
in GetSummary() 205 auto udType = UtdUtils::GetUtdIdFromUtdEnum(record->GetType());
in GetSummary() 603 std::shared_ptr<UnifiedRecord> record;
in UnmarshalEntries() local 605 if (!TLVUtil::ReadTlv(record, recordTl in UnmarshalEntries() [all...] |
/foundation/ability/form_fwk/services/include/ |
H A D | form_sys_event_receiver.h | 59 bool IsSameForm(const FormRecord &record, const FormInfo &formInfo);
|
/foundation/ability/form_fwk/services/form_render_service/src/ |
H A D | form_render_impl.cpp | 104 auto record = FormRenderRecord::Create(formJsInfo.bundleName, uid, formJsInfo.isDynamic, formSupplyClient);
in RenderForm() local 105 if (record == nullptr) {
in RenderForm() 106 HILOG_ERROR("null record");
in RenderForm() 110 record->SetConfiguration(configuration_);
in RenderForm() 111 result = record->UpdateRenderRecord(formJsInfo, formRenderWant, hostToken);
in RenderForm() 115 renderRecordMap_.emplace(uid, record);
in RenderForm() 186 HILOG_ERROR("invalid record,formId:%{public}" PRId64, formId);
in ReleaseRenderer() 191 HILOG_ERROR("record invalid,formId:%{public}" PRId64, formId);
in ReleaseRenderer() 411 HILOG_ERROR("can't find render record of %{public}s", std::to_string(formId).c_str());
in RecycleForm() 466 HILOG_ERROR("can't find render record o in RecoverForm() [all...] |
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/object/ |
H A D | object_asset_machine.cpp | 62 static void MergeAssetData(VBucket& record, const Asset& newAsset, const AssetBindInfo& assetBindInfo); 240 static void MergeAssetData(VBucket& record, const Asset& newAsset, const AssetBindInfo& assetBindInfo) in MergeAssetData() argument 243 record[key] = primary; in MergeAssetData() 246 auto it = record.find(assetBindInfo.field); in MergeAssetData() 247 if (it == record.end()) { in MergeAssetData()
|
/foundation/distributeddatamgr/udmf/framework/jskitsimpl/data/ |
H A D | unified_record_napi.cpp | 64 ASSERT_ERR(ctxt->env, udRecord != nullptr, Status::E_ERROR, "no memory for unified record!"); in New() 165 auto *record = new (std::nothrow) UnifiedRecordNapi(); in NewInstance() local 166 ASSERT_ERR_VOID(env, record != nullptr, Status::E_ERROR, "no memory for unified record"); in NewInstance() 167 record->value_ = in; in NewInstance() 168 ASSERT_CALL_DELETE(env, napi_wrap(env, out, record, Destructor, nullptr, nullptr), record); in NewInstance()
|
/foundation/ability/form_fwk/services/src/ |
H A D | form_data_proxy_mgr.cpp | 157 for (auto& record : formDataProxyRecordMap_) { in RetryFailureSubscribes() 158 record.second->RetryFailureSubscribes(); in RetryFailureSubscribes()
|
/foundation/ability/ability_runtime/services/abilitymgr/src/start_ability_handler/ |
H A D | start_ability_sandbox_savefile.cpp | 142 SaveFileRecord record{reqCode, caller}; in PushRecord() 143 fileSavingRecords_.emplace(requestCode_, record); in PushRecord()
|
/foundation/arkui/ace_engine/test/unittest/core/pattern/rich_editor/ |
H A D | rich_editor_click_testone_ng.cpp | 92 RichEditorPattern::OperationRecord record; in HWTEST_F() local 93 richEditorPattern->DeleteSelectOperation(&record); in HWTEST_F()
|
H A D | rich_editor_edit_test_ng.cpp | 554 RichEditorPattern::OperationRecord record; in HWTEST_F() local 555 record.beforeCaretPosition = 0; in HWTEST_F() 556 record.addText = "test123"; in HWTEST_F() 557 richEditorPattern->RedoDrag(record); in HWTEST_F() 575 RichEditorPattern::OperationRecord record; in HWTEST_F() local 576 record.deleteCaretPostion = 0; in HWTEST_F() 577 record.addText = "test123"; in HWTEST_F() 578 richEditorPattern->UndoDrag(record); in HWTEST_F() 812 RichEditorPattern::OperationRecord record; in HWTEST_F() local 813 record in HWTEST_F() 857 RichEditorPattern::OperationRecord record; HWTEST_F() local [all...] |
/foundation/filemanagement/user_file_service/interfaces/inner_api/file_access/src/ |
H A D | file_access_ext_ability.cpp | 56 void FileAccessExtAbility::Init(const std::shared_ptr<AbilityLocalRecord> &record, in Init() argument 61 ExtensionBase<>::Init(record, application, handler, token); in Init()
|
/foundation/distributeddatamgr/pasteboard/framework/innerkits/src/ |
H A D | pasteboard_client.cpp | 102 PASTEBOARD_HILOGD(PASTEBOARD_MODULE_CLIENT, "New text record"); in CreateHtmlTextRecord() 108 PASTEBOARD_HILOGD(PASTEBOARD_MODULE_CLIENT, "New want record"); in CreateWantRecord() 114 PASTEBOARD_HILOGD(PASTEBOARD_MODULE_CLIENT, "New text record"); in CreatePlainTextRecord() 120 PASTEBOARD_HILOGD(PASTEBOARD_MODULE_CLIENT, "New pixelMap record"); in CreatePixelMapRecord() 126 PASTEBOARD_HILOGD(PASTEBOARD_MODULE_CLIENT, "New uri record"); in CreateUriRecord() 133 PASTEBOARD_HILOGD(PASTEBOARD_MODULE_CLIENT, "New kv record"); in CreateKvRecord() 361 auto record = pasteData.GetRecordAt(i); in RetainUri() local 362 if (record != nullptr) { in RetainUri() 363 record->SetConvertUri(""); in RetainUri() 433 for (auto record in SetUdsdData() [all...] |
/foundation/ability/ability_runtime/services/appmgr/include/ |
H A D | app_running_record.h | 138 * @brief Obtains the app record bundleName. 140 * @return Returns app record bundleName. 145 * @brief Obtains the app record CallerPid. 147 * @return Returns app record CallerPid. 159 * @brief Obtains the app record CallerUid. 161 * @return Returns app record CallerUid. 173 * @brief Obtains the app record CallerTokenId. 175 * @return Returns app record CallerTokenId. 187 * @brief Obtains the app record isLauncherApp flag. 189 * @return Returns app record isLauncherAp [all...] |
/foundation/ability/form_fwk/services/form_render_service/include/ |
H A D | form_render_service_extension.h | 45 * @param record the extension record. 50 void Init(const std::shared_ptr<AppExecFwk::AbilityLocalRecord> &record,
|
/foundation/resourceschedule/work_scheduler/frameworks/extension/include/ |
H A D | js_work_scheduler_extension.h | 43 * @param record The record info. 48 void Init(const std::shared_ptr<AppExecFwk::AbilityLocalRecord> &record,
|
/foundation/window/window_manager/extension/window_extension/include/ |
H A D | js_window_extension.h | 47 * @param record the extension record. 52 void Init(const std::shared_ptr<AppExecFwk::AbilityLocalRecord>& record,
|
/foundation/arkui/ace_engine/frameworks/core/components_ng/pattern/grid/ |
H A D | grid_layout_info.h | 111 for (const auto& record : lineHeightMap_) { in GetAverageLineHeight() 112 if (record.second > 0) { in GetAverageLineHeight() 114 totalHeight += record.second; in GetAverageLineHeight()
|
/foundation/multimedia/audio_lite/services/server/src/ |
H A D | audio_capturer_server.cpp | 223 bool record = capturer->Record(); in Start() local 224 if (record) { in Start() 229 WriteInt32(reply, record); in Start()
|
/foundation/ability/form_fwk/test/unittest/fms_form_share_mgr_test/ |
H A D | fms_form_share_mgr_test.cpp | 2358 std::string record = "aaaaa"; in HWTEST_F() local 2364 formDataMgr->CreateFormStateRecord(record, info, callerToken, callingUid); in HWTEST_F() 2376 std::string record = "aaaaa"; in HWTEST_F() local 2382 formDataMgr->CreateFormStateRecord(record, info, callerToken, callingUid); in HWTEST_F() 2394 std::string record = "aaaaa"; in HWTEST_F() local 2401 formDataMgr->formStateRecord_.emplace(record, formHostRecord); in HWTEST_F() 2402 formDataMgr->CreateFormStateRecord(record, info, callerToken, callingUid); in HWTEST_F() 2414 std::string record = "aaaaa"; in HWTEST_F() local 2422 formDataMgr->formStateRecord_.emplace(record, formHostRecord); in HWTEST_F() 2423 formDataMgr->CreateFormStateRecord(record, inf in HWTEST_F() 3162 FormRecord record; HWTEST_F() local 3178 FormRecord record; HWTEST_F() local 3198 FormRecord record; HWTEST_F() local 3218 FormRecord record; HWTEST_F() local 3233 FormRecord record; HWTEST_F() local 3249 FormRecord record; HWTEST_F() local 3267 FormRecord record; HWTEST_F() local 3287 FormRecord record; HWTEST_F() local 3305 FormRecord record; HWTEST_F() local [all...] |
/foundation/ability/ability_runtime/services/abilitymgr/src/ |
H A D | extension_record_manager.cpp | 64 const std::shared_ptr<ExtensionRecord> &record) in AddExtensionRecord() 68 extensionRecords_.emplace(extensionRecordId, record); in AddExtensionRecord() 97 // find target record firstly in GetExtensionRecord() 209 "found record, uiExtensionComponentId: %{public}" PRIu64, sessionInfo->uiExtensionComponentId); in GetAbilityRecordBySessionInfo() 217 std::shared_ptr<ExtensionRecord> &record, const std::string &process) in IsHostSpecifiedProcessValid() 227 TAG_LOGD(AAFwkTag::ABILITYMGR, "found match extension record: id %{public}d", iter.first); in IsHostSpecifiedProcessValid() 244 std::shared_ptr<ExtensionRecord> &record) in UpdateProcessName() 246 std::shared_ptr<AAFwk::AbilityRecord> abilityRecord = record->abilityRecord_; in UpdateProcessName() 247 switch (record->processMode_) { in UpdateProcessName() 261 if (!IsHostSpecifiedProcessValid(abilityRequest, record, proces in UpdateProcessName() 63 AddExtensionRecord(const int32_t extensionRecordId, const std::shared_ptr<ExtensionRecord> &record) AddExtensionRecord() argument 216 IsHostSpecifiedProcessValid(const AAFwk::AbilityRequest &abilityRequest, std::shared_ptr<ExtensionRecord> &record, const std::string &process) IsHostSpecifiedProcessValid() argument 243 UpdateProcessName(const AAFwk::AbilityRequest &abilityRequest, std::shared_ptr<ExtensionRecord> &record) UpdateProcessName() argument [all...] |