Skip to content

Commit

Permalink
Fix processing dispatch queue (ton-blockchain#1057)
Browse files Browse the repository at this point in the history
Co-authored-by: SpyCheese <[email protected]>
  • Loading branch information
2 people authored and ice-charon committed Sep 26, 2024
1 parent 3e07d1f commit aa58ccd
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 3 deletions.
2 changes: 1 addition & 1 deletion validator/impl/collator-impl.h
Original file line number Diff line number Diff line change
Expand Up @@ -213,7 +213,7 @@ class Collator final : public td::actor::Actor {
std::map<StdSmcAddress, td::uint32> sender_generated_messages_count_;
unsigned dispatch_queue_ops_{0};
std::map<StdSmcAddress, LogicalTime> last_dispatch_queue_emitted_lt_;
bool have_unprocessed_account_dispatch_queue_ = true;
bool have_unprocessed_account_dispatch_queue_ = false;
td::uint64 defer_out_queue_size_limit_;
td::uint64 hard_defer_out_queue_size_limit_;

Expand Down
3 changes: 1 addition & 2 deletions validator/impl/validate-query.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -3404,7 +3404,7 @@ bool ValidateQuery::check_account_dispatch_queue_update(td::Bits256 addr, Ref<vm
account_expected_defer_all_messages_.insert(addr);
}
}
if (old_dict_size > 0 && max_removed_lt == 0) {
if (old_dict_size > 0 && max_removed_lt != 0) {
++processed_account_dispatch_queues_;
}
return true;
Expand Down Expand Up @@ -3439,7 +3439,6 @@ bool ValidateQuery::unpack_dispatch_queue_update() {
have_unprocessed_account_dispatch_queue_ = false;
td::uint64 total_account_dispatch_queues = 0;
ps_.dispatch_queue_->check_for_each([&](Ref<vm::CellSlice>, td::ConstBitPtr, int n) -> bool {
assert(n == 352);
++total_account_dispatch_queues;
if (total_account_dispatch_queues > processed_account_dispatch_queues_) {
return false;
Expand Down

0 comments on commit aa58ccd

Please sign in to comment.