We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 9592c22 commit aeadc1bCopy full SHA for aeadc1b
src/dialer/queueManager.js
@@ -6,6 +6,8 @@ const { DIAL_ABORTED } = require('../errors')
6
const nextTick = require('async/nextTick')
7
const retimer = require('retimer')
8
const { QUARTER_HOUR } = require('../constants')
9
+const debug = require('debug')
10
+const log = debug('libp2p:switch:dial:manager')
11
const noop = () => {}
12
13
class DialQueueManager {
@@ -154,6 +156,12 @@ class DialQueueManager {
154
156
}
155
157
158
let targetQueue = this._queues[nextQueue.value]
159
+
160
+ if (!targetQueue) {
161
+ log('missing queue %s, maybe it was aborted?', nextQueue.value)
162
+ return
163
+ }
164
165
this._dialingQueues.add(targetQueue.id)
166
targetQueue.start()
167
0 commit comments