Struct massa_bootstrap::messages::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>>,
}

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>>

Implementations

impl BootstrapServerMessageDeserializer

pub fn new(args: BootstrapServerMessageDeserializerArgs) -> Self

Creates a new BootstrapServerMessageDeserializer

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_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);