Skip to content

Commit

Permalink
Fix first query discovery delay (#4980)
Browse files Browse the repository at this point in the history
* Fix first query discovery delay

* Update discover.ts
  • Loading branch information
dapplion committed Jan 10, 2023
1 parent bd3d91a commit 5f1c368
Showing 1 changed file with 4 additions and 3 deletions.
7 changes: 4 additions & 3 deletions packages/beacon-node/src/network/peers/discover.ts
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,7 @@ import {PeerId} from "@libp2p/interface-peer-id";
import {multiaddr, Multiaddr} from "@multiformats/multiaddr";
import {PeerInfo} from "@libp2p/interface-peer-info";
import {IBeaconConfig} from "@lodestar/config";
import {ILogger, pruneSetToMax} from "@lodestar/utils";
import {ILogger, pruneSetToMax, sleep} from "@lodestar/utils";
import {Discv5, ENR, IDiscv5Metrics, IDiscv5DiscoveryInputOptions} from "@chainsafe/discv5";
import {ATTESTATION_SUBNET_COUNT, SYNC_COMMITTEE_SUBNET_COUNT} from "@lodestar/params";
import {IMetrics} from "../../metrics/index.js";
Expand Down Expand Up @@ -227,8 +227,9 @@ export class PeerDiscovery {
private async runFindRandomNodeQuery(): Promise<void> {
// Delay the 1st query after starting discv5
// See https://github.com/ChainSafe/lodestar/issues/3423
if (Date.now() - this.discv5StartMs <= this.discv5FirstQueryDelayMs) {
return;
const msSinceDiscv5Start = Date.now() - this.discv5StartMs;
if (msSinceDiscv5Start <= this.discv5FirstQueryDelayMs) {
await sleep(this.discv5FirstQueryDelayMs - msSinceDiscv5Start);
}

// Run a general discv5 query if one is not already in progress
Expand Down

0 comments on commit 5f1c368

Please sign in to comment.