You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@brooklyn.apache.org by gr...@apache.org on 2016/08/11 22:44:47 UTC
brooklyn-server git commit: Log instead of exception on
SshCommandMembershipTrackingPolicy waiting for machine
Repository: brooklyn-server
Updated Branches:
refs/heads/master d69fda26e -> 215c02cb5
Log instead of exception on SshCommandMembershipTrackingPolicy waiting for machine
Project: http://git-wip-us.apache.org/repos/asf/brooklyn-server/repo
Commit: http://git-wip-us.apache.org/repos/asf/brooklyn-server/commit/215c02cb
Tree: http://git-wip-us.apache.org/repos/asf/brooklyn-server/tree/215c02cb
Diff: http://git-wip-us.apache.org/repos/asf/brooklyn-server/diff/215c02cb
Branch: refs/heads/master
Commit: 215c02cb53717fee35d3b7f6b3e1f3d902fcb351
Parents: d69fda2
Author: Andrew Donald Kennedy <an...@cloudsoftcorp.com>
Authored: Thu Aug 11 23:44:26 2016 +0100
Committer: Andrew Donald Kennedy <an...@cloudsoftcorp.com>
Committed: Thu Aug 11 23:44:35 2016 +0100
----------------------------------------------------------------------
.../entity/group/SshCommandMembershipTrackingPolicy.java | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/brooklyn-server/blob/215c02cb/core/src/main/java/org/apache/brooklyn/entity/group/SshCommandMembershipTrackingPolicy.java
----------------------------------------------------------------------
diff --git a/core/src/main/java/org/apache/brooklyn/entity/group/SshCommandMembershipTrackingPolicy.java b/core/src/main/java/org/apache/brooklyn/entity/group/SshCommandMembershipTrackingPolicy.java
index bf899ba..e7dffb5 100644
--- a/core/src/main/java/org/apache/brooklyn/entity/group/SshCommandMembershipTrackingPolicy.java
+++ b/core/src/main/java/org/apache/brooklyn/entity/group/SshCommandMembershipTrackingPolicy.java
@@ -86,7 +86,8 @@ public class SshCommandMembershipTrackingPolicy extends AbstractMembershipTracki
Collection<? extends Location> locations = Locations.getLocationsCheckingAncestors(entity.getLocations(), entity);
Maybe<SshMachineLocation> machine = Machines.findUniqueMachineLocation(locations, SshMachineLocation.class);
if (machine.isAbsentOrNull()) {
- throw new IllegalStateException("No machine available to execute command");
+ LOG.debug("No machine available to execute command");
+ return;
}
LOG.info("Executing command on {}: {}", machine.get(), command);
String executionDir = config().get(EXECUTION_DIR);
@@ -117,6 +118,6 @@ public class SshCommandMembershipTrackingPolicy extends AbstractMembershipTracki
.environmentVariables(serializer.serialize(env));
String output = DynamicTasks.submit(task.newTask(), entity).getUnchecked();
- LOG.debug("Command returned: {}", output);
+ LOG.trace("Command returned: {}", output);
}
}