View source
<?php
function background_process_settings_form() {
$form = array();
$form['background_process_service_timeout'] = array(
'#type' => 'textfield',
'#title' => t('Service timeout'),
'#description' => t('Timeout for service call in seconds (0 = disabled)'),
'#default_value' => variable_get('background_process_service_timeout', BACKGROUND_PROCESS_SERVICE_TIMEOUT),
);
$form['background_process_connection_timeout'] = array(
'#type' => 'textfield',
'#title' => t('Connection timeout'),
'#description' => t('Timeout for connection in seconds'),
'#default_value' => variable_get('background_process_connection_timeout', BACKGROUND_PROCESS_CONNECTION_TIMEOUT),
);
$form['background_process_stream_timeout'] = array(
'#type' => 'textfield',
'#title' => t('Stream timeout'),
'#description' => t('Timeout for stream in seconds'),
'#default_value' => variable_get('background_process_stream_timeout', BACKGROUND_PROCESS_STREAM_TIMEOUT),
);
$form['background_process_redispatch_threshold'] = array(
'#type' => 'textfield',
'#title' => t('Redispatch threshold (for locked processes)'),
'#description' => t('Seconds to wait before redispatching processes that never started.'),
'#default_value' => variable_get('background_process_redispatch_threshold', BACKGROUND_PROCESS_REDISPATCH_THRESHOLD),
);
$form['background_process_cleanup_age'] = array(
'#type' => 'textfield',
'#title' => t('Cleanup age'),
'#description' => t('Unlock processes that have been more than X seconds to start.'),
'#default_value' => variable_get('background_process_cleanup_age', BACKGROUND_PROCESS_CLEANUP_AGE),
);
$form['background_process_cleanup_age_running'] = array(
'#type' => 'textfield',
'#title' => t('Cleanup age for running jobs'),
'#description' => t('Unlock processes that have been running for more than X seconds.'),
'#default_value' => variable_get('background_process_cleanup_age_running', BACKGROUND_PROCESS_CLEANUP_AGE_RUNNING),
);
$form['background_process_cleanup_age_queue'] = array(
'#type' => 'textfield',
'#title' => t('Cleanup age for queued jobs'),
'#description' => t('Unlock queued processes that have been more than X seconds to start.'),
'#default_value' => variable_get('background_process_cleanup_age_queue', BACKGROUND_PROCESS_CLEANUP_AGE_QUEUE),
);
$form['background_process_use_double_encoding'] = array(
'#type' => 'checkbox',
'#title' => t('Use double encoding of URLs'),
'#description' => t('When using Apache, mod_rewrite and clean urls, this should be checked.'),
'#default_value' => variable_get('background_process_use_double_encoding', BACKGROUND_PROCESS_USE_DOUBLE_ENCODING),
);
$form['background_process_enable_diagnostics'] = array(
'#type' => 'checkbox',
'#title' => t('Enable diagnostics'),
'#description' => t('Background Process will wait for http requests to return, and log the result in watchdog. Should only be enabled for troubleshooting purposes, when there\'s a problem.'),
'#default_value' => variable_get('background_process_enable_diagnostics', FALSE),
);
$options = background_process_get_service_hosts();
foreach ($options as $key => &$value) {
$new = empty($value['description']) ? $key : $value['description'];
$base_url = empty($value['base_url']) ? $base_url : $value['base_url'];
$http_host = empty($value['http_host']) ? parse_url($base_url, PHP_URL_HOST) : $value['http_host'];
$new .= ' (' . $base_url . ' - ' . $http_host . ')';
$value = $new;
}
$form['background_process_default_service_host'] = array(
'#type' => 'select',
'#title' => t('Default service host'),
'#description' => t('The default service host to use'),
'#options' => $options,
'#default_value' => variable_get('background_process_default_service_host', 'default'),
);
$methods = module_invoke_all('service_group');
$options = background_process_get_service_groups();
foreach ($options as $key => &$value) {
$value = (empty($value['description']) ? $key : $value['description']) . ' (' . join(',', $value['hosts']) . ') : ' . $methods['methods'][$value['method']];
}
$form['background_process_default_service_group'] = array(
'#type' => 'select',
'#title' => t('Default service group'),
'#description' => t('The default service group to use.'),
'#options' => $options,
'#default_value' => variable_get('background_process_default_service_group', 'default'),
);
$form = system_settings_form($form);
$form['buttons']['#weight'] = 1000;
$form['buttons']['determine'] = array(
'#value' => t("Determine default service host"),
'#description' => t('Tries to determine the default service host.'),
'#type' => 'submit',
'#submit' => array(
'background_process_settings_form_determine_submit',
),
);
return $form;
}
function background_process_settings_form_determine_submit($form, &$form_state) {
background_process_determine_and_save_default_service_host();
}
function background_process_overview_page() {
$processes = background_process_get_processes();
$data = array();
foreach ($processes as $process) {
$progress = progress_get_progress($process->handle);
$data[] = array(
$process->handle,
$process->callback,
$process->uid,
$process->service_host,
format_date((int) $process->start, 'custom', 'Y-m-d H:i:s'),
$progress ? sprintf("%.02f%%", $progress->progress * 100) : t('N/A'),
l(t('Unlock'), 'background-process/unlock/' . $process->handle, array(
'attributes' => array(
'class' => 'button-unlock',
),
'query' => drupal_get_destination(),
)),
);
}
$header = array(
'Handle',
'Callback',
'User',
'Host',
'Start time',
'Progress',
'',
);
$output = '';
$output .= theme('table', $header, $data, array(
'class' => 'background-process-overview',
));
return $output;
}
function background_process_service_unlock($handle) {
if (background_process_unlock($handle)) {
drupal_set_message(t('Process %handle unlocked', array(
'%handle' => $handle,
)));
}
else {
drupal_set_message(t('Process %handle could not be unlocked', array(
'%handle' => $handle,
)), 'error');
}
drupal_goto();
}
