minbft 1.0.3

Efficient Byzantine Fault-Tolerance in the partially synchronous timing model
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43

use serde::Serialize;
use shared_ids::ReplicaId;
use std::fmt::Debug;
use tracing::error;
use usig::Usig;

use crate::{output::NotReflectedOutput, Error, MinBft, RequestPayload};

impl<P: RequestPayload, U: Usig> MinBft<P, U>
where
    U::Attestation: Clone,
    U::Signature: Clone + Serialize,
    U::Signature: Debug,
{
    /// Process a message of type Hello.
    ///
    /// # Arguments
    ///
    /// * `from` - The ID of the replica from which the Hello originates.
    /// * `attestation` - The attestation of the replica.
    /// * `output` - The output struct to be adjusted in case of, e.g., errors
    ///              or responses.
    pub(crate) fn process_hello_message(
        &mut self,
        from: ReplicaId,
        attestation: U::Attestation,
        output: &mut NotReflectedOutput<P, U>,
    ) {
        if self.usig.add_remote_party(from, attestation) {
            if self.recv_hellos.insert(from) && self.recv_hellos.len() as u64 == self.config.n.get()
            {
                output.ready_for_client_requests()
            }
        } else {
            error!("Failed to process Hello (origin: {from:?}): The attestation failed. For further information see output.");
            let output_error = Error::Attestation {
                receiver: self.config.id,
                origin: from,
            };
            output.error(output_error);
        }
    }
}