\n$s\n\n";
exit;
}
function handle_submit($r, $user, $app) {
global $app_name;
// read the list of template filenames
//
$files = file("../../tree_threader_template_files");
if ($files === false) error("no templates file");
$njobs = sizeof($files);
$now = time();
$batch_id = BoincBatch::insert(
"(user_id, create_time, njobs, name, app_id, state) values ($user->id, $now, $njobs, 'tree_threader batch', $app->id, ".BATCH_STATE_IN_PROGRESS.")"
);
if (!$batch_id) die("couldn't create batch\n");
// move the sequence file to the download hier
//
$config = simplexml_load_string(file_get_contents("../../config.xml"));
$fanout = (int)$config->config->uldl_dir_fanout;
$download_dir = trim((string)$config->config->download_dir);
$seq_fname = "three_threader_seq_$batch_id";
$seq_path = dir_hier_path($seq_fname, $download_dir, $fanout);
$tmp_name = $_FILES['seq_file']['tmp_name'];
$ret = rename($tmp_name, $seq_path);
if ($ret === false) {
error("couldn't rename sequence file");
}
$i = 0;
foreach ($files as $file) {
$file = trim($file);
$wu_name = "ICT_".$batch_id."_$i";
$cmd = "cd ../..; ./bin/create_work --appname $app_name --batch $batch_id --wu_name $wu_name --wu_template templates/ICT_in --result_template templates/ICT_out $file ss3.kmeans.8 $seq_fname";
$ret = system($cmd);
if ($ret === false) {
error("can't create job");
}
$i++;
}
echo "\n$batch_id\n\n";
}
// Enumerate all the successfully completed WUs for this batch.
// Each output file is a .zip that unzips into a directory ali/.
// Combine their output files into a zip file in /tmp,
// make a symbolic link to this from /download,
// and return the resulting URL
//
function handle_get_output($r, $batch) {
$wus = BoincWorkUnit::enum("batch=$batch->id");
$outdir = "/tmp/tree_threader_output_".$batch->id;
@mkdir($outdir);
foreach ($wus as $wu) {
if (!$wu->canonical_resultid) continue;
$result = BoincResult::lookup_id($wu->canonical_resultid);
if (!$result) continue;
$paths = get_outfile_paths($result);
if (sizeof($paths) < 1) continue;
// there's only one output file
//
$path = $paths[0];
// unzip it into a directory in /tmp
//
$dir = "/tmp/$wu->name";
@mkdir($dir);
$cmd = "cd $dir; unzip -q $path";
$ret = system($cmd);
if ($ret === false) {
error("can't unzip output file");
}
$cmd = "cp $dir/ali/* $outdir";
$ret = system($cmd);
if ($ret === false) {
error("can't copy output files");
}
//system("rm -rf $dir");
}
$cmd = "zip -r -q $outdir $outdir";
$ret = system($cmd);
if ($ret === false) {
error("can't zip output files");
}
$fname = "tree_threader_output_".$batch->id.".zip";
@symlink($outdir, "../../download/$fname");
$config = simplexml_load_string(file_get_contents("../../config.xml"));
$download_url = trim((string)$config->config->download_url);
echo "\n$download_url/$fname\n\n";
}
xml_header();
if (1) {
$r = simplexml_load_string($_POST['request']);
} else {
$x = file_get_contents("xml_req");
$r = simplexml_load_string($x);
}
if (!$r) {
error("can't parse request message");
}
// authenticate the user
//
$auth = (string)$r->auth;
$user = BoincUser::lookup("authenticator='$auth'");
if (!$user) error("invalid authenticator");
$user_submit = BoincUserSubmit::lookup_userid($user->id);
if (!$user_submit) error("no submit access");
$app = BoincApp::lookup("name='$app_name'");
if (!$app) error("no tree_threader app");
if (!$user_submit->submit_all) {
$usa = BoincUserSubmitApp::lookup("user_id=$user->id and app_id=$app->id");
if (!$usa) {
error("no submit access");
}
}
switch ((string)$r->action) {
case 'submit':
handle_submit($r, $user, $app);
break;
case 'get_output':
$batch_id = (int)$r->batch_id;
$batch = BoincBatch::lookup_id($batch_id);
if (!$batch) error("no such batch");
if ($batch->user_id != $user->id) error("not owner of batch");
handle_get_output($r, $batch);
break;
default: error("bad command");
}
?>