/base/telephony/sms_mms/services/sms/gsm/ |
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.destAddress.address[MAX_ADDRESS_LEN] = '\0'; in SetSmsTpduDestAddress() 101 smsTpdu_->data.submit.userData.header[index].udhType = UDH_SINGLE_SHIFT; in SetHeaderLang() 102 smsTpdu_->data.submit.userData.header[index].udh.singleShift.langId = langId; in SetHeaderLang() 122 smsTpdu_->data.submit.userData.header[index].udhType = UDH_CONCAT_8BIT; in SetHeaderConcat() [all …]
|
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() [all …]
|
D | gsm_sms_sender.cpp | 68 isStatusReport = tpdu->data.submit.bStatusReport; in TextBasedSmsDelivery() 99 …(void)memset_s(tpdu->data.submit.userData.data, MAX_USER_DATA_LEN + 1, 0x00, MAX_USER_DATA_LEN + 1… in TextBasedSmsSplitDelivery() 104 …int ret = memcpy_s(tpdu->data.submit.userData.data, MAX_USER_DATA_LEN + 1, &cellsInfos[i].encodeDa… in TextBasedSmsSplitDelivery() 110 tpdu->data.submit.userData.length = cellsInfos[i].encodeData.size(); in TextBasedSmsSplitDelivery() 111 tpdu->data.submit.userData.data[cellsInfos[i].encodeData.size()] = 0; in TextBasedSmsSplitDelivery() 112 tpdu->data.submit.msgRef = msgRef8bit; in TextBasedSmsSplitDelivery() 129 tpdu->data.submit.userData.headerCnt = headerCnt; in TextBasedSmsSplitDelivery() 130 tpdu->data.submit.bHeaderInd = (headerCnt > 0) ? true : false; in TextBasedSmsSplitDelivery() 134 tpdu->data.submit.bStatusReport = false; in TextBasedSmsSplitDelivery() 136 tpdu->data.submit.bStatusReport = isStatusReport; in TextBasedSmsSplitDelivery() [all …]
|
D | gsm_sms_tpdu_codec.cpp | 59 encodeRet = tpduEncode->EncodeSubmitPdu(pduBuffer, &(sourceData->data.submit)); in EncodeSmsPdu() 121 decodeResult = tpduDecode->DecodeSubmit(buffer, &(pSmsTpdu->data.submit)); in DecodeSmsPdu()
|
/base/telephony/call_manager/services/call/src/ |
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() 139 ffrt::submit([=]() { in JoinConference() 152 ffrt::submit([=]() { callRequestProcessPtr_->CombineConferenceRequest(mainCallId); }); in CombineConference() [all …]
|
/base/telephony/sms_mms/services/sms/cdma/ |
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.userDa… 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.dat… in TextBasedSmsSplitDelivery() 114 transMsg->data.p2p.telesvcMsg.data.submit.userData.userData.length = in TextBasedSmsSplitDelivery() 177 …(void)memset_s(tpdu->data.submit.userData.data, MAX_USER_DATA_LEN + 1, 0x00, MAX_USER_DATA_LEN + 1… in SendSmsForEveryIndexer() 182 … if (memcpy_s(tpdu->data.submit.userData.data, MAX_USER_DATA_LEN + 1, &cellsInfos[i].encodeData[0], in SendSmsForEveryIndexer() [all …]
|
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() [all …]
|
/base/telephony/core_service/utils/common/src/ |
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/test/unittest/ |
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 = msgR… 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 = inde… 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.userData); in PrintTeleserviceSubmit() [all …]
|
/base/telephony/sms_mms/test/gtest/ |
D | cdma_sms_gtest.cpp | 415 EXPECT_STREQ(GetUserDataString(v.data.submit.userData).c_str(), userData.c_str()); in CheckSubmitUserData() 434 EXPECT_STREQ(GetUserDataString(v2.data.submit.userData).c_str(), userData.c_str()); in CheckSubmitUserData() 486 EXPECT_EQ(v.data.submit.msgId.msgId, 1); 487 EXPECT_EQ(v.data.submit.priority, SmsPriorityIndicator::EMERGENCY); 488 EXPECT_EQ(v.data.submit.privacy, SmsPrivacyIndicator::CONFIDENTIAL); 489 EXPECT_EQ(v.data.submit.callbackNumber.addrLen, 7); 492 EXPECT_EQ(v.data.submit.callbackNumber.szData[i], number[i]); 494 EXPECT_EQ(v.data.submit.depositId, 1382); 495 EXPECT_EQ(v.data.submit.language, SmsLanguageType::HEBREW); 496 EXPECT_EQ(v.data.submit.alertPriority, SmsAlertPriority::HIGH); [all …]
|
/base/telephony/sms_mms/services/sms/include/gsm/ |
D | gsm_sms_tpdu_decode.h | 28 bool DecodeSubmit(SmsReadBuffer &buffer, struct SmsSubmit *submit); 33 bool DecodeSubmitPartData(SmsReadBuffer &buffer, struct SmsSubmit *submit);
|
/base/hiviewdfx/hiview/plugins/eventlogger/ |
D | active_key_event.cpp | 81 ffrt::submit(task, {}, {&taskOutDeps}, ffrt::task_attr().name(taskName.c_str())); in InitSubscribe() 104 …ffrt::submit(initSubscribeDown, {}, {}, ffrt::task_attr().name("initSubscribeDown").qos(ffrt::qos_… in Init() 105 …ffrt::submit(initSubscribePower, {}, {}, ffrt::task_attr().name("initSubscribePower").qos(ffrt::qo… in Init() 106 ffrt::submit(initSubscribeOnlyPower, {}, {}, in Init() 178 …ffrt::submit(hitraceCapture, {}, {}, ffrt::task_attr().name("HitraceCapture").qos(ffrt::qos_user_i… in CombinationKeyHandle() 197 ffrt::submit(combinationKeyHandle, {}, {}, in CombinationKeyCallback()
|
/base/telephony/sms_mms/services/sms/ |
D | sms_sender.cpp | 458 …(void)memset_s(tpdu->data.submit.userData.data, MAX_USER_DATA_LEN + 1, 0x00, MAX_USER_DATA_LEN + 1… in DataBasedSmsDeliverySplitPage() 463 …int ret = memcpy_s(tpdu->data.submit.userData.data, MAX_USER_DATA_LEN + 1, &cellsInfos[indexData].… in DataBasedSmsDeliverySplitPage() 480 tpdu->data.submit.userData.length = static_cast<int>(cellsInfos[indexData].encodeData.size()); in DataBasedSmsDeliveryPacketSplitPage() 481 tpdu->data.submit.userData.data[cellsInfos[indexData].encodeData.size()] = 0; in DataBasedSmsDeliveryPacketSplitPage() 482 tpdu->data.submit.msgRef = msgRef8bit; in DataBasedSmsDeliveryPacketSplitPage() 500 tpdu->data.submit.userData.header[headerCnt].udhType = UDH_APP_PORT_16BIT; in DataBasedSmsDeliveryPacketSplitPage() 501 …tpdu->data.submit.userData.header[headerCnt].udh.appPort16bit.destPort = ((unsigned short)port & 0… in DataBasedSmsDeliveryPacketSplitPage() 502 tpdu->data.submit.userData.header[headerCnt].udh.appPort16bit.originPort = 0; in DataBasedSmsDeliveryPacketSplitPage() 504 tpdu->data.submit.bHeaderInd = (headerCnt > 0) ? true : false; in DataBasedSmsDeliveryPacketSplitPage() 511 tpdu->data.submit.userData.headerCnt = headerCnt; in DataBasedSmsDeliveryPacketSplitPage() [all …]
|
/base/notification/common_event_service/services/src/ |
D | common_event_manager_service.cpp | 216 commonEventSrvQueue_->submit(publishCommonEventFunc); in PublishCommonEventDetailed() 268 commonEventSrvQueue_->submit(subscribeCommonEventFunc); in SubscribeCommonEvent() 295 commonEventSrvQueue_->submit(unsubscribeCommonEventFunc); in UnsubscribeCommonEvent() 366 commonEventSrvQueue_->submit(finishReceiverFunc); in FinishReceiver() 392 commonEventSrvQueue_->submit(freezeFunc); in Freeze() 419 commonEventSrvQueue_->submit(unfreezeFunc); in Unfreeze() 446 commonEventSrvQueue_->submit(unfreezeAllFunc); in UnfreezeAll()
|
/base/notification/distributed_notification_service/services/ans/src/ |
D | notification_subscriber_manager.cpp | 152 notificationSubQueue_->submit(NotifyConsumedFunc); in NotifyConsumed() 173 notificationSubQueue_->submit(batchNotifyConsumedFunc); in BatchNotifyConsumed() 193 notificationSubQueue_->submit(NotifyCanceledFunc); in NotifyCanceled() 212 notificationSubQueue_->submit(NotifyCanceledFunc); in BatchNotifyCanceled() 224 notificationSubQueue_->submit(NotifyUpdatedFunc); in NotifyUpdated() 236 notificationSubQueue_->submit(func); in NotifyDoNotDisturbDateChanged() 250 notificationSubQueue_->submit(func); in NotifyEnabledNotificationChanged() 263 notificationSubQueue_->submit(func); in NotifyBadgeEnabledChanged() 611 notificationSubQueue_->submit(setBadgeNumberFunc); in SetBadgeNumber()
|
/base/powermgr/power_manager/utils/ffrt/src/ |
D | ffrt_utils.cpp | 23 ffrt::submit(task); in SubmitTask() 28 ffrt::submit(task); in SubmitTaskSync() 38 queue.submit(task); in SubmitQueueTasks()
|
/base/hiviewdfx/hiview/framework/native/unified_collection/collector/utils/ |
D | trace_worker.cpp | 31 … ffrt::submit(ucollectionTask, {}, {}, ffrt::task_attr().name("UC_TRACE").qos(ffrt::qos_default)); in HandleUcollectionTask()
|
/base/telephony/call_manager/services/call_report/src/ |
D | app_state_observer.cpp | 42 …unregisterCallbackQueue.submit([=]() { report->UnRegisterCallBack(std::to_string(processData.pid))… in OnProcessDied()
|
/base/theme/screenlock_mgr/services/src/ |
D | screenlock_system_ability.cpp | 112 queue_->submit(callback, ffrt::task_attr().delay(INIT_INTERVAL)); in OnStart() 140 queue_->submit(callback, ffrt::task_attr().delay(DELAY_TIME)); in RegisterDisplayPowerEventListener() 404 queue_->submit(callback); in OnSystemEvent() 507 ffrt::submit(callback); in LockScreenEvent() 548 queue_->submit(callback); in SystemEventCallBack() 563 ffrt::submit(callback); in NotifyUnlockListener() 574 queue_->submit(callback); in NotifyDisplayEvent()
|
/base/security/selinux_adapter/scripts/ |
D | build_policy_api.py | 499 … normal_thread = executor.submit(generate_default_policy, args, file_list_object, cil_list, False) 500 developer_thread = executor.submit(generate_default_policy, args, file_list_object, 503 … normal_thread = executor.submit(generate_special_policy, args, file_list_object, cil_list, False) 504 developer_thread = executor.submit(generate_special_policy, args, file_list_object, 514 …build_normal_thread = executor.submit(build_binary_policy, args.tool_path, args.dst_file, True, ci… 516 …build_developer_thread = executor.submit(build_binary_policy, args.tool_path, developer_policy_pat… 562 pre_check_thread = executor.submit(pre_check, pre_check_args) 565 compile_thread = executor.submit(compile_sepolicy, compile_args)
|
/base/hiviewdfx/hiview/base/event_export/ |
D | event_export_engine.cpp | 77 ffrt::submit(exportTask, { initTaskHandle }, {}, in Start() 114 … ffrt::submit(task, {}, {}, ffrt::task_attr().name("dft_event_export").qos(ffrt::qos_default)); in InitAndRunTasks()
|
/base/hiviewdfx/hilog/services/hilogd/ |
D | main.cpp | 172 ffrt::submit([&hilogBuffer,&kmsgBuffer]() { in HilogdEntry() 191 ffrt::submit([]() { in HilogdEntry()
|
/base/hiviewdfx/hiview/base/ |
D | event_dispatch_queue.cpp | 85 ffrtQueue_->submit([event, queuePtr] { in Enqueue()
|
/base/notification/distributed_notification_service/services/distributed/src/ |
D | distributed_notification_manager.cpp | 147 distributedQueue_->submit(std::bind([=]() { in OnDatabaseInsert() 207 distributedQueue_->submit(std::bind([=]() { in OnDatabaseDelete() 229 distributedQueue_->submit(std::bind([=]() { in OnDeviceConnected() 247 distributedQueue_->submit(std::bind([=]() { in OnDeviceDisconnected()
|
/base/telephony/sms_mms/test/fuzztest/gsmsmsmessage_fuzzer/ |
D | gsmsmsmessage_fuzzer.cpp | 62 SmsSubmit submit; in CreateMessageTest() local 63 msg.AnalysisMsgSubmit(submit); in CreateMessageTest()
|