Return-Path: X-Original-To: apmail-airavata-commits-archive@www.apache.org Delivered-To: apmail-airavata-commits-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id CAE0A17A0F for ; Fri, 6 Feb 2015 16:05:15 +0000 (UTC) Received: (qmail 45589 invoked by uid 500); 6 Feb 2015 16:05:15 -0000 Delivered-To: apmail-airavata-commits-archive@airavata.apache.org Received: (qmail 45441 invoked by uid 500); 6 Feb 2015 16:05:15 -0000 Mailing-List: contact commits-help@airavata.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@airavata.apache.org Delivered-To: mailing list commits@airavata.apache.org Received: (qmail 44771 invoked by uid 99); 6 Feb 2015 16:05:15 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 06 Feb 2015 16:05:15 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id A7056E0668; Fri, 6 Feb 2015 16:05:14 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: lahiru@apache.org To: commits@airavata.apache.org Date: Fri, 06 Feb 2015 16:05:24 -0000 Message-Id: <1c5e756252914e959cd4864a0fbe7b58@git.apache.org> In-Reply-To: <0ac512fb03ab4dcea03318fd90de7f4c@git.apache.org> References: <0ac512fb03ab4dcea03318fd90de7f4c@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: [11/53] [abbrv] airavata git commit: Fix to pass the gateway name from request. AIRAVATA-1554 Fix to pass the gateway name from request. AIRAVATA-1554 Project: http://git-wip-us.apache.org/repos/asf/airavata/repo Commit: http://git-wip-us.apache.org/repos/asf/airavata/commit/b81daafb Tree: http://git-wip-us.apache.org/repos/asf/airavata/tree/b81daafb Diff: http://git-wip-us.apache.org/repos/asf/airavata/diff/b81daafb Branch: refs/heads/gfac-storm Commit: b81daafbe1dbbe3523e515f137b2ad2fdfa8e684 Parents: 18f338c Author: raminder Authored: Thu Jan 22 16:38:06 2015 -0500 Committer: raminder Committed: Thu Jan 22 16:38:06 2015 -0500 ---------------------------------------------------------------------- .../org/apache/airavata/gfac/gsissh/util/GFACGSISSHUtils.java | 4 ++-- .../java/org/apache/airavata/gfac/ssh/util/GFACSSHUtils.java | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/airavata/blob/b81daafb/modules/gfac/gfac-gsissh/src/main/java/org/apache/airavata/gfac/gsissh/util/GFACGSISSHUtils.java ---------------------------------------------------------------------- diff --git a/modules/gfac/gfac-gsissh/src/main/java/org/apache/airavata/gfac/gsissh/util/GFACGSISSHUtils.java b/modules/gfac/gfac-gsissh/src/main/java/org/apache/airavata/gfac/gsissh/util/GFACGSISSHUtils.java index c3546f0..a3c99ba 100644 --- a/modules/gfac/gfac-gsissh/src/main/java/org/apache/airavata/gfac/gsissh/util/GFACGSISSHUtils.java +++ b/modules/gfac/gfac-gsissh/src/main/java/org/apache/airavata/gfac/gsissh/util/GFACGSISSHUtils.java @@ -74,7 +74,7 @@ public class GFACGSISSHUtils { logger.error("This is a wrong method to invoke to non ssh host types,please check your gfac-config.xml"); } else if (jobProtocol == JobSubmissionProtocol.SSH && sshJobSubmission.getSecurityProtocol() == SecurityProtocol.GSI) { String credentialStoreToken = jobExecutionContext.getCredentialStoreToken(); // this is set by the framework - RequestData requestData = new RequestData(ServerSettings.getDefaultUserGateway()); + RequestData requestData = new RequestData(jobExecutionContext.getGatewayID()); requestData.setTokenId(credentialStoreToken); PBSCluster pbsCluster = null; GSISecurityContext context = null; @@ -84,7 +84,7 @@ public class GFACGSISSHUtils { if (credentialReader != null) { CertificateCredential credential = null; try { - credential = (CertificateCredential) credentialReader.getCredential(ServerSettings.getDefaultUserGateway(), credentialStoreToken); + credential = (CertificateCredential) credentialReader.getCredential(jobExecutionContext.getGatewayID(), credentialStoreToken); requestData.setMyProxyUserName(credential.getCommunityUser().getUserName()); } catch (Exception e) { logger.error(e.getLocalizedMessage()); http://git-wip-us.apache.org/repos/asf/airavata/blob/b81daafb/modules/gfac/gfac-ssh/src/main/java/org/apache/airavata/gfac/ssh/util/GFACSSHUtils.java ---------------------------------------------------------------------- diff --git a/modules/gfac/gfac-ssh/src/main/java/org/apache/airavata/gfac/ssh/util/GFACSSHUtils.java b/modules/gfac/gfac-ssh/src/main/java/org/apache/airavata/gfac/ssh/util/GFACSSHUtils.java index b3c155d..c9d5f0f 100644 --- a/modules/gfac/gfac-ssh/src/main/java/org/apache/airavata/gfac/ssh/util/GFACSSHUtils.java +++ b/modules/gfac/gfac-ssh/src/main/java/org/apache/airavata/gfac/ssh/util/GFACSSHUtils.java @@ -83,7 +83,7 @@ public class GFACSSHUtils { if (securityProtocol == SecurityProtocol.GSI || securityProtocol == SecurityProtocol.SSH_KEYS) { SSHSecurityContext sshSecurityContext = new SSHSecurityContext(); String credentialStoreToken = jobExecutionContext.getCredentialStoreToken(); // this is set by the framework - RequestData requestData = new RequestData(ServerSettings.getDefaultUserGateway()); + RequestData requestData = new RequestData(jobExecutionContext.getGatewayID()); requestData.setTokenId(credentialStoreToken); ServerInfo serverInfo = new ServerInfo(null, jobExecutionContext.getHostName());