status_chk() != 1) { $remote_servers_offline[$rhost_id] = $remote_server; continue; } else { $jobs = $remote->scheduler_list_tasks(); if($jobs != -1) { foreach($jobs as $jobId => $job) { $parts = explode(" ", $job); $minute = $parts[0]; $hour = $parts[1]; $dayOfTheMonth = $parts[2]; $month = $parts[3]; $dayOfTheWeek = $parts[4]; unset($parts[0],$parts[1],$parts[2],$parts[3],$parts[4]); $command = implode(" ", $parts); $retval = preg_match_all("/^%ACTION=(start|restart|stop)\|%\|(.*)$/", $command, $job_info ); if($retval and !empty($job_info[1][0])) { //print_r($job_info); $action = $job_info[1][0]; $server_args = explode("|%|", $job_info[2][0]); switch ($action) { case 'start': list($home_id, $home_path, $server_exe, $run_dir, $startup_cmd, $port, $ip, $cpu, $nice) = $server_args; break; case 'restart': list($home_id, $ip, $port, $control_protocol, $control_password, $control_type, $home_path, $server_exe, $run_dir, $startup_cmd, $cpu, $nice) = $server_args; break; case 'stop': list($home_id, $ip, $port, $control_protocol, $control_password, $control_type, $home_path) = $server_args; break; } if(!isset($server_homes[$home_id."_".$ip."_".$port])) continue; $jobsArray[$rhost_id][$jobId] = array( 'job' => $job, 'minute' => $minute, 'hour' => $hour, 'dayOfTheMonth' => $dayOfTheMonth, 'month' => $month, 'dayOfTheWeek' => $dayOfTheWeek, 'action' => $action, 'home_id' => $home_id, 'ip' => $ip, 'port' => $port); } } } } } return array($jobsArray, $remote_servers_offline); } function get_action_selector($action = false) { $server_actions = array('restart','stop','start'); $select_action = ''; } function get_server_selector($server_homes, $homeid_ip_port = FALSE, $onchange = FALSE) { $onchange_this_form_submit = $onchange ? 'onchange="this.form.submit();"' : ''; $select_game = "\n"; } function get_remote_server_selector($r_servers, $remote_servers_offline, $remote_server_id = FALSE, $onchange = FALSE) { $onchange_this_form_submit = $onchange ? 'onchange="this.form.submit();"' : ''; $select_rserver = "\n"; } function exec_ogp_module() { global $db; $homes = $db->getIpPortsForUser($_SESSION['user_id']); if(!$homes) { print_failure('There are no game servers assigned'); return 0; } foreach( $homes as $home ) { $id = $home['home_id']."_".$home['ip']."_".$home['port']; $server_homes[$id] = $home; $server_id = $home['remote_server_id']; $remote_servers[$server_id] = array("remote_server_id" => $home['remote_server_id'], "remote_server_name" => $home['remote_server_name'], "ogp_user" => $home['ogp_user'], "agent_ip" => $home['agent_ip'], "agent_port" => $home['agent_port'], "ftp_port" => $home['ftp_port'], "encryption_key" => $home['encryption_key'], "timeout" => $home['timeout'], "use_nat" => $home['use_nat'], "ftp_ip" => $home['ftp_ip']); } list($jobsArray, $remote_servers_offline) = reloadJobs($server_homes, $remote_servers); if( isset($_POST['addJob']) or isset($_POST['editJob']) ) { if ( isset( $_POST['homeid_ip_port'] ) and isset($server_homes[$_POST['homeid_ip_port']]) ) { $game_home = $server_homes[$_POST['homeid_ip_port']]; $server_xml = read_server_config(SERVER_CONFIG_LOCATION."/".$game_home['home_cfg_file']); $remote = new OGPRemoteLibrary( $game_home['agent_ip'], $game_home['agent_port'], $game_home['encryption_key'], $game_home['timeout']); $home_id = $game_home['home_id']; $ip = $game_home['ip']; $port = $game_home['port']; $control_protocol = $server_xml->control_protocol; $control_password = $game_home['control_password']; $control_type = $server_xml->control_protocol_type; $home_path = $game_home['home_path']; $server_exe = $server_xml->server_exec_name; $run_dir = $server_xml->exe_location; $game_home['mods'][$game_home['mod_id']] = Array ("mod_cfg_id" => $game_home['mod_cfg_id'], "max_players" => $game_home['max_players'], "extra_params" => $game_home['extra_params'], "cpu_affinity" => $game_home['cpu_affinity'], "nice" => $game_home['nice'], "precmd" => $game_home['precmd'], "postcmd" => $game_home['postcmd'], "home_cfg_id" => $game_home['home_cfg_id'], "mod_key" => $game_home['mod_key'], "mod_name" => $game_home['mod_name'], "def_precmd" => $game_home['def_precmd'], "def_postcmd" => $game_home['def_postcmd']); $startup_cmd = get_start_cmd($remote,$server_xml,$game_home,$game_home['mod_id'],$game_home['ip'],$game_home['port']); $cpu = $game_home['cpu_affinity']; $nice = $game_home['nice']; switch ($_POST['action']) { case "stop": $command = "%ACTION=stop|%|$home_id|%|$ip|%|$port|%|". "$control_protocol|%|$control_password|%|$control_type|%|$home_path"; break; case "start": $command = "%ACTION=start|%|$home_id|%|$home_path|%|$server_exe|%|$run_dir|%|". "$startup_cmd|%|$port|%|$ip|%|$cpu|%|$nice"; break; case "restart": $command = "%ACTION=restart|%|$home_id|%|$ip|%|$port|%|$control_protocol|%|". "$control_password|%|$control_type|%|$home_path|%|$server_exe|%|$run_dir|%|". "$startup_cmd|%|$cpu|%|$nice"; break; } $job = $_POST['minute']." ". $_POST['hour']." ". $_POST['dayOfTheMonth']." ". $_POST['month']." ". $_POST['dayOfTheWeek']." ". $command; if( isset($_POST['editJob']) and isset($jobsArray[$_POST['r_server_id']][$_POST['job_id']]) ) $remote->scheduler_edit_task($_POST['job_id'], $job); elseif( isset($_POST['addJob']) ) $remote->scheduler_add_task($job); list($jobsArray, $remote_servers_offline) = reloadJobs($server_homes, $remote_servers); } } elseif( isset($_POST['removeJob']) and isset($remote_servers[$_POST['r_server_id']]) and isset($jobsArray[$_POST['r_server_id']][$_POST['job_id']]) ) { $remote = new OGPRemoteLibrary( $remote_servers[$_POST['r_server_id']]['agent_ip'], $remote_servers[$_POST['r_server_id']]['agent_port'], $remote_servers[$_POST['r_server_id']]['encryption_key'], $remote_servers[$_POST['r_server_id']]['timeout'] ); $remote->scheduler_del_task($_POST['job_id']); list($jobsArray, $remote_servers_offline) = reloadJobs($server_homes, $remote_servers); } echo "

" . schedule_new_job . "

"; require_once("includes/refreshed.php"); $refresh = new refreshed(); $homeid_ip_port = isset($_POST['homeid_ip_port']) ? $_POST['homeid_ip_port'] : key($server_homes); $r_server_id = $server_homes[$homeid_ip_port]['remote_server_id']; $curtime = $refresh->add( "home.php?m=cron&p=thetime&r_server_id=$r_server_id&type=cleared" ); echo "
" . get_server_selector($server_homes, $homeid_ip_port, TRUE) .
		 "
 " . $refresh->getdiv($curtime) . "
"; ?>

$jobs ) { foreach($jobs as $jobId => $job) { if(isset($job['action'])) { $user_jobs .= ''; } } } echo $user_jobs; ?>
'.get_action_selector($job['action'])."". get_server_selector($server_homes, $job['home_id']."_".$job['ip']."_".$job['port']).'
". there_are_no_scheduled_jobs .""; ?>
<<