/foundation/resourceschedule/resource_schedule_service/ressched/sched_controller/observer/src/ |
H A D | connection_subscriber.cpp | 24 const AbilityRuntime::ConnectionData& data, nlohmann::json &payload) in MarshallingConnectionData() 26 payload["extensionPid"] = data.extensionPid; in MarshallingConnectionData() 27 payload["extensionUid"] = data.extensionUid; in MarshallingConnectionData() 28 payload["extensionBundleName"] = data.extensionBundleName; in MarshallingConnectionData() 29 payload["extensionModuleName"] = data.extensionModuleName; in MarshallingConnectionData() 30 payload["extensionName"] = data.extensionName; in MarshallingConnectionData() 31 payload["extensionType"] = static_cast<uint32_t>(data.extensionType); in MarshallingConnectionData() 32 payload["callerUid"] = data.callerUid; in MarshallingConnectionData() 33 payload["callerPid"] = data.callerPid; in MarshallingConnectionData() 34 payload["callerNam in MarshallingConnectionData() 23 MarshallingConnectionData( const AbilityRuntime::ConnectionData& data, nlohmann::json &payload) MarshallingConnectionData() argument 40 nlohmann::json payload; OnExtensionConnected() local 49 nlohmann::json payload; OnExtensionDisconnected() local 55 MarshallingDlpStateData(const AbilityRuntime::DlpStateData& data, nlohmann::json &payload) MarshallingDlpStateData() argument 70 nlohmann::json payload; OnDlpAbilityOpened() local 79 nlohmann::json payload; OnDlpAbilityClosed() local [all...] |
H A D | audio_observer.cpp | 25 const std::shared_ptr<AudioStandard::AudioRendererChangeInfo> &audioRendererChangeInfo, nlohmann::json &payload) in MarshallingAudioRendererChangeInfo() 30 payload["uid"] = std::to_string(audioRendererChangeInfo->clientUID); in MarshallingAudioRendererChangeInfo() 31 payload["sessionId"] = std::to_string(audioRendererChangeInfo->sessionId); in MarshallingAudioRendererChangeInfo() 32 payload["rendererState"] = static_cast<int32_t>(audioRendererChangeInfo->rendererState); in MarshallingAudioRendererChangeInfo() 35 payload["rendererInfo.contentType"] = static_cast<int32_t>(audioRendererChangeInfo->rendererInfo.contentType); in MarshallingAudioRendererChangeInfo() 36 payload["rendererInfo.streamUsage"] = static_cast<int32_t>(audioRendererChangeInfo->rendererInfo.streamUsage); in MarshallingAudioRendererChangeInfo() 45 nlohmann::json payload; in OnRendererStateChange() local 46 MarshallingAudioRendererChangeInfo(audioRendererChangeInfo, payload); in OnRendererStateChange() 49 audioRendererChangeInfo->rendererState, payload); in OnRendererStateChange() 58 const nlohmann::json payload in OnRingerModeUpdated() local 24 MarshallingAudioRendererChangeInfo( const std::shared_ptr<AudioStandard::AudioRendererChangeInfo> &audioRendererChangeInfo, nlohmann::json &payload) MarshallingAudioRendererChangeInfo() argument 67 nlohmann::json payload; OnVolumeKeyEvent() local 78 nlohmann::json payload; OnPreferredOutputDeviceUpdated() local [all...] |
H A D | av_session_state_listener.cpp | 25 nlohmann::json &payload) in MarshallingAVSessionDescriptor() 27 payload["sessionId_"] = descriptor.sessionId_; in MarshallingAVSessionDescriptor() 28 payload["pid_"] = descriptor.pid_; in MarshallingAVSessionDescriptor() 29 payload["uid_"] = descriptor.uid_; in MarshallingAVSessionDescriptor() 35 nlohmann::json payload; in OnSessionCreate() local 36 MarshallingAVSessionDescriptor(descriptor, payload); in OnSessionCreate() 37 ResSchedMgr::GetInstance().ReportData(ResType::RES_TYPE_AV_SESSION_ON_SESSION_CREATE, 0, payload); in OnSessionCreate() 43 nlohmann::json payload; in OnSessionRelease() local 44 MarshallingAVSessionDescriptor(descriptor, payload); in OnSessionRelease() 45 ResSchedMgr::GetInstance().ReportData(ResType::RES_TYPE_AV_SESSION_ON_SESSION_RELEASE, 0, payload); in OnSessionRelease() 24 MarshallingAVSessionDescriptor(const AVSession::AVSessionDescriptor& descriptor, nlohmann::json &payload) MarshallingAVSessionDescriptor() argument 51 nlohmann::json payload; OnTopSessionChange() local [all...] |
/foundation/resourceschedule/resource_schedule_service/ressched/test/unittest/src/ |
H A D | scene_recognize_test.cpp | 48 nlohmann::json payload; in HWTEST_F() local 50 ResType::ScreenStatus::SCREEN_ON, payload); in HWTEST_F() 52 SceneRecognizerMgr::GetInstance().DispatchResource(-1, -1, payload); in HWTEST_F() 55 ResType::AppInstallStatus::APP_INSTALL_END, payload); in HWTEST_F() 58 ResType::AppInstallStatus::APP_INSTALL_END, payload); in HWTEST_F() 71 nlohmann::json payload; in HWTEST_F() local 73 ResType::AppInstallStatus::APP_INSTALL_END, payload); in HWTEST_F() 75 ResType::AppInstallStatus::APP_INSTALL_END, payload); in HWTEST_F() 77 ResType::AppInstallStatus::APP_INSTALL_START, payload); in HWTEST_F() 91 nlohmann::json payload; in HWTEST_F() local 146 nlohmann::json payload; HWTEST_F() local 173 nlohmann::json payload; HWTEST_F() local 189 nlohmann::json payload; HWTEST_F() local 205 nlohmann::json payload; HWTEST_F() local 224 nlohmann::json payload; HWTEST_F() local 242 nlohmann::json payload; HWTEST_F() local 262 nlohmann::json payload; HWTEST_F() local 284 nlohmann::json payload; HWTEST_F() local [all...] |
H A D | res_sched_mgr_test.cpp | 57 nlohmann::json payload;
in HWTEST_F() local 58 ResSchedMgr::GetInstance().ReportData(0, 0, payload);
in HWTEST_F() 70 nlohmann::json payload;
in HWTEST_F() local 71 ResSchedMgr::GetInstance().ReportData(ResType::RES_TYPE_REPORT_KEY_THREAD, 0, payload);
in HWTEST_F() 83 nlohmann::json payload;
in HWTEST_F() local 84 ResSchedMgr::GetInstance().ReportData(ResType::RES_TYPE_REPORT_WINDOW_STATE, 0, payload);
in HWTEST_F() 98 nlohmann::json payload;
in HWTEST_F() local 99 ResSchedMgr::GetInstance().KillProcessByClient(payload);
in HWTEST_F() 100 payload["pid"] = 1234567;
in HWTEST_F() 101 payload["killReaso in HWTEST_F() 133 nlohmann::json payload; HWTEST_F() local 146 nlohmann::json payload; HWTEST_F() local [all...] |
/foundation/resourceschedule/resource_schedule_service/ressched/plugins/cgroup_sched_plugin/framework/sched_controller/ |
H A D | app_state_observer.cpp | 38 nlohmann::json payload; in OnForegroundApplicationChanged() local 39 payload["pid"] = std::to_string(appStateData.pid); in OnForegroundApplicationChanged() 40 payload["uid"] = std::to_string(appStateData.uid); in OnForegroundApplicationChanged() 41 payload["bundleName"] = appStateData.bundleName; in OnForegroundApplicationChanged() 42 ResSchedUtils::GetInstance().ReportDataInProcess(ResType::RES_TYPE_APP_STATE_CHANGE, appStateData.state, payload); in OnForegroundApplicationChanged() 67 nlohmann::json payload; in OnAbilityStateChanged() local 69 payload["pid"] = std::to_string(abilityStateData.pid); in OnAbilityStateChanged() 70 payload["uid"] = uid; in OnAbilityStateChanged() 71 payload["bundleName"] = bundleName; in OnAbilityStateChanged() 73 abilityState, payload); in OnAbilityStateChanged() 102 nlohmann::json payload; OnExtensionStateChanged() local 110 MarshallingProcessData(const ProcessData &processData, nlohmann::json &payload) MarshallingProcessData() argument 144 nlohmann::json payload; OnProcessCreated() local 167 nlohmann::json payload; OnProcessDied() local 192 nlohmann::json payload; OnApplicationStateChanged() local 201 MarshallingAppStateData(const AppStateData &appStateData, nlohmann::json &payload) MarshallingAppStateData() argument 217 nlohmann::json payload; OnAppStateChanged() local 231 nlohmann::json payload; OnAppCacheStateChanged() local 256 nlohmann::json payload; OnProcessStateChanged() local 269 nlohmann::json payload; OnAppStopped() local [all...] |
H A D | background_task_observer.cpp | 31 const std::shared_ptr<TransientTaskAppInfo>& info, nlohmann::json& payload) in MarshallingTransientTaskAppInfo() 33 payload["pid"] = std::to_string(info->GetPid()); in MarshallingTransientTaskAppInfo() 34 payload["uid"] = std::to_string(info->GetUid()); in MarshallingTransientTaskAppInfo() 35 payload["bundleName"] = info->GetPackageName(); in MarshallingTransientTaskAppInfo() 55 nlohmann::json payload; in OnTransientTaskStart() local 56 MarshallingTransientTaskAppInfo(info, payload); in OnTransientTaskStart() 58 ResType::RES_TYPE_TRANSIENT_TASK, ResType::TransientTaskStatus::TRANSIENT_TASK_START, payload); in OnTransientTaskStart() 78 nlohmann::json payload; in OnTransientTaskEnd() local 79 MarshallingTransientTaskAppInfo(info, payload); in OnTransientTaskEnd() 81 ResType::RES_TYPE_TRANSIENT_TASK, ResType::TransientTaskStatus::TRANSIENT_TASK_END, payload); in OnTransientTaskEnd() 30 MarshallingTransientTaskAppInfo( const std::shared_ptr<TransientTaskAppInfo>& info, nlohmann::json& payload) MarshallingTransientTaskAppInfo() argument 91 nlohmann::json payload; OnTransientTaskErr() local 97 MarshallingContinuousTaskCallbackInfo( const std::shared_ptr<ContinuousTaskCallbackInfo>& continuousTaskCallbackInfo, nlohmann::json& payload) MarshallingContinuousTaskCallbackInfo() argument 129 nlohmann::json payload; OnContinuousTaskStart() local 154 nlohmann::json payload; OnContinuousTaskStop() local 179 nlohmann::json payload; OnContinuousTaskUpdate() local 190 MarshallingResourceInfo( const std::shared_ptr<BackgroundTaskMgr::ResourceCallbackInfo> &resourceInfo, nlohmann::json &payload) MarshallingResourceInfo() argument 202 nlohmann::json payload; OnAppEfficiencyResourcesApply() local 213 nlohmann::json payload; OnAppEfficiencyResourcesReset() local 224 nlohmann::json payload; OnProcEfficiencyResourcesApply() local 235 nlohmann::json payload; OnProcEfficiencyResourcesReset() local [all...] |
H A D | window_state_observer.cpp | 48 nlohmann::json payload; in OnFocused() local 49 payload["pid"] = std::to_string(focusChangeInfo->pid_); in OnFocused() 50 payload["uid"] = std::to_string(focusChangeInfo->uid_); in OnFocused() 51 payload["windowId"] = std::to_string(focusChangeInfo->windowId_); in OnFocused() 52 payload["windowType"] = std::to_string((int32_t)(focusChangeInfo->windowType_)); in OnFocused() 53 payload["displayId"] = std::to_string(focusChangeInfo->displayId_); in OnFocused() 55 ResType::RES_TYPE_WINDOW_FOCUS, ResType::WindowFocusStatus::WINDOW_FOCUS, payload); in OnFocused() 78 nlohmann::json payload; in OnUnfocused() local 79 payload["pid"] = std::to_string(focusChangeInfo->pid_); in OnUnfocused() 80 payload["ui in OnUnfocused() 88 MarshallingWindowVisibilityInfo(const sptr<WindowVisibilityInfo>& info, nlohmann::json& payload) MarshallingWindowVisibilityInfo() argument 119 nlohmann::json payload; OnWindowVisibilityChanged() local 156 nlohmann::json payload; OnWindowDrawingContentChanged() local 168 nlohmann::json payload; OnWindowModeUpdate() local [all...] |
/foundation/resourceschedule/device_standby/services/test/unittest/ |
H A D | allow_record_unit_test.cpp | 51 nlohmann::json payload; in HWTEST_F() local 52 EXPECT_EQ(allowRecord->ParseFromJson(payload), false); in HWTEST_F() 53 payload["uid"] = DEFAULT_UID; in HWTEST_F() 54 EXPECT_EQ(allowRecord->ParseFromJson(payload), false); in HWTEST_F() 55 payload["pid"] = DEFAULT_PID; in HWTEST_F() 56 EXPECT_EQ(allowRecord->ParseFromJson(payload), false); in HWTEST_F() 57 payload["name"] = DEFAULT_BUNDLE_NAME; in HWTEST_F() 58 EXPECT_EQ(allowRecord->ParseFromJson(payload), false); in HWTEST_F() 59 payload["allowType"] = DEFAULT_ALLOW_TYPE; in HWTEST_F() 60 EXPECT_EQ(allowRecord->ParseFromJson(payload), fals in HWTEST_F() [all...] |
/foundation/resourceschedule/resource_schedule_service/ressched/plugins/frame_aware_plugin/test/unittest/ |
H A D | frame_aware_plugin_test.cpp | 62 nlohmann::json payload; in HWTEST_F() local 64 payload["test"] = false; in HWTEST_F() 66 std::shared_ptr<ResData> data = std::make_shared<ResData>(type, value, payload); in HWTEST_F() 75 data->payload.clear(); in HWTEST_F() 76 data->payload["pid"] = true; in HWTEST_F() 78 data->payload.clear(); in HWTEST_F() 79 data->payload["pid"] = true; in HWTEST_F() 80 data->payload["uid"] = true; in HWTEST_F() 82 data->payload["bundleName"] = true; in HWTEST_F() 84 data->payload["pi in HWTEST_F() 102 nlohmann::json payload; HWTEST_F() local 142 nlohmann::json payload; HWTEST_F() local 192 nlohmann::json payload; HWTEST_F() local 226 nlohmann::json payload; HWTEST_F() local 261 nlohmann::json payload; HWTEST_F() local 296 nlohmann::json payload; HWTEST_F() local 330 nlohmann::json payload; HWTEST_F() local [all...] |
/foundation/resourceschedule/resource_schedule_service/ressched/plugins/frame_aware_plugin/src/ |
H A D | frame_aware_plugin.cpp | 96 if (!data->payload.is_object()) {
in HandleAppStateChange() 100 if (!data->payload.contains("pid") || !data->payload.contains("uid") || !data->payload.contains("bundleName") ||
in HandleAppStateChange() 101 !data->payload["pid"].is_string() || !data->payload["uid"].is_string() ||
in HandleAppStateChange() 102 !data->payload["bundleName"].is_string()) {
in HandleAppStateChange() 103 RME_LOGI("FrameAwarePlugin::HandleAppStateChange payload is not contains pid or uid or bundleName");
in HandleAppStateChange() 109 std::string bundleName = data->payload["bundleName"].get<std::string>().c_str();
in HandleAppStateChange() 116 if (!data->payload in HandleProcessStateChange() [all...] |
/foundation/communication/bluetooth_service/services/bluetooth/service/src/avrcp_ct/ |
H A D | avrcp_ct_browse.cpp | 116 uint64_t payload = 0x00; in DisassemblePacket() local 117 offset += PopOctets1((buffer + offset), payload); in DisassemblePacket() 118 pduId_ = static_cast<uint8_t>(payload); in DisassemblePacket() 121 offset += PopOctets2((buffer + offset), payload); in DisassemblePacket() 122 parameterLength_ = static_cast<uint16_t>(payload); in DisassemblePacket() 125 offset += PopOctets1((buffer + offset), payload); in DisassemblePacket() 126 status_ = static_cast<uint8_t>(payload); in DisassemblePacket() 129 offset += PopOctets2((buffer + offset), payload); in DisassemblePacket() 130 uidCounter_ = static_cast<uint16_t>(payload); in DisassemblePacket() 133 offset += PopOctets4((buffer + offset), payload); in DisassemblePacket() 161 uint64_t payload = 0x00; DisassemblePacketName() local 253 uint64_t payload = 0x00; DisassemblePacket() local 368 uint64_t payload = 0x00; DisassemblePacket() local 423 uint64_t payload = 0x00; DisassembleMpParameter() local 478 uint64_t payload = 0x00; DisassembleMpParameterName() local 507 uint64_t payload = 0x00; DisassembleMeParameter() local 558 uint64_t payload = 0x00; DisassembleMeParameterName() local 589 uint64_t payload = 0x00; DisassembleMeParameterAttributesAndValues() local 713 uint64_t payload = 0x00; DisassemblePacket() local 759 uint64_t payload = 0x00; DisassemblePacketName() local 838 uint64_t payload = 0x00; DisassemblePacket() local [all...] |
H A D | avrcp_ct_packet.cpp | 27 uint16_t AvrcCtPacket::PushOctets1(uint8_t *pkt, uint8_t payload) const in PushOctets1() 29 HILOGI("payload: %{public}d", payload); in PushOctets1() 31 return PushOctetsUpto8(pkt, sizeof(uint8_t) * AVRC_CT_UNIT8_NUM_1, payload); in PushOctets1() 34 uint16_t AvrcCtPacket::PushOctets2(uint8_t *pkt, uint16_t payload) const in PushOctets2() 36 HILOGI("payload: %{public}d", payload); in PushOctets2() 38 return PushOctetsUpto8(pkt, sizeof(uint8_t) * AVRC_CT_UNIT8_NUM_2, payload); in PushOctets2() 41 uint16_t AvrcCtPacket::PushOctets3(uint8_t *pkt, uint32_t payload) const in PushOctets3() 43 HILOGI("payload in PushOctets3() 190 PushOctetsUpto8(uint8_t *pkt, size_t size, uint64_t payload) PushOctetsUpto8() argument 203 PopOctetsUpto8(uint8_t *pkt, size_t size, uint64_t &payload) PopOctetsUpto8() argument [all...] |
H A D | avrcp_ct_notification.cpp | 95 uint64_t payload = 0x00; in DisassembleParameters() local 96 offset += PopOctets2((buffer + offset), payload); in DisassembleParameters() 97 parameterLength_ = static_cast<uint16_t>(payload); in DisassembleParameters() 100 payload = 0x00; in DisassembleParameters() 101 PopOctets1((buffer + offset), payload); in DisassembleParameters() 102 eventId_ = static_cast<uint8_t>(payload); in DisassembleParameters() 150 uint64_t payload = 0x00; in DisassemblePlaybackStatus() local 151 PopOctets1((buffer + offset), payload); in DisassemblePlaybackStatus() 152 playStatus_ = static_cast<uint8_t>(payload); in DisassemblePlaybackStatus() 167 uint64_t payload in DisassembleTrackChanged() local 184 uint64_t payload = 0x00; DisassemblePlaybackPosChanged() local 204 uint64_t payload = 0x00; DisassemblePlayerApplicationSettingChanged() local 230 uint64_t payload = 0x00; DisassembleAddressedPlayerChanged() local 252 uint64_t payload = 0x00; DisassembleUidsChanged() local 269 uint64_t payload = 0x00; DisassembleVolumeChanged() local [all...] |
H A D | avrcp_ct_vendor.cpp | 61 uint64_t payload = 0x00; in DisassemblePacket() local 62 PopOctets1((buffer + offset), payload); in DisassemblePacket() 63 crCode_ = static_cast<uint8_t>(payload); in DisassemblePacket() 67 payload = 0x00; in DisassemblePacket() 68 PopOctets3((buffer + offset), payload); in DisassemblePacket() 69 companyId_ = static_cast<uint32_t>(payload); in DisassemblePacket() 73 payload = 0x00; in DisassemblePacket() 74 PopOctets1((buffer + offset), payload); in DisassemblePacket() 75 packetType_ = static_cast<uint8_t>(payload); in DisassemblePacket() 82 payload in DisassemblePacket() 137 uint64_t payload = 0x00; IsValidParameterLength() local 220 uint64_t payload = 0x00; DisassembleParameters() local 316 uint64_t payload = 0x00; DisassembleParameters() local 408 uint64_t payload = 0x00; DisassembleParameters() local 538 uint64_t payload = 0x00; DisassembleParameters() local 672 uint64_t payload = 0x00; DisassembleParameters() local 786 uint64_t payload = 0x00; DisassembleParameters() local 909 uint64_t payload = 0x00; DisassembleParameters() local 986 uint64_t payload = 0x00; DisassemblePacketAttributes() local 1086 uint64_t payload = 0x00; DisassembleParameters() local 1182 uint64_t payload = 0x00; DisassembleParameters() local 1360 uint64_t payload = 0x00; DisassembleParameters() local 1434 uint64_t payload = 0x00; DisassembleParameters() local 1524 uint64_t payload = 0x00; DisassembleParameters() local 1612 uint64_t payload = 0x00; DisassembleParameters() local 1692 uint64_t payload = 0x00; DisassembleParameters() local [all...] |
/foundation/communication/bluetooth_service/services/bluetooth/service/src/avrcp_tg/ |
H A D | avrcp_tg_packet.cpp | 21 uint16_t AvrcTgPacket::PushOctets1(uint8_t *pkt, uint8_t payload) in PushOctets1() argument 23 HILOGI("payload:%{public}d", payload); in PushOctets1() 25 return PushOctetsUpto8(pkt, sizeof(uint8_t) * AVRC_TG_OFFSET_ONE_BIT, payload); in PushOctets1() 28 uint16_t AvrcTgPacket::PushOctets2(uint8_t *pkt, uint16_t payload) in PushOctets2() argument 30 HILOGI("payload:%{public}d", payload); in PushOctets2() 32 return PushOctetsUpto8(pkt, sizeof(uint8_t) * AVRC_TG_OFFSET_TWO_BITS, payload); in PushOctets2() 35 uint16_t AvrcTgPacket::PushOctets3(uint8_t *pkt, uint32_t payload) in PushOctets3() argument 37 HILOGI("payload in PushOctets3() 42 PushOctets4(uint8_t *pkt, uint32_t payload) PushOctets4() argument 49 PushOctets8(uint8_t *pkt, uint64_t payload) PushOctets8() argument 65 PopOctets1(uint8_t *pkt, uint64_t &payload) PopOctets1() argument 76 PopOctets2(uint8_t *pkt, uint64_t &payload) PopOctets2() argument 87 PopOctets3(uint8_t *pkt, uint64_t &payload) PopOctets3() argument 98 PopOctets4(uint8_t *pkt, uint64_t &payload) PopOctets4() argument 109 PopOctets8(uint8_t *pkt, uint64_t &payload) PopOctets8() argument 184 PushOctetsUpto8(uint8_t *pkt, size_t size, uint64_t payload) PushOctetsUpto8() argument 197 PopOctetsUpto8(uint8_t *pkt, size_t size, uint64_t &payload) PopOctetsUpto8() argument [all...] |
/foundation/communication/netmanager_ext/services/mdnsmanager/src/ |
H A D | mdns_packet_parser.cpp | 32 template <class T> void WriteRawData(const T &data, MDnsPayload &payload) in WriteRawData() argument 35 payload.insert(payload.end(), begin, begin + sizeof(T)); in WriteRawData() 73 MDnsMessage MDnsPayloadParser::FromBytes(const MDnsPayload &payload) in FromBytes() argument 77 pos_ = Parse(payload.data(), payload, msg); in FromBytes() 83 MDnsPayload payload; in ToBytes() local 84 MDnsPayload *cachedPayload = &payload; in ToBytes() 86 Serialize(msg, payload, cachedPayload, strCacheMap); in ToBytes() 87 return payload; in ToBytes() 90 Parse(const uint8_t *begin, const MDnsPayload &payload, MDnsMessage &msg) Parse() argument 123 ParseHeader(const uint8_t *begin, const MDnsPayload &payload, DNSProto::Header &header) ParseHeader() argument 141 ParseQuestion(const uint8_t *begin, const MDnsPayload &payload, std::vector<DNSProto::Question> &questions) ParseQuestion() argument 164 ParseRR(const uint8_t *begin, const MDnsPayload &payload, std::vector<DNSProto::ResourceRecord> &answers) ParseRR() argument 189 ParseRData(const uint8_t *begin, const MDnsPayload &payload, int type, int length, std::any &data) ParseRData() argument 239 ParseSrv(const uint8_t *begin, const MDnsPayload &payload, std::any &data) ParseSrv() argument 261 ParseTxt(const uint8_t *begin, const MDnsPayload &payload, int length, std::any &data) ParseTxt() argument 273 ParseDnsString(const uint8_t *begin, const MDnsPayload &payload, std::string &str) ParseDnsString() argument 314 Serialize(const MDnsMessage &msg, MDnsPayload &payload, MDnsPayload *cachedPayload, std::map<std::string, uint16_t> &strCacheMap) Serialize() argument 338 SerializeHeader(const DNSProto::Header &header, const MDnsMessage &msg, MDnsPayload &payload) SerializeHeader() argument 340 WriteRawData(htons(header.id), payload); SerializeHeader() local 341 WriteRawData(htons(header.flags), payload); SerializeHeader() local 342 WriteRawData(htons(header.qdcount), payload); SerializeHeader() local 343 WriteRawData(htons(header.ancount), payload); SerializeHeader() local 344 WriteRawData(htons(header.nscount), payload); SerializeHeader() local 345 WriteRawData(htons(header.arcount), payload); SerializeHeader() local 348 SerializeQuestion(const DNSProto::Question &question, MDnsPayload &payload, MDnsPayload *cachedPayload, std::map<std::string, uint16_t> &strCacheMap) SerializeQuestion() argument 352 WriteRawData(htons(question.qtype), payload); SerializeQuestion() local 353 WriteRawData(htons(question.qclass), payload); SerializeQuestion() local 356 SerializeRR(const DNSProto::ResourceRecord &rr, MDnsPayload &payload, MDnsPayload *cachedPayload, std::map<std::string, uint16_t> &strCacheMap) SerializeRR() argument 360 WriteRawData(htons(rr.rtype), payload); SerializeRR() local 361 WriteRawData(htons(rr.rclass), payload); SerializeRR() local 362 WriteRawData(htonl(rr.ttl), payload); SerializeRR() local 364 WriteRawData(htons(rr.length), payload); SerializeRR() local 370 SerializeRData(const std::any &rdata, MDnsPayload &payload, MDnsPayload *cachedPayload, std::map<std::string, uint16_t> &strCacheMap) SerializeRData() argument 374 WriteRawData(*std::any_cast<const in_addr>(&rdata), payload); SerializeRData() local 376 WriteRawData(*std::any_cast<const in6_addr>(&rdata), payload); SerializeRData() local 378 SerializeDnsString(*std::any_cast<const std::string>(&rdata), payload, cachedPayload, strCacheMap); SerializeRData() local 391 SerializeDnsString(const std::string &str, MDnsPayload &payload, MDnsPayload *cachedPayload, std::map<std::string, uint16_t> &strCacheMap) SerializeDnsString() argument [all...] |
/foundation/arkui/ace_engine/frameworks/base/ressched/ |
H A D | ressched_report.cpp | 66 void LoadAceApplicationContext(std::unordered_map<std::string, std::string>& payload) in LoadAceApplicationContext() argument 69 payload[PID] = std::to_string(aceApplicationInfo.GetPid()); in LoadAceApplicationContext() 70 payload[UID] = std::to_string(aceApplicationInfo.GetUid()); in LoadAceApplicationContext() 71 payload[BUNDLE_NAME] = aceApplicationInfo.GetPackageName(); in LoadAceApplicationContext() 72 payload[ABILITY_NAME] = aceApplicationInfo.GetAbilityName(); in LoadAceApplicationContext() 86 std::unordered_map<std::string, std::string> payload = param; in ResSchedDataReport() local 87 payload[Ressched::NAME] = name; in ResSchedDataReport() 97 [this](std::unordered_map<std::string, std::string>& payload) { in ResSchedDataReport() 98 reportDataFunc_(RES_TYPE_CLICK_RECOGNIZE, CLICK_EVENT, payload); in ResSchedDataReport() 102 [this](std::unordered_map<std::string, std::string>& payload) { in ResSchedDataReport() 149 ResSchedDataReport(uint32_t resType, int32_t value, const std::unordered_map<std::string, std::string>& payload) ResSchedDataReport() argument 202 std::unordered_map<std::string, std::string> payload; HandleTouchDown() local 211 std::unordered_map<std::string, std::string> payload; HandleTouchUp() local 227 std::unordered_map<std::string, std::string> payload; HandleTouchMove() local 249 std::unordered_map<std::string, std::string> payload; HandleTouchPullUp() local 259 std::unordered_map<std::string, std::string> payload; HandleTouchPullMove() local 289 std::unordered_map<std::string, std::string> payload; LoadPageEvent() local [all...] |
/foundation/resourceschedule/resource_schedule_service/ressched/scene_recognize/src/ |
H A D | slide_recognizer.cpp | 33 static auto g_reportListFlingLockedEnd = [](const nlohmann::json payload) { 39 ResType::SlideEventStatus::SLIDE_EVENT_OFF, payload); 52 void SlideRecognizer::OnDispatchResource(uint32_t resType, int64_t value, const nlohmann::json& payload) in OnDispatchResource() argument 56 HandleSlideEvent(value, payload); in OnDispatchResource() 59 HandleSendFrameEvent(FillRealPid(payload)); in OnDispatchResource() 62 HandleClickEvent(value, payload); in OnDispatchResource() 70 void SlideRecognizer::HandleSlideEvent(int64_t value, const nlohmann::json& payload) in HandleSlideEvent() argument 73 HandleSlideDetecting(payload); in HandleSlideEvent() 75 HandleListFlingStart(payload); in HandleSlideEvent() 99 void SlideRecognizer::HandleSlideDetecting(const nlohmann::json& payload) in HandleSlideDetecting() argument 124 HandleListFlingStart(const nlohmann::json& payload) HandleListFlingStart() argument 148 HandleSendFrameEvent(const nlohmann::json& payload) HandleSendFrameEvent() argument 173 HandleClickEvent(int64_t value, const nlohmann::json& payload) HandleClickEvent() argument 209 FillRealPid(const nlohmann::json& payload) FillRealPid() argument [all...] |
H A D | background_sensitive_task_overlapping_scene_recognizer.cpp | 52 const nlohmann::json& payload) in OnDispatchResource() 54 if (!payload.contains(PID_KEY) || !payload[PID_KEY].is_string()) { in OnDispatchResource() 60 HandleForeground(resType, value, payload); in OnDispatchResource() 63 HandleContinuousTask(resType, value, payload); in OnDispatchResource() 66 StrToInt(payload[PID_KEY].get<std::string>(), sceneboardPid_); in OnDispatchResource() 74 const nlohmann::json& payload) in HandleContinuousTask() 77 StrToInt(payload[PID_KEY].get<std::string>(), pid); in HandleContinuousTask() 79 if (payload.contains(TYPE_IDS_KEY) && payload[TYPE_IDS_KE in HandleContinuousTask() 51 OnDispatchResource(uint32_t resType, int64_t value, const nlohmann::json& payload) OnDispatchResource() argument 73 HandleContinuousTask(uint32_t resType, int64_t value, const nlohmann::json& payload) HandleContinuousTask() argument 134 nlohmann::json payload; EnterScene() local 142 nlohmann::json payload; ExitScene() local 172 nlohmann::json payload; HandleTaskUpdate() local 190 HandleForeground(uint32_t resType, int64_t value, const nlohmann::json& payload) HandleForeground() argument [all...] |
/foundation/resourceschedule/qos_manager/test/unittest/phone/ |
H A D | concurrent_task_client_test.cpp | 59 std::unordered_map<std::string, std::string> payload; in HWTEST_F() local 60 payload["uid"] = "3587"; in HWTEST_F() 61 payload["pid"] = "12345"; in HWTEST_F() 62 payload["type"] = "appStart"; in HWTEST_F() 63 ConcurrentTaskClient::GetInstance().ReportData(resType, value, payload); in HWTEST_F() 97 std::unordered_map<pid_t, uint32_t> payload; in HWTEST_F() local 98 payload[1111] = 60; in HWTEST_F() 99 payload[2222] = 90; in HWTEST_F() 100 ConcurrentTaskClient::GetInstance().QueryDeadline(queryItem, ddlReply, payload); in HWTEST_F() 110 std::unordered_map<std::string, std::string> payload; in HWTEST_F() local [all...] |
/foundation/resourceschedule/resource_schedule_service/ressched/services/resschedmgr/resschedfwk/src/ |
H A D | kill_process.cpp | 36 int32_t KillProcess::KillProcessByPidWithClient(const nlohmann::json& payload)
in KillProcessByPidWithClient() argument 38 if ((payload == nullptr) || !(payload.contains("pid") && payload["pid"].is_string())) {
in KillProcessByPidWithClient() 42 pid_t pid = static_cast<int32_t>(atoi(payload["pid"].get<string>().c_str()));
in KillProcessByPidWithClient() 43 std::string processName = payload.contains("processName") && payload["processName"].is_string() ?
in KillProcessByPidWithClient() 44 payload["processName"].get<string>() : UNKNOWN_PROCESS;
in KillProcessByPidWithClient() 45 if (payload.contains("killReason") && payload["killReaso in KillProcessByPidWithClient() [all...] |
/foundation/resourceschedule/resource_schedule_service/ressched/sched_controller/common_event/src/ |
H A D | event_controller.cpp | 80 void EventController::HandlePkgAddRemove(const EventFwk::Want &want, nlohmann::json &payload) const in HandlePkgAddRemove() 86 payload["bundleName"] = bundleName; in HandlePkgAddRemove() 87 payload["uid"] = uid; in HandlePkgAddRemove() 88 payload["appIndex"] = appIndex; in HandlePkgAddRemove() 115 const EventFwk::Want &want, const int32_t &code, nlohmann::json &payload) in HandleConnectivityChange() 121 ReportDataInProcess(ResType::RES_TYPE_WIFI_CONNECT_STATE_CHANGE, code, payload); in HandleConnectivityChange() 124 void EventController::ReportDataInProcess(const uint32_t &resType, const int64_t &value, const nlohmann::json& payload) in ReportDataInProcess() argument 126 ResSchedMgr::GetInstance().ReportData(resType, value, payload); in ReportDataInProcess() 129 payload_ = payload; in ReportDataInProcess() 213 nlohmann::json payload in OnReceiveEvent() local 114 HandleConnectivityChange( const EventFwk::Want &want, const int32_t &code, nlohmann::json &payload) HandleConnectivityChange() argument 261 handleEvent(int32_t userId, const std::string &action, nlohmann::json &payload) handleEvent() argument 306 handleOtherEvent(int32_t userId, const std::string &action, nlohmann::json &payload) handleOtherEvent() argument 316 HandlePkgCommonEvent(const std::string &action, Want &want, nlohmann::json &payload) HandlePkgCommonEvent() argument [all...] |
/foundation/resourceschedule/resource_schedule_service/ressched_executor/services/resschedexemgr/src/ |
H A D | res_sched_exe_mgr.cpp | 65 const nlohmann::json& payload, nlohmann::json& reply) in SendRequestSync() 72 InitPluginMgr(payload); in SendRequestSync() 78 HandleRequestForCgroup(resType, payload, reply); in SendRequestSync() 81 auto resData = std::make_shared<ResData>(resType, value, payload, reply); in SendRequestSync() 91 void ResSchedExeMgr::SendRequestAsync(uint32_t resType, int64_t value, const nlohmann::json& payload) in SendRequestAsync() argument 95 InitPluginMgr(payload); in SendRequestAsync() 100 PluginMgr::GetInstance().DispatchResource(std::make_shared<ResData>(resType, value, payload)); in SendRequestAsync() 109 void ResSchedExeMgr::InitPluginMgr(const nlohmann::json& payload) in InitPluginMgr() argument 116 if (!payload.contains(STR_CONFIG_READER) || !payload[STR_CONFIG_READE in InitPluginMgr() 64 SendRequestSync(uint32_t resType, int64_t value, const nlohmann::json& payload, nlohmann::json& reply) SendRequestSync() argument 150 HandleRequestForCgroup(uint32_t resType, const nlohmann::json& payload, nlohmann::json& reply) HandleRequestForCgroup() argument 193 ParseValue(int32_t& value, const char* name, const nlohmann::json& payload) ParseValue() argument 202 GetCgroupFileContent(uint32_t resType, const nlohmann::json& payload, nlohmann::json& reply) GetCgroupFileContent() argument 224 CheckProcTaskForCgroup(uint32_t resType, const nlohmann::json& payload, nlohmann::json& reply) CheckProcTaskForCgroup() argument [all...] |
/foundation/communication/nfc/services/src/tag/ |
H A D | ndef_bt_data_parser.cpp | 82 std::string NdefBtDataParser::GetOrgBtMacFromPayload(const std::string& payload, uint32_t& offset)
in GetOrgBtMacFromPayload() argument 84 if (payload.length() < (offset * HEX_BYTE_LEN)) {
in GetOrgBtMacFromPayload() 85 ErrorLog("NdefBtDataParser::GetBtMacFromPayload, payload.length error");
in GetOrgBtMacFromPayload() 88 if (MAC_ADDR_SIZE * HEX_BYTE_LEN > payload.length() - (offset * HEX_BYTE_LEN)) {
in GetOrgBtMacFromPayload() 90 "payload len %{public}lu offset.%{public}d", payload.length(), offset);
in GetOrgBtMacFromPayload() 93 std::string mac = payload.substr(offset * HEX_BYTE_LEN, MAC_ADDR_SIZE * HEX_BYTE_LEN);
in GetOrgBtMacFromPayload() 98 bool NdefBtDataParser::GetBtDevClass(const std::string& payload, uint32_t& offset,
in GetBtDevClass() argument 101 if (payload.length() == 0 || (payload in GetBtDevClass() 155 GetDataFromPayload(const std::string& payload, uint32_t& offset, uint32_t dataLen) GetDataFromPayload() argument 165 GetUuidFromPayload(const std::string& payload, uint32_t& offset, uint32_t type, uint32_t len) GetUuidFromPayload() argument 206 ParseBtRecord(const std::string& payload) ParseBtRecord() argument 321 ParseBleRecord(const std::string& payload) ParseBleRecord() argument [all...] |