You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@jena.apache.org by aj...@apache.org on 2017/02/14 14:40:03 UTC
[48/50] jena git commit: Remove timeout
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 <aj...@virginia.edu>
Authored: Sun Jan 8 09:22:47 2017 -0500
Committer: ajs6f <aj...@virginia.edu>
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!",