-
Notifications
You must be signed in to change notification settings - Fork 257
/
Scheduler.pm
155 lines (113 loc) · 3.74 KB
/
Scheduler.pm
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
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
package C4::Scheduler;
# Copyright 2007 Liblime Ltd
#
# This file is part of Koha.
#
# Koha is free software; you can redistribute it and/or modify it
# under the terms of the GNU General Public License as published by
# the Free Software Foundation; either version 3 of the License, or
# (at your option) any later version.
#
# Koha is distributed in the hope that it will be useful, but
# WITHOUT ANY WARRANTY; without even the implied warranty of
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
# GNU General Public License for more details.
#
# You should have received a copy of the GNU General Public License
# along with Koha; if not, see <http://www.gnu.org/licenses>.
use Modern::Perl;
use C4::Context;
use Schedule::At;
our (@ISA, @EXPORT_OK);
BEGIN {
require Exporter;
@ISA = qw(Exporter);
@EXPORT_OK = qw(get_jobs get_at_jobs get_at_job add_at_job remove_at_job);
}
=head1 NAME
C4::Scheduler - Module for running jobs with the unix at command
=head1 SYNOPSIS
use C4::Scheduler;
=head1 DESCRIPTION
=cut
=head1 METHODS
=head2 get_jobs();
This will return all scheduled jobs
=cut
sub get_jobs {
my $jobs = get_at_jobs();
# add call to get cron jobs here too
return ($jobs);
}
=head2 get_at_jobs();
This will return all At scheduled jobs
=cut
sub get_at_jobs {
my %jobs = Schedule::At::getJobs();
return (\%jobs);
}
=head2 get_at_job($id)
This will return the At job with the given id
=cut
sub get_at_job {
my ($id)=@_;
my %jobs = Schedule::At::getJobs(JOBID => $id);
}
=head2 add_at_job ($time,$command)
Given a timestamp and a command this will schedule the job to run at that time.
Returns true if the job is added to the queue and false otherwise.
=cut
sub add_at_job {
my ($time,$command) = @_;
# FIXME - a description of the task to be run
# may be a better tag, since the tag is displayed
# in the job list that the administrator sees - e.g.,
# "run report foo, send to [email protected]"
Schedule::At::add(TIME => $time, COMMAND => $command, TAG => $command);
# FIXME - this method of checking whether the job was added
# to the queue is less than perfect:
#
# 1. Since the command is the tag, it is possible that there is
# already a job in the queue with the same tag. However, since
# the tag is what displays in the job list, we can't just
# give it a unique ID.
# 2. Schedule::At::add() is supposed to return a non-zero
# value if it fails to add a job - however, it does
# not check all error conditions - in particular, it does
# not check the return value of the "at" run; it basically
# complains only if it can't find at.
# 3. Similary, Schedule::At::add() does not do something more useful,
# such as returning the job ID. To be fair, it is possible
# that 'at' does not allow this in any portable way.
# 4. Although unlikely, it is possible that a job could be added
# and completed instantly, thus dropping off the queue.
my $job_found = 0;
eval {
my %jobs = Schedule::At::getJobs(TAG => $command);
$job_found = scalar(keys %jobs) > 0;
};
if ($@) {
return 0;
} else {
return $job_found;
}
}
sub remove_at_job {
my ($jobid)=@_;
Schedule::At::remove(JOBID => $jobid);
}
1;
__END__
=head1 BUGS
At some point C<C4::Scheduler> should be refactored:
=over
=item At and C<Schedule::At> does not work on Win32.
=item At is not installed by default on all platforms.
=item The At queue used by Koha is owned by the httpd user. If multiple
Koha databases share an Apache instance on a server, everybody can
see everybody's jobs.
=item There is no support for scheduling a job to run more than once.
=back
=head1 AUTHOR
Chris Cormack <[email protected]>
=cut