chore: fix typos
This commit is contained in:
parent
81e65dba56
commit
0b2613ec21
@ -841,7 +841,7 @@ func (b *CommitBatcher) getCommitCutoff(si SectorInfo) (time.Time, error) {
|
|||||||
}
|
}
|
||||||
av, err := actorstypes.VersionForNetwork(nv)
|
av, err := actorstypes.VersionForNetwork(nv)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
log.Errorf("unsupported network vrsion: %s", err)
|
log.Errorf("unsupported network version: %s", err)
|
||||||
return time.Now(), err
|
return time.Now(), err
|
||||||
}
|
}
|
||||||
mpcd, err := policy.GetMaxProveCommitDuration(av, si.SectorType)
|
mpcd, err := policy.GetMaxProveCommitDuration(av, si.SectorType)
|
||||||
|
@ -64,7 +64,7 @@ func writeTrailer(maxPieceSize int64, w *os.File, r rlepluslazy.RunIterator) err
|
|||||||
func CreatePartialFile(maxPieceSize abi.PaddedPieceSize, path string) (*PartialFile, error) {
|
func CreatePartialFile(maxPieceSize abi.PaddedPieceSize, path string) (*PartialFile, error) {
|
||||||
f, err := os.OpenFile(path, os.O_RDWR|os.O_CREATE, 0644) // nolint
|
f, err := os.OpenFile(path, os.O_RDWR|os.O_CREATE, 0644) // nolint
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, xerrors.Errorf("openning partial file '%s': %w", path, err)
|
return nil, xerrors.Errorf("opening partial file '%s': %w", path, err)
|
||||||
}
|
}
|
||||||
|
|
||||||
err = func() error {
|
err = func() error {
|
||||||
@ -99,7 +99,7 @@ func CreatePartialFile(maxPieceSize abi.PaddedPieceSize, path string) (*PartialF
|
|||||||
func OpenPartialFile(maxPieceSize abi.PaddedPieceSize, path string) (*PartialFile, error) {
|
func OpenPartialFile(maxPieceSize abi.PaddedPieceSize, path string) (*PartialFile, error) {
|
||||||
f, err := os.OpenFile(path, os.O_RDWR, 0644) // nolint
|
f, err := os.OpenFile(path, os.O_RDWR, 0644) // nolint
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, xerrors.Errorf("openning partial file '%s': %w", path, err)
|
return nil, xerrors.Errorf("opening partial file '%s': %w", path, err)
|
||||||
}
|
}
|
||||||
|
|
||||||
st, err := f.Stat()
|
st, err := f.Stat()
|
||||||
|
@ -137,7 +137,7 @@ func (sw *schedWorker) handleWorker() {
|
|||||||
}
|
}
|
||||||
|
|
||||||
// wait for more tasks to be assigned by the main scheduler or for the worker
|
// wait for more tasks to be assigned by the main scheduler or for the worker
|
||||||
// to finish precessing a task
|
// to finish processing a task
|
||||||
update, pokeSched, ok := sw.waitForUpdates()
|
update, pokeSched, ok := sw.waitForUpdates()
|
||||||
if !ok {
|
if !ok {
|
||||||
return
|
return
|
||||||
|
Loading…
Reference in New Issue
Block a user