diff options
author | Péter Szilágyi <peterke@gmail.com> | 2018-02-18 00:47:44 +0800 |
---|---|---|
committer | GitHub <noreply@github.com> | 2018-02-18 00:47:44 +0800 |
commit | 9fd76e33af367752160ab0e33d1097e1e9aff6e4 (patch) | |
tree | 2cead3501991bb474f0a50727b625fea75700797 /p2p/discover/database_test.go | |
parent | 4e61ed02e2d32aa38f5a2f37b87bc52a71657809 (diff) | |
parent | aeedec4078647c22244552803c88521391224ab1 (diff) | |
download | dexon-9fd76e33af367752160ab0e33d1097e1e9aff6e4.tar dexon-9fd76e33af367752160ab0e33d1097e1e9aff6e4.tar.gz dexon-9fd76e33af367752160ab0e33d1097e1e9aff6e4.tar.bz2 dexon-9fd76e33af367752160ab0e33d1097e1e9aff6e4.tar.lz dexon-9fd76e33af367752160ab0e33d1097e1e9aff6e4.tar.xz dexon-9fd76e33af367752160ab0e33d1097e1e9aff6e4.tar.zst dexon-9fd76e33af367752160ab0e33d1097e1e9aff6e4.zip |
Merge pull request #16109 from karalabe/p2p-bond-check
p2p/discover: validate bond against lastpong, not db presence
Diffstat (limited to 'p2p/discover/database_test.go')
-rw-r--r-- | p2p/discover/database_test.go | 18 |
1 files changed, 9 insertions, 9 deletions
diff --git a/p2p/discover/database_test.go b/p2p/discover/database_test.go index be972fd2c..c4fa44d09 100644 --- a/p2p/discover/database_test.go +++ b/p2p/discover/database_test.go @@ -125,13 +125,13 @@ func TestNodeDBFetchStore(t *testing.T) { t.Errorf("ping: value mismatch: have %v, want %v", stored, inst) } // Check fetch/store operations on a node pong object - if stored := db.lastPong(node.ID); stored.Unix() != 0 { + if stored := db.bondTime(node.ID); stored.Unix() != 0 { t.Errorf("pong: non-existing object: %v", stored) } - if err := db.updateLastPong(node.ID, inst); err != nil { + if err := db.updateBondTime(node.ID, inst); err != nil { t.Errorf("pong: failed to update: %v", err) } - if stored := db.lastPong(node.ID); stored.Unix() != inst.Unix() { + if stored := db.bondTime(node.ID); stored.Unix() != inst.Unix() { t.Errorf("pong: value mismatch: have %v, want %v", stored, inst) } // Check fetch/store operations on a node findnode-failure object @@ -224,8 +224,8 @@ func TestNodeDBSeedQuery(t *testing.T) { if err := db.updateNode(seed.node); err != nil { t.Fatalf("node %d: failed to insert: %v", i, err) } - if err := db.updateLastPong(seed.node.ID, seed.pong); err != nil { - t.Fatalf("node %d: failed to insert lastPong: %v", i, err) + if err := db.updateBondTime(seed.node.ID, seed.pong); err != nil { + t.Fatalf("node %d: failed to insert bondTime: %v", i, err) } } @@ -332,8 +332,8 @@ func TestNodeDBExpiration(t *testing.T) { if err := db.updateNode(seed.node); err != nil { t.Fatalf("node %d: failed to insert: %v", i, err) } - if err := db.updateLastPong(seed.node.ID, seed.pong); err != nil { - t.Fatalf("node %d: failed to update pong: %v", i, err) + if err := db.updateBondTime(seed.node.ID, seed.pong); err != nil { + t.Fatalf("node %d: failed to update bondTime: %v", i, err) } } // Expire some of them, and check the rest @@ -365,8 +365,8 @@ func TestNodeDBSelfExpiration(t *testing.T) { if err := db.updateNode(seed.node); err != nil { t.Fatalf("node %d: failed to insert: %v", i, err) } - if err := db.updateLastPong(seed.node.ID, seed.pong); err != nil { - t.Fatalf("node %d: failed to update pong: %v", i, err) + if err := db.updateBondTime(seed.node.ID, seed.pong); err != nil { + t.Fatalf("node %d: failed to update bondTime: %v", i, err) } } // Expire the nodes and make sure self has been evacuated too |