Home
last modified time | relevance | path

Searched refs:waitLatch (Results 1 – 5 of 5) sorted by relevance

/dports/devel/spark/spark-2.1.1/streaming/src/test/scala/org/apache/spark/streaming/scheduler/
H A DJobGeneratorSuite.scala77 while (waitLatch.getCount() > 0) {
78 waitLatch.await()
125 waitLatch.countDown()
131 val waitLatch = new CountDownLatch(1) constant
/dports/databases/hbase/hbase-1.2.1/hbase-server/src/test/java/org/apache/hadoop/hbase/
H A DGenericTestUtils.java166 private final CountDownLatch waitLatch = new CountDownLatch(1); field in GenericTestUtils.DelayAnswer
192 waitLatch.countDown(); in proceed()
202 waitLatch.await(); in answer()
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/test/
H A DGenericTestUtils.java209 private final CountDownLatch waitLatch = new CountDownLatch(1); field in GenericTestUtils.DelayAnswer
235 waitLatch.countDown(); in proceed()
245 waitLatch.await(); in answer()
/dports/java/berkeley-db/je-6.2.31/src/com/sleepycat/je/rep/vlsn/
H A DVLSNIndex.java552 VLSNAwaitLatch waitLatch = null; in waitForVLSN() local
564 waitLatch = vlsnPutLatch; in waitForVLSN()
573 if (!waitLatch.await(waitTime, TimeUnit.MILLISECONDS) || in waitForVLSN()
574 waitLatch.isTerminated()) { in waitForVLSN()
585 LogItem logItem = waitLatch.getLogItem(); in waitForVLSN()
/dports/devel/hadoop/hadoop-1.2.1/src/test/org/apache/hadoop/hdfs/
H A DTestFileAppend4.java1152 private final CountDownLatch waitLatch = new CountDownLatch(1); field in TestFileAppend4.DelayAnswer
1182 waitLatch.countDown(); in proceed()
1203 waitLatch.await(); in doDelay()