This commit is contained in:
Piotr Wójcik 2024-09-23 16:37:40 +02:00
commit 16f60f86af
2 changed files with 5 additions and 3 deletions

View file

@ -425,7 +425,7 @@ void nano::keepalive::operator() (nano::object_stream & obs) const
nano::publish::publish (bool & error_a, nano::stream & stream_a, nano::message_header const & header_a, nano::uint128_t const & digest_a, nano::block_uniquer * uniquer_a) : nano::publish::publish (bool & error_a, nano::stream & stream_a, nano::message_header const & header_a, nano::uint128_t const & digest_a, nano::block_uniquer * uniquer_a) :
message (header_a), message (header_a),
digest (digest_a) digest{ digest_a }
{ {
if (!error_a) if (!error_a)
{ {
@ -435,7 +435,7 @@ nano::publish::publish (bool & error_a, nano::stream & stream_a, nano::message_h
nano::publish::publish (nano::network_constants const & constants, std::shared_ptr<nano::block> const & block_a, bool is_originator_a) : nano::publish::publish (nano::network_constants const & constants, std::shared_ptr<nano::block> const & block_a, bool is_originator_a) :
message (constants, nano::message_type::publish), message (constants, nano::message_type::publish),
block (block_a) block{ block_a }
{ {
header.block_type_set (block->type ()); header.block_type_set (block->type ());
header.flag_set (originator_flag, is_originator_a); header.flag_set (originator_flag, is_originator_a);

View file

@ -188,7 +188,7 @@ public: // Logging
class publish final : public message class publish final : public message
{ {
public: public:
publish (bool &, nano::stream &, nano::message_header const &, nano::uint128_t const & = 0, nano::block_uniquer * = nullptr); publish (bool &, nano::stream &, nano::message_header const &, nano::uint128_t const & digest = 0, nano::block_uniquer * = nullptr);
publish (nano::network_constants const & constants, std::shared_ptr<nano::block> const &, bool is_originator = false); publish (nano::network_constants const & constants, std::shared_ptr<nano::block> const &, bool is_originator = false);
void serialize (nano::stream &) const override; void serialize (nano::stream &) const override;
@ -201,6 +201,8 @@ public:
public: // Payload public: // Payload
std::shared_ptr<nano::block> block; std::shared_ptr<nano::block> block;
// Messages deserialized from network should have their digest set
nano::uint128_t digest{ 0 }; nano::uint128_t digest{ 0 };
public: // Logging public: // Logging