Skip to content

Commit 7954538

Browse files
committed
Supress header download when queue is full
1 parent e5ec181 commit 7954538

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

sync/src/block/downloader/header.rs

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -25,6 +25,7 @@ use primitives::{H256, U256};
2525
use super::super::message::RequestMessage;
2626

2727
const MAX_HEADER_REQUEST_LENGTH: u64 = 128;
28+
const MAX_HEADER_QUEUE_LENGTH: usize = 1024;
2829
const MAX_RETRY: usize = 3;
2930
const MAX_WAIT: u64 = 15;
3031

@@ -128,6 +129,9 @@ impl HeaderDownloader {
128129
if !self.is_idle() {
129130
return None
130131
}
132+
if self.queued.len() > MAX_HEADER_QUEUE_LENGTH {
133+
return None
134+
}
131135

132136
let pivot_number = self.pivot_header().number();
133137

0 commit comments

Comments
 (0)