Skip to content

Commit

Permalink
GH-529 Make sure sync_recv_block is called for every block. Remove un…
Browse files Browse the repository at this point in the history
…used dispatch_manager::recv_block.
  • Loading branch information
heifner committed Aug 13, 2024
1 parent 60b9f18 commit 17bdffc
Showing 1 changed file with 6 additions and 7 deletions.
13 changes: 6 additions & 7 deletions plugins/net_plugin/net_plugin.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -291,7 +291,6 @@ namespace eosio {
void bcast_block( const signed_block_ptr& b, const block_id_type& id );
void rejected_block(const block_id_type& id);

void recv_block(const connection_ptr& c, const block_id_type& id, uint32_t bnum);
void expire_blocks( uint32_t lib_num );
void recv_notice(const connection_ptr& conn, const notice_message& msg, bool generated);

Expand Down Expand Up @@ -2698,10 +2697,6 @@ namespace eosio {
} );
}

// called from c's connection strand
void dispatch_manager::recv_block(const connection_ptr& c, const block_id_type& id, uint32_t bnum) {
}

void dispatch_manager::rejected_block(const block_id_type& id) {
fc_dlog( logger, "rejected block ${id}", ("id", id) );
}
Expand Down Expand Up @@ -3786,6 +3781,12 @@ namespace eosio {

// ready to process immediately, so signal producer to interrupt start_block
my_impl->producer_plug->received_block(block_num);
} else {
c->strand.post([sync_master = my_impl->sync_master.get(), c, id, block_num, timestamp=obh->timestamp()]() {
const fc::microseconds age(fc::time_point::now() - timestamp);
bool blk_applied = true; // not really applied, but accepted by controller into forkdb
sync_master->sync_recv_block(c, id, block_num, blk_applied, age);
});
}
});
}
Expand Down Expand Up @@ -3864,9 +3865,7 @@ namespace eosio {
}
});
c->strand.post( [sync_master = my_impl->sync_master.get(),
&dispatcher = my_impl->dispatcher,
c, blk_id, blk_num, latency = age]() {
dispatcher.recv_block( c, blk_id, blk_num );
sync_master->sync_recv_block( c, blk_id, blk_num, true, latency );
});
} else {
Expand Down

0 comments on commit 17bdffc

Please sign in to comment.