[Swift-commit] Cog update
swift at ci.uchicago.edu
swift at ci.uchicago.edu
Tue Jan 17 17:05:08 CST 2012
------------------------------------------------------------------------
r3350 | hategan | 2012-01-17 17:04:04 -0600 (Tue, 17 Jan 2012) | 1 line
updated to reflect changes in local provider
------------------------------------------------------------------------
Index: modules/provider-ssh/src/org/globus/cog/abstraction/impl/sshcl/execution/JobSubmissionTaskHandler.java
===================================================================
--- modules/provider-ssh/src/org/globus/cog/abstraction/impl/sshcl/execution/JobSubmissionTaskHandler.java (revision 3349)
+++ modules/provider-ssh/src/org/globus/cog/abstraction/impl/sshcl/execution/JobSubmissionTaskHandler.java (working copy)
@@ -23,7 +23,7 @@
public class JobSubmissionTaskHandler extends org.globus.cog.abstraction.impl.execution.local.JobSubmissionTaskHandler {
- protected String[] buildCmdArray(JobSpecification spec) {
+ protected List<String> buildCmdArray(JobSpecification spec) {
Service service = getTask().getService(0);
String ssh = (String) getTask().getAttribute("ssh");
@@ -57,10 +57,18 @@
*/
cmdarray.add("-s");
- return cmdarray.toArray(new String[0]);
+ return cmdarray;
}
@Override
+ protected void addEnvs(ProcessBuilder pb, JobSpecification spec) {
+ // override to do nothing. Environment variables are passed
+ // through the ssh shell
+ }
+
+
+
+ @Override
protected void processIN(String in, File dir, OutputStream os) throws IOException {
JobSpecification spec = (JobSpecification) getTask().getSpecification();
More information about the Swift-commit
mailing list