From e5ff2d681f85299871abc0fb68921ba11d119b5c Mon Sep 17 00:00:00 2001 From: Aaron Schulz Date: Mon, 11 May 2015 16:55:42 -0700 Subject: [PATCH] Send job ACKs to statsd Change-Id: Idf6dcd6baf39484ac6fcf14465e13ae12405dd3a --- includes/jobqueue/JobQueueDB.php | 2 ++ includes/jobqueue/JobQueueRedis.php | 2 ++ 2 files changed, 4 insertions(+) diff --git a/includes/jobqueue/JobQueueDB.php b/includes/jobqueue/JobQueueDB.php index b1b650ba81..000fa4fb00 100644 --- a/includes/jobqueue/JobQueueDB.php +++ b/includes/jobqueue/JobQueueDB.php @@ -471,6 +471,8 @@ class JobQueueDB extends JobQueue { // Delete a row with a single DELETE without holding row locks over RTTs... $dbw->delete( 'job', array( 'job_cmd' => $this->type, 'job_id' => $job->metadata['id'] ), __METHOD__ ); + + JobQueue::incrStats( 'job-ack', $this->type ); } catch ( DBError $e ) { $this->throwDBException( $e ); } diff --git a/includes/jobqueue/JobQueueRedis.php b/includes/jobqueue/JobQueueRedis.php index f1de76cbb8..7edb6ad702 100644 --- a/includes/jobqueue/JobQueueRedis.php +++ b/includes/jobqueue/JobQueueRedis.php @@ -389,6 +389,8 @@ LUA; return false; } + + JobQueue::incrStats( 'job-ack', $this->type ); } catch ( RedisException $e ) { $this->throwRedisException( $conn, $e ); } -- 2.20.1