Skip to content

Commit

Permalink
Undo changes for rpc/handler from master
Browse files Browse the repository at this point in the history
  • Loading branch information
paulhauner committed Jan 29, 2020
1 parent e8007b0 commit 876edff
Showing 1 changed file with 3 additions and 7 deletions.
10 changes: 3 additions & 7 deletions beacon_node/eth2-libp2p/src/rpc/handler.rs
Original file line number Diff line number Diff line change
Expand Up @@ -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};
Expand Down Expand Up @@ -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
}
Expand Down

0 comments on commit 876edff

Please sign in to comment.