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 5F50D17205 for ; Tue, 11 Nov 2014 20:12:07 +0000 (UTC) Received: (qmail 55788 invoked by uid 500); 11 Nov 2014 20:12:07 -0000 Delivered-To: apmail-airavata-commits-archive@airavata.apache.org Received: (qmail 55709 invoked by uid 500); 11 Nov 2014 20:12:07 -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 55480 invoked by uid 99); 11 Nov 2014 20:12:07 -0000 Received: from tyr.zones.apache.org (HELO tyr.zones.apache.org) (140.211.11.114) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 11 Nov 2014 20:12:07 +0000 Received: by tyr.zones.apache.org (Postfix, from userid 65534) id EDB47A0DE86; Tue, 11 Nov 2014 20:12:06 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: chathuri@apache.org To: commits@airavata.apache.org Date: Tue, 11 Nov 2014 20:12:27 -0000 Message-Id: In-Reply-To: <6c6ea258790d469fadd5d9608689051e@git.apache.org> References: <6c6ea258790d469fadd5d9608689051e@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: [23/50] [abbrv] airavata git commit: merging merging Project: http://git-wip-us.apache.org/repos/asf/airavata/repo Commit: http://git-wip-us.apache.org/repos/asf/airavata/commit/fa666b30 Tree: http://git-wip-us.apache.org/repos/asf/airavata/tree/fa666b30 Diff: http://git-wip-us.apache.org/repos/asf/airavata/diff/fa666b30 Branch: refs/heads/master Commit: fa666b30ce5c3408b43cb5616c99d4d3d17a3b51 Parents: d856d24 Author: Chathuri Wimalasena Authored: Wed Nov 5 13:19:50 2014 -0500 Committer: Chathuri Wimalasena Committed: Wed Nov 5 13:19:50 2014 -0500 ---------------------------------------------------------------------- .../airavata/gfac/monitor/impl/pull/qstat/HPCPullMonitor.java | 5 ----- .../airavata/gfac/ssh/handler/AdvancedSCPOutputHandler.java | 4 ---- 2 files changed, 9 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/airavata/blob/fa666b30/modules/gfac/gfac-monitor/src/main/java/org/apache/airavata/gfac/monitor/impl/pull/qstat/HPCPullMonitor.java ---------------------------------------------------------------------- diff --git a/modules/gfac/gfac-monitor/src/main/java/org/apache/airavata/gfac/monitor/impl/pull/qstat/HPCPullMonitor.java b/modules/gfac/gfac-monitor/src/main/java/org/apache/airavata/gfac/monitor/impl/pull/qstat/HPCPullMonitor.java index 122d1e2..331663f 100644 --- a/modules/gfac/gfac-monitor/src/main/java/org/apache/airavata/gfac/monitor/impl/pull/qstat/HPCPullMonitor.java +++ b/modules/gfac/gfac-monitor/src/main/java/org/apache/airavata/gfac/monitor/impl/pull/qstat/HPCPullMonitor.java @@ -35,16 +35,12 @@ import org.apache.airavata.gfac.monitor.UserMonitorData; import org.apache.airavata.gfac.monitor.core.PullMonitor; import org.apache.airavata.gfac.monitor.exception.AiravataMonitorException; import org.apache.airavata.gfac.monitor.impl.push.amqp.SimpleJobFinishConsumer; -import org.apache.airavata.gfac.monitor.util.CommonUtils; import org.apache.airavata.gsi.ssh.api.SSHApiException; import org.apache.airavata.gsi.ssh.api.authentication.AuthenticationInfo; import org.apache.airavata.model.appcatalog.computeresource.JobSubmissionProtocol; import org.apache.airavata.model.messaging.event.JobIdentifier; import org.apache.airavata.model.messaging.event.JobStatusChangeRequestEvent; import org.apache.airavata.model.workspace.experiment.JobState; -import org.apache.airavata.schemas.gfac.GsisshHostType; -import org.apache.airavata.schemas.gfac.SSHHostType; -import org.apache.zookeeper.ZooKeeper; import java.sql.Timestamp; import java.util.*; @@ -239,7 +235,6 @@ public class HPCPullMonitor extends PullMonitor { !JobState.COMPLETE.equals(iMonitorID.getStatus())) { iMonitorID.setStatus(jobStatuses.get(iMonitorID.getJobID() + "," + iMonitorID.getJobName())); //IMPORTANT this is NOT a simple setter we have a logic }else if(JobState.COMPLETE.equals(iMonitorID.getStatus())){ - completedJobs.put(iMonitorID.getJobName(), iMonitorID); logger.debugId(iMonitorID.getJobID(), "Moved job {} to completed jobs map, experiment {}, " + "task {}", iMonitorID.getJobID(), iMonitorID.getExperimentID(), iMonitorID.getTaskID()); iterator.remove(); http://git-wip-us.apache.org/repos/asf/airavata/blob/fa666b30/modules/gfac/gfac-ssh/src/main/java/org/apache/airavata/gfac/ssh/handler/AdvancedSCPOutputHandler.java ---------------------------------------------------------------------- diff --git a/modules/gfac/gfac-ssh/src/main/java/org/apache/airavata/gfac/ssh/handler/AdvancedSCPOutputHandler.java b/modules/gfac/gfac-ssh/src/main/java/org/apache/airavata/gfac/ssh/handler/AdvancedSCPOutputHandler.java index f508e23..f34b82a 100644 --- a/modules/gfac/gfac-ssh/src/main/java/org/apache/airavata/gfac/ssh/handler/AdvancedSCPOutputHandler.java +++ b/modules/gfac/gfac-ssh/src/main/java/org/apache/airavata/gfac/ssh/handler/AdvancedSCPOutputHandler.java @@ -110,10 +110,6 @@ public class AdvancedSCPOutputHandler extends AbstractHandler { this.passPhrase); } try { - ApplicationDeploymentDescriptionType app = jobExecutionContext.getApplicationContext() - .getApplicationDeploymentDescription().getType(); - String standardError = app.getStandardError(); - String standardOutput = app.getStandardOutput(); if (jobExecutionContext.getSecurityContext(SSHSecurityContext.SSH_SECURITY_CONTEXT) == null) { try { GFACSSHUtils.addSecurityContext(jobExecutionContext);