increase timeouts for context switch

This commit is contained in:
William Banfield
2021-08-24 11:46:28 -04:00
parent 8cbe79386f
commit 61ed8136db

View File

@@ -85,8 +85,8 @@ func TestBlock(t *testing.T) {
}()
// FIXME: used to induce context switch.
// Determine more deterministic method for prompting a context switch
time.Sleep(time.Microsecond)
requireConnect(t, rpcConfig.ListenAddress, 15)
time.Sleep(10 * time.Microsecond)
requireConnect(t, rpcConfig.ListenAddress, 20)
cli, err := httpclient.New(rpcConfig.ListenAddress)
require.NoError(t, err)
resultBlock, err := cli.Block(context.Background(), &testHeight)
@@ -129,7 +129,7 @@ func TestTxSearch(t *testing.T) {
defer wg.Done()
require.NoError(t, d.Run(ctx))
}()
requireConnect(t, rpcConfig.ListenAddress, 15)
requireConnect(t, rpcConfig.ListenAddress, 20)
cli, err := httpclient.New(rpcConfig.ListenAddress)
require.NoError(t, err)
@@ -169,7 +169,7 @@ func TestTx(t *testing.T) {
defer wg.Done()
require.NoError(t, d.Run(ctx))
}()
requireConnect(t, rpcConfig.ListenAddress, 15)
requireConnect(t, rpcConfig.ListenAddress, 20)
cli, err := httpclient.New(rpcConfig.ListenAddress)
require.NoError(t, err)
@@ -211,8 +211,8 @@ func TestConsensusParams(t *testing.T) {
}()
// FIXME: used to induce context switch.
// Determine more deterministic method for prompting a context switch
time.Sleep(time.Microsecond)
requireConnect(t, rpcConfig.ListenAddress, 15)
time.Sleep(10 * time.Microsecond)
requireConnect(t, rpcConfig.ListenAddress, 20)
cli, err := httpclient.New(rpcConfig.ListenAddress)
require.NoError(t, err)
params, err := cli.ConsensusParams(context.Background(), &testHeight)
@@ -258,8 +258,8 @@ func TestBlockResults(t *testing.T) {
}()
// FIXME: used to induce context switch.
// Determine more deterministic method for prompting a context switch
time.Sleep(time.Microsecond)
requireConnect(t, rpcConfig.ListenAddress, 15)
time.Sleep(10 * time.Microsecond)
requireConnect(t, rpcConfig.ListenAddress, 20)
cli, err := httpclient.New(rpcConfig.ListenAddress)
require.NoError(t, err)
res, err := cli.BlockResults(context.Background(), &testHeight)
@@ -300,8 +300,8 @@ func TestCommit(t *testing.T) {
}()
// FIXME: used to induce context switch.
// Determine more deterministic method for prompting a context switch
time.Sleep(time.Microsecond)
requireConnect(t, rpcConfig.ListenAddress, 15)
time.Sleep(10 * time.Microsecond)
requireConnect(t, rpcConfig.ListenAddress, 20)
cli, err := httpclient.New(rpcConfig.ListenAddress)
require.NoError(t, err)
res, err := cli.Commit(context.Background(), &testHeight)
@@ -348,8 +348,8 @@ func TestBlockByHash(t *testing.T) {
}()
// FIXME: used to induce context switch.
// Determine more deterministic method for prompting a context switch
time.Sleep(time.Microsecond)
requireConnect(t, rpcConfig.ListenAddress, 15)
time.Sleep(10 * time.Microsecond)
requireConnect(t, rpcConfig.ListenAddress, 20)
cli, err := httpclient.New(rpcConfig.ListenAddress)
require.NoError(t, err)
res, err := cli.BlockByHash(context.Background(), testHash)
@@ -395,8 +395,8 @@ func TestBlockchain(t *testing.T) {
}()
// FIXME: used to induce context switch.
// Determine more deterministic method for prompting a context switch
time.Sleep(time.Microsecond)
requireConnect(t, rpcConfig.ListenAddress, 15)
time.Sleep(10 * time.Microsecond)
requireConnect(t, rpcConfig.ListenAddress, 20)
cli, err := httpclient.New(rpcConfig.ListenAddress)
require.NoError(t, err)
res, err := cli.BlockchainInfo(context.Background(), 0, 100)
@@ -442,8 +442,8 @@ func TestValidators(t *testing.T) {
}()
// FIXME: used to induce context switch.
// Determine more deterministic method for prompting a context switch
time.Sleep(time.Microsecond)
requireConnect(t, rpcConfig.ListenAddress, 15)
time.Sleep(10 * time.Microsecond)
requireConnect(t, rpcConfig.ListenAddress, 20)
cli, err := httpclient.New(rpcConfig.ListenAddress)
require.NoError(t, err)
@@ -497,8 +497,8 @@ func TestBlockSearch(t *testing.T) {
}()
// FIXME: used to induce context switch.
// Determine more deterministic method for prompting a context switch
time.Sleep(time.Microsecond)
requireConnect(t, rpcConfig.ListenAddress, 15)
time.Sleep(10 * time.Microsecond)
requireConnect(t, rpcConfig.ListenAddress, 20)
cli, err := httpclient.New(rpcConfig.ListenAddress)
require.NoError(t, err)