Skip to content

Commit 3c4583c

Browse files
committed
client: added RLPXServer discovery info, only restart RLPx server and provide feedback on peer searching when discovery enabled
1 parent f86eb40 commit 3c4583c

File tree

2 files changed

+5
-3
lines changed

2 files changed

+5
-3
lines changed

packages/client/lib/net/peerpool.ts

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -204,7 +204,7 @@ export class PeerPool extends EventEmitter {
204204
this.noPeerPeriods += 1
205205
if (this.noPeerPeriods >= 3) {
206206
const promises = this.config.servers.map(async (server) => {
207-
if (server instanceof RlpxServer) {
207+
if (server instanceof RlpxServer && server.discovery) {
208208
this.config.logger.info('Restarting RLPx server: bootstrap')
209209
await server.stop()
210210
await server.start()
@@ -215,11 +215,11 @@ export class PeerPool extends EventEmitter {
215215
} else {
216216
let tablesize: number | undefined = 0
217217
this.config.servers.forEach((server) => {
218-
if (server instanceof RlpxServer) {
218+
if (server instanceof RlpxServer && server.discovery) {
219219
tablesize = server.dpt?.getPeers().length
220+
this.config.logger.info(`Looking for suited peers: peertablesize=${tablesize}`)
220221
}
221222
})
222-
this.config.logger.info(`Looking for suited peers: peertablesize=${tablesize}`)
223223
}
224224
} else {
225225
this.noPeerPeriods = 0

packages/client/lib/net/server/rlpxserver.ts

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -51,6 +51,7 @@ export class RlpxServer extends Server {
5151
private peers: Map<string, RlpxPeer> = new Map()
5252

5353
public port: number
54+
public discovery: boolean
5455
private clientFilter: string[]
5556

5657
public rlpx: Devp2pRLPx | null = null
@@ -67,6 +68,7 @@ export class RlpxServer extends Server {
6768
// TODO: get the external ip from the upnp service
6869
this.ip = '::'
6970
this.port = options.port ?? 30303
71+
this.discovery = options.config.discV4 || options.config.discDns
7072
this.clientFilter = options.clientFilter ?? [
7173
'go1.5',
7274
'go1.6',

0 commit comments

Comments
 (0)