Repository: airavata Updated Branches: refs/heads/develop 4139ae997 -> f66043474
continue.. keep session with login username + protocol + computer resource Id as key Project: http://git-wip-us.apache.org/repos/asf/airavata/repo Commit: http://git-wip-us.apache.org/repos/asf/airavata/commit/f6604347 Tree: http://git-wip-us.apache.org/repos/asf/airavata/tree/f6604347 Diff: http://git-wip-us.apache.org/repos/asf/airavata/diff/f6604347 Branch: refs/heads/develop Commit: f66043474e4cc14b37f8b20d0e16246967c70a96 Parents: 4139ae9 Author: Shameera Rathnayaka <[email protected]> Authored: Fri Nov 11 16:36:08 2016 -0500 Committer: Shameera Rathnayaka <[email protected]> Committed: Fri Nov 11 16:36:08 2016 -0500 ---------------------------------------------------------------------- .../src/main/java/org/apache/airavata/gfac/impl/Factory.java | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/airavata/blob/f6604347/modules/gfac/gfac-impl/src/main/java/org/apache/airavata/gfac/impl/Factory.java ---------------------------------------------------------------------- diff --git a/modules/gfac/gfac-impl/src/main/java/org/apache/airavata/gfac/impl/Factory.java b/modules/gfac/gfac-impl/src/main/java/org/apache/airavata/gfac/impl/Factory.java index 22986f2..e6211e7 100644 --- a/modules/gfac/gfac-impl/src/main/java/org/apache/airavata/gfac/impl/Factory.java +++ b/modules/gfac/gfac-impl/src/main/java/org/apache/airavata/gfac/impl/Factory.java @@ -242,7 +242,11 @@ public abstract class Factory { String computeResourceId = processContext.getComputeResourceId(); JobSubmissionProtocol jobSubmissionProtocol = processContext.getJobSubmissionProtocol(); - String key = jobSubmissionProtocol.name() + ":" + computeResourceId; + String key = new StringBuilder(processContext.getLoginUserName()) + .append(':') + .append(jobSubmissionProtocol.name()) + .append(':') + .append(computeResourceId).toString(); RemoteCluster remoteCluster = remoteClusterMap.get(key); if (remoteCluster == null) { JobManagerConfiguration jobManagerConfiguration = getJobManagerConfiguration(processContext.getResourceJobManager());
