mirror of
https://github.com/ethereum/go-ethereum.git
synced 2026-07-26 14:46:42 +00:00
FIX: Log info fix
This commit is contained in:
parent
3e10bd67ba
commit
8eb3d90346
1 changed files with 1 additions and 2 deletions
|
|
@ -267,8 +267,7 @@ func NewFirehose(config *FirehoseConfig) *Firehose {
|
||||||
}
|
}
|
||||||
|
|
||||||
if config.ConcurrentBlockFlushing > 0 {
|
if config.ConcurrentBlockFlushing > 0 {
|
||||||
log.Info("Firehose concurrent block flushing enabled, starting", config.ConcurrentBlockFlushing,
|
log.Info(fmt.Sprintf("Firehose concurrent block flushing enabled, starting %d worker goroutine", config.ConcurrentBlockFlushing))
|
||||||
"block print worker goroutine")
|
|
||||||
|
|
||||||
firehose.flushJobQueue = make(chan *blockPrintJob, firehose.flushBufferSize)
|
firehose.flushJobQueue = make(chan *blockPrintJob, firehose.flushBufferSize)
|
||||||
firehose.flushOrderedOutputQueue = make(chan *blockOutput, firehose.flushBufferSize)
|
firehose.flushOrderedOutputQueue = make(chan *blockOutput, firehose.flushBufferSize)
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue