Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Corrected typos #282

Open
wants to merge 3 commits into
base: main
Choose a base branch
from
Open
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 test/cfx_validate.go
Original file line number Diff line number Diff line change
Expand Up @@ -172,7 +172,7 @@ func (validator *EpochValidator) Run(ctx context.Context, wg *sync.WaitGroup) {
})

// Randomly sampling nearhead epoch for validation. Nearhead epochs are very likely to be reverted
// due to pivot switch, it's acceptable to just trigger a warnning once the validation failed.
// due to pivot switch, it's acceptable to just trigger a warning once the validation failed.
samplingTicker := time.NewTicker(validator.conf.SamplingInterval)
defer samplingTicker.Stop()

Expand Down
8 changes: 4 additions & 4 deletions test/eth_validate.go
Original file line number Diff line number Diff line change
Expand Up @@ -127,7 +127,7 @@ func (validator *EthValidator) Run(ctx context.Context, wg *sync.WaitGroup) {
samplingTicker := time.NewTicker(validator.conf.SamplingInterval)
defer samplingTicker.Stop()

// Sequentially scaning blocks from specified blocks to latest block.
// Sequentially scanning blocks from specified blocks to latest block.
scanTicker := time.NewTicker(validator.conf.ScanInterval)
defer scanTicker.Stop()

Expand Down Expand Up @@ -221,7 +221,7 @@ func (validator *EthValidator) doScanning(ticker *time.Ticker) error {
logrus.WithField("blockRange", citypes.RangeUint64{
From: validator.conf.ScanFromBlock,
To: maxBlockTo,
}).Debug("ETH validator scaning skipped due to catched up already")
}).Debug("ETH validator scanning skipped due to catched up already")

return nil
}
Expand All @@ -234,7 +234,7 @@ func (validator *EthValidator) doScanning(ticker *time.Ticker) error {

validator.conf.ScanFromBlock++

// periodly save the scaning progress per 1000 blocks in case of data lost
// periodly save the scanning progress per 1000 blocks in case of data lost
if validator.conf.ScanFromBlock%1000 == 0 {
validator.saveScanCursor()
}
Expand Down Expand Up @@ -676,6 +676,6 @@ func (validator *EthValidator) saveScanCursor() error {
}

func (validator *EthValidator) Destroy() {
// Save scaning cursor
// Save scanning cursor
validator.saveScanCursor()
}
4 changes: 2 additions & 2 deletions virtualfilter/worker.go
Original file line number Diff line number Diff line change
Expand Up @@ -67,7 +67,7 @@ type pollingObserver interface {
onClosed(nodeName string, fid rpc.ID) error
}

// filterWorker consistantly polls filter changes from full node and simulate
// filterWorker consistently polls filter changes from full node and simulate
// a virtual filter chain for late retrieval.
type filterWorker struct {
mu sync.Mutex
Expand Down Expand Up @@ -140,7 +140,7 @@ func (w *filterWorker) reject(f virtualFilter) (bool, error) {
return false, nil
}

// poll consistantly polls filter changes from full node and applies the polled data
// poll consistently polls filter changes from full node and applies the polled data
// to the current polling session.
func (w *filterWorker) poll() {
ticker := time.NewTicker(pollingInterval)
Expand Down