diff --git a/extensions/Push/lib/Daemon.pm b/extensions/Push/lib/Daemon.pm index 7fb5352caf..9f23904f73 100644 --- a/extensions/Push/lib/Daemon.pm +++ b/extensions/Push/lib/Daemon.pm @@ -14,6 +14,8 @@ use warnings; use Bugzilla::Constants; use Bugzilla::Extension::Push::Push; use Bugzilla::Extension::Push::Logger; +use Bugzilla::Util qw(get_text); + use Carp qw(confess); use Daemon::Generic; use File::Basename; @@ -95,4 +97,15 @@ sub gd_run { $push->start(); } +sub gd_check { + my $self = shift; + my $dbh = Bugzilla->dbh; + + # Get a count of all the push jobs currently in the queue. + my $push_count = $dbh->selectrow_array('SELECT COUNT(*) FROM push'); + my $backlog_count = $dbh->selectrow_array('SELECT COUNT(*) FROM push_backlog'); + print get_text('push_queue_depth', {count => $push_count}) . "\n"; + print get_text('push_queue_backlog_depth', {count => $backlog_count}) . "\n"; +} + 1; diff --git a/extensions/Push/template/en/default/hook/global/messages-messages.html.tmpl b/extensions/Push/template/en/default/hook/global/messages-messages.html.tmpl index e4a016aee0..8242cdbd68 100644 --- a/extensions/Push/template/en/default/hook/global/messages-messages.html.tmpl +++ b/extensions/Push/template/en/default/hook/global/messages-messages.html.tmpl @@ -13,4 +13,10 @@ [% ELSIF message_tag == "push_message_deleted" %] The message has been deleted. +[% ELSIF message_tag == "push_queue_depth" %] + [% count FILTER html %] push jobs in the queue. + +[% ELSIF message_tag == "push_queue_backlog_depth" %] + [% count FILTER html %] push jobs in the backlog queue. + [% END %]