gnosis/lighthouse
1
0
Fork 0
mirror of https://github.com/sigp/lighthouse.git synced 2026-05-08 09:16:00 +00:00
Code Issues Packages Projects Releases Wiki Activity

Undo changes for rpc/handler from master

Browse Source
This commit is contained in:
Paul Hauner
2020-01-29 14:20:19 +11:00
parent e8007b0c12
commit 876edff0e4
1 changed files with 3 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
beacon_node/eth2-libp2p/src/rpc/handler.rs
View File

@@ -12,7 +12,7 @@ use libp2p::core::upgrade::{InboundUpgrade, OutboundUpgrade, UpgradeError};
use libp2p::swarm::protocols_handler::{ use libp2p::swarm::protocols_handler::{
KeepAlive, ProtocolsHandler, ProtocolsHandlerEvent, ProtocolsHandlerUpgrErr, SubstreamProtocol, KeepAlive, ProtocolsHandler, ProtocolsHandlerEvent, ProtocolsHandlerUpgrErr, SubstreamProtocol,
}; };
use slog::{crit, debug, error, warn}; use slog::{crit, debug, error};
use smallvec::SmallVec; use smallvec::SmallVec;
use std::collections::hash_map::Entry; use std::collections::hash_map::Entry;
use std::time::{Duration, Instant}; use std::time::{Duration, Instant};
@@ -319,12 +319,8 @@ where
substream: out, substream: out,
request, request,
}; };
if let Some(_) = self self.outbound_substreams
.outbound_substreams .insert(id, (awaiting_stream, delay_key));
.insert(id, (awaiting_stream, delay_key))
{
warn!(self.log, "Duplicate outbound substream id"; "id" => format!("{:?}", id));
}
} }
_ => { // a response is not expected, drop the stream for all other requests _ => { // a response is not expected, drop the stream for all other requests
} }