Lines Matching refs:smsIndexer
47 shared_ptr<SmsSendIndexer> smsIndexer = nullptr; in ProcessEvent() local
55 smsIndexer = FindCacheMapAndTransform(event); in ProcessEvent()
56 HandleMessageResponse(smsIndexer); in ProcessEvent()
60 smsIndexer = event->GetSharedObject<SmsSendIndexer>(); in ProcessEvent()
62 sendRetryFun_(smsIndexer); in ProcessEvent()
94 void SmsSender::HandleMessageResponse(const shared_ptr<SmsSendIndexer> &smsIndexer) in HandleMessageResponse() argument
96 if (smsIndexer == nullptr) { in HandleMessageResponse()
100 if (!SendCacheMapEraseItem(smsIndexer->GetMsgRefId64Bit())) { in HandleMessageResponse()
104 if (!smsIndexer->GetIsFailure()) { in HandleMessageResponse()
105 if (smsIndexer->GetDeliveryCallback() != nullptr) { in HandleMessageResponse()
110 reportList_.push_back(smsIndexer); in HandleMessageResponse()
112 SendMessageSucceed(smsIndexer); in HandleMessageResponse()
114 HandleResend(smsIndexer); in HandleMessageResponse()
118 void SmsSender::SendMessageSucceed(const shared_ptr<SmsSendIndexer> &smsIndexer) in SendMessageSucceed() argument
120 if (smsIndexer == nullptr) { in SendMessageSucceed()
126 uint8_t unSentCellCount = smsIndexer->GetUnSentCellCount(); in SendMessageSucceed()
132 smsIndexer->SetPsResendCount(INITIAL_COUNT); in SendMessageSucceed()
133 smsIndexer->SetCsResendCount(INITIAL_COUNT); in SendMessageSucceed()
135 if (smsIndexer->GetHasCellFailed() != nullptr) { in SendMessageSucceed()
136 if (*smsIndexer->GetHasCellFailed()) { in SendMessageSucceed()
140 SendResultCallBack(smsIndexer->GetSendCallback(), messageType); in SendMessageSucceed()
147 void SmsSender::SendMessageFailed(const shared_ptr<SmsSendIndexer> &smsIndexer) in SendMessageFailed() argument
149 if (smsIndexer == nullptr) { in SendMessageFailed()
153 shared_ptr<bool> hasCellFailed = smsIndexer->GetHasCellFailed(); in SendMessageFailed()
159 uint8_t unSentCellCount = smsIndexer->GetUnSentCellCount(); in SendMessageFailed()
165 smsIndexer->SetPsResendCount(INITIAL_COUNT); in SendMessageFailed()
166 smsIndexer->SetCsResendCount(INITIAL_COUNT); in SendMessageFailed()
168 sptr<ISendShortMessageCallback> sendCallback = smsIndexer->GetSendCallback(); in SendMessageFailed()
218 bool SmsSender::SendCacheMapAddItem(int64_t id, const std::shared_ptr<SmsSendIndexer> &smsIndexer) in SendCacheMapAddItem() argument
221 if (smsIndexer != nullptr) { in SendCacheMapAddItem()
222 auto result = sendCacheMap_.emplace(id, smsIndexer); in SendCacheMapAddItem()
243 std::shared_ptr<SmsSendIndexer> smsIndexer = nullptr; in FindCacheMapAndTransform() local
250 smsIndexer = iter->second; in FindCacheMapAndTransform()
251 if (smsIndexer == nullptr) { in FindCacheMapAndTransform()
255 smsIndexer->SetErrorCode(ISendShortMessageCallback::SEND_SMS_FAILURE_UNKNOWN); in FindCacheMapAndTransform()
256 smsIndexer->SetMsgRefId64Bit(res->flag); in FindCacheMapAndTransform()
257 smsIndexer->SetIsFailure(true); in FindCacheMapAndTransform()
258 UpdateUnSentCellCount(smsIndexer->GetMsgRefId()); in FindCacheMapAndTransform()
260 return smsIndexer; in FindCacheMapAndTransform()
268 smsIndexer = iter->second; in FindCacheMapAndTransform()
269 if (smsIndexer == nullptr) { in FindCacheMapAndTransform()
273 smsIndexer->SetAckPdu(std::move(StringUtils::HexToByteVector(info->pdu))); in FindCacheMapAndTransform()
274 info->errCode != 0? smsIndexer->SetIsFailure(true) : smsIndexer->SetIsFailure(false); in FindCacheMapAndTransform()
275 smsIndexer->SetErrorCode(info->errCode); in FindCacheMapAndTransform()
276 smsIndexer->SetMsgRefId64Bit(info->flag); in FindCacheMapAndTransform()
277 UpdateUnSentCellCount(smsIndexer->GetMsgRefId()); in FindCacheMapAndTransform()
280 return smsIndexer; in FindCacheMapAndTransform()
285 std::shared_ptr<SmsSendIndexer> smsIndexer = nullptr; in UpdateUnSentCellCount() local
287 smsIndexer = it->second; in UpdateUnSentCellCount()
288 if (smsIndexer == nullptr) { in UpdateUnSentCellCount()
291 uint8_t unSentCount = smsIndexer->GetUnSentCellCount(); in UpdateUnSentCellCount()
292 if (smsIndexer->GetMsgRefId() == refId && unSentCount > 0) { in UpdateUnSentCellCount()
293 smsIndexer->SetUnSentCellCount(unSentCount - 1); in UpdateUnSentCellCount()
321 void SmsSender::HandleResend(const std::shared_ptr<SmsSendIndexer> &smsIndexer) in HandleResend() argument
323 if (smsIndexer == nullptr) { in HandleResend()
329 if ((smsIndexer->GetErrorCode() == static_cast<int32_t>(ErrType::ERR_GENERIC_FAILURE)) || in HandleResend()
330 (smsIndexer->GetErrorCode() == static_cast<int32_t>(ErrType::ERR_CMD_SEND_FAILURE))) { in HandleResend()
334 if (!lastSmsDomain_ && smsIndexer->GetCsResendCount() < MAX_SEND_RETRIES) { in HandleResend()
338 if (lastSmsDomain_ && smsIndexer->GetPsResendCount() <= MAX_SEND_RETRIES) { in HandleResend()
343 smsIndexer->SetPsResendCount(smsIndexer->GetPsResendCount() + 1); in HandleResend()
344 SendEvent(MSG_SMS_RETRY_DELIVERY, smsIndexer, DELAY_MAX_TIME_MSCE); in HandleResend()
346 smsIndexer->SetCsResendCount(smsIndexer->GetCsResendCount() + 1); in HandleResend()
347 SendEvent(MSG_SMS_RETRY_DELIVERY, smsIndexer, DELAY_MAX_TIME_MSCE); in HandleResend()
350 SendMessageFailed(smsIndexer); in HandleResend()
405 std::shared_ptr<SmsSendIndexer> smsIndexer = nullptr; in OnRilAdapterHostDied() local
407 smsIndexer = it->second; in OnRilAdapterHostDied()
408 if (smsIndexer == nullptr || smsIndexer->GetIsFailure()) { in OnRilAdapterHostDied()
412 if (!SendCacheMapEraseItem(smsIndexer->GetMsgRefId64Bit())) { in OnRilAdapterHostDied()
415 smsIndexer->SetIsFailure(true); in OnRilAdapterHostDied()
416 smsIndexer->SetPsResendCount(INITIAL_COUNT); in OnRilAdapterHostDied()
417 smsIndexer->SetCsResendCount(INITIAL_COUNT); in OnRilAdapterHostDied()
418 sptr<ISendShortMessageCallback> sendCallback = smsIndexer->GetSendCallback(); in OnRilAdapterHostDied()