File tree 1 file changed +4
-4
lines changed
1 file changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -110,7 +110,7 @@ type waitingCh struct {
110
110
// end up adding fuel to the fire. Since we have no deterministic way to detect this for now, we hard-limit concurrency
111
111
// to config.maxParallelism.
112
112
func newDialQueue (params * dqParams ) (* dialQueue , error ) {
113
- sq := & dialQueue {
113
+ dq := & dialQueue {
114
114
dqParams : params ,
115
115
nWorkers : params .config .minParallelism ,
116
116
out : queue .NewChanQueue (params .ctx , queue .NewXORDistancePQ (params .target )),
@@ -121,10 +121,10 @@ func newDialQueue(params *dqParams) (*dialQueue, error) {
121
121
}
122
122
123
123
for i := 0 ; i < int (params .config .minParallelism ); i ++ {
124
- go sq .worker ()
124
+ go dq .worker ()
125
125
}
126
- go sq .control ()
127
- return sq , nil
126
+ go dq .control ()
127
+ return dq , nil
128
128
}
129
129
130
130
func (dq * dialQueue ) control () {
You can’t perform that action at this time.
0 commit comments