Skip to content

Commit

Permalink
dialqueue: rename local var for clarity.
Browse files Browse the repository at this point in the history
  • Loading branch information
raulk committed Feb 19, 2019
1 parent 8bacc6c commit 4f0cf48
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions dial_queue.go
Original file line number Diff line number Diff line change
Expand Up @@ -110,7 +110,7 @@ type waitingCh struct {
// end up adding fuel to the fire. Since we have no deterministic way to detect this for now, we hard-limit concurrency
// to config.maxParallelism.
func newDialQueue(params *dqParams) (*dialQueue, error) {
sq := &dialQueue{
dq := &dialQueue{
dqParams: params,
nWorkers: params.config.minParallelism,
out: queue.NewChanQueue(params.ctx, queue.NewXORDistancePQ(params.target)),
Expand All @@ -121,10 +121,10 @@ func newDialQueue(params *dqParams) (*dialQueue, error) {
}

for i := 0; i < int(params.config.minParallelism); i++ {
go sq.worker()
go dq.worker()
}
go sq.control()
return sq, nil
go dq.control()
return dq, nil
}

func (dq *dialQueue) control() {
Expand Down

0 comments on commit 4f0cf48

Please sign in to comment.