Skip to content

Commit

Permalink
lint
Browse files Browse the repository at this point in the history
  • Loading branch information
jimjbrettj committed Mar 21, 2024
1 parent fd3a222 commit d030b28
Showing 1 changed file with 7 additions and 2 deletions.
9 changes: 7 additions & 2 deletions dot/sync/chain_sync.go
Original file line number Diff line number Diff line change
Expand Up @@ -562,15 +562,20 @@ func (cs *chainSync) requestMaxBlocksFrom(bestBlockHeader *types.Header, origin
return nil
}

func (cs *chainSync) submitRequest(request *network.BlockRequestMessage, who *peer.ID, resultCh chan<- *syncTaskResult) error {
func (cs *chainSync) submitRequest(
request *network.BlockRequestMessage,
who *peer.ID,
resultCh chan<- *syncTaskResult,
) error {
if !cs.blockState.IsPaused() {
cs.workerPool.submitRequest(request, who, resultCh)
return nil
}
return errBlockStatePaused
}

func (cs *chainSync) submitRequests(requests []*network.BlockRequestMessage) (resultCh chan *syncTaskResult, err error) {
func (cs *chainSync) submitRequests(requests []*network.BlockRequestMessage) (
resultCh chan *syncTaskResult, err error) {
if !cs.blockState.IsPaused() {
return cs.workerPool.submitRequests(requests), nil
}
Expand Down

0 comments on commit d030b28

Please sign in to comment.