honeymoose
/
OpenSearch
mirror of https://github.com/honeymoose/OpenSearch.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

[test] make sure result is never null and that flush and get start at same time

This commit is contained in:
Britta Weber 2015-09-09 12:41:32 +02:00
parent fa9696fb8c
commit 281eac757d
1 changed files with 11 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
core/src/test/java/org/elasticsearch/index/engine/InternalEngineTests.java
View File

@ -93,7 +93,9 @@ import java.nio.file.DirectoryStream;
import java.nio.file.Files; import java.nio.file.Files;
import java.nio.file.Path; import java.nio.file.Path;
import java.util.*; import java.util.*;
import java.util.concurrent.BrokenBarrierException;
import java.util.concurrent.CountDownLatch; import java.util.concurrent.CountDownLatch;
import java.util.concurrent.CyclicBarrier;
import java.util.concurrent.atomic.AtomicBoolean; import java.util.concurrent.atomic.AtomicBoolean;
import java.util.concurrent.atomic.AtomicInteger; import java.util.concurrent.atomic.AtomicInteger;
import java.util.concurrent.atomic.AtomicReference; import java.util.concurrent.atomic.AtomicReference;
@ -527,11 +529,19 @@ public class InternalEngineTests extends ESTestCase {
public void testConcurrentGetAndFlush() throws Exception { public void testConcurrentGetAndFlush() throws Exception {
ParsedDocument doc = testParsedDocument("1", "1", "test", null, -1, -1, testDocumentWithTextField(), B_1, null); ParsedDocument doc = testParsedDocument("1", "1", "test", null, -1, -1, testDocumentWithTextField(), B_1, null);
engine.create(new Engine.Create(newUid("1"), doc)); engine.create(new Engine.Create(newUid("1"), doc));
final AtomicReference<Engine.GetResult> latestGetResult = new AtomicReference<>(); final AtomicReference<Engine.GetResult> latestGetResult = new AtomicReference<>();
latestGetResult.set(engine.get(new Engine.Get(true, newUid("1"))));
final AtomicBoolean flushFinished = new AtomicBoolean(false); final AtomicBoolean flushFinished = new AtomicBoolean(false);
final CyclicBarrier barrier = new CyclicBarrier(2);
Thread getThread = new Thread() { Thread getThread = new Thread() {
@Override @Override
public void run() { public void run() {
try {
barrier.await();
} catch (InterruptedException | BrokenBarrierException e) {
throw new RuntimeException(e);
}
while (flushFinished.get() == false) { while (flushFinished.get() == false) {
Engine.GetResult previousGetResult = latestGetResult.get(); Engine.GetResult previousGetResult = latestGetResult.get();
if (previousGetResult != null) { if (previousGetResult != null) {
@ -545,6 +555,7 @@ public class InternalEngineTests extends ESTestCase {
} }
}; };
getThread.start(); getThread.start();
barrier.await();
engine.flush(); engine.flush();
flushFinished.set(true); flushFinished.set(true);
getThread.join(); getThread.join();