address review
This commit is contained in:
parent
dc8206e581
commit
7609655986
@ -199,7 +199,7 @@ func DefaultUpgradeSchedule() stmgr.UpgradeSchedule {
|
|||||||
PreMigration: PreUpgradeActorsV9,
|
PreMigration: PreUpgradeActorsV9,
|
||||||
StartWithin: 240,
|
StartWithin: 240,
|
||||||
DontStartWithin: 60,
|
DontStartWithin: 60,
|
||||||
StopWithin: 5,
|
StopWithin: 20,
|
||||||
}, {
|
}, {
|
||||||
PreMigration: PreUpgradeActorsV9,
|
PreMigration: PreUpgradeActorsV9,
|
||||||
StartWithin: 15,
|
StartWithin: 15,
|
||||||
|
@ -91,28 +91,6 @@ var diffMinerStates = &cli.Command{
|
|||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
//minerCode, err := cid.Decode("bafk2bzacedxmikgiz7du7e36vzsbmmhhozdtsucjkdo4uzkhj7nacajm33rx4")
|
|
||||||
//if err != nil {
|
|
||||||
// return err
|
|
||||||
//}
|
|
||||||
//
|
|
||||||
//minerStIntA, err := miner.Load(actorStore, &types.Actor{Head: stCidA, Code: minerCode})
|
|
||||||
//if err != nil {
|
|
||||||
// return err
|
|
||||||
//}
|
|
||||||
//
|
|
||||||
//minerStIntB, err := miner.Load(actorStore, &types.Actor{Head: stCidB, Code: minerCode})
|
|
||||||
//if err != nil {
|
|
||||||
// return err
|
|
||||||
//}
|
|
||||||
//
|
|
||||||
//dlDiff, err := miner.DiffDeadlines(minerStIntA, minerStIntB)
|
|
||||||
//if err != nil {
|
|
||||||
// return err
|
|
||||||
//}
|
|
||||||
//
|
|
||||||
//fmt.Println(dlDiff)
|
|
||||||
|
|
||||||
fmt.Println(minerStA.Deadlines)
|
fmt.Println(minerStA.Deadlines)
|
||||||
fmt.Println(minerStB.Deadlines)
|
fmt.Println(minerStB.Deadlines)
|
||||||
|
|
||||||
@ -167,18 +145,6 @@ var diffMinerStates = &cli.Command{
|
|||||||
fmt.Println(i, "isn't found in infoB!!")
|
fmt.Println(i, "isn't found in infoB!!")
|
||||||
}
|
}
|
||||||
|
|
||||||
if infoA.SimpleQAPower != infoB.SimpleQAPower {
|
|
||||||
fmt.Println("gfreak1")
|
|
||||||
}
|
|
||||||
|
|
||||||
if infoA.SectorKeyCID != infoB.SectorKeyCID {
|
|
||||||
fmt.Println("gfreak2")
|
|
||||||
}
|
|
||||||
|
|
||||||
if infoA.SealedCID != infoB.SealedCID {
|
|
||||||
fmt.Println("gfreak3")
|
|
||||||
}
|
|
||||||
|
|
||||||
if !infoA.DealWeight.Equals(infoB.DealWeight) {
|
if !infoA.DealWeight.Equals(infoB.DealWeight) {
|
||||||
fmt.Println("Deal Weights differ! ", infoA.DealWeight, infoB.DealWeight)
|
fmt.Println("Deal Weights differ! ", infoA.DealWeight, infoB.DealWeight)
|
||||||
}
|
}
|
||||||
|
@ -176,7 +176,7 @@ var migrationsCmd = &cli.Command{
|
|||||||
fmt.Println("completed round actual (without cache), took ", uncachedMigrationTime)
|
fmt.Println("completed round actual (without cache), took ", uncachedMigrationTime)
|
||||||
|
|
||||||
if cctx.Bool("check-invariants") {
|
if cctx.Bool("check-invariants") {
|
||||||
err = checkStateInvariants(ctx, blk.ParentStateRoot, newCid1, bs, blk.Height-1)
|
err = checkMigrationInvariants(ctx, blk.ParentStateRoot, newCid1, bs, blk.Height-1)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
@ -186,7 +186,7 @@ var migrationsCmd = &cli.Command{
|
|||||||
},
|
},
|
||||||
}
|
}
|
||||||
|
|
||||||
func checkStateInvariants(ctx context.Context, v8StateRoot cid.Cid, v9StateRoot cid.Cid, bs blockstore.Blockstore, epoch abi.ChainEpoch) error {
|
func checkMigrationInvariants(ctx context.Context, v8StateRoot cid.Cid, v9StateRoot cid.Cid, bs blockstore.Blockstore, epoch abi.ChainEpoch) error {
|
||||||
actorStore := store.ActorStore(ctx, bs)
|
actorStore := store.ActorStore(ctx, bs)
|
||||||
startTime := time.Now()
|
startTime := time.Now()
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user