v1.27.0-a #10
@ -24,7 +24,7 @@ func NewWindow(capacity int, size time.Duration) *Window {
|
||||
}
|
||||
|
||||
// Add attempts to append a new timestamp into the current window. Previously
|
||||
// added values that are not not within `size` difference from the value being
|
||||
// added values that are not within `size` difference from the value being
|
||||
// added are first removed. Add fails if adding the value would cause the
|
||||
// window to exceed capacity.
|
||||
func (w *Window) Add() error {
|
||||
|
@ -57,7 +57,7 @@ func doExtractTipset(opts extractOpts) error {
|
||||
return err
|
||||
}
|
||||
|
||||
// are are squashing all tipsets into a single multi-tipset vector?
|
||||
// are squashing all tipsets into a single multi-tipset vector?
|
||||
if opts.squash {
|
||||
vector, err := extractTipsets(ctx, tss...)
|
||||
if err != nil {
|
||||
|
@ -53,7 +53,7 @@ func TestParitalConfig(t *testing.T) {
|
||||
f, err := os.CreateTemp("", "config-*.toml")
|
||||
fname := f.Name()
|
||||
|
||||
assert.NoError(err, "tmp file shold not error")
|
||||
assert.NoError(err, "tmp file should not error")
|
||||
_, err = f.WriteString(cfgString)
|
||||
assert.NoError(err, "writing to tmp file should not error")
|
||||
err = f.Close()
|
||||
|
@ -21,7 +21,7 @@ type mutator interface {
|
||||
|
||||
// globalMutator is an event which can apply in every state
|
||||
type globalMutator interface {
|
||||
// applyGlobal applies the event to the state. If if returns true,
|
||||
// applyGlobal applies the event to the state. If it returns true,
|
||||
// event processing should be interrupted
|
||||
applyGlobal(state *SectorInfo) bool
|
||||
}
|
||||
|
@ -91,7 +91,7 @@ type BufferedTipsetChannelApi interface {
|
||||
}
|
||||
|
||||
// BufferedTipsetChannel returns an unbuffered channel of tipsets. Buffering occurs internally to handle revert
|
||||
// ChainNotify changes. The returned channel can output tipsets at the same height twice if a reorg larger the the
|
||||
// ChainNotify changes. The returned channel can output tipsets at the same height twice if a reorg larger the
|
||||
// provided `size` occurs.
|
||||
func BufferedTipsetChannel(ctx context.Context, api BufferedTipsetChannelApi, lastHeight abi.ChainEpoch, size int) (<-chan *types.TipSet, error) {
|
||||
chmain := make(chan *types.TipSet)
|
||||
|
Loading…
Reference in New Issue
Block a user