summaryrefslogtreecommitdiffstats
path: root/src/com.gluster.storage.management.server
diff options
context:
space:
mode:
authorShireesh Anjal <shireesh@gluster.com>2011-07-01 20:29:40 +0530
committerShireesh Anjal <shireesh@gluster.com>2011-07-01 20:29:40 +0530
commit5cb94f565f49b2a952d941df18507049364a1b6d (patch)
treed71bade80bbe496ff564687859c39d20ec93feb3 /src/com.gluster.storage.management.server
parent2c4ea3418784160bdf4f186b2488e974465161e7 (diff)
Task#111 - Auto-refresh of data in views
Diffstat (limited to 'src/com.gluster.storage.management.server')
-rw-r--r--src/com.gluster.storage.management.server/src/com/gluster/storage/management/server/utils/SshUtil.java33
1 files changed, 16 insertions, 17 deletions
diff --git a/src/com.gluster.storage.management.server/src/com/gluster/storage/management/server/utils/SshUtil.java b/src/com.gluster.storage.management.server/src/com/gluster/storage/management/server/utils/SshUtil.java
index d56cd47c..4f0b04cf 100644
--- a/src/com.gluster.storage.management.server/src/com/gluster/storage/management/server/utils/SshUtil.java
+++ b/src/com.gluster.storage.management.server/src/com/gluster/storage/management/server/utils/SshUtil.java
@@ -226,6 +226,10 @@ public class SshUtil {
return conn;
}
+ private boolean wasTerminated(int condition) {
+ return ((condition | ChannelCondition.EXIT_SIGNAL) == condition);
+ }
+
private boolean hasErrors(int condition, Session session) {
return (hasErrorStream(condition) || (exitedGracefully(condition) && exitedWithError(session)));
}
@@ -239,7 +243,7 @@ public class SshUtil {
}
private boolean exitedGracefully(int condition) {
- return (condition == ChannelCondition.EXIT_STATUS);
+ return (condition | ChannelCondition.EXIT_STATUS) == condition;
}
private boolean hasErrorStream(int condition) {
@@ -292,24 +296,19 @@ public class SshUtil {
private ProcessResult prepareProcessResult(Session session, int condition, String output) {
ProcessResult result = null;
- switch(condition) {
- case ChannelCondition.TIMEOUT:
- result = new ProcessResult(ProcessResult.FAILURE, "Command timed out!");
- break;
- case ChannelCondition.EXIT_SIGNAL:
- // terminated
+
+ if (wasTerminated(condition)) {
result = new ProcessResult(ProcessResult.FAILURE, output);
- break;
- default:
- if (hasErrors(condition, session)) {
- Integer exitStatus = session.getExitStatus();
- int statusCode = (exitStatus == null ? ProcessResult.FAILURE : exitStatus);
- result = new ProcessResult(statusCode, output);
- } else {
- result = new ProcessResult(ProcessResult.SUCCESS, output);
- }
- break;
+ } else if (timedOut(condition)) {
+ result = new ProcessResult(ProcessResult.FAILURE, "Command timed out!");
+ } else if (hasErrors(condition, session)) {
+ Integer exitStatus = session.getExitStatus();
+ int statusCode = (exitStatus == null ? ProcessResult.FAILURE : exitStatus);
+ result = new ProcessResult(statusCode, output);
+ } else {
+ result = new ProcessResult(ProcessResult.SUCCESS, output);
}
+
return result;
}