@@ -421,13 +421,12 @@ class IdDuplicateCheckerOld {
421421 if (saved_message_ids_.size () == MAX_SAVED_MESSAGE_IDS ) {
422422 auto oldest_message_id = *saved_message_ids_.begin ();
423423 if (message_id < oldest_message_id) {
424- return td::Status::Error (2 , PSLICE () << " Ignore very old message_id "
425- << td::tag (" oldest message_id" , oldest_message_id)
426- << td::tag (" got message_id" , message_id));
424+ return td::Status::Error (2 , PSLICE () << " Ignore very old message " << message_id
425+ << " older than the oldest known message " << oldest_message_id);
427426 }
428427 }
429428 if (saved_message_ids_.count (message_id) != 0 ) {
430- return td::Status::Error (1 , PSLICE () << " Ignore duplicated message_id " << td::tag ( " message_id" , message_id) );
429+ return td::Status::Error (1 , PSLICE () << " Ignore already processed message " << message_id);
431430 }
432431
433432 saved_message_ids_.insert (message_id);
@@ -451,16 +450,15 @@ class IdDuplicateCheckerNew {
451450 td::Status check (td::int64 message_id) {
452451 auto insert_result = saved_message_ids_.insert (message_id);
453452 if (!insert_result.second ) {
454- return td::Status::Error (1 , PSLICE () << " Ignore duplicated message_id " << td::tag ( " message_id" , message_id) );
453+ return td::Status::Error (1 , PSLICE () << " Ignore already processed message " << message_id);
455454 }
456455 if (saved_message_ids_.size () == MAX_SAVED_MESSAGE_IDS + 1 ) {
457456 auto begin_it = saved_message_ids_.begin ();
458457 bool is_very_old = begin_it == insert_result.first ;
459458 saved_message_ids_.erase (begin_it);
460459 if (is_very_old) {
461- return td::Status::Error (2 , PSLICE () << " Ignore very old message_id "
462- << td::tag (" oldest message_id" , *saved_message_ids_.begin ())
463- << td::tag (" got message_id" , message_id));
460+ return td::Status::Error (2 , PSLICE () << " Ignore very old message " << message_id
461+ << " older than the oldest known message " << *saved_message_ids_.begin ());
464462 }
465463 }
466464 return td::Status::OK ();
@@ -477,16 +475,15 @@ class IdDuplicateCheckerNewOther {
477475 }
478476 td::Status check (td::int64 message_id) {
479477 if (!saved_message_ids_.insert (message_id).second ) {
480- return td::Status::Error (1 , PSLICE () << " Ignore duplicated message_id " << td::tag ( " message_id" , message_id) );
478+ return td::Status::Error (1 , PSLICE () << " Ignore already processed message " << message_id);
481479 }
482480 if (saved_message_ids_.size () == MAX_SAVED_MESSAGE_IDS + 1 ) {
483481 auto begin_it = saved_message_ids_.begin ();
484482 bool is_very_old = *begin_it == message_id;
485483 saved_message_ids_.erase (begin_it);
486484 if (is_very_old) {
487- return td::Status::Error (2 , PSLICE () << " Ignore very old message_id "
488- << td::tag (" oldest message_id" , *saved_message_ids_.begin ())
489- << td::tag (" got message_id" , message_id));
485+ return td::Status::Error (2 , PSLICE () << " Ignore very old message " << message_id
486+ << " older than the oldest known message " << *saved_message_ids_.begin ());
490487 }
491488 }
492489 return td::Status::OK ();
@@ -505,14 +502,14 @@ class IdDuplicateCheckerNewSimple {
505502 td::Status check (td::int64 message_id) {
506503 auto insert_result = saved_message_ids_.insert (message_id);
507504 if (!insert_result.second ) {
508- return td::Status::Error (1 , " Ignore duplicated message_id " );
505+ return td::Status::Error (1 , " Ignore already processed message " );
509506 }
510507 if (saved_message_ids_.size () == MAX_SAVED_MESSAGE_IDS + 1 ) {
511508 auto begin_it = saved_message_ids_.begin ();
512509 bool is_very_old = begin_it == insert_result.first ;
513510 saved_message_ids_.erase (begin_it);
514511 if (is_very_old) {
515- return td::Status::Error (2 , " Ignore very old message_id " );
512+ return td::Status::Error (2 , " Ignore very old message " );
516513 }
517514 }
518515 return td::Status::OK ();
@@ -540,13 +537,12 @@ class IdDuplicateCheckerArray {
540537 return td::Status::OK ();
541538 }
542539 if (end_pos_ >= max_size && message_id < saved_message_ids_[0 ]) {
543- return td::Status::Error (2 , PSLICE () << " Ignore very old message_id "
544- << td::tag (" oldest message_id" , saved_message_ids_[0 ])
545- << td::tag (" got message_id" , message_id));
540+ return td::Status::Error (2 , PSLICE () << " Ignore very old message " << message_id
541+ << " older than the oldest known message " << saved_message_ids_[0 ]);
546542 }
547543 auto it = std::lower_bound (&saved_message_ids_[0 ], &saved_message_ids_[end_pos_], message_id);
548544 if (*it == message_id) {
549- return td::Status::Error (1 , PSLICE () << " Ignore duplicated message_id " << td::tag ( " message_id" , message_id) );
545+ return td::Status::Error (1 , PSLICE () << " Ignore already processed message " << message_id);
550546 }
551547 std::copy_backward (it, &saved_message_ids_[end_pos_], &saved_message_ids_[end_pos_ + 1 ]);
552548 *it = message_id;
0 commit comments