aboutsummaryrefslogtreecommitdiff
path: root/src/lib/workers-list.js
diff options
context:
space:
mode:
authorEvgeny Zinoviev <me@ch1p.io>2021-03-01 02:05:37 +0300
committerEvgeny Zinoviev <me@ch1p.io>2021-03-01 02:05:37 +0300
commit8783de4fe5945a7ea22995c25a3e546c0426c7f6 (patch)
tree17711b548483b57a5b5b2b81594ad2a19fc6eeab /src/lib/workers-list.js
parent57f541a6ea6722a2902e7cc7774aefca883fe8de (diff)
update protocol
Diffstat (limited to 'src/lib/workers-list.js')
-rw-r--r--src/lib/workers-list.js4
1 files changed, 2 insertions, 2 deletions
diff --git a/src/lib/workers-list.js b/src/lib/workers-list.js
index 620f711..ed436e0 100644
--- a/src/lib/workers-list.js
+++ b/src/lib/workers-list.js
@@ -1,7 +1,7 @@
const intersection = require('lodash/intersection')
const config = require('./config')
const {getLogger} = require('./logger')
-const {RequestMessage} = require('./server')
+const {RequestMessage, PingMessage} = require('./server')
const throttle = require('lodash/throttle')
class WorkersList {
@@ -136,7 +136,7 @@ class WorkersList {
this.workers
.forEach(w => {
this.logger.trace(`sending ping to ${w.connection.remoteAddr()}`)
- w.connection.send(new RequestMessage('ping'))
+ w.connection.send(new PingMessage())
})
}