-
Notifications
You must be signed in to change notification settings - Fork 33
Performance: Store packed block in signed_block #1148
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Conversation
…ta as it reads.
…ock was the correct block id. Not used, so just removed it.
…block so it does not need to be re-packed when needed for the block log or for P2P. Refactor signed_block construction so that it is harder to use incorrectly. It is necessary to always store the packed block in case it is needed. Specialize signed_block unpack so that it always fills in the packed_block of signed_block.
| using block_extension = block_extension_types::block_extension_t; | ||
|
|
||
| using signed_block_ptr = std::shared_ptr<const signed_block>; | ||
| using mutable_block_ptr = std::unique_ptr<signed_block>; |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Why not keep the original name mutable_signed_block_ptr? That's more clearer.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Because in most cases it is not "signed" yet.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Can you add a comment? We have other cases where mutable and non-mutable use the same root like mutale_db() and db().
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
| template <typename Stream> | ||
| void unpack(Stream& s, eosio::chain::signed_block& v) { | ||
| try { | ||
| if constexpr (requires { s.extract_mirror(); }) { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Don't quite get this code. Why the if constexpr check? Why the 4096 below?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Because if signed_block is being unpacked with a datastream_mirror then we can use the extract_mirror() to populate signed_block::packed_block. If a different Stream type is being used, then wrap it in a datastream_mirror to capture the packed block data. The 4096 is used to reserve a size in the vector; open to removing the + 4096 if we think it might be wasteful.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Thanks. I got confused by the method name is unpack but then it sets packed_block. Add a comment about 4096.
| // blog.append could fail due to failures like running out of space. | ||
| // Do it before commit so that in case it throws, DB can be rolled back. | ||
| blog.append( (*bitr)->block, (*bitr)->id(), irreversible_mode() ? f.get() : it++->get() ); | ||
| blog.append( (*bitr)->block, (*bitr)->id(), (*bitr)->block->packed_signed_block() ); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Now it is cleaner.
| FC_REFLECT(eosio::chain::additional_block_signatures_extension, (signatures)); | ||
| FC_REFLECT(eosio::chain::quorum_certificate_extension, (qc)); | ||
| FC_REFLECT_DERIVED(eosio::chain::signed_block, (eosio::chain::signed_block_header), (transactions)(block_extensions) ) | ||
|
|
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Why not put this code some where in fc?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Not sure I follow. signed_block is defined in libraries/chain which depends on libraries/libfc.
I did try to move the forward declare out of fc, but couldn't get it to work without the fc forward declare.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I meant unpack(Stream& s, eosio::chain::signed_block& v) is defined in raw_fwd.hpp, why not put the implementation there. I think about it more. It is also OK to remain here.
| else { | ||
| eosio::chain::genesis_state gs; | ||
| log->reset(gs, std::make_shared<eosio::chain::signed_block>()); | ||
| log->reset(gs, eosio::chain::signed_block::create_signed_block(eosio::chain::signed_block::create_mutable_block({}))); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Why this complicated?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
The idea is to make it difficult to misuse signed_block. We want packed_block data of signed_block to always be populated. Could create a method of signed_block that just does this, but since that would only be useful in tests I didn't.
| return read_block(*ds, block_num); | ||
| uint64_t block_size = 0; | ||
|
|
||
| auto ds = catalog.ro_stream_and_size_for_block(block_num, block_size); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Not from your changes. I wish ro_stream_and_size_for_block returned ds and size explicitly.
|
Note:start |
greg7mdp
left a comment
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I think I know why adding the:
namespace eosio::chain { struct signed_block; }
at the top of block.hpp didn't work. It is because some files like block_state_legacy.cpp include block_state_legacy.hpp first, and then block_state_legacy.hpp includes block_header_state_legacy.hpp before block.hpp.
So for files like this the raw_fwd.hpp is included before the forward delaration of signed_block is seen.
gdb4713
left a comment
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Ok
gdb4713
left a comment
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
2
Cache the packed block data in
signed_blockso that it can be retrieved without having topackit at time of serialization.Resolves #1062