File tree 1 file changed +5
-5
lines changed
1 file changed +5
-5
lines changed Original file line number Diff line number Diff line change @@ -117,7 +117,7 @@ func newDialQueue(params *dqParams) (*dialQueue, error) {
117
117
// we need a dedicated context for the out queue, in order to control its lifecycle explicitly
118
118
// because it cannot be stopped before all workers have yielded, or else we can block forever.
119
119
outCtx , outCancelFn := context .WithCancel (context .Background ())
120
- sq := & dialQueue {
120
+ dq := & dialQueue {
121
121
dqParams : params ,
122
122
nWorkers : params .config .minParallelism ,
123
123
out : queue .NewChanQueue (outCtx , queue .NewXORDistancePQ (params .target )),
@@ -129,12 +129,12 @@ func newDialQueue(params *dqParams) (*dialQueue, error) {
129
129
}
130
130
131
131
for i := 0 ; i < int (params .config .minParallelism ); i ++ {
132
- sq .workerWg .Add (1 )
133
- go sq .worker ()
132
+ dq .workerWg .Add (1 )
133
+ go dq .worker ()
134
134
}
135
135
136
- go sq .control ()
137
- return sq , nil
136
+ go dq .control ()
137
+ return dq , nil
138
138
}
139
139
140
140
func (dq * dialQueue ) control () {
You can’t perform that action at this time.
0 commit comments