File sandbox
";
page_tail();
}
// verify that an input file exists in sandbox, and return its physical path
//
function get_file_path($user, $name) {
$fname = get_str($name);
// verify that the files exist in sandbox
//
$sbdir = sandbox_dir($user);
list($error, $size, $md5) = sandbox_parse_link_file("$sbdir/$fname");
if ($error) error_page("no $name file");
return sandbox_physical_path($user, $md5);
}
function project_flops() {
$x = BoincUser::sum("expavg_credit");
if ($x == 0) $x = 200;
$y = 1e9*$x/200;
return $y;
}
// Estimate how long a batch will take.
// Let N = # jobs, M = # hosts
// If N < M we can start all the jobs more or less now,
// so let T = F/H, where H is the median FLOPS of the hosts.
// If N > M we'll have to do the jobs in stages,
// so let T = ceil(N/M)*F/H.
//
// Note: these are both extremely optimistic estimates
//
function estimated_makespan($njobs, $flops_per_job) {
$nhosts = BoincHost::count("expavg_credit > 1");
if ($nhosts < 10) {
$median_flops = 2e9;
} else {
$n = (int)($nhosts/2);
$hs = BoincHost::enum("expavg_credit>1 order by p_fpops limit $n,1");
$h = $hs[0];
$median_flops = $h->p_fpops;
}
if ($njobs < $nhosts) {
return $flops_per_job/$median_flops;
} else {
$k = (int)(($njobs+$nhosts-1)/$nhosts);
return $k*$flops_per_job/$median_flops;
}
}
function prepare_batch($user) {
$structure_file_path = get_file_path($user, 'structure_file');
$command_file_path = get_file_path($user, 'lammps_script');
$cmdline_file_path = get_file_path($user, 'cmdline_file');
$pot_files_path = get_file_path($user, 'zip');
$info = new StdClass;
$info->structure_file_path = $structure_file_path;
$info->command_file_path = $command_file_path;
$info->cmdline_file_path = $cmdline_file_path;
$info->pot_files_path = $pot_files_path;
$info->area = get_str("area");
// get the directory in which to run the test,
// clear it out,
// and set up links to the input files
//
$test_dir = "../../lammps_test/$user->id";
//echo "test_dir is ".$test_dir;
if (!is_dir($test_dir)) {
mkdir($test_dir);
}
$old_dir = getcwd();
if (!chdir($test_dir)) {
error_page("Can't chdir");
}
system("rm *");
symlink($structure_file_path, "structure_file");
symlink($command_file_path, "lammps_script");
symlink($cmdline_file_path, "cmd_variables");
symlink($pot_files_path, "pot_files");
list($error, $est_cpu_time, $disk) = lammps_est();
if ($GLOBALS["debug"]) {
print "est_cpu_time is ".$est_cpu_time."
";
}
if ($error==0) {
$err_msgs=file("output");
$err="Your test job failed
Please refer to the following Error Message:
";
foreach($err_msgs as $line){
$err=$err.$line."
";
}
$err=$err."
File_Sandbox "; error_page($err); } system("rm *"); $info->rsc_fpops_est = $est_cpu_time * 1.5e9; $info->rsc_fpops_bound = $info->rsc_fpops_est * 20; if ($disk==0){ $info->rsc_disk_bound=1000000; } else{ $info->rsc_disk_bound = $disk; } $tmpfile = tempnam("/tmp", "lammps_"); file_put_contents($tmpfile, serialize($info)); // get the # of jobs // $njobs = count(file($cmdline_file_path)); $secs_est = estimated_makespan($njobs, $info->rsc_fpops_est); if($GLOBALS["debug"])echo "secs_est is $secs_est\n"; //assume the server's flops is 1.5G and the average client's flops is 1G $hrs_est = number_format($secs_est*1.5/60, 2); //$hrs_est = number_format($secs_est, 2); $client_mb = number_format($info->rsc_disk_bound/1e6, 1); $server_mb = number_format($njobs*$info->rsc_disk_bound/1e6, 1); chdir($old_dir); page_head("Batch prepared"); echo " Your batch has $njobs jobs.
Estimated time to completion: $hrs_est Minutes.
Estimated client disk usage: $client_mb MB
Estimated server disk usage: $server_mb MB
";
show_button("lammps.php?action=submit&tmpfile=$tmpfile", "Submit Batch");
page_tail();
}
function submit_job($app, $batch_id, $info, $cmdline, $i) {
$client_disk=$info->rsc_disk_bound*2;
if($client_disk<500000000) $client_disk=500000000;
$cmd = "cd ../..; ./bin/create_work --appname $app->name --batch $batch_id --rsc_fpops_est $info->rsc_fpops_est --rsc_fpops_bound $info->rsc_fpops_bound --rsc_disk_bound $client_disk";
if ($cmdline) {
$cmd .= " --command_line \"$cmdline\"";
}
$cmd .= " --wu_name batch_".$batch_id."_".$i;
$cmd .= " ".basename($info->structure_file_path);
$cmd .= " ".basename($info->command_file_path);
$cmd .= " ".basename($info->pot_files_path);
//echo "
$cmd\n";
system($cmd, $ret);
if ($ret === FALSE) {
error_page("can't create job");
} else {
header('Location: submit.php');
}
}
function submit_batch($user, $app) {
$tmpfile = get_str('tmpfile');
$x = file_get_contents("$tmpfile");
$info = unserialize($x);
$njobs=0;
$cmdlines = file($info->cmdline_file_path);
foreach ($cmdlines as $cmdline){
if (preg_match("/^\s*-var/", $cmdline)) {
$njobs++;
}
}
$now = time();
$batch_name = $info->area."_".date("Y-M-d D H:i:s");
$batch_id = BoincBatch::insert(
"(user_id, create_time, njobs, name, app_id, state) values ($user->id, $now, $njobs, '$batch_name', $app->id, ".BATCH_STATE_IN_PROGRESS.")"
);
// $batch_id=99;
$i = 0;
foreach ($cmdlines as $cmdline) {
if (preg_match("/^\s*-var/", $cmdline)){
submit_job($app, $batch_id, $info, $cmdline, $i);
$i++;
}
}
}
$user = get_logged_in_user();
$user_submit = BoincUserSubmit::lookup_userid($user->id);
if (!$user_submit) error_page("no submit access");
$app = BoincApp::lookup("name='lammps'");
if (!$app) error_page("no lammps app");
if (!$user_submit->submit_all) {
$usa = BoincUserSubmitApp::lookup("user_id=$user->id and app_id=$app->id");
if (!$usa) {
error_page("no submit access");
}
}
$action = get_str('action', true);
switch ($action) {
case '': show_submit_form($user); break;
case 'prepare': prepare_batch($user); break;
case 'submit': submit_batch($user, $app); break;
default: error_page("no such action $action");
}
?>