Struct BootstrapServerMessageDeserializer 

pub struct BootstrapServerMessageDeserializer {

    message_id_deserializer: U32VarIntDeserializer,
    time_deserializer: MassaTimeDeserializer,
    version_deserializer: VersionDeserializer,
    peers_deserializer: BootstrapPeersDeserializer,
    state_new_elements_length_deserializer: U64VarIntDeserializer,
    versioning_part_new_elements_length_deserializer: U64VarIntDeserializer,
    stream_batch_updates_length_deserializer: U64VarIntDeserializer,
    datastore_key_deserializer: VecU8Deserializer,
    datastore_val_deserializer: VecU8Deserializer,
    opt_vec_u8_deserializer: OptionDeserializer<Vec<u8>, VecU8Deserializer>,
    bootstrapable_graph_deserializer: BootstrapableGraphDeserializer,
    block_id_set_deserializer: PreHashSetDeserializer<BlockId, BlockIdDeserializer>,
    length_bootstrap_error: U64VarIntDeserializer,
    slot_deserializer: SlotDeserializer,
    opt_last_start_period_deserializer: OptionDeserializer<u64, U64VarIntDeserializer>,
    opt_last_slot_before_downtime_deserializer: OptionDeserializer<Option<Slot>, OptionDeserializer<Slot, SlotDeserializer>>,
    state_batch_budget: usize,
    versioning_batch_budget: usize,
    updates_batch_budget: usize,
}

Deserializer for BootstrapServerMessage

Fields

message_id_deserializer: U32VarIntDeserializer

time_deserializer: MassaTimeDeserializer

version_deserializer: VersionDeserializer

peers_deserializer: BootstrapPeersDeserializer

state_new_elements_length_deserializer: U64VarIntDeserializer

versioning_part_new_elements_length_deserializer: U64VarIntDeserializer

stream_batch_updates_length_deserializer: U64VarIntDeserializer

datastore_key_deserializer: VecU8Deserializer

datastore_val_deserializer: VecU8Deserializer

opt_vec_u8_deserializer: OptionDeserializer<Vec<u8>, VecU8Deserializer>

bootstrapable_graph_deserializer: BootstrapableGraphDeserializer

block_id_set_deserializer: PreHashSetDeserializer<BlockId, BlockIdDeserializer>

length_bootstrap_error: U64VarIntDeserializer

slot_deserializer: SlotDeserializer

opt_last_start_period_deserializer: OptionDeserializer<u64, U64VarIntDeserializer>

opt_last_slot_before_downtime_deserializer: OptionDeserializer<Option<Slot>, OptionDeserializer<Slot, SlotDeserializer>>

state_batch_budget: usize

versioning_batch_budget: usize

updates_batch_budget: usize

Implementations

impl BootstrapServerMessageDeserializer

pub fn with_last_start_period( args: BootstrapServerMessageDeserializerArgs, last_start_period: Option<u64>, ) -> Self

Builds a deserializer that applies last_start_period to bootstrap block header deserialization so genesis vs non-genesis parent-count rules are enforced while parsing. Pass None for the first part; the server sends restart metadata once on that part (empty consensus graph), then the client reuses the cached value.

fn deserialize_kv_map<'a, V, E, F>( &self, input: &'a [u8], parse_entry: F, budget: usize, ) -> IResult<&'a [u8], BTreeMap<Vec<u8>, V>, E>

where E: ParseError<&'a [u8]> + ContextError<&'a [u8]>, F: FnMut(&'a [u8]) -> IResult<&'a [u8], (Vec<u8>, V), E>,

Deserialize a map of (key, value) pairs, bounding the in-memory footprint of the result.

Charges every parsed pair the bytes it occupied on the wire plus BOOTSTRAP_BATCH_ENTRY_OVERHEAD, and fails once budget is spent. Bounding the section in wire bytes alone is not enough: an entry can cost two bytes on the wire and two orders of magnitude more as a map node, so a flood of tiny entries amplifies well past the size the section announced. Pairs are charged as parsed rather than as inserted, so a duplicate-key flood is charged too.

The map is folded during parsing rather than collected into an intermediate Vec first: these sections can be large, so skipping the extra full-size allocation roughly halves the peak memory of parsing one.

Trait Implementations

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_final_state_batch_allocation: 1_000_000, max_versioning_batch_allocation: 1_000_000,
    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::with_last_start_period(args, None);
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);