mirror of
https://github.com/ethereum/go-ethereum.git
synced 2026-07-27 15:16:43 +00:00
fix: parallelise tests in core
This commit is contained in:
parent
a159bf7597
commit
ef88b4dfce
4 changed files with 8 additions and 3 deletions
|
|
@ -74,8 +74,8 @@ JavaScript API. See https://geth.ethereum.org/docs/interacting-with-geth/javascr
|
||||||
func localConsole(ctx *cli.Context) error {
|
func localConsole(ctx *cli.Context) error {
|
||||||
// Create and start the node based on the CLI flags
|
// Create and start the node based on the CLI flags
|
||||||
prepare(ctx)
|
prepare(ctx)
|
||||||
stack := makeFullNode(ctx)
|
stack, backend := makeFullNode(ctx)
|
||||||
startNode(ctx, stack, true)
|
startNode(ctx, stack, backend, true)
|
||||||
defer stack.Close()
|
defer stack.Close()
|
||||||
|
|
||||||
// Attach to the newly started node and create the JavaScript console.
|
// Attach to the newly started node and create the JavaScript console.
|
||||||
|
|
|
||||||
|
|
@ -1756,6 +1756,7 @@ func testLongReorgedSnapSyncingDeepRepair(t *testing.T, snapshots bool) {
|
||||||
}
|
}
|
||||||
|
|
||||||
func testRepair(t *testing.T, tt *rewindTest, snapshots bool) {
|
func testRepair(t *testing.T, tt *rewindTest, snapshots bool) {
|
||||||
|
t.Parallel()
|
||||||
for _, scheme := range []string{rawdb.HashScheme, rawdb.PathScheme} {
|
for _, scheme := range []string{rawdb.HashScheme, rawdb.PathScheme} {
|
||||||
testRepairWithScheme(t, tt, snapshots, scheme)
|
testRepairWithScheme(t, tt, snapshots, scheme)
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -530,6 +530,8 @@ func TestLowCommitCrashWithNewSnapshot(t *testing.T) {
|
||||||
// Expected head fast block: C8
|
// Expected head fast block: C8
|
||||||
// Expected head block : C2
|
// Expected head block : C2
|
||||||
// Expected snapshot disk : C4
|
// Expected snapshot disk : C4
|
||||||
|
|
||||||
|
t.Parallel()
|
||||||
for _, scheme := range []string{rawdb.HashScheme, rawdb.PathScheme} {
|
for _, scheme := range []string{rawdb.HashScheme, rawdb.PathScheme} {
|
||||||
test := &crashSnapshotTest{
|
test := &crashSnapshotTest{
|
||||||
snapshotTestBasic{
|
snapshotTestBasic{
|
||||||
|
|
@ -572,6 +574,8 @@ func TestHighCommitCrashWithNewSnapshot(t *testing.T) {
|
||||||
// Expected head fast block: C8
|
// Expected head fast block: C8
|
||||||
// Expected head block : G
|
// Expected head block : G
|
||||||
// Expected snapshot disk : C4
|
// Expected snapshot disk : C4
|
||||||
|
|
||||||
|
t.Parallel()
|
||||||
for _, scheme := range []string{rawdb.HashScheme, rawdb.PathScheme} {
|
for _, scheme := range []string{rawdb.HashScheme, rawdb.PathScheme} {
|
||||||
expHead := uint64(0)
|
expHead := uint64(0)
|
||||||
if scheme == rawdb.PathScheme {
|
if scheme == rawdb.PathScheme {
|
||||||
|
|
|
||||||
|
|
@ -187,7 +187,7 @@ const (
|
||||||
rmLogsChanSize = 10
|
rmLogsChanSize = 10
|
||||||
// logsChanSize is the size of channel listening to LogsEvent.
|
// logsChanSize is the size of channel listening to LogsEvent.
|
||||||
// Updated to fix TestEth2NeBlock testcase, as the feed was unable to send
|
// Updated to fix TestEth2NeBlock testcase, as the feed was unable to send
|
||||||
// logs to the channel. check - @anshalshukla
|
// logs to the channel. todo: @anshalshukla
|
||||||
logsChanSize = 100
|
logsChanSize = 100
|
||||||
// chainEvChanSize is the size of channel listening to ChainEvent.
|
// chainEvChanSize is the size of channel listening to ChainEvent.
|
||||||
chainEvChanSize = 10
|
chainEvChanSize = 10
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue