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
|
<?php
/*
* cronjob callback. This script does periodic checks, logging,
* housekeeping etc. Should be called every 5 mins by cron.
* Make a crontab entry that runs this as the same user the
* www-php is normally run as, eg. */
// */5 * * * * www-data php /path/to/api.php cron
if (!isLocalExecution())
exit(0);
define('CRON_KEY_STATUS', 'cron.key.status');
define('CRON_KEY_BLOCKED', 'cron.key.blocked');
// Crash report mode - used by system crontab entry
if (($report = Request::get('crashreport', false, 'string'))) {
$list = Property::getList(CRON_KEY_STATUS);
if (empty($list)) {
error_log('Cron crashreport triggered but no cronjob marked active.');
exit(0);
}
$str = array();
foreach ($list as $item) {
Property::removeFromList(CRON_KEY_STATUS, $item);
$entry = explode('|', $item, 2);
if (count($entry) !== 2)
continue;
$time = time() - $entry[1];
if ($time > 3600) // Sanity check
continue;
$str[] = $entry[0] . ' (started ' . $time . 's ago)';
Property::addToList(CRON_KEY_BLOCKED, $entry[0], 1800);
}
if (empty($str)) {
$str = 'an unknown module';
}
$message = 'Conjob failed. No reply by ' . implode(', ', $str);
$details = '';
if (is_readable($report)) {
$details = file_get_contents($report);
if (!empty($details)) {
$message .=', click "details" for log';
}
}
EventLog::failure($message, $details);
exit(0);
}
function getJobStatus($id)
{
// Re fetch from D on every call as some jobs could take longer
// and we don't want to work with stale data
$activeList = Property::getList(CRON_KEY_STATUS);
foreach ($activeList as $item) {
$entry = explode('|', $item, 2);
if (count($entry) !== 2 || $id !== $entry[0])
continue;
return array('start' => $entry[1], 'string' => $item);
}
return false;
}
// Hooks by other modules
function handleModule($file)
{
include_once $file;
}
$blocked = Property::getList(CRON_KEY_BLOCKED);
foreach (Hook::load('cron') as $hook) {
// Check if job is still running, or should be considered crashed
$status = getJobStatus($hook->moduleId);
if ($status !== false) {
$runtime = (time() - $status['start']);
if ($runtime < 0) {
// Clock skew
Property::removeFromList(CRON_KEY_STATUS, $status['string']);
} elseif ($runtime < 900) {
// Allow up to 15 minutes for a job to complete before we complain...
continue;
} else {
// Consider job crashed
Property::removeFromList(CRON_KEY_STATUS, $status['string']);
EventLog::failure('Cronjob for module ' . $hook->moduleId . ' seems to be stuck or has crashed.');
continue;
}
}
// Are we blocked
if (in_array($hook->moduleId, $blocked))
continue;
// Fire away
$value = $hook->moduleId . '|' . time();
Property::addToList(CRON_KEY_STATUS, $value, 1800);
try {
handleModule($hook->file);
} catch (Exception $e) {
// Logging
EventLog::failure('Cronjob for module ' . $hook->moduleId . ' has crashed. Check the php or web server error log.', $e->toString());
}
Property::removeFromList(CRON_KEY_STATUS, $value);
}
|
