From 876edff0e4a501aafbb47113454852826dcc24e8 Mon Sep 17 00:00:00 2001 From: Paul Hauner Date: Wed, 29 Jan 2020 14:20:19 +1100 Subject: [PATCH] Undo changes for rpc/handler from master --- beacon_node/eth2-libp2p/src/rpc/handler.rs | 10 +++------- 1 file changed, 3 insertions(+), 7 deletions(-) diff --git a/beacon_node/eth2-libp2p/src/rpc/handler.rs b/beacon_node/eth2-libp2p/src/rpc/handler.rs index ea59722850..d6424f0afe 100644 --- a/beacon_node/eth2-libp2p/src/rpc/handler.rs +++ b/beacon_node/eth2-libp2p/src/rpc/handler.rs @@ -12,7 +12,7 @@ use libp2p::core::upgrade::{InboundUpgrade, OutboundUpgrade, UpgradeError}; use libp2p::swarm::protocols_handler::{ KeepAlive, ProtocolsHandler, ProtocolsHandlerEvent, ProtocolsHandlerUpgrErr, SubstreamProtocol, }; -use slog::{crit, debug, error, warn}; +use slog::{crit, debug, error}; use smallvec::SmallVec; use std::collections::hash_map::Entry; use std::time::{Duration, Instant}; @@ -319,12 +319,8 @@ where substream: out, request, }; - if let Some(_) = self - .outbound_substreams - .insert(id, (awaiting_stream, delay_key)) - { - warn!(self.log, "Duplicate outbound substream id"; "id" => format!("{:?}", id)); - } + self.outbound_substreams + .insert(id, (awaiting_stream, delay_key)); } _ => { // a response is not expected, drop the stream for all other requests }