coosld/kubo
1
0
Fork 0
mirror of https://github.com/ipfs/kubo.git synced 2026-03-03 23:38:07 +08:00
Code Issues Actions 14 Packages Projects Releases Wiki Activity

one worker

Browse Source
This commit is contained in:
Brian Tiger Chow 2015-01-20 16:51:45 -08:00
parent 721ff57263
commit ed019e2f7d
1 changed files with 19 additions and 21 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

40
blockservice/worker/worker.go
View File

@ -114,32 +114,30 @@ func (w *Worker) start(c Config) {
}
})
for i := 0; i < c.NumWorkers; i++ {
// reads from |workerChan| until process closes
w.process.Go(func(proc process.Process) {
ctx, cancel := context.WithCancel(context.Background())
// reads from |workerChan| until process closes
w.process.Go(func(proc process.Process) {
ctx, cancel := context.WithCancel(context.Background())
// shuts down an in-progress HasBlock operation
proc.Go(func(proc process.Process) {
<-proc.Closing()
cancel()
})
// shuts down an in-progress HasBlock operation
proc.Go(func(proc process.Process) {
<-proc.Closing()
cancel()
})
for {
select {
case <-proc.Closing():
for {
select {
case <-proc.Closing():
return
case block, ok := <-workerChan:
if !ok {
return
case block, ok := <-workerChan:
if !ok {
return
}
if err := w.exchange.HasBlock(ctx, block); err != nil {
// TODO log event?
}
}
if err := w.exchange.HasBlock(ctx, block); err != nil {
// TODO log event?
}
}
})
}
}
})
}
type BlockList struct {