accumulo-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From e..@apache.org
Subject [1/3] git commit: ACCUMULO-3098 fix timeout
Date Wed, 03 Sep 2014 18:23:17 GMT
Repository: accumulo
Updated Branches:
  refs/heads/master e98d81bbe -> e1a6e5284


ACCUMULO-3098 fix timeout


Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo
Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/f01ac9f9
Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/f01ac9f9
Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/f01ac9f9

Branch: refs/heads/master
Commit: f01ac9f995e35c7e1c990fb64f3cd68f98c0d083
Parents: e98d81b
Author: Eric C. Newton <eric.newton@gmail.com>
Authored: Wed Sep 3 14:20:16 2014 -0400
Committer: Eric C. Newton <eric.newton@gmail.com>
Committed: Wed Sep 3 14:20:52 2014 -0400

----------------------------------------------------------------------
 .../accumulo/test/functional/MonitorLoggingIT.java    | 14 +++++++-------
 1 file changed, 7 insertions(+), 7 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/accumulo/blob/f01ac9f9/test/src/test/java/org/apache/accumulo/test/functional/MonitorLoggingIT.java
----------------------------------------------------------------------
diff --git a/test/src/test/java/org/apache/accumulo/test/functional/MonitorLoggingIT.java
b/test/src/test/java/org/apache/accumulo/test/functional/MonitorLoggingIT.java
index bfee213..b843a1d 100644
--- a/test/src/test/java/org/apache/accumulo/test/functional/MonitorLoggingIT.java
+++ b/test/src/test/java/org/apache/accumulo/test/functional/MonitorLoggingIT.java
@@ -49,14 +49,14 @@ public class MonitorLoggingIT extends ConfigurableMacIT {
   }
 
   private static final int NUM_LOCATION_PASSES = 5;
-  private static final int LOCATION_DELAY = 5000;
+  private static final int LOCATION_DELAY_SECS = 5;
 
   @Override
   protected int defaultTimeoutSeconds() {
-    return (NUM_LOCATION_PASSES + 2) * LOCATION_DELAY;
+    return 30 + ((NUM_LOCATION_PASSES + 2) * LOCATION_DELAY_SECS);
   }
 
-  @Test(timeout = (NUM_LOCATION_PASSES + 2) * LOCATION_DELAY)
+  @Test(timeout = 30 + ((NUM_LOCATION_PASSES + 2) * LOCATION_DELAY_SECS * 1000))
   public void logToMonitor() throws Exception {
     // Start the monitor.
     log.debug("Starting Monitor");
@@ -65,15 +65,15 @@ public class MonitorLoggingIT extends ConfigurableMacIT {
     // Get monitor location to ensure it is running.
     String monitorLocation = null;
     for (int i = 0; i < NUM_LOCATION_PASSES; i++) {
-      Thread.sleep(LOCATION_DELAY);
+      Thread.sleep(LOCATION_DELAY_SECS * 1000);
       try {
         monitorLocation = getMonitor();
         break;
       } catch (KeeperException e) {
-        log.debug("Monitor not up yet, trying again in " + LOCATION_DELAY + " ms");
+        log.debug("Monitor not up yet, trying again in " + LOCATION_DELAY_SECS + " secs");
       }
     }
-    assertNotNull("Monitor failed to start within " + (LOCATION_DELAY * NUM_LOCATION_PASSES)
+ " ms", monitorLocation);
+    assertNotNull("Monitor failed to start within " + (LOCATION_DELAY_SECS * NUM_LOCATION_PASSES)
+ " secs", monitorLocation);
     log.debug("Monitor running at " + monitorLocation);
 
     // Attempt a scan with an invalid iterator to force a log message in the monitor.
@@ -89,7 +89,7 @@ public class MonitorLoggingIT extends ConfigurableMacIT {
 
     String result = "";
     while(true) {
-      Thread.sleep(LOCATION_DELAY);  // extra precaution to ensure monitor has opportunity
to log
+      Thread.sleep(LOCATION_DELAY_SECS * 1000);  // extra precaution to ensure monitor has
opportunity to log
 
       // Verify messages were received at the monitor.
       URL url = new URL("http://" + monitorLocation + "/log");


Mime
View raw message