storiface

package
v1.1.3-pre2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 12, 2020 License: Apache-2.0, MIT Imports: 12 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	RWRetWait  = -1
	RWReturned = -2
	RWRetDone  = -3
)
View Source 
const FSOverheadDen = 10

Variables

View Source 
var ErrSectorNotFound = errors.New("sector not found")
View Source 
var FSOverheadSeal = map[SectorFileType]int{
	FTUnsealed: FSOverheadDen,
	FTSealed:   FSOverheadDen,
	FTCache:    141,
}
View Source 
var FsOverheadFinalized = map[SectorFileType]int{
	FTUnsealed: FSOverheadDen,
	FTSealed:   FSOverheadDen,
	FTCache:    2,
}
View Source 
var PathTypes = []SectorFileType{FTUnsealed, FTSealed, FTCache}

Functions

func ParseSectorID added in v1.1.3 

func ParseSectorID(baseName string) (abi.SectorID, error)

func PathByType added in v1.1.3 

func PathByType(sps SectorPaths, fileType SectorFileType) string

func SectorName added in v1.1.3 

func SectorName(sid abi.SectorID) string

func SetPathByType added in v1.1.3 

func SetPathByType(sps *SectorPaths, fileType SectorFileType, p string)

Types

type AcquireMode added in v1.1.3 

type AcquireMode string
const (
	AcquireMove AcquireMode = "move"
	AcquireCopy AcquireMode = "copy"
)

type CallID added in v1.1.3 

type CallID struct {
	Sector abi.SectorID
	ID     uuid.UUID
}
var UndefCall CallID

func (*CallID) MarshalCBOR added in v1.1.3 

func (t *CallID) MarshalCBOR(w io.Writer) error

func (CallID) String added in v1.1.3 

func (c CallID) String() string

func (*CallID) UnmarshalCBOR added in v1.1.3 

func (t *CallID) UnmarshalCBOR(r io.Reader) error

type PaddedByteIndex 

type PaddedByteIndex uint64

type PathType added in v1.1.3 

type PathType string
const (
	PathStorage PathType = "storage"
	PathSealing PathType = "sealing"
)

type SectorFileType added in v1.1.3 

type SectorFileType int
const (
	FTUnsealed SectorFileType = 1 << iota
	FTSealed
	FTCache

	FileTypes = iota
)
const (
	FTNone SectorFileType = 0
)

func (SectorFileType) All added in v1.1.3 

func (t SectorFileType) All() [FileTypes]bool

func (SectorFileType) Has added in v1.1.3 

func (t SectorFileType) Has(singleType SectorFileType) bool

func (SectorFileType) SealSpaceUse added in v1.1.3 

func (t SectorFileType) SealSpaceUse(ssize abi.SectorSize) (uint64, error)

func (SectorFileType) String added in v1.1.3 

func (t SectorFileType) String() string

type SectorPaths added in v1.1.3 

type SectorPaths struct {
	ID abi.SectorID

	Unsealed string
	Sealed   string
	Cache    string
}

type UnpaddedByteIndex 

type UnpaddedByteIndex uint64

func (UnpaddedByteIndex) Padded 

func (i UnpaddedByteIndex) Padded() PaddedByteIndex

type WorkerCalls added in v1.1.3 

type WorkerCalls interface {
	AddPiece(ctx context.Context, sector abi.SectorID, pieceSizes []abi.UnpaddedPieceSize, newPieceSize abi.UnpaddedPieceSize, pieceData storage.Data) (CallID, error)
	SealPreCommit1(ctx context.Context, sector abi.SectorID, ticket abi.SealRandomness, pieces []abi.PieceInfo) (CallID, error)
	SealPreCommit2(ctx context.Context, sector abi.SectorID, pc1o storage.PreCommit1Out) (CallID, error)
	SealCommit1(ctx context.Context, sector abi.SectorID, ticket abi.SealRandomness, seed abi.InteractiveSealRandomness, pieces []abi.PieceInfo, cids storage.SectorCids) (CallID, error)
	SealCommit2(ctx context.Context, sector abi.SectorID, c1o storage.Commit1Out) (CallID, error)
	FinalizeSector(ctx context.Context, sector abi.SectorID, keepUnsealed []storage.Range) (CallID, error)
	ReleaseUnsealed(ctx context.Context, sector abi.SectorID, safeToFree []storage.Range) (CallID, error)
	MoveStorage(ctx context.Context, sector abi.SectorID, types SectorFileType) (CallID, error)
	UnsealPiece(context.Context, abi.SectorID, UnpaddedByteIndex, abi.UnpaddedPieceSize, abi.SealRandomness, cid.Cid) (CallID, error)
	ReadPiece(context.Context, io.Writer, abi.SectorID, UnpaddedByteIndex, abi.UnpaddedPieceSize) (CallID, error)
	Fetch(context.Context, abi.SectorID, SectorFileType, PathType, AcquireMode) (CallID, error)
}

type WorkerInfo 

type WorkerInfo struct {
	Hostname string

	Resources WorkerResources
}

type WorkerJob 

type WorkerJob struct {
	ID     CallID
	Sector abi.SectorID
	Task   sealtasks.TaskType

	// 1+ - assigned
	// 0  - running
	// -1 - ret-wait
	// -2 - returned
	// -3 - ret-done
	RunWait int
	Start   time.Time

	Hostname string `json:",omitempty"` // optional, set for ret-wait jobs
}

type WorkerResources 

type WorkerResources struct {
	MemPhysical uint64
	MemSwap     uint64

	MemReserved uint64 // Used by system / other processes

	CPUs uint64 // Logical cores
	GPUs []string
}

type WorkerReturn added in v1.1.3 

type WorkerReturn interface {
	ReturnAddPiece(ctx context.Context, callID CallID, pi abi.PieceInfo, err string) error
	ReturnSealPreCommit1(ctx context.Context, callID CallID, p1o storage.PreCommit1Out, err string) error
	ReturnSealPreCommit2(ctx context.Context, callID CallID, sealed storage.SectorCids, err string) error
	ReturnSealCommit1(ctx context.Context, callID CallID, out storage.Commit1Out, err string) error
	ReturnSealCommit2(ctx context.Context, callID CallID, proof storage.Proof, err string) error
	ReturnFinalizeSector(ctx context.Context, callID CallID, err string) error
	ReturnReleaseUnsealed(ctx context.Context, callID CallID, err string) error
	ReturnMoveStorage(ctx context.Context, callID CallID, err string) error
	ReturnUnsealPiece(ctx context.Context, callID CallID, err string) error
	ReturnReadPiece(ctx context.Context, callID CallID, ok bool, err string) error
	ReturnFetch(ctx context.Context, callID CallID, err string) error
}

type WorkerStats 

type WorkerStats struct {
	Info    WorkerInfo
	Enabled bool

	MemUsedMin uint64
	MemUsedMax uint64
	GpuUsed    bool   // nolint
	CpuUse     uint64 // nolint
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.