Test pending terminations

This commit is contained in:
Łukasz Magiera 2021-01-14 12:41:27 +01:00
parent 785b660724
commit f01f1d377b
2 changed files with 16 additions and 5 deletions

View File

@ -518,7 +518,7 @@ func TestTerminate(t *testing.T, b APIBuilder, blocktime time.Duration) {
toTerminate := abi.SectorNumber(3) toTerminate := abi.SectorNumber(3)
err = miner.SectorTerminate(ctx, 3) err = miner.SectorTerminate(ctx, toTerminate)
require.NoError(t, err) require.NoError(t, err)
msgTriggerred := false msgTriggerred := false
@ -532,13 +532,24 @@ loop:
switch sealing.SectorState(si.State) { switch sealing.SectorState(si.State) {
case sealing.Terminating: case sealing.Terminating:
if !msgTriggerred { if !msgTriggerred {
c, err := miner.SectorTerminateFlush(ctx) {
if err != nil { p, err := miner.SectorTerminatePending(ctx)
return require.NoError(t, err)
require.Len(t, p, 1)
require.Equal(t, abi.SectorNumber(3), p[0].Number)
} }
c, err := miner.SectorTerminateFlush(ctx)
require.NoError(t, err)
if c != nil { if c != nil {
msgTriggerred = true msgTriggerred = true
fmt.Println("terminate message:", c) fmt.Println("terminate message:", c)
{
p, err := miner.SectorTerminatePending(ctx)
require.NoError(t, err)
require.Len(t, p, 0)
}
} }
} }
case sealing.TerminateWait, sealing.TerminateFinality, sealing.Removed: case sealing.TerminateWait, sealing.TerminateFinality, sealing.Removed:

View File

@ -84,7 +84,7 @@ func VersionForType(nodeType NodeType) (Version, error) {
// semver versions of the rpc api exposed // semver versions of the rpc api exposed
var ( var (
FullAPIVersion = newVer(1, 0, 0) FullAPIVersion = newVer(1, 0, 0)
MinerAPIVersion = newVer(1, 0, 0) MinerAPIVersion = newVer(1, 0, 1)
WorkerAPIVersion = newVer(1, 0, 0) WorkerAPIVersion = newVer(1, 0, 0)
) )