scanner: reduce channel queue buffer length
To keep memory consumption down
This commit is contained in:
parent
a0859acad3
commit
3c220e56f6
|
@ -244,7 +244,7 @@ func (s *Scanner) Scan(startIndex int64, endIndex int64, processCert ProcessCall
|
||||||
*/
|
*/
|
||||||
|
|
||||||
// Start processor workers
|
// Start processor workers
|
||||||
jobs := make(chan ct.LogEntry, 100000)
|
jobs := make(chan ct.LogEntry, 100)
|
||||||
var processorWG sync.WaitGroup
|
var processorWG sync.WaitGroup
|
||||||
for w := 0; w < s.opts.NumWorkers; w++ {
|
for w := 0; w < s.opts.NumWorkers; w++ {
|
||||||
processorWG.Add(1)
|
processorWG.Add(1)
|
||||||
|
|
Loading…
Reference in New Issue