@@ -61,7 +61,7 @@ discard block |
||
61 | 61 | foreach ($files as $file) { |
62 | 62 | $path = "$dir/$file"; |
63 | 63 | [$err, $file_size, $file_md5] = sandbox_parse_link_file($path); |
64 | - if (!$err){ |
|
64 | + if (!$err) { |
|
65 | 65 | if (strcmp($md5, $file_md5) == 0) { |
66 | 66 | $exist = true; |
67 | 67 | $elf = $file; |
@@ -124,7 +124,7 @@ discard block |
||
124 | 124 | } |
125 | 125 | $files = sandbox_file_names($user); |
126 | 126 | foreach ($files as $f) { |
127 | - if ($regexp && !preg_match("/$regexp/",$f)) continue; |
|
127 | + if ($regexp && !preg_match("/$regexp/", $f)) continue; |
|
128 | 128 | $x .= "<option value=\"$f\">$f</option>\n"; |
129 | 129 | } |
130 | 130 | $x .= "</select>\n"; |
@@ -154,7 +154,7 @@ discard block |
||
154 | 154 | // TODO: this is a kludge. |
155 | 155 | // Should we use the job_file and batch_file_assoc tables instead? |
156 | 156 | // |
157 | -function sandbox_file_in_use($user, $file){ |
|
157 | +function sandbox_file_in_use($user, $file) { |
|
158 | 158 | $ufiles = array(); |
159 | 159 | |
160 | 160 | $pbatches = BoincBatch::enum( |
@@ -164,16 +164,16 @@ discard block |
||
164 | 164 | ); |
165 | 165 | if (!$pbatches) return false; |
166 | 166 | |
167 | - foreach ($pbatches as $batch){ |
|
168 | - $wus = BoincWorkUnit::enum("batch = $batch->id limit 1" ); |
|
169 | - if ($wus == null){ |
|
167 | + foreach ($pbatches as $batch) { |
|
168 | + $wus = BoincWorkUnit::enum("batch = $batch->id limit 1"); |
|
169 | + if ($wus == null) { |
|
170 | 170 | continue; |
171 | 171 | } |
172 | - foreach($wus as $wu){ |
|
172 | + foreach ($wus as $wu) { |
|
173 | 173 | $x = "<in>".$wu->xml_doc."</in>"; |
174 | 174 | $x = simplexml_load_string($x); |
175 | 175 | global $fanout; |
176 | - foreach($x->workunit->file_ref as $fr){ |
|
176 | + foreach ($x->workunit->file_ref as $fr) { |
|
177 | 177 | $pname = (string)$fr->file_name; |
178 | 178 | $ufiles[] = $pname; |
179 | 179 | } |
@@ -182,10 +182,10 @@ discard block |
||
182 | 182 | $dir = sandbox_dir($user); |
183 | 183 | $path = $dir."/".$file; |
184 | 184 | list($err, $size, $md5) = sandbox_parse_link_file($path); |
185 | - if (!$err){ |
|
185 | + if (!$err) { |
|
186 | 186 | $f = sandbox_file_name($user, $md5); |
187 | - foreach($ufiles as $uf) { |
|
188 | - if (strcmp($f,$uf) == 0){ |
|
187 | + foreach ($ufiles as $uf) { |
|
188 | + if (strcmp($f, $uf) == 0) { |
|
189 | 189 | return true; |
190 | 190 | } |
191 | 191 | } |
@@ -61,7 +61,7 @@ discard block |
||
61 | 61 | foreach ($files as $file) { |
62 | 62 | $path = "$dir/$file"; |
63 | 63 | [$err, $file_size, $file_md5] = sandbox_parse_link_file($path); |
64 | - if (!$err){ |
|
64 | + if (!$err) { |
|
65 | 65 | if (strcmp($md5, $file_md5) == 0) { |
66 | 66 | $exist = true; |
67 | 67 | $elf = $file; |
@@ -154,7 +154,7 @@ discard block |
||
154 | 154 | // TODO: this is a kludge. |
155 | 155 | // Should we use the job_file and batch_file_assoc tables instead? |
156 | 156 | // |
157 | -function sandbox_file_in_use($user, $file){ |
|
157 | +function sandbox_file_in_use($user, $file) { |
|
158 | 158 | $ufiles = array(); |
159 | 159 | |
160 | 160 | $pbatches = BoincBatch::enum( |
@@ -164,16 +164,16 @@ discard block |
||
164 | 164 | ); |
165 | 165 | if (!$pbatches) return false; |
166 | 166 | |
167 | - foreach ($pbatches as $batch){ |
|
167 | + foreach ($pbatches as $batch) { |
|
168 | 168 | $wus = BoincWorkUnit::enum("batch = $batch->id limit 1" ); |
169 | - if ($wus == null){ |
|
169 | + if ($wus == null) { |
|
170 | 170 | continue; |
171 | 171 | } |
172 | - foreach($wus as $wu){ |
|
172 | + foreach($wus as $wu) { |
|
173 | 173 | $x = "<in>".$wu->xml_doc."</in>"; |
174 | 174 | $x = simplexml_load_string($x); |
175 | 175 | global $fanout; |
176 | - foreach($x->workunit->file_ref as $fr){ |
|
176 | + foreach($x->workunit->file_ref as $fr) { |
|
177 | 177 | $pname = (string)$fr->file_name; |
178 | 178 | $ufiles[] = $pname; |
179 | 179 | } |
@@ -182,10 +182,10 @@ discard block |
||
182 | 182 | $dir = sandbox_dir($user); |
183 | 183 | $path = $dir."/".$file; |
184 | 184 | list($err, $size, $md5) = sandbox_parse_link_file($path); |
185 | - if (!$err){ |
|
185 | + if (!$err) { |
|
186 | 186 | $f = sandbox_file_name($user, $md5); |
187 | 187 | foreach($ufiles as $uf) { |
188 | - if (strcmp($f,$uf) == 0){ |
|
188 | + if (strcmp($f,$uf) == 0) { |
|
189 | 189 | return true; |
190 | 190 | } |
191 | 191 | } |
@@ -59,7 +59,7 @@ discard block |
||
59 | 59 | if ($template) { |
60 | 60 | $t = (double)$template->workunit->rsc_fpops_est; |
61 | 61 | } |
62 | - foreach($r->batch->job as $job) { |
|
62 | + foreach ($r->batch->job as $job) { |
|
63 | 63 | $y = (double)$job->rsc_fpops_est; |
64 | 64 | if ($y) { |
65 | 65 | $x += $y; |
@@ -85,7 +85,7 @@ discard block |
||
85 | 85 | function est_elapsed_time($r, $template) { |
86 | 86 | // crude estimate: batch FLOPs / project FLOPS |
87 | 87 | // |
88 | - return batch_flop_count($r, $template) / project_flops(); |
|
88 | + return batch_flop_count($r, $template)/project_flops(); |
|
89 | 89 | } |
90 | 90 | |
91 | 91 | // if batch-level input template filename was given, read it; |
@@ -95,9 +95,9 @@ discard block |
||
95 | 95 | // |
96 | 96 | function read_input_template($app, $r) { |
97 | 97 | if ((isset($r->batch)) && (isset($r->batch->workunit_template_file)) && ($r->batch->workunit_template_file)) { |
98 | - $path = project_dir() . "/templates/".$r->batch->workunit_template_file; |
|
98 | + $path = project_dir()."/templates/".$r->batch->workunit_template_file; |
|
99 | 99 | } else { |
100 | - $path = project_dir() . "/templates/$app->name"."_in"; |
|
100 | + $path = project_dir()."/templates/$app->name"."_in"; |
|
101 | 101 | } |
102 | 102 | if (file_exists($path)) { |
103 | 103 | $x = simplexml_load_file($path); |
@@ -142,7 +142,7 @@ discard block |
||
142 | 142 | function validate_batch($jobs, $template) { |
143 | 143 | $i = 0; |
144 | 144 | $n = count($template->file_info); |
145 | - foreach($jobs as $job) { |
|
145 | + foreach ($jobs as $job) { |
|
146 | 146 | $m = count($job->input_files); |
147 | 147 | if ($n != $m) { |
148 | 148 | log_write("wrong # of input files for job $i: need $n, got $m"); |
@@ -211,7 +211,7 @@ discard block |
||
211 | 211 | // stage all the files |
212 | 212 | // |
213 | 213 | function stage_files(&$jobs, $user) { |
214 | - foreach($jobs as $job) { |
|
214 | + foreach ($jobs as $job) { |
|
215 | 215 | foreach ($job->input_files as $file) { |
216 | 216 | if ($file->mode != "remote") { |
217 | 217 | $file->name = stage_file($file, $user); |
@@ -224,7 +224,7 @@ discard block |
||
224 | 224 | // |
225 | 225 | function submit_jobs( |
226 | 226 | $jobs, $job_params, $app, $batch_id, $priority, $app_version_num, |
227 | - $input_template_filename, // batch-level; can also specify per job |
|
227 | + $input_template_filename, // batch-level; can also specify per job |
|
228 | 228 | $output_template_filename, |
229 | 229 | $user |
230 | 230 | ) { |
@@ -234,7 +234,7 @@ discard block |
||
234 | 234 | // one line per job |
235 | 235 | // |
236 | 236 | $x = ""; |
237 | - foreach($jobs as $job) { |
|
237 | + foreach ($jobs as $job) { |
|
238 | 238 | if ($job->name) { |
239 | 239 | $x .= " --wu_name $job->name"; |
240 | 240 | } |
@@ -269,7 +269,7 @@ discard block |
||
269 | 269 | $x .= "\n"; |
270 | 270 | } |
271 | 271 | |
272 | - $cmd = "cd " . project_dir() . "; ./bin/create_work --appname $app->name --batch $batch_id"; |
|
272 | + $cmd = "cd ".project_dir()."; ./bin/create_work --appname $app->name --batch $batch_id"; |
|
273 | 273 | |
274 | 274 | if ($user->seti_id) { |
275 | 275 | $cmd .= " --target_user $user->id "; |
@@ -377,7 +377,7 @@ discard block |
||
377 | 377 | // |
378 | 378 | function xml_get_jobs($r) { |
379 | 379 | $jobs = array(); |
380 | - foreach($r->batch->job as $j) { |
|
380 | + foreach ($r->batch->job as $j) { |
|
381 | 381 | $job = new StdClass; |
382 | 382 | $job->input_files = array(); |
383 | 383 | $job->command_line = (string)$j->command_line; |
@@ -428,16 +428,16 @@ discard block |
||
428 | 428 | // |
429 | 429 | function logical_end_time($r, $jobs, $user, $app) { |
430 | 430 | $total_flops = 0; |
431 | - foreach($jobs as $job) { |
|
431 | + foreach ($jobs as $job) { |
|
432 | 432 | //print_r($job); |
433 | 433 | if ($job->rsc_fpops_est) { |
434 | 434 | $total_flops += $job->rsc_fpops_est; |
435 | 435 | } else if ($job->input_template && $job->input_template->workunit->rsc_fpops_est) { |
436 | - $total_flops += (double) $job->input_template->workunit->rsc_fpops_est; |
|
436 | + $total_flops += (double)$job->input_template->workunit->rsc_fpops_est; |
|
437 | 437 | } else if ($r->batch->job_params->rsc_fpops_est) { |
438 | - $total_flops += (double) $r->batch->job_params->rsc_fpops_est; |
|
438 | + $total_flops += (double)$r->batch->job_params->rsc_fpops_est; |
|
439 | 439 | } else { |
440 | - $x = (double) $template->workunit->rsc_fpops_est; |
|
440 | + $x = (double)$template->workunit->rsc_fpops_est; |
|
441 | 441 | if ($x) { |
442 | 442 | $total_flops += $x; |
443 | 443 | } else { |
@@ -445,7 +445,7 @@ discard block |
||
445 | 445 | } |
446 | 446 | } |
447 | 447 | } |
448 | - $cmd = "cd " . project_dir() . "/bin; ./adjust_user_priority --user $user->id --flops $total_flops --app $app->name"; |
|
448 | + $cmd = "cd ".project_dir()."/bin; ./adjust_user_priority --user $user->id --flops $total_flops --app $app->name"; |
|
449 | 449 | $x = exec($cmd); |
450 | 450 | if (!is_numeric($x) || (double)$x == 0) { |
451 | 451 | xml_error(-1, "$cmd returned $x"); |
@@ -530,15 +530,15 @@ discard block |
||
530 | 530 | } |
531 | 531 | |
532 | 532 | $job_params = new StdClass; |
533 | - $job_params->rsc_disk_bound = (double) $r->batch->job_params->rsc_disk_bound; |
|
534 | - $job_params->rsc_fpops_est = (double) $r->batch->job_params->rsc_fpops_est; |
|
535 | - $job_params->rsc_fpops_bound = (double) $r->batch->job_params->rsc_fpops_bound; |
|
536 | - $job_params->rsc_memory_bound = (double) $r->batch->job_params->rsc_memory_bound; |
|
537 | - $job_params->delay_bound = (double) $r->batch->job_params->delay_bound; |
|
533 | + $job_params->rsc_disk_bound = (double)$r->batch->job_params->rsc_disk_bound; |
|
534 | + $job_params->rsc_fpops_est = (double)$r->batch->job_params->rsc_fpops_est; |
|
535 | + $job_params->rsc_fpops_bound = (double)$r->batch->job_params->rsc_fpops_bound; |
|
536 | + $job_params->rsc_memory_bound = (double)$r->batch->job_params->rsc_memory_bound; |
|
537 | + $job_params->delay_bound = (double)$r->batch->job_params->delay_bound; |
|
538 | 538 | // could add quorum-related stuff |
539 | 539 | |
540 | - $input_template_filename = (string) $r->batch->input_template_filename; |
|
541 | - $output_template_filename = (string) $r->batch->output_template_filename; |
|
540 | + $input_template_filename = (string)$r->batch->input_template_filename; |
|
541 | + $output_template_filename = (string)$r->batch->output_template_filename; |
|
542 | 542 | // possibly empty |
543 | 543 | |
544 | 544 | submit_jobs( |
@@ -631,7 +631,7 @@ discard block |
||
631 | 631 | } |
632 | 632 | |
633 | 633 | function n_outfiles($wu) { |
634 | - $path = project_dir() . "/$wu->output_template_filename"; |
|
634 | + $path = project_dir()."/$wu->output_template_filename"; |
|
635 | 635 | $r = simplexml_load_file($path); |
636 | 636 | return count($r->file_info); |
637 | 637 | } |
@@ -838,7 +838,7 @@ discard block |
||
838 | 838 | "; |
839 | 839 | if ($result->server_state == 5) { // over? |
840 | 840 | $paths = get_outfile_paths($result); |
841 | - foreach($paths as $path) { |
|
841 | + foreach ($paths as $path) { |
|
842 | 842 | if (is_file($path)) { |
843 | 843 | $size = filesize($path); |
844 | 844 | echo " <outfile> |
@@ -882,7 +882,7 @@ discard block |
||
882 | 882 | } else { |
883 | 883 | $results = BoincResult::enum("workunitid=$job_id"); |
884 | 884 | foreach ($results as $r) { |
885 | - switch($r->outcome) { |
|
885 | + switch ($r->outcome) { |
|
886 | 886 | case 1: |
887 | 887 | case 3: |
888 | 888 | case 6: |
@@ -997,8 +997,8 @@ discard block |
||
997 | 997 | } |
998 | 998 | |
999 | 999 | list($user, $user_submit) = check_remote_submit_permissions($r, $app); |
1000 | - $in = file_get_contents(project_dir() . "/templates/".$app->name."_in"); |
|
1001 | - $out = file_get_contents(project_dir() . "/templates/".$app->name."_out"); |
|
1000 | + $in = file_get_contents(project_dir()."/templates/".$app->name."_in"); |
|
1001 | + $out = file_get_contents(project_dir()."/templates/".$app->name."_out"); |
|
1002 | 1002 | if ($in === false || $out === false) { |
1003 | 1003 | log_write("template file missing"); |
1004 | 1004 | xml_error(-1, "template file missing"); |
@@ -1010,7 +1010,7 @@ discard block |
||
1010 | 1010 | |
1011 | 1011 | function ping($r) { |
1012 | 1012 | xml_start_tag("ping"); |
1013 | - BoincDb::get(); // errors out if DB down or web disabled |
|
1013 | + BoincDb::get(); // errors out if DB down or web disabled |
|
1014 | 1014 | echo "<success>1</success> |
1015 | 1015 | </ping> |
1016 | 1016 | "; |
@@ -1077,9 +1077,9 @@ discard block |
||
1077 | 1077 | $request_log = parse_config(get_config(), "<remote_submit_request_log>"); |
1078 | 1078 | if ($request_log) { |
1079 | 1079 | $log_dir = parse_config(get_config(), "<log_dir>"); |
1080 | - $request_log = $log_dir . "/" . $request_log; |
|
1080 | + $request_log = $log_dir."/".$request_log; |
|
1081 | 1081 | if ($file = fopen($request_log, "a")) { |
1082 | - fwrite($file, "\n<submit_rpc_handler date=\"" . date(DATE_ATOM) . "\">\n" . $_POST['request'] . "\n</submit_rpc_handler>\n"); |
|
1082 | + fwrite($file, "\n<submit_rpc_handler date=\"".date(DATE_ATOM)."\">\n".$_POST['request']."\n</submit_rpc_handler>\n"); |
|
1083 | 1083 | fclose($file); |
1084 | 1084 | } |
1085 | 1085 | } |
@@ -79,7 +79,7 @@ discard block |
||
79 | 79 | require_once("../inc/submit_util.inc"); |
80 | 80 | |
81 | 81 | function upload_error_description($errno) { |
82 | - switch($errno) { |
|
82 | + switch ($errno) { |
|
83 | 83 | case UPLOAD_ERR_INI_SIZE: |
84 | 84 | return "The uploaded file exceeds upload_max_filesize of php.ini."; break; |
85 | 85 | case UPLOAD_ERR_FORM_SIZE: |
@@ -105,13 +105,13 @@ discard block |
||
105 | 105 | $delete_time = (int)$r->delete_time; |
106 | 106 | $batch_id = (int)$r->batch_id; |
107 | 107 | $fanout = parse_config(get_config(), "<uldl_dir_fanout>"); |
108 | - $phys_names= array(); |
|
109 | - foreach($r->phys_name as $f) { |
|
108 | + $phys_names = array(); |
|
109 | + foreach ($r->phys_name as $f) { |
|
110 | 110 | $phys_names[] = (string)$f; |
111 | 111 | } |
112 | 112 | $i = 0; |
113 | - foreach($phys_names as $fname) { |
|
114 | - $path = dir_hier_path($fname, project_dir() . "/download", $fanout); |
|
113 | + foreach ($phys_names as $fname) { |
|
114 | + $path = dir_hier_path($fname, project_dir()."/download", $fanout); |
|
115 | 115 | |
116 | 116 | // if the job_file record is there, |
117 | 117 | // update the delete time first to avoid race condition |
@@ -218,11 +218,11 @@ discard block |
||
218 | 218 | foreach ($_FILES as $f) { |
219 | 219 | $tmp_name = $f['tmp_name']; |
220 | 220 | $fname = $phys_names[$i]; |
221 | - $path = dir_hier_path($fname, project_dir() . "/download", $fanout); |
|
221 | + $path = dir_hier_path($fname, project_dir()."/download", $fanout); |
|
222 | 222 | |
223 | 223 | // see if file is in download hierarchy |
224 | 224 | // |
225 | - switch(check_download_file($tmp_name, $path)) { |
|
225 | + switch (check_download_file($tmp_name, $path)) { |
|
226 | 226 | case 0: |
227 | 227 | // file is already there |
228 | 228 | // note: check_download_file() generates .md5 in cases 1 and 2 |
@@ -277,10 +277,10 @@ discard block |
||
277 | 277 | if ($request_log) { |
278 | 278 | $request_log_dir = parse_config(get_config(), "<log_dir>"); |
279 | 279 | if ($request_log_dir) { |
280 | - $request_log = $request_log_dir . "/" . $request_log; |
|
280 | + $request_log = $request_log_dir."/".$request_log; |
|
281 | 281 | } |
282 | 282 | if ($file = fopen($request_log, "a+")) { |
283 | - fwrite($file, "\n<job_file date=\"" . date(DATE_ATOM) . "\">\n" . $_POST['request'] . "\n</job_file>\n"); |
|
283 | + fwrite($file, "\n<job_file date=\"".date(DATE_ATOM)."\">\n".$_POST['request']."\n</job_file>\n"); |
|
284 | 284 | fclose($file); |
285 | 285 | } |
286 | 286 | } |
@@ -292,7 +292,7 @@ discard block |
||
292 | 292 | xml_error(-1, "can't parse request message: $req", __FILE__, __LINE__); |
293 | 293 | } |
294 | 294 | |
295 | -switch($r->getName()) { |
|
295 | +switch ($r->getName()) { |
|
296 | 296 | case 'query_files': |
297 | 297 | query_files($r); |
298 | 298 | break; |