cfxcore/pos/protocol/message/
mempool_sync_msg.rs

1// Copyright 2019-2020 Conflux Foundation. All rights reserved.
2// TreeGraph is free software and distributed under Apache License 2.0.
3// See https://www.apache.org/licenses/LICENSE-2.0
4
5use crate::{
6    pos::{
7        mempool::network::MempoolSyncMsg,
8        protocol::sync_protocol::{Context, Handleable},
9    },
10    sync::Error,
11};
12use std::mem::discriminant;
13
14impl Handleable for MempoolSyncMsg {
15    fn handle(self, ctx: &Context) -> Result<(), Error> {
16        ctx.manager
17            .mempool_network_task
18            .mempool_sync_message_tx
19            .push((ctx.peer, discriminant(&self)), (ctx.peer, self))?;
20        Ok(())
21    }
22}