Remove timeout
Project: http://git-wip-us.apache.org/repos/asf/jena/repo Commit: http://git-wip-us.apache.org/repos/asf/jena/commit/2727c6bd Tree: http://git-wip-us.apache.org/repos/asf/jena/tree/2727c6bd Diff: http://git-wip-us.apache.org/repos/asf/jena/diff/2727c6bd Branch: refs/heads/ThreadPerGraphDataset Commit: 2727c6bdb5bc1f811d53fb119d3bac524747ee72 Parents: 7e60377 Author: ajs6f <[email protected]> Authored: Sun Jan 8 09:22:47 2017 -0500 Committer: ajs6f <[email protected]> Committed: Tue Feb 14 09:39:04 2017 -0500 ---------------------------------------------------------------------- .../jena/sparql/core/pergraph/MultithreadingTest.java | 9 ++++----- 1 file changed, 4 insertions(+), 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/jena/blob/2727c6bd/jena-arq/src/test/java/org/apache/jena/sparql/core/pergraph/MultithreadingTest.java ---------------------------------------------------------------------- diff --git a/jena-arq/src/test/java/org/apache/jena/sparql/core/pergraph/MultithreadingTest.java b/jena-arq/src/test/java/org/apache/jena/sparql/core/pergraph/MultithreadingTest.java index 40efaf7..3df0582 100644 --- a/jena-arq/src/test/java/org/apache/jena/sparql/core/pergraph/MultithreadingTest.java +++ b/jena-arq/src/test/java/org/apache/jena/sparql/core/pergraph/MultithreadingTest.java @@ -18,8 +18,7 @@ package org.apache.jena.sparql.core.pergraph; -import static com.jayway.awaitility.Awaitility.waitAtMost; -import static com.jayway.awaitility.Duration.TEN_SECONDS; +import static com.jayway.awaitility.Awaitility.await; import static org.apache.jena.graph.NodeFactory.createLiteral; import static org.apache.jena.graph.NodeFactory.createURI; import static org.apache.jena.query.ReadWrite.READ; @@ -60,7 +59,7 @@ public class MultithreadingTest extends BaseTest { dataset.add(graph1, dummy, dummy, before); // wait for the baton startMain.set(true); - waitAtMost(TEN_SECONDS).untilTrue(baton); + await().untilTrue(baton); dataset.add(graph1, dummy, dummy, after); dataset.commit(); finishLine.set(true); @@ -69,7 +68,7 @@ public class MultithreadingTest extends BaseTest { } }).start(); - waitAtMost(TEN_SECONDS).untilTrue(startMain); + await().untilTrue(startMain); dataset.begin(WRITE); try { dataset.add(graph2, dummy, dummy, before); @@ -80,7 +79,7 @@ public class MultithreadingTest extends BaseTest { } finally { dataset.end(); } - waitAtMost(TEN_SECONDS).untilTrue(finishLine); + await().untilTrue(finishLine); dataset.begin(READ); try { assertTrue("Failed to find the triple that proves that the first thread finished!",
