/base/telephony/sms_mms/services/sms/gsm/ |
H A D | gsm_sms_message.cpp | 64 tPdu->data.submit.destAddress.ton = TYPE_UNKNOWN; in SetSmsTpduDestAddress() 65 tPdu->data.submit.destAddress.npi = SMS_NPI_ISDN; in SetSmsTpduDestAddress() 67 ret = memcpy_s(tPdu->data.submit.destAddress.address, sizeof(tPdu->data.submit.destAddress.address), in SetSmsTpduDestAddress() 73 tPdu->data.submit.destAddress.address[addLen] = '\0'; in SetSmsTpduDestAddress() 76 ret = memcpy_s(tPdu->data.submit.destAddress.address, sizeof(tPdu->data.submit.destAddress.address), in SetSmsTpduDestAddress() 79 ret = memcpy_s(tPdu->data.submit.destAddress.address, sizeof(tPdu->data.submit.destAddress.address), in SetSmsTpduDestAddress() 86 tPdu->data.submit in SetSmsTpduDestAddress() 478 AnalysisMsgSubmit(const SmsSubmit &submit) AnalysisMsgSubmit() argument [all...] |
H A D | gsm_sms_tpdu_decode.cpp | 36 bool GsmSmsTpduDecode::DecodeSubmit(SmsReadBuffer &buffer, struct SmsSubmit *submit) in DecodeSubmit() argument 38 if (submit == nullptr || tpdu_ == nullptr) { in DecodeSubmit() 51 submit->bRejectDup = false; in DecodeSubmit() 53 submit->bRejectDup = true; in DecodeSubmit() 60 submit->vpf = static_cast<enum SmsVpf>(oneByte & HEX_VALUE_18); in DecodeSubmit() 67 submit->bStatusReport = true; in DecodeSubmit() 69 submit->bStatusReport = false; in DecodeSubmit() 77 submit->bHeaderInd = true; in DecodeSubmit() 79 submit->bHeaderInd = false; in DecodeSubmit() 81 return DecodeSubmitPartData(buffer, submit); in DecodeSubmit() 84 DecodeSubmitPartData(SmsReadBuffer &buffer, struct SmsSubmit *submit) DecodeSubmitPartData() argument [all...] |
H A D | gsm_sms_sender.cpp | 68 isStatusReport = tpdu->data.submit.bStatusReport; in TextBasedSmsDelivery() 102 (void)memset_s(tpdu->data.submit.userData.data, MAX_USER_DATA_LEN + 1, 0x00, MAX_USER_DATA_LEN + 1); in TextBasedSmsSplitDelivery() 107 int ret = memcpy_s(tpdu->data.submit.userData.data, MAX_USER_DATA_LEN + 1, &cellsInfos[i].encodeData[0], in TextBasedSmsSplitDelivery() 113 tpdu->data.submit.userData.length = cellsInfos[i].encodeData.size(); in TextBasedSmsSplitDelivery() 114 tpdu->data.submit.userData.data[cellsInfos[i].encodeData.size()] = 0; in TextBasedSmsSplitDelivery() 115 tpdu->data.submit.msgRef = msgRef8bit; in TextBasedSmsSplitDelivery() 132 tpdu->data.submit.userData.headerCnt = headerCnt; in TextBasedSmsSplitDelivery() 133 tpdu->data.submit.bHeaderInd = (headerCnt > 0) ? true : false; in TextBasedSmsSplitDelivery() 137 tpdu->data.submit.bStatusReport = false; in TextBasedSmsSplitDelivery() 139 tpdu->data.submit in TextBasedSmsSplitDelivery() [all...] |
H A D | gsm_sms_tpdu_codec.cpp | 59 encodeRet = tpduEncode->EncodeSubmitPdu(pduBuffer, &(sourceData->data.submit)); in EncodeSmsPdu() 120 decodeResult = tpduDecode->DecodeSubmit(buffer, &(pSmsTpdu->data.submit)); in DecodeSmsPdu()
|
/base/telephony/call_manager/services/call/src/ |
H A D | call_request_handler.cpp | 53 ffrt::submit([=]() { callRequestProcessPtr_->AnswerRequest(callId, videoState); }); in AnswerCall() 63 ffrt::submit([=]() { in RejectCall() 76 ffrt::submit([=]() { callRequestProcessPtr_->HangUpRequest(callId); }); in HangUpCall() 86 ffrt::submit([=]() { callRequestProcessPtr_->HoldRequest(callId); }); in HoldCall() 96 ffrt::submit([=]() { callRequestProcessPtr_->UnHoldRequest(callId); }); in UnHoldCall() 106 ffrt::submit([=]() { callRequestProcessPtr_->SwitchRequest(callId); }); in SwitchCall() 116 ffrt::submit([=]() { in StartRtt() 129 ffrt::submit([=]() { callRequestProcessPtr_->StopRttRequest(callId); }); in StopRtt() 140 ffrt::submit([callId, callRequestProcessPtr, numberList]() { in JoinConference() 158 ffrt::submit([ in CombineConference() [all...] |
/base/telephony/sms_mms/services/sms/cdma/ |
H A D | cdma_sms_sender.cpp | 73 transMsg->data.p2p.telesvcMsg.data.submit.msgId.msgId = msgId; in TextBasedSmsDelivery() 91 (void)memset_s(transMsg->data.p2p.telesvcMsg.data.submit.userData.userData.data, in TextBasedSmsSplitDelivery() 92 sizeof(transMsg->data.p2p.telesvcMsg.data.submit.userData.userData.data), 0x00, in TextBasedSmsSplitDelivery() 93 sizeof(transMsg->data.p2p.telesvcMsg.data.submit.userData.userData.data)); in TextBasedSmsSplitDelivery() 94 if (splits[i].encodeData.size() > sizeof(transMsg->data.p2p.telesvcMsg.data.submit.userData.userData.data)) { in TextBasedSmsSplitDelivery() 98 int value = memcpy_s(transMsg->data.p2p.telesvcMsg.data.submit.userData.userData.data, in TextBasedSmsSplitDelivery() 99 sizeof(transMsg->data.p2p.telesvcMsg.data.submit.userData.userData.data), splits[i].encodeData.data(), in TextBasedSmsSplitDelivery() 114 transMsg->data.p2p.telesvcMsg.data.submit.userData.userData.length = in TextBasedSmsSplitDelivery() 194 (void)memset_s(tpdu->data.submit.userData.data, MAX_USER_DATA_LEN + 1, 0x00, MAX_USER_DATA_LEN + 1); in SendSmsForEveryIndexer() 199 if (memcpy_s(tpdu->data.submit in SendSmsForEveryIndexer() [all...] |
H A D | cdma_sms_message.cpp | 40 transMsg->data.p2p.telesvcMsg.data.submit.userData.encodeType = CovertEncodingType(codingScheme); in CreateSubmitTransMsg() 42 transMsg->data.p2p.telesvcMsg.data.submit.replyOpt.dak = bStatusReport; in CreateSubmitTransMsg() 76 transMsg->data.p2p.telesvcMsg.data.submit.replyOpt.dak = bStatusReport; in CreateSubmitTransMsg() 116 transMsg->data.p2p.telesvcMsg.data.submit.valPeriod.format = SMS_TIME_RELATIVE; in GreateTransMsg() 117 transMsg->data.p2p.telesvcMsg.data.submit.valPeriod.time.relTime.time = SMS_REL_TIME_INDEFINITE; in GreateTransMsg() 119 transMsg->data.p2p.telesvcMsg.data.submit.priority = SmsPriorityIndicator::NORMAL; in GreateTransMsg() 121 transMsg->data.p2p.telesvcMsg.data.submit.privacy = SmsPrivacyIndicator::NOT_RESTRICTED; in GreateTransMsg() 123 transMsg->data.p2p.telesvcMsg.data.submit.alertPriority = SmsAlertPriority::DEFAULT; in GreateTransMsg() 125 transMsg->data.p2p.telesvcMsg.data.submit.language = SmsLanguageType::UNKNOWN; in GreateTransMsg() 246 AnalsisSubmitMsg(p2pMsg.telesvcMsg.data.submit); in AnalysisP2pMsg() 312 AnalsisSubmitMsg(const TeleserviceSubmit &submit) AnalsisSubmitMsg() argument [all...] |
/base/telephony/core_service/utils/common/src/ |
H A D | tel_event_handler.cpp | 26 ffrt::submit(task); in Submit() 31 ffrt::submit(task); in Submit() 36 ffrt::submit(task); in SubmitSync() 42 ffrt::submit(task); in SubmitSync()
|
/base/telephony/sms_mms/services/sms/include/gsm/ |
H A D | gsm_sms_tpdu_decode.h | 28 bool DecodeSubmit(SmsReadBuffer &buffer, struct SmsSubmit *submit); 33 bool DecodeSubmitPartData(SmsReadBuffer &buffer, struct SmsSubmit *submit);
|
/base/telephony/call_manager/services/telephony_interaction/src/ |
H A D | report_call_info_handler.cpp | 49 TELEPHONY_LOGW("UpdateCallReportInfo submit task enter"); in UpdateCallReportInfo() 50 reportCallInfoQueue.submit([callStatusManagerPtr, callDetailInfo]() { in UpdateCallReportInfo() 95 TELEPHONY_LOGW("UpdateCallsReportInfo submit task enter"); in UpdateCallsReportInfo() 96 reportCallInfoQueue.submit([callStatusManagerPtr, callDetailsInfo]() { in UpdateCallsReportInfo() 136 TELEPHONY_LOGI("UpdateDisconnectedCause submit task enter"); in UpdateDisconnectedCause() 137 reportCallInfoQueue.submit([callStatusManagerPtr, disconnectedDetails]() { in UpdateDisconnectedCause() 159 TELEPHONY_LOGI("UpdateEventResultInfo submit task enter"); in UpdateEventResultInfo() 160 reportCallInfoQueue.submit([callStatusManagerPtr, info]() { in UpdateEventResultInfo() 183 TELEPHONY_LOGI("UpdateOttEventInfo submit task enter"); in UpdateOttEventInfo() 184 reportCallInfoQueue.submit([callStatusManagerPt in UpdateOttEventInfo() [all...] |
/base/telephony/sms_mms/test/unittest/ |
H A D | cdma_sms_test.cpp | 55 transMsg->data.p2p.telesvcMsg.data.submit.msgId.headerInd = true; in SetPduSeqInfo() 56 transMsg->data.p2p.telesvcMsg.data.submit.userData.userData.headerCnt = 1; in SetPduSeqInfo() 57 transMsg->data.p2p.telesvcMsg.data.submit.userData.userData.header[0].udhType = UDH_CONCAT_8BIT; in SetPduSeqInfo() 58 transMsg->data.p2p.telesvcMsg.data.submit.userData.userData.header[0].udh.concat8bit.msgRef = msgRef8bit; in SetPduSeqInfo() 59 transMsg->data.p2p.telesvcMsg.data.submit.userData.userData.header[0].udh.concat8bit.totalSeg = in SetPduSeqInfo() 61 transMsg->data.p2p.telesvcMsg.data.submit.userData.userData.header[0].udh.concat8bit.seqNum = index + 1; in SetPduSeqInfo() 372 void CdmaSmsTest::PrintTeleserviceSubmit(TeleserviceSubmit submit, string s) const in PrintTeleserviceSubmit() argument 374 cout << s << " msgId : " << static_cast<int>(submit.msgId.msgId) << endl; in PrintTeleserviceSubmit() 375 cout << s << " headerInd : " << static_cast<int>(submit.msgId.headerInd) << endl; in PrintTeleserviceSubmit() 377 PrintUserData(submit in PrintTeleserviceSubmit() [all...] |
/base/telephony/sms_mms/test/gtest/ |
H A D | cdma_sms_gtest.cpp | 426 EXPECT_STREQ(GetUserDataString(v.data.submit.userData).c_str(), userData.c_str()); in CheckSubmitUserData() 445 EXPECT_STREQ(GetUserDataString(v2.data.submit.userData).c_str(), userData.c_str()); in CheckSubmitUserData() 497 EXPECT_EQ(v.data.submit.msgId.msgId, 1); in HWTEST_F() 498 EXPECT_EQ(v.data.submit.priority, SmsPriorityIndicator::EMERGENCY); in HWTEST_F() 499 EXPECT_EQ(v.data.submit.privacy, SmsPrivacyIndicator::CONFIDENTIAL); in HWTEST_F() 500 EXPECT_EQ(v.data.submit.callbackNumber.addrLen, 7); in HWTEST_F() 503 EXPECT_EQ(v.data.submit.callbackNumber.szData[i], number[i]); in HWTEST_F() 505 EXPECT_EQ(v.data.submit.depositId, 1382); in HWTEST_F() 506 EXPECT_EQ(v.data.submit.language, SmsLanguageType::HEBREW); in HWTEST_F() 507 EXPECT_EQ(v.data.submit in HWTEST_F() [all...] |
/base/hiviewdfx/hiview/plugins/eventlogger/ |
H A D | active_key_event.cpp | 94 ffrt::submit(task, {}, {&taskOutDeps}, ffrt::task_attr().name(taskName.c_str()));
in InitSubscribe() 116 ffrt::submit(initSubscribePower, {}, {}, ffrt::task_attr().name("initSubscribePower").qos(ffrt::qos_default));
in Init() 117 ffrt::submit(initSubscribeOnlyPower, {}, {},
in Init() 189 ffrt::submit(hitraceCapture, {}, {}, ffrt::task_attr().name("HitraceCapture").qos(ffrt::qos_user_initiated));
in CombinationKeyHandle() 208 ffrt::submit(combinationKeyHandle, {}, {},
in CombinationKeyCallback()
|
H A D | event_focus_listener.cpp | 70 HIVIEW_LOGI("before submit registerFocusListener task to ffrt"); in RegisterFocusListener() 71 ffrt::submit(registerTask, {}, {}, ffrt::task_attr().name("rgs_fcs_lst")); in RegisterFocusListener() 72 HIVIEW_LOGI("after submit registerFocusListener task to ffrt"); in RegisterFocusListener()
|
/base/hiviewdfx/hiview/framework/native/unified_collection/collector/utils/ |
H A D | trace_worker.cpp | 31 ffrtQueue_->submit(ucollectionTask, ffrt::task_attr().name("dft_uc_trace"));
in HandleUcollectionTask()
|
/base/telephony/sms_mms/services/sms/ |
H A D | sms_sender.cpp | 491 (void)memset_s(tpdu->data.submit.userData.data, MAX_USER_DATA_LEN + 1, 0x00, MAX_USER_DATA_LEN + 1); in DataBasedSmsDeliverySplitPage() 496 int ret = memcpy_s(tpdu->data.submit.userData.data, MAX_USER_DATA_LEN + 1, &cellsInfos[indexData].encodeData[0], in DataBasedSmsDeliverySplitPage() 513 tpdu->data.submit.userData.length = static_cast<int>(cellsInfos[indexData].encodeData.size()); in DataBasedSmsDeliveryPacketSplitPage() 514 tpdu->data.submit.userData.data[cellsInfos[indexData].encodeData.size()] = 0; in DataBasedSmsDeliveryPacketSplitPage() 515 tpdu->data.submit.msgRef = msgRef8bit; in DataBasedSmsDeliveryPacketSplitPage() 533 tpdu->data.submit.userData.header[headerCnt].udhType = UDH_APP_PORT_16BIT; in DataBasedSmsDeliveryPacketSplitPage() 534 tpdu->data.submit.userData.header[headerCnt].udh.appPort16bit.destPort = ((unsigned short)port & 0xFFFF); in DataBasedSmsDeliveryPacketSplitPage() 535 tpdu->data.submit.userData.header[headerCnt].udh.appPort16bit.originPort = 0; in DataBasedSmsDeliveryPacketSplitPage() 537 tpdu->data.submit.bHeaderInd = (headerCnt > 0) ? true : false; in DataBasedSmsDeliveryPacketSplitPage() 544 tpdu->data.submit in DataBasedSmsDeliveryPacketSplitPage() [all...] |
/base/telephony/call_manager/services/call_report/src/ |
H A D | app_state_observer.cpp | 42 unregisterCallbackQueue.submit([=]() { report->UnRegisterCallBack(std::to_string(processData.pid)); }); in OnProcessDied()
|
/base/notification/common_event_service/services/src/ |
H A D | common_event_manager_service.cpp | 222 EVENT_LOGI("Start to submit publish commonEvent <%{public}d>", uid); in PublishCommonEventDetailed() 223 commonEventSrvQueue_->submit(publishCommonEventFunc); in PublishCommonEventDetailed() 287 EVENT_LOGI("Start to submit subscribe commonEvent <%{public}d>", callingUid); in SubscribeCommonEvent() 288 commonEventSrvQueue_->submit(subscribeCommonEventFunc); in SubscribeCommonEvent() 315 commonEventSrvQueue_->submit(unsubscribeCommonEventFunc); in UnsubscribeCommonEvent() 391 commonEventSrvQueue_->submit(finishReceiverFunc); in FinishReceiver() 420 commonEventSrvQueue_->submit(freezeFunc); in Freeze() 450 commonEventSrvQueue_->submit(unfreezeFunc); in Unfreeze() 480 commonEventSrvQueue_->submit(unfreezeAllFunc); in UnfreezeAll() 577 commonEventSrvQueue_->submit(setFreezeStatusFun in SetFreezeStatus() [all...] |
/base/powermgr/power_manager/utils/ffrt/src/ |
H A D | ffrt_utils.cpp | 23 ffrt::submit(task);
in SubmitTask() 28 ffrt::submit(task);
in SubmitTaskSync() 38 queue.submit(task);
in SubmitQueueTasks()
|
/base/notification/distributed_notification_service/services/ans/src/ |
H A D | notification_subscriber_manager.cpp | 155 notificationSubQueue_->submit(NotifyConsumedFunc); in NotifyConsumed() 176 notificationSubQueue_->submit(batchNotifyConsumedFunc); in BatchNotifyConsumed() 196 notificationSubQueue_->submit(NotifyCanceledFunc); in NotifyCanceled() 215 notificationSubQueue_->submit(NotifyCanceledFunc); in BatchNotifyCanceled() 227 notificationSubQueue_->submit(NotifyUpdatedFunc); in NotifyUpdated() 240 notificationSubQueue_->submit(func); in NotifyDoNotDisturbDateChanged() 254 notificationSubQueue_->submit(func); in NotifyEnabledNotificationChanged() 267 notificationSubQueue_->submit(func); in NotifyBadgeEnabledChanged() 664 notificationSubQueue_->submit(setBadgeNumberFunc); in SetBadgeNumber()
|
/base/security/selinux_adapter/scripts/ |
H A D | build_policy_api.py | 501 normal_thread = executor.submit(generate_default_policy, args, file_list_object, cil_list, False) 502 developer_thread = executor.submit(generate_default_policy, args, file_list_object, 505 normal_thread = executor.submit(generate_special_policy, args, file_list_object, cil_list, False) 506 developer_thread = executor.submit(generate_special_policy, args, file_list_object, 516 build_normal_thread = executor.submit(build_binary_policy, args.tool_path, args.dst_file, True, cil_list) 518 build_developer_thread = executor.submit(build_binary_policy, args.tool_path, developer_policy_path, 564 pre_check_thread = executor.submit(pre_check, pre_check_args) 567 compile_thread = executor.submit(compile_sepolicy, compile_args)
|
/base/hiviewdfx/hiappevent/frameworks/native/libhiappevent/utility/ |
H A D | app_event_stat.cpp | 49 ffrt::submit([appEventPack]() { in WriteApiEndEventAsync()
|
/base/hiviewdfx/hilog/services/hilogd/ |
H A D | main.cpp | 172 ffrt::submit([&hilogBuffer, &kmsgBuffer]() { in HilogdEntry() 191 ffrt::submit([]() { in HilogdEntry()
|
/base/security/security_guard/services/risk_classify/src/ |
H A D | risk_analysis_manager_service.cpp | 75 ffrt::submit(task);
in OnStart() 162 ffrt::submit(task);
in PushRiskAnalysisTask()
|
/base/hiviewdfx/hiview/base/ |
H A D | event_dispatch_queue.cpp | 85 ffrtQueue_->submit([event, queuePtr] {
in Enqueue()
|