tornadocontrib/infra
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

delay 500ms instead of 100ms

Browse Source
This commit is contained in:
Felipe Andrade 2023-05-31 13:13:31 -07:00
parent a09795f83d
commit a4d4d8750f
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
proxyd/proxyd/integration_tests/consensus_test.go
View File

@ -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) {
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) {