" );
$user = get_logged_in_user();
$jobapplicationname = mysql_fetch_object( mysql_query( "SELECT * FROM app WHERE id=".$jobapplication ) );
$app = $jobapplicationname;
$jobapplicationfriendlyname = $jobapplicationname -> user_friendly_name;
$jobapplicationname = $jobapplicationname -> name;
$title = "New job for '".$jobname."' ".$user -> name." at ".$timestr;
page_head( $title );
start_table();
row1( "Job speciffics" );
row2( "Job application: ", $jobapplicationfriendlyname );
row2( "Job name: ", $jobname );
row2( "Job estimated time to complete: ", floor( ( float )( $jobfops ) / 92254963740 )." min. " );
row2( "Job estimated memory usage: ", floor( ( float )( $jobmem ) / 1048576 )." Mb. " );
row2( "Job estimated disk usage: ", floor( ( float )( $jobdisk ) / 1048576 )." Mb. " );
row2( "Job input:", '' );
end_table();
if( ( $jobname == "" ) || strpos( $jobname, "queue" ) || strpos( $jobname, " " ) ||
strpos( $jobname, '"' ) || strpos( $jobname, "'" ) || strpos( $jobname, "`" ) ||
strpos( $jobname, "\\" ) )
exit_with_text( "The job name is invalid !" );
if( $jobinput == "" )
exit_with_text( "There was no input !" );
$appqmax = nr_of_jobs_for_user_for_app( $user, $app );
$appsubmitted = nr_of_submitted_jobs_for_user_for_app( $user, $app );
if( $appqmax <= $appsubmitted )
exit_with_text( "Job limit would be exceeded!" );
$bin_dir = parse_config( $config, "" );
$download_dir = parse_config( $config, "" );
$upload_dir = parse_config( $config, "" );
$template_dir = parse_config( $config, "" );
$config_dir = parse_config( $config, "" );
$createworkprogram = parse_config( $config, "" );
$extendedjobname = $jobname."_queue_".$jobapplication."_".time(0)."_".random_string();
$extendedjobname = escapeshellcmd( $extendedjobname );
$wu_template = $template_dir."/queue_".$jobapplicationname."_work_unit_template";
$result_template = $template_dir."/queue_".$jobapplicationname."_result_unit_template";
$temporaryinputfile = $extendedjobname;
$command_to_submit = $bin_dir."/".$createworkprogram;
$command_to_submit .= " -config_dir ".$config_dir;
$command_to_submit .= " -appname ".$jobapplicationname;
$command_to_submit .= " -wu_name ".$extendedjobname;
$command_to_submit .= " -wu_template ".$wu_template;
$command_to_submit .= " -result_template ".$result_template;
$command_to_submit .= " -rsc_fpops_est ".floor( ( float )( $jobfops ) );
$command_to_submit .= " -rsc_fpops_bound ".floor( 3.0 * ( float )( $jobfops ) );
$command_to_submit .= " -rsc_memory_bound ".floor( ( float )( $jobmem ) );
$command_to_submit .= " -rsc_disk_bound ".floor( ( float )( $jobdisk ) );
$command_to_submit .= " -priority 10 -batch ".$user -> id;
$command_to_submit .= " ".$temporaryinputfile;
$command_to_submit = escapeshellcmd( $command_to_submit );
$command_to_submit = "cd ".$config_dir."; ".$command_to_submit;
$temporaryinputfile = $download_dir."/".$temporaryinputfile;
$filehandle = fopen( $temporaryinputfile, "w" );
if( !$filehandle )
exit_with_text( "Cannot create the temporary input file !" );
if( !fwrite( $filehandle, $jobinput ) )
{
fclose( $filehandle );
exit_with_text( "Cannot write to the temporary input file !" );
}
fclose( $filehandle );
// We at Leiden Classical have a special mode for our app, it can verify the user supplied
// input and return an exit code signaling an error. We tend to parse the input before let
// it run on our desktop pool ;-)... Here's how...
//
// if( strpos( $jobapplicationname, "classical" ) !== false )
// {
// $testinputcommand = $bin_dir."/verify_classical_input ".$temporaryinputfile." /dev/null /dev/stdout /dev/stdout";
// $testinputcommand = escapeshellcmd( $testinputcommand );
// $testinputcommand = "cd ".$config_dir."; ".$testinputcommand;
// $errorline = 0;
// exec( $testinputcommand, &$outputoftest, &$errorline );
// if( $errorline != 0 )
// {
// $errorstring = "Your input had an error on line ".$errorline." ! The job was not submitted !";
// unlink( $temporaryinputfile );
// exit_with_text( $errorstring );
// }
// }
system( $command_to_submit );
unlink( $temporaryinputfile );
$workunit = mysql_fetch_object( mysql_query( "SELECT * FROM workunit WHERE name='".$extendedjobname."'" ) );
if( !$workunit )
exit_with_text( "Error during submition of the workunit associated with your job !" );
$qlistentry = mysql_query( "INSERT INTO q_list VALUES('','".$user->id."','".$workunit->id."')" );
if( !$qlistentry )
exit_with_text( "Error during submition of your job !" );
$jobidlink = ''.$jobname.' ('.$workunit -> id.')';
start_table();
row1( "Your job has been submitted !" );
row2( "Job status: ", workunit_status_string( $workunit ) );
row2( "Job id: ", $jobidlink );
row1( "Commands" );
row2( "Status of this job: ", 'Show job status' );
$max_jobs = max_nr_of_jobs_of_user( $user );
$njobs = nr_of_jobs_of_user( $user );
if( $njobs < $max_jobs )
{
if( $max_jobs - $njobs > 1 )
$line = "You can submit ".($max_jobs-$njobs)." more jobs: ";
else
$line = "You can submit one more job: ";
row2( $line, 'Submit another job' );
}
row2( "", 'Go back to your queue' );
row2( "", 'Log out' );
end_table();
page_tail();
?>