opensource/kubo
1
0
Fork 0
mirror of https://github.com/ipfs/kubo.git synced 2025-06-28 00:39:31 +08:00
Code Issues Projects Releases Wiki Activity

rename for clarity

Browse Source
This commit is contained in:
Jeromy
2015-02-19 13:41:18 -08:00
parent d7eb57f48f
commit 5924f4a3db
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
exchange/bitswap/workers.go
View File

@ -29,7 +29,7 @@ func (bs *bitswap) startWorkers(px process.Process, ctx context.Context) {
// file transfers // file transfers
for i := 0; i < provideWorkers; i++ { for i := 0; i < provideWorkers; i++ {
px.Go(func(px process.Process) { px.Go(func(px process.Process) {
bs.blockReceiveWorker(ctx) bs.provideWorker(ctx)
}) })
} }
} }
@ -55,7 +55,7 @@ func (bs *bitswap) taskWorker(ctx context.Context) {
} }
} }
func (bs *bitswap) blockReceiveWorker(ctx context.Context) { func (bs *bitswap) provideWorker(ctx context.Context) {
for { for {
select { select {
case blk, ok := <-bs.newBlocks: case blk, ok := <-bs.newBlocks: