2019-09-06 06:26:02 +00:00
|
|
|
package stmgr
|
|
|
|
|
|
|
|
import (
|
2020-04-30 22:11:14 +00:00
|
|
|
"bytes"
|
2019-09-06 06:26:02 +00:00
|
|
|
"context"
|
2020-09-04 03:28:42 +00:00
|
|
|
"fmt"
|
2020-04-20 17:43:02 +00:00
|
|
|
"os"
|
2020-07-03 16:57:58 +00:00
|
|
|
"reflect"
|
2020-09-04 03:28:42 +00:00
|
|
|
"runtime"
|
|
|
|
"strings"
|
2020-04-17 23:36:54 +00:00
|
|
|
|
2020-09-07 06:08:53 +00:00
|
|
|
saruntime "github.com/filecoin-project/specs-actors/actors/runtime"
|
|
|
|
"github.com/filecoin-project/specs-actors/actors/runtime/proof"
|
|
|
|
|
2020-04-20 17:43:02 +00:00
|
|
|
cid "github.com/ipfs/go-cid"
|
|
|
|
cbor "github.com/ipfs/go-ipld-cbor"
|
|
|
|
cbg "github.com/whyrusleeping/cbor-gen"
|
|
|
|
"golang.org/x/xerrors"
|
|
|
|
|
|
|
|
"github.com/filecoin-project/go-address"
|
2020-07-01 04:57:49 +00:00
|
|
|
"github.com/filecoin-project/go-bitfield"
|
2020-09-07 03:49:10 +00:00
|
|
|
"github.com/filecoin-project/go-state-types/abi"
|
|
|
|
"github.com/filecoin-project/go-state-types/crypto"
|
2020-09-14 12:17:45 +00:00
|
|
|
power2 "github.com/filecoin-project/lotus/chain/actors/builtin/power"
|
2020-08-17 13:26:18 +00:00
|
|
|
"github.com/filecoin-project/lotus/extern/sector-storage/ffiwrapper"
|
2020-02-19 20:39:10 +00:00
|
|
|
"github.com/filecoin-project/specs-actors/actors/builtin"
|
2020-07-03 16:57:58 +00:00
|
|
|
"github.com/filecoin-project/specs-actors/actors/builtin/account"
|
|
|
|
"github.com/filecoin-project/specs-actors/actors/builtin/cron"
|
2020-03-31 23:13:37 +00:00
|
|
|
init_ "github.com/filecoin-project/specs-actors/actors/builtin/init"
|
2020-02-08 02:18:32 +00:00
|
|
|
"github.com/filecoin-project/specs-actors/actors/builtin/market"
|
2020-02-11 02:33:27 +00:00
|
|
|
"github.com/filecoin-project/specs-actors/actors/builtin/miner"
|
2020-07-03 16:57:58 +00:00
|
|
|
"github.com/filecoin-project/specs-actors/actors/builtin/multisig"
|
|
|
|
"github.com/filecoin-project/specs-actors/actors/builtin/paych"
|
2020-02-11 02:33:27 +00:00
|
|
|
"github.com/filecoin-project/specs-actors/actors/builtin/power"
|
2020-07-03 16:57:58 +00:00
|
|
|
"github.com/filecoin-project/specs-actors/actors/builtin/reward"
|
|
|
|
"github.com/filecoin-project/specs-actors/actors/builtin/verifreg"
|
2020-02-11 02:33:27 +00:00
|
|
|
"github.com/filecoin-project/specs-actors/actors/util/adt"
|
2020-02-08 02:18:32 +00:00
|
|
|
|
2019-10-18 04:47:41 +00:00
|
|
|
"github.com/filecoin-project/lotus/api"
|
2020-04-17 23:36:54 +00:00
|
|
|
"github.com/filecoin-project/lotus/build"
|
2020-04-30 22:11:14 +00:00
|
|
|
"github.com/filecoin-project/lotus/chain/beacon"
|
2020-03-31 23:13:37 +00:00
|
|
|
"github.com/filecoin-project/lotus/chain/state"
|
2020-01-17 02:33:43 +00:00
|
|
|
"github.com/filecoin-project/lotus/chain/store"
|
2019-10-18 04:47:41 +00:00
|
|
|
"github.com/filecoin-project/lotus/chain/types"
|
2020-01-17 02:33:43 +00:00
|
|
|
"github.com/filecoin-project/lotus/chain/vm"
|
2020-07-23 02:05:11 +00:00
|
|
|
"github.com/filecoin-project/lotus/lib/blockstore"
|
2020-03-31 23:13:37 +00:00
|
|
|
"github.com/filecoin-project/lotus/node/modules/dtypes"
|
2019-09-06 06:26:02 +00:00
|
|
|
)
|
|
|
|
|
2020-03-31 23:13:37 +00:00
|
|
|
func GetNetworkName(ctx context.Context, sm *StateManager, st cid.Cid) (dtypes.NetworkName, error) {
|
|
|
|
var state init_.State
|
2020-07-14 11:45:45 +00:00
|
|
|
err := sm.WithStateTree(st, sm.WithActor(builtin.InitActorAddr, sm.WithActorState(ctx, &state)))
|
2020-03-31 23:13:37 +00:00
|
|
|
if err != nil {
|
2020-07-14 11:45:45 +00:00
|
|
|
return "", err
|
2020-03-31 23:13:37 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
return dtypes.NetworkName(state.NetworkName), nil
|
|
|
|
}
|
|
|
|
|
2019-10-23 17:39:14 +00:00
|
|
|
func GetMinerWorkerRaw(ctx context.Context, sm *StateManager, st cid.Cid, maddr address.Address) (address.Address, error) {
|
2020-02-11 02:33:27 +00:00
|
|
|
var mas miner.State
|
|
|
|
_, err := sm.LoadActorStateRaw(ctx, maddr, &mas, st)
|
2019-09-06 06:26:02 +00:00
|
|
|
if err != nil {
|
2020-02-11 02:33:27 +00:00
|
|
|
return address.Undef, xerrors.Errorf("(get sset) failed to load miner actor state: %w", err)
|
2019-09-06 06:26:02 +00:00
|
|
|
}
|
|
|
|
|
2020-02-21 16:57:40 +00:00
|
|
|
cst := cbor.NewCborStore(sm.cs.Blockstore())
|
|
|
|
state, err := state.LoadStateTree(cst, st)
|
|
|
|
if err != nil {
|
|
|
|
return address.Undef, xerrors.Errorf("load state tree: %w", err)
|
|
|
|
}
|
|
|
|
|
2020-07-01 11:47:40 +00:00
|
|
|
info, err := mas.GetInfo(sm.cs.Store(ctx))
|
|
|
|
if err != nil {
|
|
|
|
return address.Address{}, err
|
|
|
|
}
|
|
|
|
|
|
|
|
return vm.ResolveToKeyAddr(state, cst, info.Worker)
|
2019-09-06 06:26:02 +00:00
|
|
|
}
|
|
|
|
|
2020-04-17 22:02:04 +00:00
|
|
|
func GetPower(ctx context.Context, sm *StateManager, ts *types.TipSet, maddr address.Address) (power.Claim, power.Claim, error) {
|
2020-04-17 23:36:54 +00:00
|
|
|
return GetPowerRaw(ctx, sm, ts.ParentState(), maddr)
|
2020-04-02 01:25:58 +00:00
|
|
|
}
|
|
|
|
|
2020-04-17 23:36:54 +00:00
|
|
|
func GetPowerRaw(ctx context.Context, sm *StateManager, st cid.Cid, maddr address.Address) (power.Claim, power.Claim, error) {
|
2020-02-11 02:33:27 +00:00
|
|
|
var ps power.State
|
2020-04-02 01:25:58 +00:00
|
|
|
_, err := sm.LoadActorStateRaw(ctx, builtin.StoragePowerActorAddr, &ps, st)
|
2020-02-11 02:33:27 +00:00
|
|
|
if err != nil {
|
2020-04-17 22:02:04 +00:00
|
|
|
return power.Claim{}, power.Claim{}, xerrors.Errorf("(get sset) failed to load power actor state: %w", err)
|
2020-02-11 02:33:27 +00:00
|
|
|
}
|
2019-09-09 20:03:10 +00:00
|
|
|
|
2020-04-17 22:02:04 +00:00
|
|
|
var mpow power.Claim
|
2019-09-09 20:03:10 +00:00
|
|
|
if maddr != address.Undef {
|
2020-04-13 21:05:34 +00:00
|
|
|
cm, err := adt.AsMap(sm.cs.Store(ctx), ps.Claims)
|
|
|
|
if err != nil {
|
2020-04-17 22:02:04 +00:00
|
|
|
return power.Claim{}, power.Claim{}, err
|
2020-04-13 21:05:34 +00:00
|
|
|
}
|
|
|
|
|
2020-02-11 02:33:27 +00:00
|
|
|
var claim power.Claim
|
2020-04-13 21:05:34 +00:00
|
|
|
if _, err := cm.Get(adt.AddrKey(maddr), &claim); err != nil {
|
2020-04-17 22:02:04 +00:00
|
|
|
return power.Claim{}, power.Claim{}, err
|
2019-09-09 20:03:10 +00:00
|
|
|
}
|
|
|
|
|
2020-04-17 22:02:04 +00:00
|
|
|
mpow = claim
|
2019-09-09 20:03:10 +00:00
|
|
|
}
|
|
|
|
|
2020-04-17 22:02:04 +00:00
|
|
|
return mpow, power.Claim{
|
|
|
|
RawBytePower: ps.TotalRawBytePower,
|
|
|
|
QualityAdjPower: ps.TotalQualityAdjPower,
|
|
|
|
}, nil
|
2019-09-09 20:03:10 +00:00
|
|
|
}
|
2019-09-17 08:00:38 +00:00
|
|
|
|
2020-04-04 02:55:19 +00:00
|
|
|
func PreCommitInfo(ctx context.Context, sm *StateManager, maddr address.Address, sid abi.SectorNumber, ts *types.TipSet) (miner.SectorPreCommitOnChainInfo, error) {
|
|
|
|
var mas miner.State
|
|
|
|
_, err := sm.LoadActorState(ctx, maddr, &mas, ts)
|
|
|
|
if err != nil {
|
|
|
|
return miner.SectorPreCommitOnChainInfo{}, xerrors.Errorf("(get sset) failed to load miner actor state: %w", err)
|
|
|
|
}
|
|
|
|
|
|
|
|
i, ok, err := mas.GetPrecommittedSector(sm.cs.Store(ctx), sid)
|
|
|
|
if err != nil {
|
|
|
|
return miner.SectorPreCommitOnChainInfo{}, err
|
|
|
|
}
|
|
|
|
if !ok {
|
|
|
|
return miner.SectorPreCommitOnChainInfo{}, xerrors.New("precommit not found")
|
|
|
|
}
|
|
|
|
|
|
|
|
return *i, nil
|
|
|
|
}
|
|
|
|
|
2020-05-28 00:06:29 +00:00
|
|
|
func MinerSectorInfo(ctx context.Context, sm *StateManager, maddr address.Address, sid abi.SectorNumber, ts *types.TipSet) (*miner.SectorOnChainInfo, error) {
|
|
|
|
var mas miner.State
|
|
|
|
_, err := sm.LoadActorState(ctx, maddr, &mas, ts)
|
|
|
|
if err != nil {
|
|
|
|
return nil, xerrors.Errorf("(get sset) failed to load miner actor state: %w", err)
|
|
|
|
}
|
|
|
|
|
|
|
|
sectorInfo, ok, err := mas.GetSector(sm.cs.Store(ctx), sid)
|
|
|
|
if err != nil {
|
|
|
|
return nil, err
|
|
|
|
}
|
|
|
|
if !ok {
|
2020-08-27 11:51:13 +00:00
|
|
|
return nil, nil
|
2020-05-28 00:06:29 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
return sectorInfo, nil
|
|
|
|
}
|
|
|
|
|
2020-09-07 03:49:10 +00:00
|
|
|
func GetMinerSectorSet(ctx context.Context, sm *StateManager, ts *types.TipSet, maddr address.Address, filter *bitfield.BitField, filterOut bool) ([]*api.ChainSectorInfo, error) {
|
2020-02-25 20:35:15 +00:00
|
|
|
var mas miner.State
|
2019-09-18 02:55:51 +00:00
|
|
|
_, err := sm.LoadActorState(ctx, maddr, &mas, ts)
|
|
|
|
if err != nil {
|
2019-11-30 04:31:16 +00:00
|
|
|
return nil, xerrors.Errorf("(get sset) failed to load miner actor state: %w", err)
|
2019-09-18 02:55:51 +00:00
|
|
|
}
|
|
|
|
|
2020-04-21 17:22:53 +00:00
|
|
|
return LoadSectorsFromSet(ctx, sm.ChainStore().Blockstore(), mas.Sectors, filter, filterOut)
|
2019-09-18 02:55:51 +00:00
|
|
|
}
|
|
|
|
|
2020-09-07 03:49:10 +00:00
|
|
|
func GetSectorsForWinningPoSt(ctx context.Context, pv ffiwrapper.Verifier, sm *StateManager, st cid.Cid, maddr address.Address, rand abi.PoStRandomness) ([]proof.SectorInfo, error) {
|
|
|
|
var partsProving []bitfield.BitField
|
2020-07-14 11:45:45 +00:00
|
|
|
var mas *miner.State
|
|
|
|
var info *miner.MinerInfo
|
2020-04-17 14:47:19 +00:00
|
|
|
|
2020-07-14 11:45:45 +00:00
|
|
|
err := sm.WithStateTree(st, sm.WithActor(maddr, sm.WithActorState(ctx, func(store adt.Store, mst *miner.State) error {
|
|
|
|
var err error
|
2020-07-01 04:57:49 +00:00
|
|
|
|
2020-07-14 11:45:45 +00:00
|
|
|
mas = mst
|
2020-07-01 04:57:49 +00:00
|
|
|
|
2020-07-14 11:45:45 +00:00
|
|
|
info, err = mas.GetInfo(store)
|
|
|
|
if err != nil {
|
|
|
|
return xerrors.Errorf("getting miner info: %w", err)
|
|
|
|
}
|
|
|
|
|
|
|
|
deadlines, err := mas.LoadDeadlines(store)
|
|
|
|
if err != nil {
|
|
|
|
return xerrors.Errorf("loading deadlines: %w", err)
|
|
|
|
}
|
|
|
|
|
|
|
|
return deadlines.ForEach(store, func(dlIdx uint64, deadline *miner.Deadline) error {
|
|
|
|
partitions, err := deadline.PartitionsArray(store)
|
|
|
|
if err != nil {
|
|
|
|
return xerrors.Errorf("getting partition array: %w", err)
|
|
|
|
}
|
|
|
|
|
|
|
|
var partition miner.Partition
|
|
|
|
return partitions.ForEach(&partition, func(partIdx int64) error {
|
|
|
|
p, err := bitfield.SubtractBitField(partition.Sectors, partition.Faults)
|
|
|
|
if err != nil {
|
|
|
|
return xerrors.Errorf("subtract faults from partition sectors: %w", err)
|
|
|
|
}
|
|
|
|
|
|
|
|
partsProving = append(partsProving, p)
|
|
|
|
|
|
|
|
return nil
|
|
|
|
})
|
|
|
|
})
|
|
|
|
})))
|
2020-07-01 04:57:49 +00:00
|
|
|
if err != nil {
|
2020-07-14 11:45:45 +00:00
|
|
|
return nil, err
|
2020-07-01 04:57:49 +00:00
|
|
|
}
|
|
|
|
|
2020-07-14 11:45:45 +00:00
|
|
|
provingSectors, err := bitfield.MultiMerge(partsProving...)
|
2020-07-01 04:57:49 +00:00
|
|
|
if err != nil {
|
2020-07-14 11:45:45 +00:00
|
|
|
return nil, xerrors.Errorf("merge partition proving sets: %w", err)
|
2020-07-01 04:57:49 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
numProvSect, err := provingSectors.Count()
|
2020-04-17 14:47:19 +00:00
|
|
|
if err != nil {
|
2020-07-01 04:57:49 +00:00
|
|
|
return nil, xerrors.Errorf("failed to count bits: %w", err)
|
2020-04-17 14:47:19 +00:00
|
|
|
}
|
|
|
|
|
2020-07-01 04:57:49 +00:00
|
|
|
// TODO(review): is this right? feels fishy to me
|
|
|
|
if numProvSect == 0 {
|
2020-04-23 21:12:42 +00:00
|
|
|
return nil, nil
|
|
|
|
}
|
|
|
|
|
2020-07-01 11:47:40 +00:00
|
|
|
spt, err := ffiwrapper.SealProofTypeFromSectorSize(info.SectorSize)
|
2020-04-17 14:47:19 +00:00
|
|
|
if err != nil {
|
|
|
|
return nil, xerrors.Errorf("getting seal proof type: %w", err)
|
|
|
|
}
|
|
|
|
|
|
|
|
wpt, err := spt.RegisteredWinningPoStProof()
|
|
|
|
if err != nil {
|
|
|
|
return nil, xerrors.Errorf("getting window proof type: %w", err)
|
|
|
|
}
|
|
|
|
|
|
|
|
mid, err := address.IDFromAddress(maddr)
|
|
|
|
if err != nil {
|
|
|
|
return nil, xerrors.Errorf("getting miner ID: %w", err)
|
|
|
|
}
|
|
|
|
|
2020-07-01 04:57:49 +00:00
|
|
|
ids, err := pv.GenerateWinningPoStSectorChallenge(ctx, wpt, abi.ActorID(mid), rand, numProvSect)
|
2020-04-17 14:47:19 +00:00
|
|
|
if err != nil {
|
|
|
|
return nil, xerrors.Errorf("generating winning post challenges: %w", err)
|
|
|
|
}
|
|
|
|
|
2020-07-01 04:57:49 +00:00
|
|
|
sectors, err := provingSectors.All(miner.SectorsMax)
|
|
|
|
if err != nil {
|
|
|
|
return nil, xerrors.Errorf("failed to enumerate all sector IDs: %w", err)
|
|
|
|
}
|
|
|
|
|
2020-07-23 00:14:54 +00:00
|
|
|
sectorAmt, err := adt.AsArray(sm.cs.Store(ctx), mas.Sectors)
|
2020-07-01 04:57:49 +00:00
|
|
|
if err != nil {
|
|
|
|
return nil, xerrors.Errorf("failed to load sectors amt: %w", err)
|
|
|
|
}
|
|
|
|
|
2020-09-07 03:49:10 +00:00
|
|
|
out := make([]proof.SectorInfo, len(ids))
|
2020-04-17 14:47:19 +00:00
|
|
|
for i, n := range ids {
|
2020-07-01 04:57:49 +00:00
|
|
|
sid := sectors[n]
|
|
|
|
|
|
|
|
var sinfo miner.SectorOnChainInfo
|
2020-07-23 00:14:54 +00:00
|
|
|
if found, err := sectorAmt.Get(sid, &sinfo); err != nil {
|
2020-07-01 04:57:49 +00:00
|
|
|
return nil, xerrors.Errorf("failed to get sector %d: %w", sid, err)
|
2020-07-23 00:14:54 +00:00
|
|
|
} else if !found {
|
|
|
|
return nil, xerrors.Errorf("failed to find sector %d", sid)
|
2020-07-01 04:57:49 +00:00
|
|
|
}
|
|
|
|
|
2020-09-07 03:49:10 +00:00
|
|
|
out[i] = proof.SectorInfo{
|
2020-06-15 16:30:49 +00:00
|
|
|
SealProof: spt,
|
2020-07-01 09:22:57 +00:00
|
|
|
SectorNumber: sinfo.SectorNumber,
|
|
|
|
SealedCID: sinfo.SealedCID,
|
2020-04-17 14:47:19 +00:00
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
return out, nil
|
2020-04-17 05:39:55 +00:00
|
|
|
}
|
|
|
|
|
2020-07-01 11:47:40 +00:00
|
|
|
func StateMinerInfo(ctx context.Context, sm *StateManager, ts *types.TipSet, maddr address.Address) (*miner.MinerInfo, error) {
|
2020-04-16 17:36:36 +00:00
|
|
|
var mas miner.State
|
|
|
|
_, err := sm.LoadActorStateRaw(ctx, maddr, &mas, ts.ParentState())
|
|
|
|
if err != nil {
|
2020-07-01 11:47:40 +00:00
|
|
|
return nil, xerrors.Errorf("(get ssize) failed to load miner actor state: %w", err)
|
2020-04-16 17:36:36 +00:00
|
|
|
}
|
|
|
|
|
2020-07-01 11:47:40 +00:00
|
|
|
return mas.GetInfo(sm.cs.Store(ctx))
|
2020-04-02 01:25:58 +00:00
|
|
|
}
|
|
|
|
|
2020-03-02 01:09:38 +00:00
|
|
|
func GetMinerSlashed(ctx context.Context, sm *StateManager, ts *types.TipSet, maddr address.Address) (bool, error) {
|
|
|
|
var spas power.State
|
2020-08-17 13:32:47 +00:00
|
|
|
_, err := sm.LoadActorState(ctx, builtin.StoragePowerActorAddr, &spas, ts)
|
2020-03-02 01:09:38 +00:00
|
|
|
if err != nil {
|
|
|
|
return false, xerrors.Errorf("(get miner slashed) failed to load power actor state")
|
|
|
|
}
|
|
|
|
|
|
|
|
store := sm.cs.Store(ctx)
|
2020-04-13 21:05:34 +00:00
|
|
|
|
2020-04-21 14:32:17 +00:00
|
|
|
claims, err := adt.AsMap(store, spas.Claims)
|
|
|
|
if err != nil {
|
|
|
|
return false, err
|
2020-03-02 01:09:38 +00:00
|
|
|
}
|
2020-04-16 20:52:40 +00:00
|
|
|
|
2020-04-21 14:32:17 +00:00
|
|
|
ok, err := claims.Get(power.AddrKey(maddr), nil)
|
|
|
|
if err != nil {
|
|
|
|
return false, err
|
|
|
|
}
|
|
|
|
if !ok {
|
|
|
|
return true, nil
|
2020-03-02 01:09:38 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
return false, nil
|
2019-11-15 01:01:53 +00:00
|
|
|
}
|
|
|
|
|
2020-06-02 14:29:39 +00:00
|
|
|
func GetStorageDeal(ctx context.Context, sm *StateManager, dealID abi.DealID, ts *types.TipSet) (*api.MarketDeal, error) {
|
2020-02-23 15:50:36 +00:00
|
|
|
var state market.State
|
2020-02-25 20:54:58 +00:00
|
|
|
if _, err := sm.LoadActorState(ctx, builtin.StorageMarketActorAddr, &state, ts); err != nil {
|
2019-11-07 07:57:10 +00:00
|
|
|
return nil, err
|
|
|
|
}
|
2020-07-23 00:14:54 +00:00
|
|
|
store := sm.ChainStore().Store(ctx)
|
2019-11-07 07:57:10 +00:00
|
|
|
|
2020-07-23 00:14:54 +00:00
|
|
|
da, err := adt.AsArray(store, state.Proposals)
|
2019-11-07 07:57:10 +00:00
|
|
|
if err != nil {
|
|
|
|
return nil, err
|
|
|
|
}
|
|
|
|
|
2020-02-09 06:06:32 +00:00
|
|
|
var dp market.DealProposal
|
2020-07-23 00:14:54 +00:00
|
|
|
if found, err := da.Get(uint64(dealID), &dp); err != nil {
|
2019-11-07 07:57:10 +00:00
|
|
|
return nil, err
|
2020-07-23 00:14:54 +00:00
|
|
|
} else if !found {
|
|
|
|
return nil, xerrors.Errorf("deal %d not found", dealID)
|
2019-11-07 07:57:10 +00:00
|
|
|
}
|
|
|
|
|
2020-07-23 00:14:54 +00:00
|
|
|
sa, err := market.AsDealStateArray(store, state.States)
|
2020-04-13 21:05:34 +00:00
|
|
|
if err != nil {
|
|
|
|
return nil, err
|
|
|
|
}
|
|
|
|
|
2020-06-02 14:29:39 +00:00
|
|
|
st, found, err := sa.Get(dealID)
|
2020-02-09 06:06:32 +00:00
|
|
|
if err != nil {
|
|
|
|
return nil, err
|
|
|
|
}
|
|
|
|
|
2020-05-06 00:04:25 +00:00
|
|
|
if !found {
|
|
|
|
st = &market.DealState{
|
|
|
|
SectorStartEpoch: -1,
|
|
|
|
LastUpdatedEpoch: -1,
|
|
|
|
SlashEpoch: -1,
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2020-02-09 06:06:32 +00:00
|
|
|
return &api.MarketDeal{
|
|
|
|
Proposal: dp,
|
2020-02-23 15:50:36 +00:00
|
|
|
State: *st,
|
2020-02-09 06:06:32 +00:00
|
|
|
}, nil
|
2019-11-07 07:57:10 +00:00
|
|
|
}
|
|
|
|
|
2019-12-17 06:51:41 +00:00
|
|
|
func ListMinerActors(ctx context.Context, sm *StateManager, ts *types.TipSet) ([]address.Address, error) {
|
2020-02-25 20:35:15 +00:00
|
|
|
var state power.State
|
2020-02-25 20:54:58 +00:00
|
|
|
if _, err := sm.LoadActorState(ctx, builtin.StoragePowerActorAddr, &state, ts); err != nil {
|
2019-12-17 06:51:41 +00:00
|
|
|
return nil, err
|
|
|
|
}
|
|
|
|
|
2020-04-13 21:05:34 +00:00
|
|
|
m, err := adt.AsMap(sm.cs.Store(ctx), state.Claims)
|
|
|
|
if err != nil {
|
|
|
|
return nil, err
|
|
|
|
}
|
|
|
|
|
2020-02-11 02:33:27 +00:00
|
|
|
var miners []address.Address
|
2020-04-13 21:05:34 +00:00
|
|
|
err = m.ForEach(nil, func(k string) error {
|
2020-02-11 02:33:27 +00:00
|
|
|
a, err := address.NewFromBytes([]byte(k))
|
|
|
|
if err != nil {
|
|
|
|
return err
|
|
|
|
}
|
|
|
|
miners = append(miners, a)
|
|
|
|
return nil
|
|
|
|
})
|
2019-12-17 06:51:41 +00:00
|
|
|
if err != nil {
|
|
|
|
return nil, err
|
|
|
|
}
|
|
|
|
|
|
|
|
return miners, nil
|
|
|
|
}
|
|
|
|
|
2020-09-07 03:49:10 +00:00
|
|
|
func LoadSectorsFromSet(ctx context.Context, bs blockstore.Blockstore, ssc cid.Cid, filter *bitfield.BitField, filterOut bool) ([]*api.ChainSectorInfo, error) {
|
2020-07-23 00:14:54 +00:00
|
|
|
a, err := adt.AsArray(store.ActorStore(ctx, bs), ssc)
|
2019-09-17 22:43:47 +00:00
|
|
|
if err != nil {
|
|
|
|
return nil, err
|
|
|
|
}
|
|
|
|
|
2019-11-08 18:15:13 +00:00
|
|
|
var sset []*api.ChainSectorInfo
|
2020-07-23 00:14:54 +00:00
|
|
|
var v cbg.Deferred
|
|
|
|
if err := a.ForEach(&v, func(i int64) error {
|
2020-04-15 19:59:11 +00:00
|
|
|
if filter != nil {
|
2020-07-23 00:14:54 +00:00
|
|
|
set, err := filter.IsSet(uint64(i))
|
2020-04-15 19:59:11 +00:00
|
|
|
if err != nil {
|
|
|
|
return xerrors.Errorf("filter check error: %w", err)
|
|
|
|
}
|
2020-04-21 17:22:53 +00:00
|
|
|
if set == filterOut {
|
2020-04-15 19:59:11 +00:00
|
|
|
return nil
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2020-02-19 19:26:11 +00:00
|
|
|
var oci miner.SectorOnChainInfo
|
|
|
|
if err := cbor.DecodeInto(v.Raw, &oci); err != nil {
|
2019-09-17 22:43:47 +00:00
|
|
|
return err
|
|
|
|
}
|
2019-11-08 18:15:13 +00:00
|
|
|
sset = append(sset, &api.ChainSectorInfo{
|
2020-02-19 20:34:21 +00:00
|
|
|
Info: oci,
|
2020-02-21 19:28:20 +00:00
|
|
|
ID: abi.SectorNumber(i),
|
2019-09-17 22:43:47 +00:00
|
|
|
})
|
|
|
|
return nil
|
|
|
|
}); err != nil {
|
|
|
|
return nil, err
|
|
|
|
}
|
|
|
|
|
|
|
|
return sset, nil
|
|
|
|
}
|
2020-01-17 02:33:43 +00:00
|
|
|
|
2020-03-08 02:31:36 +00:00
|
|
|
func ComputeState(ctx context.Context, sm *StateManager, height abi.ChainEpoch, msgs []*types.Message, ts *types.TipSet) (cid.Cid, []*api.InvocResult, error) {
|
2020-01-17 02:33:43 +00:00
|
|
|
if ts == nil {
|
|
|
|
ts = sm.cs.GetHeaviestTipSet()
|
|
|
|
}
|
|
|
|
|
2020-03-08 02:31:36 +00:00
|
|
|
base, trace, err := sm.ExecutionTrace(ctx, ts)
|
2020-01-17 02:33:43 +00:00
|
|
|
if err != nil {
|
2020-03-08 02:31:36 +00:00
|
|
|
return cid.Undef, nil, err
|
2020-01-17 02:33:43 +00:00
|
|
|
}
|
|
|
|
|
2020-09-01 19:48:16 +00:00
|
|
|
r := store.NewChainRand(sm.cs, ts.Cids())
|
2020-08-06 17:09:03 +00:00
|
|
|
vmopt := &vm.VMOpts{
|
2020-08-09 22:49:38 +00:00
|
|
|
StateBase: base,
|
|
|
|
Epoch: height,
|
|
|
|
Rand: r,
|
|
|
|
Bstore: sm.cs.Blockstore(),
|
|
|
|
Syscalls: sm.cs.VMSys(),
|
|
|
|
CircSupplyCalc: sm.GetCirculatingSupply,
|
2020-09-07 20:01:09 +00:00
|
|
|
NtwkVersion: sm.GetNtwkVersion,
|
2020-08-09 22:49:38 +00:00
|
|
|
BaseFee: ts.Blocks()[0].ParentBaseFee,
|
2020-08-06 17:09:03 +00:00
|
|
|
}
|
|
|
|
vmi, err := vm.NewVM(vmopt)
|
2020-01-17 02:33:43 +00:00
|
|
|
if err != nil {
|
2020-03-08 02:31:36 +00:00
|
|
|
return cid.Undef, nil, err
|
2020-01-17 02:33:43 +00:00
|
|
|
}
|
|
|
|
|
2020-07-28 12:31:13 +00:00
|
|
|
for i := ts.Height(); i < height; i++ {
|
|
|
|
// handle state forks
|
2020-09-08 20:45:44 +00:00
|
|
|
err = sm.handleStateForks(ctx, vmi.StateTree(), i, ts)
|
2020-07-28 12:31:13 +00:00
|
|
|
if err != nil {
|
|
|
|
return cid.Undef, nil, xerrors.Errorf("error handling state forks: %w", err)
|
|
|
|
}
|
|
|
|
|
|
|
|
// TODO: should we also run cron here?
|
2020-01-17 02:33:43 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
for i, msg := range msgs {
|
2020-03-25 11:29:35 +00:00
|
|
|
// TODO: Use the signed message length for secp messages
|
2020-03-25 19:13:09 +00:00
|
|
|
ret, err := vmi.ApplyMessage(ctx, msg)
|
2020-01-17 02:33:43 +00:00
|
|
|
if err != nil {
|
2020-03-08 02:31:36 +00:00
|
|
|
return cid.Undef, nil, xerrors.Errorf("applying message %s: %w", msg.Cid(), err)
|
2020-01-17 02:33:43 +00:00
|
|
|
}
|
|
|
|
if ret.ExitCode != 0 {
|
2020-01-17 06:14:00 +00:00
|
|
|
log.Infof("compute state apply message %d failed (exit: %d): %s", i, ret.ExitCode, ret.ActorErr)
|
2020-01-17 02:33:43 +00:00
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2020-03-08 02:31:36 +00:00
|
|
|
root, err := vmi.Flush(ctx)
|
|
|
|
if err != nil {
|
|
|
|
return cid.Undef, nil, err
|
|
|
|
}
|
|
|
|
|
|
|
|
return root, trace, nil
|
2020-01-17 02:33:43 +00:00
|
|
|
}
|
2020-04-02 01:10:28 +00:00
|
|
|
|
2020-04-17 23:36:54 +00:00
|
|
|
func GetLookbackTipSetForRound(ctx context.Context, sm *StateManager, ts *types.TipSet, round abi.ChainEpoch) (*types.TipSet, error) {
|
|
|
|
var lbr abi.ChainEpoch
|
|
|
|
if round > build.WinningPoStSectorSetLookback {
|
|
|
|
lbr = round - build.WinningPoStSectorSetLookback
|
|
|
|
}
|
|
|
|
|
|
|
|
// more null blocks than our lookback
|
|
|
|
if lbr > ts.Height() {
|
|
|
|
return ts, nil
|
|
|
|
}
|
|
|
|
|
2020-05-05 17:06:05 +00:00
|
|
|
lbts, err := sm.ChainStore().GetTipsetByHeight(ctx, lbr, ts, true)
|
2020-04-17 23:36:54 +00:00
|
|
|
if err != nil {
|
|
|
|
return nil, xerrors.Errorf("failed to get lookback tipset: %w", err)
|
|
|
|
}
|
|
|
|
|
|
|
|
return lbts, nil
|
|
|
|
}
|
|
|
|
|
2020-09-08 20:28:06 +00:00
|
|
|
func MinerGetBaseInfo(ctx context.Context, sm *StateManager, bcs beacon.Schedule, tsk types.TipSetKey, round abi.ChainEpoch, maddr address.Address, pv ffiwrapper.Verifier) (*api.MiningBaseInfo, error) {
|
2020-04-02 01:10:28 +00:00
|
|
|
ts, err := sm.ChainStore().LoadTipSet(tsk)
|
|
|
|
if err != nil {
|
|
|
|
return nil, xerrors.Errorf("failed to load tipset for mining base: %w", err)
|
|
|
|
}
|
|
|
|
|
2020-04-30 22:11:14 +00:00
|
|
|
prev, err := sm.ChainStore().GetLatestBeaconEntry(ts)
|
|
|
|
if err != nil {
|
|
|
|
if os.Getenv("LOTUS_IGNORE_DRAND") != "_yes_" {
|
|
|
|
return nil, xerrors.Errorf("failed to get latest beacon entry: %w", err)
|
|
|
|
}
|
|
|
|
|
|
|
|
prev = &types.BeaconEntry{}
|
|
|
|
}
|
|
|
|
|
2020-09-08 20:28:06 +00:00
|
|
|
entries, err := beacon.BeaconEntriesForBlock(ctx, bcs, round, ts.Height(), *prev)
|
2020-04-30 22:11:14 +00:00
|
|
|
if err != nil {
|
|
|
|
return nil, err
|
|
|
|
}
|
|
|
|
|
|
|
|
rbase := *prev
|
|
|
|
if len(entries) > 0 {
|
|
|
|
rbase = entries[len(entries)-1]
|
|
|
|
}
|
|
|
|
|
2020-04-17 23:36:54 +00:00
|
|
|
lbts, err := GetLookbackTipSetForRound(ctx, sm, ts, round)
|
|
|
|
if err != nil {
|
|
|
|
return nil, xerrors.Errorf("getting lookback miner actor state: %w", err)
|
|
|
|
}
|
|
|
|
|
|
|
|
lbst, _, err := sm.TipSetState(ctx, lbts)
|
2020-04-02 01:10:28 +00:00
|
|
|
if err != nil {
|
|
|
|
return nil, err
|
|
|
|
}
|
|
|
|
|
2020-04-15 19:59:11 +00:00
|
|
|
var mas miner.State
|
2020-04-17 23:36:54 +00:00
|
|
|
if _, err := sm.LoadActorStateRaw(ctx, maddr, &mas, lbst); err != nil {
|
|
|
|
return nil, err
|
|
|
|
}
|
|
|
|
|
2020-04-30 22:11:14 +00:00
|
|
|
buf := new(bytes.Buffer)
|
|
|
|
if err := maddr.MarshalCBOR(buf); err != nil {
|
|
|
|
return nil, xerrors.Errorf("failed to marshal miner address: %w", err)
|
|
|
|
}
|
|
|
|
|
2020-05-01 19:42:59 +00:00
|
|
|
prand, err := store.DrawRandomness(rbase.Data, crypto.DomainSeparationTag_WinningPoStChallengeSeed, round, buf.Bytes())
|
2020-04-02 01:10:28 +00:00
|
|
|
if err != nil {
|
2020-04-17 23:36:54 +00:00
|
|
|
return nil, xerrors.Errorf("failed to get randomness for winning post: %w", err)
|
2020-04-02 01:10:28 +00:00
|
|
|
}
|
|
|
|
|
2020-04-17 23:36:54 +00:00
|
|
|
sectors, err := GetSectorsForWinningPoSt(ctx, pv, sm, lbst, maddr, prand)
|
2020-04-02 01:10:28 +00:00
|
|
|
if err != nil {
|
2020-04-17 23:36:54 +00:00
|
|
|
return nil, xerrors.Errorf("getting wpost proving set: %w", err)
|
2020-04-02 01:10:28 +00:00
|
|
|
}
|
|
|
|
|
2020-04-23 21:12:42 +00:00
|
|
|
if len(sectors) == 0 {
|
|
|
|
return nil, nil
|
|
|
|
}
|
|
|
|
|
2020-04-17 23:36:54 +00:00
|
|
|
mpow, tpow, err := GetPowerRaw(ctx, sm, lbst, maddr)
|
2020-04-02 01:10:28 +00:00
|
|
|
if err != nil {
|
2020-04-15 19:59:11 +00:00
|
|
|
return nil, xerrors.Errorf("failed to get power: %w", err)
|
2020-04-02 01:10:28 +00:00
|
|
|
}
|
|
|
|
|
2020-07-01 11:47:40 +00:00
|
|
|
info, err := mas.GetInfo(sm.cs.Store(ctx))
|
|
|
|
if err != nil {
|
|
|
|
return nil, err
|
|
|
|
}
|
|
|
|
|
|
|
|
worker, err := sm.ResolveToKeyAddress(ctx, info.Worker, ts)
|
2020-04-16 17:17:56 +00:00
|
|
|
if err != nil {
|
|
|
|
return nil, xerrors.Errorf("resolving worker address: %w", err)
|
|
|
|
}
|
|
|
|
|
2020-07-27 23:51:30 +00:00
|
|
|
hmp, err := MinerHasMinPower(ctx, sm, maddr, lbts)
|
|
|
|
if err != nil {
|
|
|
|
return nil, xerrors.Errorf("determining if miner has min power failed: %w", err)
|
|
|
|
}
|
|
|
|
|
2020-04-02 01:10:28 +00:00
|
|
|
return &api.MiningBaseInfo{
|
2020-04-17 22:02:04 +00:00
|
|
|
MinerPower: mpow.QualityAdjPower,
|
|
|
|
NetworkPower: tpow.QualityAdjPower,
|
2020-04-17 23:36:54 +00:00
|
|
|
Sectors: sectors,
|
2020-04-16 17:17:56 +00:00
|
|
|
WorkerKey: worker,
|
2020-07-01 11:47:40 +00:00
|
|
|
SectorSize: info.SectorSize,
|
2020-04-09 17:13:09 +00:00
|
|
|
PrevBeaconEntry: *prev,
|
2020-04-30 22:11:14 +00:00
|
|
|
BeaconEntries: entries,
|
2020-07-27 23:51:30 +00:00
|
|
|
HasMinPower: hmp,
|
2020-04-02 01:10:28 +00:00
|
|
|
}, nil
|
|
|
|
}
|
2020-06-26 13:49:39 +00:00
|
|
|
|
2020-09-04 03:28:42 +00:00
|
|
|
type MethodMeta struct {
|
2020-07-03 16:57:58 +00:00
|
|
|
Name string
|
|
|
|
|
|
|
|
Params reflect.Type
|
|
|
|
Ret reflect.Type
|
|
|
|
}
|
|
|
|
|
2020-09-04 03:28:42 +00:00
|
|
|
var MethodsMap = map[cid.Cid]map[abi.MethodNum]MethodMeta{}
|
2020-07-03 16:57:58 +00:00
|
|
|
|
|
|
|
func init() {
|
|
|
|
cidToMethods := map[cid.Cid][2]interface{}{
|
|
|
|
// builtin.SystemActorCodeID: {builtin.MethodsSystem, system.Actor{} }- apparently it doesn't have methods
|
|
|
|
builtin.InitActorCodeID: {builtin.MethodsInit, init_.Actor{}},
|
|
|
|
builtin.CronActorCodeID: {builtin.MethodsCron, cron.Actor{}},
|
|
|
|
builtin.AccountActorCodeID: {builtin.MethodsAccount, account.Actor{}},
|
|
|
|
builtin.StoragePowerActorCodeID: {builtin.MethodsPower, power.Actor{}},
|
|
|
|
builtin.StorageMinerActorCodeID: {builtin.MethodsMiner, miner.Actor{}},
|
|
|
|
builtin.StorageMarketActorCodeID: {builtin.MethodsMarket, market.Actor{}},
|
|
|
|
builtin.PaymentChannelActorCodeID: {builtin.MethodsPaych, paych.Actor{}},
|
|
|
|
builtin.MultisigActorCodeID: {builtin.MethodsMultisig, multisig.Actor{}},
|
|
|
|
builtin.RewardActorCodeID: {builtin.MethodsReward, reward.Actor{}},
|
|
|
|
builtin.VerifiedRegistryActorCodeID: {builtin.MethodsVerifiedRegistry, verifreg.Actor{}},
|
|
|
|
}
|
|
|
|
|
|
|
|
for c, m := range cidToMethods {
|
2020-09-07 03:49:10 +00:00
|
|
|
exports := m[1].(saruntime.Invokee).Exports()
|
2020-09-04 03:28:42 +00:00
|
|
|
methods := make(map[abi.MethodNum]MethodMeta, len(exports))
|
2020-07-03 16:57:58 +00:00
|
|
|
|
2020-09-04 03:28:42 +00:00
|
|
|
// Explicitly add send, it's special.
|
|
|
|
methods[builtin.MethodSend] = MethodMeta{
|
2020-07-03 16:57:58 +00:00
|
|
|
Name: "Send",
|
2020-09-10 06:21:38 +00:00
|
|
|
Params: reflect.TypeOf(new(abi.EmptyValue)),
|
|
|
|
Ret: reflect.TypeOf(new(abi.EmptyValue)),
|
2020-09-04 03:28:42 +00:00
|
|
|
}
|
2020-07-03 16:57:58 +00:00
|
|
|
|
2020-09-04 03:28:42 +00:00
|
|
|
// Learn method names from the builtin.Methods* structs.
|
|
|
|
rv := reflect.ValueOf(m[0])
|
|
|
|
rt := rv.Type()
|
|
|
|
nf := rt.NumField()
|
|
|
|
methodToName := make([]string, len(exports))
|
2020-07-03 16:57:58 +00:00
|
|
|
for i := 0; i < nf; i++ {
|
2020-09-04 03:28:42 +00:00
|
|
|
name := rt.Field(i).Name
|
|
|
|
number := rv.Field(i).Interface().(abi.MethodNum)
|
|
|
|
methodToName[number] = name
|
|
|
|
}
|
2020-07-03 16:57:58 +00:00
|
|
|
|
2020-09-04 03:28:42 +00:00
|
|
|
// Iterate over exported methods. Some of these _may_ be nil and
|
|
|
|
// must be skipped.
|
|
|
|
for number, export := range exports {
|
|
|
|
if export == nil {
|
|
|
|
continue
|
|
|
|
}
|
|
|
|
|
|
|
|
ev := reflect.ValueOf(export)
|
|
|
|
et := ev.Type()
|
|
|
|
|
|
|
|
// Make sure the method name is correct.
|
|
|
|
// This is just a nice sanity check.
|
|
|
|
fnName := runtime.FuncForPC(ev.Pointer()).Name()
|
|
|
|
fnName = strings.TrimSuffix(fnName[strings.LastIndexByte(fnName, '.')+1:], "-fm")
|
|
|
|
mName := methodToName[number]
|
|
|
|
if mName != fnName {
|
|
|
|
panic(fmt.Sprintf(
|
|
|
|
"actor method name is %s but exported method name is %s",
|
|
|
|
fnName, mName,
|
|
|
|
))
|
|
|
|
}
|
|
|
|
|
|
|
|
switch abi.MethodNum(number) {
|
|
|
|
case builtin.MethodSend:
|
|
|
|
panic("method 0 is reserved for Send")
|
|
|
|
case builtin.MethodConstructor:
|
|
|
|
if fnName != "Constructor" {
|
|
|
|
panic("method 1 is reserved for Constructor")
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
methods[abi.MethodNum(number)] = MethodMeta{
|
|
|
|
Name: fnName,
|
|
|
|
Params: et.In(1),
|
|
|
|
Ret: et.Out(0),
|
|
|
|
}
|
2020-07-03 16:57:58 +00:00
|
|
|
}
|
2020-09-04 03:28:42 +00:00
|
|
|
MethodsMap[c] = methods
|
2020-07-03 16:57:58 +00:00
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
func GetReturnType(ctx context.Context, sm *StateManager, to address.Address, method abi.MethodNum, ts *types.TipSet) (cbg.CBORUnmarshaler, error) {
|
2020-07-14 11:45:45 +00:00
|
|
|
var act types.Actor
|
|
|
|
if err := sm.WithParentState(ts, sm.WithActor(to, GetActor(&act))); err != nil {
|
|
|
|
return nil, xerrors.Errorf("getting actor: %w", err)
|
2020-07-03 16:57:58 +00:00
|
|
|
}
|
|
|
|
|
2020-09-04 03:28:42 +00:00
|
|
|
m, found := MethodsMap[act.Code][method]
|
|
|
|
if !found {
|
|
|
|
return nil, fmt.Errorf("unknown method %d for actor %s", method, act.Code)
|
|
|
|
}
|
2020-07-03 16:57:58 +00:00
|
|
|
return reflect.New(m.Ret.Elem()).Interface().(cbg.CBORUnmarshaler), nil
|
|
|
|
}
|
2020-07-27 23:51:30 +00:00
|
|
|
|
|
|
|
func MinerHasMinPower(ctx context.Context, sm *StateManager, addr address.Address, ts *types.TipSet) (bool, error) {
|
2020-09-14 12:17:45 +00:00
|
|
|
pact, err := sm.LoadActor(ctx, builtin.StoragePowerActorAddr, ts)
|
2020-07-27 23:51:30 +00:00
|
|
|
if err != nil {
|
|
|
|
return false, xerrors.Errorf("loading power actor state: %w", err)
|
|
|
|
}
|
|
|
|
|
2020-09-14 12:17:45 +00:00
|
|
|
ps, err := power2.Load(sm.cs.Store(ctx), pact)
|
|
|
|
if err != nil {
|
|
|
|
return false, err
|
|
|
|
}
|
|
|
|
|
2020-07-27 23:51:30 +00:00
|
|
|
return ps.MinerNominalPowerMeetsConsensusMinimum(sm.ChainStore().Store(ctx), addr)
|
|
|
|
}
|
2020-08-12 22:20:32 +00:00
|
|
|
|
|
|
|
func CheckTotalFIL(ctx context.Context, sm *StateManager, ts *types.TipSet) (abi.TokenAmount, error) {
|
2020-09-14 12:17:45 +00:00
|
|
|
str, err := state.LoadStateTree(sm.ChainStore().Store(ctx), ts.ParentState(), sm.GetNtwkVersion(ctx, ts.Height()))
|
2020-08-12 22:20:32 +00:00
|
|
|
if err != nil {
|
|
|
|
return abi.TokenAmount{}, err
|
|
|
|
}
|
|
|
|
|
|
|
|
sum := types.NewInt(0)
|
|
|
|
err = str.ForEach(func(a address.Address, act *types.Actor) error {
|
|
|
|
sum = types.BigAdd(sum, act.Balance)
|
|
|
|
return nil
|
|
|
|
})
|
|
|
|
if err != nil {
|
|
|
|
return abi.TokenAmount{}, err
|
|
|
|
}
|
|
|
|
|
|
|
|
return sum, nil
|
|
|
|
}
|