aboutsummaryrefslogtreecommitdiffstats
path: root/eth/downloader/downloader_test.go
diff options
context:
space:
mode:
authorPéter Szilágyi <peterke@gmail.com>2015-05-15 06:40:16 +0800
committerPéter Szilágyi <peterke@gmail.com>2015-05-15 20:01:58 +0800
commitcd2fb0905109828028172c84f9c10f1343647ca6 (patch)
treeede1984738a0d16f338341f7a1bc94e17381a715 /eth/downloader/downloader_test.go
parentc1f0d40e34a80f4453a9a54f90e2d4551c3bdb05 (diff)
downloadgo-tangerine-cd2fb0905109828028172c84f9c10f1343647ca6.tar
go-tangerine-cd2fb0905109828028172c84f9c10f1343647ca6.tar.gz
go-tangerine-cd2fb0905109828028172c84f9c10f1343647ca6.tar.bz2
go-tangerine-cd2fb0905109828028172c84f9c10f1343647ca6.tar.lz
go-tangerine-cd2fb0905109828028172c84f9c10f1343647ca6.tar.xz
go-tangerine-cd2fb0905109828028172c84f9c10f1343647ca6.tar.zst
go-tangerine-cd2fb0905109828028172c84f9c10f1343647ca6.zip
eth, eth/downloader: prevent hash repeater attack
Diffstat (limited to 'eth/downloader/downloader_test.go')
-rw-r--r--eth/downloader/downloader_test.go29
1 files changed, 29 insertions, 0 deletions
diff --git a/eth/downloader/downloader_test.go b/eth/downloader/downloader_test.go
index 50fe00d42..1bba3ca51 100644
--- a/eth/downloader/downloader_test.go
+++ b/eth/downloader/downloader_test.go
@@ -336,3 +336,32 @@ func TestNonExistingParentAttack(t *testing.T) {
t.Fatalf("tester doesn't know about the origin hash")
}
}
+
+// Tests that if a malicious peers keeps sending us repeating hashes, we don't
+// loop indefinitely.
+func TestRepeatingHashAttack(t *testing.T) {
+ // Create a valid chain, but drop the last link
+ hashes := createHashes(1000, 1)
+ blocks := createBlocksFromHashes(hashes)
+
+ hashes = hashes[:len(hashes)-1]
+
+ // Try and sync with the malicious node
+ tester := newTester(t, hashes, blocks)
+ tester.newPeer("attack", big.NewInt(10000), hashes[0])
+
+ errc := make(chan error)
+ go func() {
+ errc <- tester.sync("attack", hashes[0])
+ }()
+
+ // Make sure that syncing returns and does so with a failure
+ select {
+ case <-time.After(100 * time.Millisecond):
+ t.Fatalf("synchronisation blocked")
+ case err := <-errc:
+ if err == nil {
+ t.Fatalf("synchronisation succeeded")
+ }
+ }
+}