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

// Copyright 2019-2020 Conflux Foundation. All rights reserved.
// TreeGraph is free software and distributed under Apache License 2.0.
// See https://www.apache.org/licenses/LICENSE-2.0

use crate::{
    pos::{
        consensus::network::ConsensusMsg,
        protocol::sync_protocol::{Context, Handleable},
    },
    sync::Error,
};
use consensus_types::vote_msg::VoteMsg;
use diem_logger::prelude::diem_debug;
use std::mem::discriminant;

impl Handleable for VoteMsg {
    fn handle(self, ctx: &Context) -> Result<(), Error> {
        diem_debug!("on_vote, msg={:?}", &self);

        let peer_address = ctx.get_peer_account_address()?;

        /*ensure!(
            self.vote().author() == peer_address,
            "vote received must be from the sending peer"
        );*/

        //self.verify(&ctx.manager.network_task.epoch_info.read().verifier())?;
        let author = self.vote().author();
        let msg = ConsensusMsg::VoteMsg(Box::new(self));
        ctx.manager
            .consensus_network_task
            .consensus_messages_tx
            .push((author, discriminant(&msg)), (peer_address, msg))?;
        Ok(())
    }
}