Skip to content

Commit 23cda35

Browse files
committed
client -> restart rlpx server on peerpool re-bootstrap
1 parent 761bef0 commit 23cda35

File tree

3 files changed

+5
-3
lines changed

3 files changed

+5
-3
lines changed

packages/client/lib/net/peerpool.ts

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -205,8 +205,9 @@ export class PeerPool extends EventEmitter {
205205
if (this.noPeerPeriods >= 3) {
206206
const promises = this.config.servers.map(async (server) => {
207207
if (server instanceof RlpxServer) {
208-
this.config.logger.info('Retriggering bootstrap.')
209-
await server.bootstrap()
208+
this.config.logger.info('Restarting RLPx server: bootstrap')
209+
await server.stop()
210+
await server.start()
210211
}
211212
})
212213
await Promise.all(promises)

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

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -36,6 +36,7 @@ const ignoredErrors = new RegExp(
3636

3737
// Client
3838
'Handshake timed out', // Protocol handshake
39+
'Server already destroyed', // Bootstrap retrigger
3940
].join('|')
4041
)
4142

packages/client/lib/sync/fetcher/fetcher.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -348,7 +348,7 @@ export abstract class Fetcher<JobTask, JobResult, StorageItem> extends Readable
348348
this.config.logger.debug(
349349
`Task timed out for peer (banning) ${JSON.stringify(job.task)} ${job.peer}`
350350
)
351-
this.pool.ban(job.peer!, 300000)
351+
this.pool.ban(job.peer!, this.banTime)
352352
} else {
353353
this.config.logger.debug(
354354
`Peer disconnected while performing task ${JSON.stringify(job.task)} ${job.peer}`

0 commit comments

Comments
 (0)