You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by sh...@apache.org on 2016/11/11 21:36:13 UTC
airavata git commit: continue.. keep session with login username +
protocol + computer resource Id as key
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 <sh...@gmail.com>
Authored: Fri Nov 11 16:36:08 2016 -0500
Committer: Shameera Rathnayaka <sh...@gmail.com>
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());