[geode-benchmarks] branch sni updated: instrument StartSniProxy

[burcham]

This is an automated email from the ASF dual-hosted git repository.

burcham pushed a commit to branch sni
in repository https://gitbox.apache.org/repos/asf/geode-benchmarks.git


The following commit(s) were added to refs/heads/sni by this push:
     new e336a53  instrument StartSniProxy
e336a53 is described below

commit e336a536839d1dccf92af916e35e4eb9c0a623bc
Author: Bill Burcham <bburc...@pivotal.io>
AuthorDate: Tue May 19 10:41:09 2020 -0700

    instrument StartSniProxy
---
 .../geode/benchmark/tasks/StartSniProxy.java       | 33 +++++++++++++++++-----
 1 file changed, 26 insertions(+), 7 deletions(-)

diff --git 
a/geode-benchmarks/src/main/java/org/apache/geode/benchmark/tasks/StartSniProxy.java
 
b/geode-benchmarks/src/main/java/org/apache/geode/benchmark/tasks/StartSniProxy.java
index eda5798..3a5b955 100644
--- 
a/geode-benchmarks/src/main/java/org/apache/geode/benchmark/tasks/StartSniProxy.java
+++ 
b/geode-benchmarks/src/main/java/org/apache/geode/benchmark/tasks/StartSniProxy.java
@@ -27,6 +27,9 @@ import java.net.InetAddress;
 import java.util.List;
 import java.util.stream.Collectors;
 
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
 import org.apache.geode.benchmark.topology.Roles;
 import org.apache.geode.perftest.Task;
 import org.apache.geode.perftest.TestContext;
@@ -36,28 +39,44 @@ import org.apache.geode.perftest.TestContext;
  */
 public class StartSniProxy implements Task {
 
+  private static final Logger logger = 
LoggerFactory.getLogger(StartSniProxy.class);
+
   public static final String START_DOCKER_DAEMON_COMMAND = "sudo service 
docker start";
   public static final String START_PROXY_COMMAND = "docker-compose up -d 
haproxy";
 
   private int locatorPort;
 
   public StartSniProxy(int locatorPort) {
+    logger.info("BGB StartSniProxy constructed");
     this.locatorPort = locatorPort;
   }
 
   @Override
   public void run(TestContext context) throws Exception {
+    logger.info("BGB StartSniProxy.run() entered");
+
+    try {
+      final String config = generateHaProxyConfig(
+          hostNamesFor(context, LOCATOR),
+          hostNamesFor(context, SERVER));
 
-    final String config = generateHaProxyConfig(
-        hostNamesFor(context, LOCATOR),
-        hostNamesFor(context, SERVER));
+      logger.info("BGB StartSniProxy.run() generated config");
 
-    writeToFile(config, "haproxy.cfg");
+      writeToFile(config, "haproxy.cfg");
 
-    final ProcessControl processControl = new ProcessControl();
+      logger.info("BGB StartSniProxy.run() wrote haproxy.cfg");
 
-    processControl.runCommand(START_DOCKER_DAEMON_COMMAND);
-    processControl.runCommand(START_PROXY_COMMAND);
+      final ProcessControl processControl = new ProcessControl();
+
+      processControl.runCommand(START_DOCKER_DAEMON_COMMAND);
+      logger.info("BGB StartSniProxy.run() started Docker daemon");
+      processControl.runCommand(START_PROXY_COMMAND);
+      logger.info("BGB StartSniProxy.run() started HAproxy");
+    } catch(final Throwable t) {
+      logger.error("BGB caught exception in StartSniProxy.run()", t);
+      throw t;
+    }
+    logger.info("BGB StartSniProxy.run() completed without error");
   }
 
   private void writeToFile(final String content, final String fileName) throws 
IOException {