Address review
This commit is contained in:
parent
4b74aa5768
commit
4e1e9ecf3e
@ -369,8 +369,8 @@ type MinerSectors struct {
|
|||||||
type SectorExpiration struct {
|
type SectorExpiration struct {
|
||||||
OnTime abi.ChainEpoch
|
OnTime abi.ChainEpoch
|
||||||
|
|
||||||
// non-zero if sector is faulty, epoch at which it will it will be
|
// non-zero if sector is faulty, epoch at which it will be permanently
|
||||||
// permanently removed if it doesn't recover
|
// removed if it doesn't recover
|
||||||
Early abi.ChainEpoch
|
Early abi.ChainEpoch
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -191,17 +191,15 @@ func startSealingWaiting(t *testing.T, ctx context.Context, miner TestStorageNod
|
|||||||
snums, err := miner.SectorsList(ctx)
|
snums, err := miner.SectorsList(ctx)
|
||||||
require.NoError(t, err)
|
require.NoError(t, err)
|
||||||
|
|
||||||
fmt.Printf("Miner sector states: ")
|
|
||||||
for _, snum := range snums {
|
for _, snum := range snums {
|
||||||
si, err := miner.SectorsStatus(ctx, snum)
|
si, err := miner.SectorsStatus(ctx, snum)
|
||||||
require.NoError(t, err)
|
require.NoError(t, err)
|
||||||
|
|
||||||
fmt.Printf("%s ", si.State)
|
t.Logf("Sector state: %s", si.State)
|
||||||
if si.State == api.SectorState(sealing.WaitDeals) {
|
if si.State == api.SectorState(sealing.WaitDeals) {
|
||||||
require.NoError(t, miner.SectorStartSealing(ctx, snum))
|
require.NoError(t, miner.SectorStartSealing(ctx, snum))
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
fmt.Println("")
|
|
||||||
}
|
}
|
||||||
|
|
||||||
func testRetrieval(t *testing.T, ctx context.Context, err error, client *impl.FullNodeAPI, fcid cid.Cid, piece *cid.Cid, carExport bool, data []byte) {
|
func testRetrieval(t *testing.T, ctx context.Context, err error, client *impl.FullNodeAPI, fcid cid.Cid, piece *cid.Cid, carExport bool, data []byte) {
|
||||||
|
Loading…
Reference in New Issue
Block a user