cerc-io/lighthouse
16
0
Fork 0
Code Issues 1 Pull Requests Packages Projects Releases Wiki Activity

fix wrong draining of queued requests on handler shutdown (#1288)

Browse Source
This commit is contained in:
divma 2020-06-24 02:44:28 -05:00 committed by GitHub
parent da6ab85e99
commit 259502829e
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
beacon_node/eth2_libp2p/src/rpc/handler.rs
View File

@ -326,7 +326,7 @@ where
if matches!(self.state, HandlerState::Active) { if matches!(self.state, HandlerState::Active) {
debug!(self.log, "Starting handler shutdown"; "unsent_queued_requests" => self.dial_queue.len()); debug!(self.log, "Starting handler shutdown"; "unsent_queued_requests" => self.dial_queue.len());
// we now drive to completion communications already dialed/established // we now drive to completion communications already dialed/established
for (id, req) in self.dial_queue.pop() { while let Some((id, req)) = self.dial_queue.pop() {
self.pending_errors.push(HandlerErr::Outbound { self.pending_errors.push(HandlerErr::Outbound {
id, id,
proto: req.protocol(), proto: req.protocol(),