Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion blockstore/splitstore/splitstore_compact.go
Original file line number Diff line number Diff line change
Expand Up @@ -457,7 +457,7 @@ func (s *SplitStore) doTxnProtect(root cid.Cid, markSet MarkSet) (int64, error)
return 0, err
}

// Note: cold objects are deleted heaviest first, so the consituents of an object
// Note: cold objects are deleted heaviest first, so the constituents of an object
// cannot be deleted before the object itself.
return s.walkObjectIncomplete(root, newTmpVisitor(),
func(c cid.Cid) error {
Expand Down
4 changes: 2 additions & 2 deletions blockstore/splitstore/splitstore_prune.go
Original file line number Diff line number Diff line change
Expand Up @@ -177,7 +177,7 @@ func (s *SplitStore) doPrune(curTs *types.TipSet, retainStateP func(int64) bool,
}

// 1. mark reachable objects by walking the chain from the current epoch; we keep all messages
// and chain headers; state and reciepts are retained only if it is within retention policy scope
// and chain headers; state and receipts are retained only if it is within retention policy scope
log.Info("marking reachable objects")
startMark := time.Now()

Expand Down Expand Up @@ -402,7 +402,7 @@ func (s *SplitStore) completePrune() error {
return nil
}

// like walkChain but peforms a deep walk, using parallel walking with walkObjectLax,
// like walkChain but performs a deep walk, using parallel walking with walkObjectLax,
// whereby all extant messages are retained and state roots are retained if they satisfy
// the given predicate.
// missing references are ignored, as we expect to have plenty for snapshot syncs.
Expand Down
2 changes: 1 addition & 1 deletion chain/events/observer.go
Original file line number Diff line number Diff line change
Expand Up @@ -185,7 +185,7 @@ func (o *observer) headChange(ctx context.Context, rev, app []*types.TipSet) err
// If we have more reverts, the next revert is the next head.
to = rev[i+1]
} else {
// At the end of the revert sequenece, we need to lookup the joint tipset
// At the end of the revert sequence, we need to lookup the joint tipset
// between the revert sequence and the apply sequence.
var err error
to, err = o.api.ChainGetTipSet(ctx, from.Parents())
Expand Down
2 changes: 1 addition & 1 deletion itests/worker_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -480,7 +480,7 @@ func TestSchedulerRemoveRequest(t *testing.T) {
err = miner.SealingRemoveRequest(ctx, b.SchedInfo.Requests[0].SchedId)
require.NoError(t, err)

// Dump the schduler again and compare the UUID if a request is present
// Dump the scheduler again and compare the UUID if a request is present
// If no request present then pass the test
a := miner.SchedInfo(ctx)

Expand Down
4 changes: 2 additions & 2 deletions storage/pipeline/precommit_policy.go
Original file line number Diff line number Diff line change
Expand Up @@ -132,11 +132,11 @@ func (p *BasicPreCommitPolicy) getCCSectorLifetime(nv network.Version) (abi.Chai
}

if minExpiration := policy.GetMinSectorExpiration(); ccLifetimeEpochs < minExpiration {
log.Warnf("value for CommittedCapacitySectorLiftime is too short, using default minimum (%d epochs)", minExpiration)
log.Warnf("value for CommittedCapacitySectorLifetime is too short, using default minimum (%d epochs)", minExpiration)
return minExpiration, nil
}
if ccLifetimeEpochs > maxCommitment {
log.Warnf("value for CommittedCapacitySectorLiftime is too long, using default maximum (%d epochs)", maxCommitment)
log.Warnf("value for CommittedCapacitySectorLifetime is too long, using default maximum (%d epochs)", maxCommitment)
return maxCommitment, nil
}

Expand Down