Enum massa_bootstrap::messages::BootstrapServerMessage

pub enum BootstrapServerMessage {
    BootstrapTime {
        server_time: MassaTime,
        version: Version,
    },
    BootstrapPeers {
        peers: BootstrapPeers,
    },
    BootstrapPart {
        slot: Slot,
        state_part: StreamBatch<Slot>,
        versioning_part: StreamBatch<Slot>,
        consensus_part: BootstrapableGraph,
        consensus_outdated_ids: PreHashSet<BlockId>,
        last_start_period: Option<u64>,
        last_slot_before_downtime: Option<Option<Slot>>,
    },
    BootstrapFinished,
    SlotTooOld,
    BootstrapError {
        error: String,
    },
}

Messages used during bootstrap by server

Variants

BootstrapTime

Sync clocks

Fields

server_time: MassaTime

The current time on the bootstrap server.

version: Version

The version of the bootstrap server.

BootstrapPeers

Bootstrap peers

Fields

peers: BootstrapPeers

Server peers

BootstrapPart

Part of final state and consensus

Fields

slot: Slot

Slot the state changes are attached to

state_part: StreamBatch<Slot>

Part of the state in a serialized way

versioning_part: StreamBatch<Slot>

Part of the state (specific to versioning) in a serialized way

consensus_part: BootstrapableGraph

Part of the consensus graph

consensus_outdated_ids: PreHashSet<BlockId>

Outdated block ids in the current consensus graph bootstrap

last_start_period: Option<u64>

Last Start Period for network restart management

last_slot_before_downtime: Option<Option<Slot>>

Last Slot before downtime for network restart management

BootstrapFinished

Message sent when the final state and consensus bootstrap are finished

SlotTooOld

Slot sent to get state changes is too old

BootstrapError

Bootstrap error

Fields

error: String

Error message

Trait Implementations

impl Clone for BootstrapServerMessage

fn clone(&self) -> BootstrapServerMessage

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for BootstrapServerMessage

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Deserializer<BootstrapServerMessage> for BootstrapServerMessageDeserializer

fn deserialize<'a, E: ParseError<&'a [u8]> + ContextError<&'a [u8]>>( &self, buffer: &'a [u8], ) -> IResult<&'a [u8], BootstrapServerMessage, E>

Example

use massa_bootstrap::{BootstrapServerMessage, BootstrapServerMessageSerializer, BootstrapServerMessageDeserializer};
use massa_bootstrap::BootstrapServerMessageDeserializerArgs;
use massa_serialization::{Serializer, Deserializer, DeserializeError};
use massa_time::MassaTime;
use massa_models::version::Version;
use std::str::FromStr;
use massa_models::config::CHAINID;

let message_serializer = BootstrapServerMessageSerializer::new();
let args = BootstrapServerMessageDeserializerArgs {
    thread_count: 32, endorsement_count: 16,
    max_listeners_per_peer: 1000,
    max_advertise_length: 1000, max_bootstrap_blocks_length: 1000,
    max_operations_per_block: 1000, max_versioning_elements_size: 1000,
    max_ledger_changes_count: 1000, max_datastore_key_length: 255,
    max_datastore_value_length: 1000,
    max_final_state_elements_size: 1000,
    max_datastore_entry_count: 1000, max_bootstrap_error_length: 1000, max_changes_slot_count: 1000,
    max_rolls_length: 1000, max_production_stats_length: 1000, max_credits_length: 1000,
    max_executed_ops_length: 1000, max_ops_changes_length: 1000,
    mip_store_stats_block_considered: 100,
    max_denunciations_per_block_header: 128, max_denunciation_changes_length: 1000,
    chain_id: *CHAINID
};
let message_deserializer = BootstrapServerMessageDeserializer::new(args);
let bootstrap_server_message = BootstrapServerMessage::BootstrapTime {
   server_time: MassaTime::from_millis(0),
   version: Version::from_str("TEST.1.10").unwrap(),
};
let mut message_serialized = Vec::new();
message_serializer.serialize(&bootstrap_server_message, &mut message_serialized).unwrap();
let (rest, message_deserialized) = message_deserializer.deserialize::<DeserializeError>(&message_serialized).unwrap();
match message_deserialized {
    BootstrapServerMessage::BootstrapTime {
       server_time,
       version,
   } => {
    assert_eq!(server_time, MassaTime::from_millis(0));
    assert_eq!(version, Version::from_str("TEST.1.10").unwrap());
  }
  _ => panic!("Unexpected message"),
}
assert_eq!(rest.len(), 0);

impl Serializer<BootstrapServerMessage> for BootstrapServerMessageSerializer

fn serialize( &self, value: &BootstrapServerMessage, buffer: &mut Vec<u8>, ) -> Result<(), SerializeError>

Example

use massa_bootstrap::{BootstrapServerMessage, BootstrapServerMessageSerializer};
use massa_serialization::Serializer;
use massa_time::MassaTime;
use massa_models::version::Version;
use std::str::FromStr;

let message_serializer = BootstrapServerMessageSerializer::new();
let bootstrap_server_message = BootstrapServerMessage::BootstrapTime {
   server_time: MassaTime::from_millis(0),
   version: Version::from_str("TEST.1.10").unwrap(),
};
let mut message_serialized = Vec::new();
message_serializer.serialize(&bootstrap_server_message, &mut message_serialized).unwrap();

impl ToString for BootstrapServerMessage

fn to_string(&self) -> String

Converts the given value to a String.