View source
<?php
function ultimate_cron_run_cron() {
ultimate_cron_cron(TRUE);
drupal_goto('admin/reports/status');
}
function ultimate_cron_settings_form() {
$form = array();
$advanced_help_enabled = module_exists('advanced_help');
$form['general'] = array(
'#title' => t('General'),
'#type' => 'fieldset',
'#collapsible' => TRUE,
'#collapsed' => FALSE,
'#tree' => FALSE,
);
$form['general']['ultimate_cron_handle_prefix'] = array(
'#title' => t("Handle prefix"),
'#type' => 'textfield',
'#default_value' => variable_get('ultimate_cron_handle_prefix', ULTIMATE_CRON_HANDLE_PREFIX),
'#description' => ($advanced_help_enabled ? theme('advanced_help_topic', 'ultimate_cron', 'handle_prefix') : '') . t('Handle prefix. Use with care. Changing this from the default value ("' . ULTIMATE_CRON_HANDLE_PREFIX . '"), might break compatibility with 3rd party modules. Also, make sure that no jobs are running when changing this.'),
);
$form['general']['ultimate_cron_simultaneous_connections'] = array(
'#title' => t("Simultaneous connections"),
'#type' => 'textfield',
'#default_value' => variable_get('ultimate_cron_simultaneous_connections', ULTIMATE_CRON_SIMULTANEOUS_CONNECTIONS),
'#description' => ($advanced_help_enabled ? theme('advanced_help_topic', 'ultimate_cron', 'simultaneous_connections') : '') . t('Maximum number of simultaneous connections'),
);
$form['general']['ultimate_cron_rule'] = array(
'#title' => t("Default rule"),
'#type' => 'textfield',
'#default_value' => variable_get('ultimate_cron_rule', ULTIMATE_CRON_RULE),
'#description' => ($advanced_help_enabled ? theme('advanced_help_topic', 'ultimate_cron', 'rules') : '') . t('Enter the default fallback rule'),
);
$form['general']['ultimate_cron_cleanup_log'] = array(
'#title' => t("Clean up logs older than X seconds"),
'#type' => 'textfield',
'#default_value' => variable_get('ultimate_cron_cleanup_log', ULTIMATE_CRON_CLEANUP_LOG),
'#description' => ($advanced_help_enabled ? theme('advanced_help_topic', 'ultimate_cron', 'cleanup_log') : '') . t('Enter maximum age, in seconds, for log entries'),
);
$form['general']['ultimate_cron_catch_up'] = array(
'#title' => t('Default catch up'),
'#type' => 'textfield',
'#default_value' => variable_get('ultimate_cron_catch_up', ULTIMATE_CRON_CATCH_UP),
'#description' => ($advanced_help_enabled ? theme('advanced_help_topic', 'ultimate_cron', 'catch_up') : '') . t('Time in seconds to catch up, if a job could not be run within its time frame. (blank = ' . variable_get('ultimate_cron_catch_up', ULTIMATE_CRON_CATCH_UP) . ')'),
);
if (module_exists('drupal_queue')) {
$form['general']['ultimate_cron_queue_polling_latency'] = array(
'#title' => t("Queue polling latency"),
'#type' => 'textfield',
'#default_value' => variable_get('ultimate_cron_queue_polling_latency', ULTIMATE_CRON_QUEUE_POLLING_LATENCY),
'#description' => ($advanced_help_enabled ? theme('advanced_help_topic', 'ultimate_cron', 'polling_latency') : '') . t('Queue polling latency in miliseconds. Leave blank to disable continuous processing of queues.'),
);
$form['general']['ultimate_cron_queue_lease_time'] = array(
'#title' => t('Queue lease time'),
'#type' => 'textfield',
'#default_value' => variable_get('ultimate_cron_queue_lease_time', ULTIMATE_CRON_QUEUE_LEASE_TIME),
'#description' => ($advanced_help_enabled ? theme('advanced_help_topic', 'ultimate_cron', 'queue_lease_time') : '') . t('Time in seconds to keep lock on claimed item'),
);
}
$methods = module_invoke_all('service_group');
$options = ultimate_cron_get_service_groups();
foreach ($options as $key => &$value) {
$value = (empty($value['description']) ? $key : $value['description']) . ' (' . join(',', $value['hosts']) . ') : ' . $methods['methods'][$value['method']];
}
$form['general']['ultimate_cron_service_group'] = array(
'#type' => 'select',
'#title' => t('Service group'),
'#description' => ($advanced_help_enabled ? theme('advanced_help_topic', 'ultimate_cron', 'service_group') : '') . t('Service group to use for all jobs. See Background Process !url for managing service groups.', array(
'!url' => l(t('settings'), 'admin/settings/background-process'),
)),
'#options' => $options,
'#default_value' => variable_get('ultimate_cron_service_group', ULTIMATE_CRON_SERVICE_GROUP),
);
$form['general']['ultimate_cron_poorman'] = array(
'#title' => t("Poormans cron"),
'#type' => 'checkbox',
'#default_value' => variable_get('ultimate_cron_poorman', ULTIMATE_CRON_POORMAN),
'#description' => ($advanced_help_enabled ? theme('advanced_help_topic', 'ultimate_cron', 'poorman') : '') . t('Keep background process alive, checking for cron every minute.'),
);
$form = system_settings_form($form);
$form['buttons']['#weight'] = 1000;
$form['buttons']['reclaim'] = array(
'#value' => t("Reclaim position"),
'#description' => t('Changes weight of module to the lowest possible.'),
'#type' => 'submit',
'#submit' => array(
'ultimate_cron_reclaim_submit',
),
'#disabled' => !ultimate_cron_uncronable_modules(),
);
return $form;
}
function ultimate_cron_reclaim_submit($form, &$form_state) {
ultimate_cron_reclaim();
drupal_set_message(t('Module position reclaimed.'));
}
function ultimate_cron_function_settings_form($form, $function) {
$hooks = ultimate_cron_get_hooks();
if (!isset($hooks[(string) $function])) {
drupal_not_found();
exit;
}
$hook = $hooks[$function];
$conf = ultimate_cron_get_settings($function);
$conf += _ultimate_cron_default_settings();
drupal_set_title(check_plain($function));
$form = array();
$advanced_help_enabled = module_exists('advanced_help');
$form['function'] = array(
'#type' => 'value',
'#value' => $function,
);
$form['general'] = array(
'#title' => t('General'),
'#type' => 'fieldset',
'#collapsible' => TRUE,
'#collapsed' => FALSE,
'#tree' => TRUE,
);
$form['general']['enabled'] = array(
'#title' => t('Enabled'),
'#type' => 'checkbox',
'#default_value' => $conf['enabled'],
'#description' => t('Enable this cron job.'),
);
$form['general']['rules'] = array(
'#title' => t('Rules'),
'#type' => 'textfield',
'#default_value' => implode(';', $conf['rules']),
'#description' => ($advanced_help_enabled ? theme('advanced_help_topic', 'ultimate_cron', 'rules') : '') . t('Semi-colon separated list of rules for this job. (blank = ' . implode(';', $hook['settings']['rules']) . ')'),
);
$form['general']['catch_up'] = array(
'#title' => t('Catch up'),
'#type' => 'textfield',
'#default_value' => $conf['catch_up'],
'#description' => ($advanced_help_enabled ? theme('advanced_help_topic', 'ultimate_cron', 'catch_up') : '') . t('Time in seconds to catch up, if a job could not be run within its time frame. (blank = ' . variable_get('ultimate_cron_catch_up', ULTIMATE_CRON_CATCH_UP) . ')'),
);
if (module_exists('drupal_queue') && strpos($function, 'ultimate_cron_queue_') === 0) {
$form['general']['queue_lease_time'] = array(
'#title' => t('Queue lease time'),
'#type' => 'textfield',
'#default_value' => $conf['queue_lease_time'],
'#description' => ($advanced_help_enabled ? theme('advanced_help_topic', 'ultimate_cron', 'queue_lease_time') : '') . t('Time in seconds to keep lock on claimed item. (blank = ' . variable_get('ultimate_cron_queue_lease_time', ULTIMATE_CRON_QUEUE_LEASE_TIME) . ')'),
);
$form['general']['queue_polling_throttle'] = array(
'#title' => t("Queue polling throttle"),
'#type' => 'textfield',
'#default_value' => $conf['queue_polling_throttle'],
'#description' => ($advanced_help_enabled ? theme('advanced_help_topic', array(
'module' => 'ultimate_cron',
'topic' => 'polling_throttle',
'type' => 'icon',
)) : '') . t('Queue polling throttle in miliseconds.'),
);
}
$methods = module_invoke_all('service_group');
$service_groups = $options = ultimate_cron_get_service_groups();
foreach ($options as $key => &$value) {
$value = (empty($value['description']) ? $key : $value['description']) . ' (' . join(',', $value['hosts']) . ') : ' . $methods['methods'][$value['method']];
}
$options += array(
NULL => 'Ultimate Cron service group (' . join(',', $service_groups[variable_get('ultimate_cron_service_group', ULTIMATE_CRON_SERVICE_GROUP)]['hosts']) . ') : ' . $methods['methods'][$service_groups[variable_get('ultimate_cron_service_group', ULTIMATE_CRON_SERVICE_GROUP)]['method']],
);
$form['general']['service_group'] = array(
'#type' => 'select',
'#title' => t('Service group'),
'#description' => ($advanced_help_enabled ? theme('advanced_help_topic', 'ultimate_cron', 'service_group') : '') . t('Service group to use for this job. See Background Process !url for managing service groups.', array(
'!url' => l(t('settings'), 'admin/settings/background-process'),
)),
'#options' => $options,
'#default_value' => isset($conf['service_group']) ? $conf['service_group'] : NULL,
);
$form['buttons'] = array(
'#weight' => 1000,
);
$form['buttons']['submit'] = array(
'#type' => 'submit',
'#value' => t('Save settings'),
);
$form['#redirect'] = 'admin/settings/cron';
return $form;
}
function ultimate_cron_function_settings_form_validate($form, &$form_state) {
$conf =& $form_state['values']['general'];
$conf['rules'] = trim($conf['rules']);
$conf['rules'] = $conf['rules'] ? explode(';', $conf['rules']) : array();
if ($conf['rules']) {
foreach ($conf['rules'] as &$rule) {
$rule = trim($rule);
if (!ultimate_cron_validate_rule($rule)) {
form_set_error('rules', t('Invalid rule.'));
}
}
}
else {
unset($conf['rules']);
}
}
function ultimate_cron_function_settings_form_submit($form, &$form_state) {
$conf =& $form_state['values']['general'];
ultimate_cron_set_settings($form_state['values']['function'], $conf);
unset($form_state['storage']);
}
function ultimate_cron_view_page($status = NULL) {
require_once 'CronRule.class.php';
drupal_add_css(drupal_get_path('module', 'ultimate_cron') . '/css/ultimate_cron.admin.css');
drupal_add_js(drupal_get_path('module', 'ultimate_cron') . '/js/ultimate_cron.js');
module_load_install('ultimate_cron');
$requirements = ultimate_cron_requirements('runtime');
if ($requirements['ultimate_cron']['severity'] != REQUIREMENT_OK) {
drupal_set_message($requirements['ultimate_cron']['value'], 'error');
drupal_set_message($requirements['ultimate_cron']['description'], 'error');
}
$data = _ultimate_cron_preload_cron_data();
$hooks = ultimate_cron_get_hooks();
$modules = array();
foreach ($hooks as $function => $hook) {
$hook['settings'] = $data[$function]['settings'] + $hook['settings'];
$hook['background_process'] = $data[$function]['background_process'];
$hook['log'] = ultimate_cron_get_log($function);
$modules[$hook['module']][$function] = $hook;
}
$output = '';
$rows = array();
$handle_prefix = variable_get('ultimate_cron_handle_prefix', ULTIMATE_CRON_HANDLE_PREFIX);
$overview = array();
$overview['running'] = 0;
$overview['success'] = 0;
$overview['info'] = 0;
$overview['warning'] = 0;
$overview['error'] = 0;
$revert = array(
'%21' => '!',
'%2A' => '*',
'%27' => "'",
'%28' => '(',
'%29' => ')',
);
foreach ($modules as $module => $hooks) {
foreach ($hooks as $function => $hook) {
$conf = $hook['settings'];
$rules = $hook['settings']['rules'];
$cron = new CronRule();
$parsed_rules = array();
foreach ($rules as $rule) {
$cron->rule = $rule;
$cron->offset = $hook['delta'];
$parsed_rules[] = $cron
->parseRule();
}
$process = $hook['background_process'];
$service_host = empty($process->service_host) ? t('N/A') : $process->service_host;
$log = $hook['log'];
if (!$log) {
$log = array(
'severity' => -1,
'status' => NULL,
'start' => NULL,
'end' => NULL,
);
}
$severity_type = $log['severity'] < 0 ? 'success' : ($log['severity'] >= WATCHDOG_NOTICE ? 'info' : ($log['severity'] >= WATCHDOG_WARNING ? 'warning' : 'error'));
$css_status = !empty($process) ? 'running' : $severity_type;
$short_msg = $log['severity'];
$msg = !empty($log['msg']) ? $log['msg'] : t('No errors');
$duration = '';
if ($process) {
$overview['running']++;
$log['previous_start'] = $log['start'];
$log['previous_end'] = $log['end'];
$log['start'] = $process->start;
if ($process->status == BACKGROUND_PROCESS_STATUS_RUNNING) {
$log['end'] = microtime(TRUE);
}
else {
$log['end'] = NULL;
}
$progress = progress_get_progress($handle_prefix . $function);
if ($progress && $progress->progress > 0) {
$duration .= sprintf(" (%d%%)", $progress->progress * 100);
}
}
$overview[$severity_type]++;
$link_configure = '';
if (!empty($hook['configure'])) {
$link_configure = _ultimate_cron_l('Settings', $hook['configure']);
}
$link_unlock = '';
if ($process) {
$link_unlock = _ultimate_cron_l('Unlock', 'background-process/unlock/' . $process->handle);
}
$link_settings = _ultimate_cron_l('Schedule', 'admin/settings/cron/settings/' . $function);
$link_execute = _ultimate_cron_l('Run', 'admin/ultimate-cron/service/start/' . $function);
$link_log = _ultimate_cron_l('Log', 'admin/reports/cron/' . $function);
$enable = !empty($conf) && empty($conf['enabled']);
$link_toggle = _ultimate_cron_l($enable ? 'Enable' : 'Disable', 'admin/ultimate-cron/service/' . ($enable ? 'enable' : 'disable') . '/' . $function);
$data = array(
array(
'class' => $enable ? 'ultimate-cron-admin-enable' : 'ultimate-cron-admin-disable',
),
array(
'class' => 'ultimate-cron-admin-module',
),
array(
'class' => 'ultimate-cron-admin-function',
),
array(
'class' => 'ultimate-cron-admin-rules',
),
array(
'class' => 'ultimate-cron-admin-start',
),
array(
'class' => 'ultimate-cron-admin-end',
),
array(
'class' => 'ultimate-cron-admin-status ultimate-cron-admin-status-' . $css_status,
),
array(
'class' => 'ultimate-cron-admin-settings',
),
array(
'class' => 'ultimate-cron-admin-configure',
),
array(
'class' => 'ultimate-cron-admin-log',
),
array(
'class' => $process ? 'ultimate-cron-admin-unlock' : 'ultimate-cron-admin-execute',
),
);
$data[0]['data'] = $link_toggle;
$data[0]['title'] = $enable ? t('Enable') : t('Disable');
$data[1]['data'] = ultimate_cron_module_name($module);
$data[2]['data'] = $hook['description'];
$data[2]['title'] = $function;
$data[3]['data'] = join("<br/>", $rules);
$data[3]['title'] = join("\n", $parsed_rules);
$data[4]['data'] = $log['start'] ? format_date((int) $log['start'], 'custom', 'Y-m-d H:i:s') : t('Never');
$data[5]['data'] = $log['end'] ? gmdate('H:i:s', (int) ($log['end'] - $log['start'])) . $duration : ($process ? t('Starting') : t('N/A'));
$finish = !empty($log['previous_end']) ? $log['previous_end'] : $log['end'];
$data[5]['title'] = t('Previous run finished @ !timestamp', array(
'!timestamp' => $finish ? format_date((int) $finish, 'custom', 'Y-m-d H:i:s') : t('N/A'),
));
if (!empty($log['previous_start'])) {
$data[4]['title'] = t('Previous run started @ !timestamp', array(
'!timestamp' => format_date((int) $log['previous_start'], 'custom', 'Y-m-d H:i:s'),
));
$data[5]['title'] .= ' - ' . t('Run time: !duration', array(
'!duration' => gmdate('H:i:s', (int) ($log['previous_end'] - $log['previous_start'])) . $duration,
));
}
if ($process) {
$data[6]['data'] = '<span>' . t('Running') . '</span>';
$data[6]['title'] = t('Running on @host', array(
'@host' => $service_host,
));
}
else {
$data[6]['data'] = '<span>' . $short_msg . '</span>';
$data[6]['title'] = strip_tags(html_entity_decode($msg, ENT_QUOTES));
}
$data[7]['data'] = $link_settings;
$data[7]['title'] = t('Schedule');
$data[8]['data'] = $link_configure;
$data[8]['title'] = $link_configure ? t('Settings') : '';
$data[9]['data'] = $link_log;
$data[9]['title'] = t('Log');
$data[10]['data'] = $hook['unsafe'] ? '' : ($process ? $link_unlock : $link_execute);
$data[10]['title'] = $hook['unsafe'] ? '' : ($process ? t('Unlock') : t('Run'));
$rows[(int) $enable][] = array(
'class' => array(
'row-' . str_replace('%', '_', strtr(rawurlencode($function), $revert)),
),
'data' => $data,
'style' => $status && $status != 'all' && $css_status != $status ? 'display: none' : '',
);
}
}
if (!empty($rows[0])) {
$headers = array(
t('Enabled'),
t('Module'),
t('Function'),
t('Rules'),
t('Start'),
t('Duration'),
t('Status'),
array(
'colspan' => 3,
'data' => '',
),
l(t('Run all'), 'admin/reports/status/run-cron', array(
'query' => drupal_get_destination(),
)),
);
$output .= theme('table', $headers, $rows[0]);
$output .= '<div class="clear-block"></div>';
}
if (!empty($rows[1])) {
$headers = array(
t('Disabled'),
t('Module'),
t('Function'),
t('Rules'),
t('Start'),
t('Duration'),
t('Status'),
array(
'colspan' => 4,
'data' => '',
),
);
$output .= theme('table', $headers, $rows[1]);
$output .= '<div class="clear-block"></div>';
}
if ($overview['running']) {
drupal_set_message(format_plural($overview['running'], '@jobs job is currently running', '@jobs jobs are currently running', array(
'@jobs' => $overview['running'],
)));
}
if ($overview['warning']) {
drupal_set_message(format_plural($overview['warning'], '@jobs job had warnings during its last run', '@jobs jobs had warnings during their last run', array(
'@jobs' => $overview['warning'],
)), 'warning');
}
if ($overview['error']) {
drupal_set_message(format_plural($overview['error'], '@jobs job had errors during its last run', '@jobs jobs had errors during their last run', array(
'@jobs' => $overview['error'],
)), 'error');
}
return $output;
}
function ultimate_cron_function_log_page($function) {
$hooks = ultimate_cron_get_hooks();
if (!isset($hooks[(string) $function])) {
drupal_not_found();
exit;
}
drupal_add_css(drupal_get_path('module', 'ultimate_cron') . '/css/ultimate_cron.admin.css');
$header = array(
array(
'data' => t('Start'),
'field' => 'start_stamp',
'sort' => 'DESC',
),
array(
'data' => t('End'),
'field' => 'end_stamp',
),
t('Duration'),
t('Service host'),
t('Status'),
t('Message'),
);
drupal_set_title(check_plain($function));
$sql = "SELECT l.lid, l.name, l.start_stamp, l.end_stamp, l.service_host, l.exec_status, l.msg, l.severity FROM {ultimate_cron_log} l WHERE l.name = '%s'";
$sql .= tablesort_sql($header);
$result = pager_query($sql, 10, 0, NULL, $function);
$logs = array();
while ($log = db_fetch_object($result)) {
$logs[] = $log;
}
$handle_prefix = variable_get('ultimate_cron_handle_prefix', ULTIMATE_CRON_HANDLE_PREFIX);
$output = '';
$rows = array();
if (empty($_GET['page']) && ($process = background_process_get_process($handle_prefix . $function))) {
$data = array(
array(
'class' => 'ultimate-cron-admin-start',
),
array(
'class' => 'ultimate-cron-admin-end',
),
array(
'class' => 'ultimate-cron-admin-duration',
),
array(
'class' => 'ultimate-cron-admin-service-host',
),
array(
'class' => 'ultimate-cron-admin-status ultimate-cron-admin-status-running',
),
array(
'class' => 'ultimate-cron-admin-message',
),
);
$duration = time() - $process->start_stamp;
$duration = gmdate('H:i:s', (int) $duration);
$progress = progress_get_progress($handle_prefix . $function);
if ($progress && $progress->progress > 0) {
$duration .= sprintf(" (%d%%)", $progress->progress * 100);
}
$data[0]['data'] = format_date((int) $process->start_stamp, 'custom', 'Y-m-d H:i:s');
$data[1]['data'] = t('N/A');
$data[2]['data'] = $duration;
$data[3]['data'] = $process->service_host ? $process->service_host : t('N/A');
$data[4]['data'] = '<span>' . t('running') . '</span>';
$data[5]['data'] = '';
$rows[] = $data;
}
foreach ($logs as $log) {
$log->function = $log->name;
$log->status = $log->exec_status;
$log->start = $log->start_stamp;
$log->end = $log->end_stamp;
$severity_type = $log->severity < 0 ? 'success' : ($log->severity >= WATCHDOG_NOTICE ? 'info' : ($log->severity >= WATCHDOG_WARNING ? 'warning' : 'error'));
$css_status = $severity_type;
$data = array(
array(
'class' => 'ultimate-cron-admin-start',
),
array(
'class' => 'ultimate-cron-admin-end',
),
array(
'class' => 'ultimate-cron-admin-duration',
),
array(
'class' => 'ultimate-cron-admin-service-host',
),
array(
'class' => 'ultimate-cron-admin-status ultimate-cron-admin-status-' . $css_status,
),
array(
'class' => 'ultimate-cron-admin-message',
),
);
$data[0]['data'] = format_date((int) $log->start, 'custom', 'Y-m-d H:i:s');
$data[1]['data'] = format_date((int) $log->end, 'custom', 'Y-m-d H:i:s');
$data[2]['data'] = gmdate('H:i:s', (int) ($log->end - $log->start));
$data[3]['data'] = $log->service_host;
$data[4]['data'] = '<span>' . $log->status . '</span>';
$data[5]['data'] = $log->msg;
$rows[] = $data;
}
$output .= theme('table', $header, $rows);
$output .= theme('pager');
return $output;
}
function ultimate_cron_service_start($function) {
$hooks = ultimate_cron_get_hooks();
if (!isset($hooks[(string) $function])) {
drupal_not_found();
exit;
}
if ($modules = _ultimate_cron_incompatible_modules()) {
drupal_set_message(t('%function could not start (incompatible module installed)', array(
'%function' => $function,
)), 'error');
drupal_set_message(t('%modules is installed on the system, but is incompatible with Ultimate Cron.<br/>Please disable the conflicting modules.<br/>You might want to !url settings first.', array(
'%modules' => join(', ', $modules),
'!url' => l(t('import'), 'admin/settings/cron/import'),
)), 'error');
drupal_goto();
}
if (!empty($hooks['unsafe'])) {
drupal_set_message(t('%function could not start (unsafe)', array(
'%function' => $function,
)), 'error');
drupal_goto();
}
$hooks[$function]['skip_catch_up'] = TRUE;
ultimate_cron_load_hook_data($hooks[$function]);
$handle = ultimate_cron_run_hook($function, $hooks[$function]);
if ($handle === FALSE) {
drupal_set_message(t('%function could not start (already running?)', array(
'%function' => $function,
)), 'error');
}
elseif ($handle === NULL) {
drupal_set_message(t('%function could not start (service unavailable)', array(
'%function' => $function,
)), 'error');
}
else {
drupal_set_message(t('%function started', array(
'%function' => $function,
)));
}
drupal_goto();
}
function ultimate_cron_service_enable($function, $enabled) {
$conf = ultimate_cron_get_settings($function);
$conf['enabled'] = $enabled;
ultimate_cron_set_settings($function, $conf);
drupal_goto();
}
function ultimate_cron_import_form() {
$form = array();
$options = array();
if (module_exists('parallel_cron')) {
$options['parallel_cron'] = 'Parallel Cron';
}
if ($options) {
$form['import']['module'] = array(
'#type' => 'select',
'#options' => $options,
'#title' => t('Module'),
'#description' => t('Module to import settings from'),
);
$form['import']['submit'] = array(
'#type' => 'submit',
'#submit' => array(
'ultimate_cron_import_form_submit',
),
'#value' => t('Import'),
);
}
return $form;
}
function ultimate_cron_import_form_submit($form, &$form_state) {
switch ($form_state['values']['module']) {
case 'parallel_cron':
return _ultimate_cron_import_parallel_cron();
}
}
function _ultimate_cron_import_parallel_cron() {
$result = db_query("SELECT j.function, j.rule, j.active, g.name AS `group` FROM {parallel_cron_jobs} j LEFT JOIN {parallel_cron_groups} g ON j.gid = g.gid");
$imported = 0;
$conf = array();
while ($row = db_fetch_object($result)) {
$conf = ultimate_cron_get_settings($row->function);
if (!is_null($conf)) {
$conf['enabled'] = $row->active ? 1 : 0;
$rule = trim($row->rule);
if (!empty($rule)) {
$conf['rules'] = array(
trim($row->rule),
);
}
$conf['service_group'] = $row->group;
ultimate_cron_set_settings($row->function, $conf);
drupal_set_message(t('Imported %function', array(
'%function' => $row->function,
)));
$imported++;
}
}
drupal_set_message(t('Imported %imported settings', array(
'%imported' => $imported,
)));
}
function _ultimate_cron_l($text, $path) {
return l('<span>' . t($text) . '</span>', $path, array(
'query' => drupal_get_destination(),
'html' => TRUE,
));
}
