1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
|
#!/usr/bin/perl -T
# This Source Code Form is subject to the terms of the Mozilla Public
# License, v. 2.0. If a copy of the MPL was not distributed with this
# file, You can obtain one at http://mozilla.org/MPL/2.0/.
#
# This Source Code Form is "Incompatible With Secondary Licenses", as
# defined by the Mozilla Public License, v. 2.0.
use 5.10.1;
use strict;
use warnings;
use lib qw(. lib local/lib/perl5);
use Bugzilla;
use Bugzilla::Constants;
use Bugzilla::Error;
use Bugzilla::Util qw(template_var);
use Scalar::Util qw(blessed);
use Storable qw(read_magic thaw);
my $user = Bugzilla->login(LOGIN_REQUIRED);
($user->in_group("admin") || $user->in_group('infra'))
|| ThrowUserError("auth_failure",
{group => "admin", action => "access", object => "job_queue"});
my $vars = {};
generate_report($vars);
print Bugzilla->cgi->header();
my $template = Bugzilla->template;
$template->process('admin/reports/job_queue.html.tmpl', $vars)
|| ThrowTemplateError($template->error());
sub generate_report {
my ($vars) = @_;
my $dbh = Bugzilla->dbh;
my $user = Bugzilla->user;
my $query = "
SELECT
j.jobid,
j.arg,
j.run_after AS run_time,
j.grabbed_until,
f.funcname AS func,
(SELECT COUNT(*)
FROM ts_error
WHERE ts_error.jobid = j.jobid
) AS error_count,
e.error_time AS error_time,
e.message AS error_message
FROM
ts_job j
INNER JOIN ts_funcmap f
ON f.funcid = j.funcid
NATURAL LEFT JOIN (
SELECT MAX(error_time) AS error_time, jobid
FROM ts_error
GROUP BY jobid
) t
LEFT JOIN ts_error e
ON (e.error_time = t.error_time) AND (e.jobid = t.jobid)
ORDER BY
j.run_after, j.grabbed_until, j.insert_time, j.jobid
" . $dbh->sql_limit(JOB_QUEUE_VIEW_MAX_JOBS + 1);
$vars->{jobs} = $dbh->selectall_arrayref($query, {Slice => {}});
if (@{$vars->{jobs}} == JOB_QUEUE_VIEW_MAX_JOBS + 1) {
pop @{$vars->{jobs}};
$vars->{job_count} = $dbh->selectrow_array("SELECT COUNT(*) FROM ts_job");
$vars->{too_many_jobs} = 1;
}
my $bug_word = template_var('terms')->{bug};
foreach my $job (@{$vars->{jobs}}) {
my ($recipient, $description);
eval {
if ($job->{func} eq 'Bugzilla::Job::BugMail') {
my $arg = _cond_thaw(delete $job->{arg});
next unless $arg;
my $vars = $arg->{vars};
$recipient = $vars->{to_user}->{login_name};
$description
= "[$bug_word " . $vars->{bug}->{bug_id} . '] ' . $vars->{bug}->{short_desc};
}
elsif ($job->{func} eq 'Bugzilla::Job::Mailer') {
my $arg = _cond_thaw(delete $job->{arg});
next unless $arg;
my $msg = $arg->{msg};
if (ref($msg) && blessed($msg) eq 'Email::MIME') {
$recipient = $msg->header('to');
$description = $msg->header('subject');
}
else {
($recipient) = $msg =~ /\nTo: ([^\n]+)/i;
($description) = $msg =~ /\nSubject: ([^\n]+)/i;
}
}
};
if ($recipient) {
$job->{subject} = "<$recipient> $description";
}
}
}
sub _cond_thaw {
my $data = shift;
my $magic = eval { read_magic($data); };
if ($magic && $magic->{major} && $magic->{major} >= 2 && $magic->{major} <= 5) {
my $thawed = eval { thaw($data) };
if ($@) {
# false alarm... looked like a Storable, but wasn't
return undef;
}
return $thawed;
}
else {
return undef;
}
}
|
