[Swift-commit] r2836 - trunk/src/org/griphyn/vdl/karajan/monitor/monitors/ansi

[noreply at svn.ci.uchicago.edu]

Author: hategan
Date: 2009-04-06 16:58:20 -0500 (Mon, 06 Apr 2009)
New Revision: 2836

Modified:
   trunk/src/org/griphyn/vdl/karajan/monitor/monitors/ansi/WorkerTerminalInputHandler.java
Log:
use coaster-url attribute if set

Modified: trunk/src/org/griphyn/vdl/karajan/monitor/monitors/ansi/WorkerTerminalInputHandler.java
===================================================================
--- trunk/src/org/griphyn/vdl/karajan/monitor/monitors/ansi/WorkerTerminalInputHandler.java	2009-04-05 23:07:02 UTC (rev 2835)
+++ trunk/src/org/griphyn/vdl/karajan/monitor/monitors/ansi/WorkerTerminalInputHandler.java	2009-04-06 21:58:20 UTC (rev 2836)
@@ -15,6 +15,7 @@
 import org.apache.log4j.Logger;
 import org.globus.cog.abstraction.coaster.service.local.LocalRequestManager;
 import org.globus.cog.abstraction.impl.execution.coaster.WorkerShellCommand;
+import org.globus.cog.abstraction.interfaces.Service;
 import org.globus.cog.abstraction.interfaces.Task;
 import org.globus.cog.karajan.workflow.service.ProtocolException;
 import org.globus.cog.karajan.workflow.service.channels.ChannelManager;
@@ -40,7 +41,11 @@
         this.term = term;
         this.task = task;
         this.workerId = workerId;
-        this.contact = task.getService(0).getServiceContact().getContact();
+        Service s = task.getService(0);
+        this.contact = (String) s.getAttribute("coaster-url");
+        if (this.contact == null) {
+            this.contact = task.getService(0).getServiceContact().getContact();
+        }
         this.cred = (GSSCredential) task.getService(0).getSecurityContext()
             .getCredentials();
     }