Commit d630e983 authored by Brian Tiger Chow's avatar Brian Tiger Chow

one worker

parent c68129e9
...@@ -114,32 +114,30 @@ func (w *Worker) start(c Config) { ...@@ -114,32 +114,30 @@ func (w *Worker) start(c Config) {
} }
}) })
for i := 0; i < c.NumWorkers; i++ { // reads from |workerChan| until process closes
// reads from |workerChan| until process closes w.process.Go(func(proc process.Process) {
w.process.Go(func(proc process.Process) { ctx, cancel := context.WithCancel(context.Background())
ctx, cancel := context.WithCancel(context.Background())
// shuts down an in-progress HasBlock operation
// shuts down an in-progress HasBlock operation proc.Go(func(proc process.Process) {
proc.Go(func(proc process.Process) { <-proc.Closing()
<-proc.Closing() cancel()
cancel() })
})
for {
for { select {
select { case <-proc.Closing():
case <-proc.Closing(): return
case block, ok := <-workerChan:
if !ok {
return return
case block, ok := <-workerChan: }
if !ok { if err := w.exchange.HasBlock(ctx, block); err != nil {
return // TODO log event?
}
if err := w.exchange.HasBlock(ctx, block); err != nil {
// TODO log event?
}
} }
} }
}) }
} })
} }
type BlockList struct { type BlockList struct {
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment