Lines Matching refs:smsIndexer
49 shared_ptr<SmsSendIndexer> smsIndexer = nullptr;
57 smsIndexer = FindCacheMapAndTransform(event);
58 HandleMessageResponse(smsIndexer);
62 smsIndexer = event->GetSharedObject<SmsSendIndexer>();
64 sendRetryFun_(smsIndexer);
96 void SmsSender::HandleMessageResponse(const shared_ptr<SmsSendIndexer> &smsIndexer)
98 if (smsIndexer == nullptr) {
99 TELEPHONY_LOGE("smsIndexer is nullptr");
102 if (!SendCacheMapEraseItem(smsIndexer->GetMsgRefId64Bit())) {
106 if (!smsIndexer->GetIsFailure()) {
107 if (smsIndexer->GetDeliveryCallback() != nullptr) {
112 reportList_.push_back(smsIndexer);
114 SendMessageSucceed(smsIndexer);
116 HandleResend(smsIndexer);
120 void SmsSender::SendMessageSucceed(const shared_ptr<SmsSendIndexer> &smsIndexer)
122 if (smsIndexer == nullptr) {
123 TELEPHONY_LOGE("SendMessageSucceed but smsIndexer drop!");
128 uint8_t unSentCellCount = smsIndexer->GetUnSentCellCount();
134 smsIndexer->SetPsResendCount(INITIAL_COUNT);
135 smsIndexer->SetCsResendCount(INITIAL_COUNT);
137 if (smsIndexer->GetHasCellFailed() != nullptr) {
138 if (*smsIndexer->GetHasCellFailed()) {
142 SendResultCallBack(smsIndexer->GetSendCallback(), messageType);
146 if (smsIndexer->GetDataBaseId() == 0) {
152 predicates.EqualTo(SmsMmsInfo::MSG_ID, smsIndexer->GetDataBaseId());
154 TELEPHONY_LOGE("modify db fail while SendMessageSucceed. id:%{public}d;", smsIndexer->GetDataBaseId());
157 if (smsIndexer->GetIsMmsApp()) {
160 TELEPHONY_LOGI("before send boradcast. SendMessageSucceed %{public}d", smsIndexer->GetDataBaseId());
161 DelayedSingleton<SmsMmsCommon>::GetInstance()->SendBroadcast(smsIndexer->GetDataBaseId(),
167 void SmsSender::SendMessageFailed(const shared_ptr<SmsSendIndexer> &smsIndexer)
169 if (smsIndexer == nullptr) {
170 TELEPHONY_LOGE("smsIndexer is nullptr");
173 shared_ptr<bool> hasCellFailed = smsIndexer->GetHasCellFailed();
179 uint8_t unSentCellCount = smsIndexer->GetUnSentCellCount();
185 smsIndexer->SetPsResendCount(INITIAL_COUNT);
186 smsIndexer->SetCsResendCount(INITIAL_COUNT);
188 sptr<ISendShortMessageCallback> sendCallback = smsIndexer->GetSendCallback();
191 smsIndexer->GetIsMmsApp(), smsIndexer->GetDataBaseId());
194 if (smsIndexer->GetDataBaseId() == 0) {
200 predicates.EqualTo(SmsMmsInfo::MSG_ID, smsIndexer->GetDataBaseId());
202 TELEPHONY_LOGE("modify fail while SendMessageFailed. id:%{public}d;", smsIndexer->GetDataBaseId());
205 if (smsIndexer->GetIsMmsApp()) {
208 TELEPHONY_LOGI("before send boradcast. SendMessageSucceed %{public}d", smsIndexer->GetDataBaseId());
209 DelayedSingleton<SmsMmsCommon>::GetInstance()->SendBroadcast(smsIndexer->GetDataBaseId(),
212 TELEPHONY_LOGI("after send boradcast. SendMessageSucceed %{public}d", smsIndexer->GetDataBaseId());
258 bool SmsSender::SendCacheMapAddItem(int64_t id, const std::shared_ptr<SmsSendIndexer> &smsIndexer)
261 if (smsIndexer != nullptr) {
262 auto result = sendCacheMap_.emplace(id, smsIndexer);
283 std::shared_ptr<SmsSendIndexer> smsIndexer = nullptr;
290 smsIndexer = iter->second;
291 if (smsIndexer == nullptr) {
292 TELEPHONY_LOGE("smsIndexer is nullptr");
295 smsIndexer->SetErrorCode(ISendShortMessageCallback::SEND_SMS_FAILURE_UNKNOWN);
296 smsIndexer->SetMsgRefId64Bit(res->flag);
297 smsIndexer->SetIsFailure(true);
298 UpdateUnSentCellCount(smsIndexer->GetMsgRefId());
300 return smsIndexer;
308 smsIndexer = iter->second;
309 if (smsIndexer == nullptr) {
310 TELEPHONY_LOGE("smsIndexer is nullptr");
313 smsIndexer->SetAckPdu(std::move(StringUtils::HexToByteVector(info->pdu)));
314 info->errCode != 0? smsIndexer->SetIsFailure(true) : smsIndexer->SetIsFailure(false);
315 smsIndexer->SetErrorCode(info->errCode);
316 smsIndexer->SetMsgRefId64Bit(info->flag);
317 UpdateUnSentCellCount(smsIndexer->GetMsgRefId());
320 return smsIndexer;
325 std::shared_ptr<SmsSendIndexer> smsIndexer = nullptr;
327 smsIndexer = it->second;
328 if (smsIndexer == nullptr) {
331 uint8_t unSentCount = smsIndexer->GetUnSentCellCount();
332 if (smsIndexer->GetMsgRefId() == refId && unSentCount > 0) {
333 smsIndexer->SetUnSentCellCount(unSentCount - 1);
361 void SmsSender::HandleResend(const std::shared_ptr<SmsSendIndexer> &smsIndexer)
363 if (smsIndexer == nullptr) {
364 TELEPHONY_LOGE("smsIndexer is nullptr");
369 if ((smsIndexer->GetErrorCode() == static_cast<int32_t>(ErrType::ERR_GENERIC_FAILURE)) ||
370 (smsIndexer->GetErrorCode() == static_cast<int32_t>(ErrType::ERR_CMD_SEND_FAILURE))) {
374 if (!lastSmsDomain_ && smsIndexer->GetCsResendCount() < MAX_SEND_RETRIES) {
378 if (lastSmsDomain_ && smsIndexer->GetPsResendCount() <= MAX_SEND_RETRIES) {
383 smsIndexer->SetPsResendCount(smsIndexer->GetPsResendCount() + 1);
384 SendEvent(MSG_SMS_RETRY_DELIVERY, smsIndexer, DELAY_MAX_TIME_MSCE);
386 smsIndexer->SetCsResendCount(smsIndexer->GetCsResendCount() + 1);
387 SendEvent(MSG_SMS_RETRY_DELIVERY, smsIndexer, DELAY_MAX_TIME_MSCE);
390 SendMessageFailed(smsIndexer);
445 std::shared_ptr<SmsSendIndexer> smsIndexer = nullptr;
447 smsIndexer = it->second;
448 if (smsIndexer == nullptr || smsIndexer->GetIsFailure()) {
449 TELEPHONY_LOGE("smsIndexer is nullptr");
452 if (!SendCacheMapEraseItem(smsIndexer->GetMsgRefId64Bit())) {
455 smsIndexer->SetIsFailure(true);
456 smsIndexer->SetPsResendCount(INITIAL_COUNT);
457 smsIndexer->SetCsResendCount(INITIAL_COUNT);
458 sptr<ISendShortMessageCallback> sendCallback = smsIndexer->GetSendCallback();