From 773e17df66f702e600ef9b57adc4808aef0c903c Mon Sep 17 00:00:00 2001 From: James Allen Date: Thu, 7 Aug 2014 13:16:11 +0100 Subject: [PATCH] Send worker idle waiting times to statsd --- services/document-updater/app/coffee/WorkersManager.coffee | 3 +++ 1 file changed, 3 insertions(+) diff --git a/services/document-updater/app/coffee/WorkersManager.coffee b/services/document-updater/app/coffee/WorkersManager.coffee index bfc2d705e4..b421422f29 100644 --- a/services/document-updater/app/coffee/WorkersManager.coffee +++ b/services/document-updater/app/coffee/WorkersManager.coffee @@ -3,6 +3,7 @@ logger = require('logger-sharelatex') Keys = require('./RedisKeyBuilder') redis = require('redis') UpdateManager = require('./UpdateManager') +Metrics = require('./Metrics') module.exports = WorkersManager = createWorker: () -> @@ -13,7 +14,9 @@ module.exports = WorkersManager = worker = { client: client waitForAndProcessUpdate: (callback = (error) ->) -> + timer = new Metrics.Timer "worker.waiting" worker.client.blpop "pending-updates-list", 0, (error, result) -> + timer.done() return callback(error) if error? return callback() if !result? [list_name, doc_key] = result