cerc-io/lotus
16
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 27 Wiki Activity

use a single context for miner

Browse Source
This commit is contained in:
vyzo 2020-06-25 14:26:43 +03:00
parent b476bc86ce
commit 1eeeff82d1
1 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
lotus-soup/baseline.go
View File

@ -67,6 +67,8 @@ func runBaselineMiner(t *TestEnvironment) error {
return err return err
} }
ctx := context.Background()
clients := t.IntParam("clients") clients := t.IntParam("clients")
miners := t.IntParam("miners") miners := t.IntParam("miners")
@ -79,12 +81,12 @@ func runBaselineMiner(t *TestEnvironment) error {
// synchronize all miners to mine the next block // synchronize all miners to mine the next block
t.RecordMessage("synchronizing all miners to mine next block") t.RecordMessage("synchronizing all miners to mine next block")
t.SyncClient.MustSignalAndWait(context.Background(), stateMineNext, miners) t.SyncClient.MustSignalAndWait(ctx, stateMineNext, miners)
time.Sleep(time.Duration(rand.Intn(int(100 * time.Millisecond)))) time.Sleep(time.Duration(rand.Intn(int(100 * time.Millisecond))))
// wait and synchronise // wait and synchronise
err := miner.MineOne(context.TODO(), func(bool) { err := miner.MineOne(ctx, func(bool) {
// after a block is mined // after a block is mined
}) })
if err != nil { if err != nil {
@ -94,7 +96,7 @@ func runBaselineMiner(t *TestEnvironment) error {
}() }()
// wait for a signal from all clients to stop mining // wait for a signal from all clients to stop mining
err = <-t.SyncClient.MustBarrier(context.Background(), stateStopMining, clients).C err = <-t.SyncClient.MustBarrier(ctx, stateStopMining, clients).C
if err != nil { if err != nil {
return err return err
} }
@ -103,7 +105,7 @@ func runBaselineMiner(t *TestEnvironment) error {
t.RecordMessage("shutting down mining") t.RecordMessage("shutting down mining")
<-done <-done
t.SyncClient.MustSignalAndWait(context.Background(), stateDone, t.TestInstanceCount) t.SyncClient.MustSignalAndWait(ctx, stateDone, t.TestInstanceCount)
return nil return nil
} }