Commit 91701d4a authored by Felipe Andrade's avatar Felipe Andrade

delay 500ms instead of 100ms

parent 6d6b8a6b
...@@ -640,13 +640,13 @@ func TestConsensus(t *testing.T) { ...@@ -640,13 +640,13 @@ func TestConsensus(t *testing.T) {
defer func() { nodes["node1"].mockBackend.handler = oldHandler }() defer func() { nodes["node1"].mockBackend.handler = oldHandler }()
nodes["node1"].mockBackend.SetHandler(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) { nodes["node1"].mockBackend.SetHandler(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
time.Sleep(100 * time.Millisecond) time.Sleep(500 * time.Millisecond)
oldHandler.ServeHTTP(w, r) oldHandler.ServeHTTP(w, r)
})) }))
update() update()
// send 10 requests - so the latency window should be at ~100ms // send 10 requests to make node1 degraded
numberReqs := 10 numberReqs := 10
for numberReqs > 0 { for numberReqs > 0 {
_, statusCode, err := client.SendRPC("eth_getBlockByNumber", []interface{}{"0x101", false}) _, statusCode, err := client.SendRPC("eth_getBlockByNumber", []interface{}{"0x101", false})
...@@ -676,8 +676,8 @@ func TestConsensus(t *testing.T) { ...@@ -676,8 +676,8 @@ func TestConsensus(t *testing.T) {
msg := fmt.Sprintf("n1 %d, n2 %d", msg := fmt.Sprintf("n1 %d, n2 %d",
len(nodes["node1"].mockBackend.Requests()), len(nodes["node2"].mockBackend.Requests())) len(nodes["node1"].mockBackend.Requests()), len(nodes["node2"].mockBackend.Requests()))
require.Equal(t, len(nodes["node1"].mockBackend.Requests()), 0, msg) require.Equal(t, 0, len(nodes["node1"].mockBackend.Requests()), msg)
require.Equal(t, len(nodes["node2"].mockBackend.Requests()), 10, msg) require.Equal(t, 10, len(nodes["node2"].mockBackend.Requests()), msg)
}) })
t.Run("rewrite response of eth_blockNumber", func(t *testing.T) { t.Run("rewrite response of eth_blockNumber", func(t *testing.T) {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment