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

validate that block propagation works after a worker key change

Browse Source
This commit is contained in:
Steven Allen 2020-10-23 19:52:23 -07:00
parent 0d06f8fa2b
commit 832c0998e4
1 changed files with 39 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

45
cmd/lotus-storage-miner/actor_test.go
View File

@ -44,12 +44,22 @@ func TestWorkerKeyChange(t *testing.T) {
logging.SetLogLevel("miner", "ERROR") logging.SetLogLevel("miner", "ERROR")
logging.SetLogLevel("chainstore", "ERROR") logging.SetLogLevel("chainstore", "ERROR")
logging.SetLogLevel("chain", "ERROR") logging.SetLogLevel("chain", "ERROR")
logging.SetLogLevel("pubsub", "ERROR")
logging.SetLogLevel("sub", "ERROR") logging.SetLogLevel("sub", "ERROR")
logging.SetLogLevel("storageminer", "ERROR") logging.SetLogLevel("storageminer", "ERROR")
blocktime := 1 * time.Millisecond blocktime := 1 * time.Millisecond
n, sn := builder.MockSbBuilder(t, []test.FullNodeOpts{test.FullNodeWithUpgradeAt(1)}, test.OneMiner) n, sn := builder.MockSbBuilder(t, []test.FullNodeOpts{test.FullNodeWithUpgradeAt(1), test.FullNodeWithUpgradeAt(1)}, test.OneMiner)
client1 := n[0]
client2 := n[1]
// Connect the nodes.
addrinfo, err := client1.NetAddrsListen(ctx)
require.NoError(t, err)
err = client2.NetConnect(ctx, addrinfo)
require.NoError(t, err)
output := bytes.NewBuffer(nil) output := bytes.NewBuffer(nil)
run := func(cmd *cli.Command, args ...string) error { run := func(cmd *cli.Command, args ...string) error {
@ -92,13 +102,11 @@ func TestWorkerKeyChange(t *testing.T) {
<-done <-done
}() }()
client := n[0] newKey, err := client1.WalletNew(ctx, types.KTBLS)
newKey, err := client.WalletNew(ctx, types.KTBLS)
require.NoError(t, err) require.NoError(t, err)
// Initialize wallet. // Initialize wallet.
test.SendFunds(ctx, t, client, newKey, abi.NewTokenAmount(0)) test.SendFunds(ctx, t, client1, newKey, abi.NewTokenAmount(0))
require.NoError(t, run(actorProposeChangeWorker, "--really-do-it", newKey.String())) require.NoError(t, run(actorProposeChangeWorker, "--really-do-it", newKey.String()))
@ -119,7 +127,7 @@ func TestWorkerKeyChange(t *testing.T) {
output.Reset() output.Reset()
for { for {
head, err := client.ChainHead(ctx) head, err := client1.ChainHead(ctx)
require.NoError(t, err) require.NoError(t, err)
if head.Height() >= abi.ChainEpoch(targetEpoch) { if head.Height() >= abi.ChainEpoch(targetEpoch) {
break break
@ -128,4 +136,29 @@ func TestWorkerKeyChange(t *testing.T) {
} }
require.NoError(t, run(actorConfirmChangeWorker, "--really-do-it", newKey.String())) require.NoError(t, run(actorConfirmChangeWorker, "--really-do-it", newKey.String()))
output.Reset() output.Reset()
head, err := client1.ChainHead(ctx)
require.NoError(t, err)
// Wait for finality (worker key switch).
targetHeight := head.Height() + policy.ChainFinality
for {
head, err := client1.ChainHead(ctx)
require.NoError(t, err)
if head.Height() >= targetHeight {
break
}
build.Clock.Sleep(10 * blocktime)
}
// Make sure the other node can catch up.
for i := 0; i < 20; i++ {
head, err := client2.ChainHead(ctx)
require.NoError(t, err)
if head.Height() >= targetHeight {
return
}
build.Clock.Sleep(10 * blocktime)
}
t.Fatal("failed to reach target epoch on the second miner")
} }