Updates to ECM interface
Change-Id: Ie0cae42ac2b361cf3b94e5047c157cb0945f4209
Adding origin to IntentData and use it to pick GossipIntentStore peer
Change-Id: I50e9621a69a35ec02b8c8dd79cc926591e5a73e9
diff --git a/utils/misc/src/test/java/org/onlab/util/BlockingBooleanTest.java b/utils/misc/src/test/java/org/onlab/util/BlockingBooleanTest.java
index 087b692..2d8b688 100644
--- a/utils/misc/src/test/java/org/onlab/util/BlockingBooleanTest.java
+++ b/utils/misc/src/test/java/org/onlab/util/BlockingBooleanTest.java
@@ -31,6 +31,8 @@
*/
public class BlockingBooleanTest {
+ private static final int TIMEOUT = 100; //ms
+
@Test
public void basics() {
BlockingBoolean b = new BlockingBoolean(false);
@@ -60,7 +62,7 @@
}
b.set(value);
try {
- assertTrue(latch.await(10, TimeUnit.MILLISECONDS));
+ assertTrue(latch.await(TIMEOUT, TimeUnit.MILLISECONDS));
} catch (InterruptedException e) {
fail();
}
@@ -92,7 +94,7 @@
}
});
try {
- assertTrue(latch.await(10, TimeUnit.MILLISECONDS));
+ assertTrue(latch.await(TIMEOUT, TimeUnit.MILLISECONDS));
} catch (InterruptedException e) {
fail();
}
@@ -124,14 +126,14 @@
});
}
try {
- assertTrue(sameLatch.await(10, TimeUnit.MILLISECONDS));
+ assertTrue(sameLatch.await(TIMEOUT, TimeUnit.MILLISECONDS));
assertEquals(waitLatch.getCount(), numThreads / 2);
} catch (InterruptedException e) {
fail();
}
b.set(true);
try {
- assertTrue(waitLatch.await(10, TimeUnit.MILLISECONDS));
+ assertTrue(waitLatch.await(TIMEOUT, TimeUnit.MILLISECONDS));
} catch (InterruptedException e) {
fail();
}
@@ -156,7 +158,7 @@
}
});
try {
- assertTrue(latch.await(10, TimeUnit.MILLISECONDS));
+ assertTrue(latch.await(TIMEOUT, TimeUnit.MILLISECONDS));
} catch (InterruptedException e) {
fail();
}