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

DiscoveryWithServiceDisruptions: some more java docs and todos

This commit is contained in:
Boaz Leskes 2014-10-02 13:29:44 +02:00
parent 3b38db121b
commit c4866b3f03
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/test/java/org/elasticsearch/discovery/DiscoveryWithServiceDisruptions.java
View File

@ -410,14 +410,17 @@ public class DiscoveryWithServiceDisruptions extends ElasticsearchIntegrationTes
} }
/** /**
* Test the we do not loose document whose indexing request was successful, under a randomly selected disruption scheme * Test that we do not loose document whose indexing request was successful, under a randomly selected disruption scheme
* We also collect & report the type of indexing failures that occur. * We also collect & report the type of indexing failures that occur.
*
* This test is a superset of tests run in the Jepsen test suite, with the exception of versioned updates
*/ */
@Test @Test
// NOTE: if you remove the awaitFix, make sure to port the test to the 1.x branch // NOTE: if you remove the awaitFix, make sure to port the test to the 1.x branch
@LuceneTestCase.AwaitsFix(bugUrl = "needs some more work to stabilize") @LuceneTestCase.AwaitsFix(bugUrl = "needs some more work to stabilize")
@TestLogging("action.index:TRACE,action.get:TRACE,discovery:TRACE,cluster.service:TRACE,indices.recovery:TRACE,indices.cluster:TRACE") @TestLogging("action.index:TRACE,action.get:TRACE,discovery:TRACE,cluster.service:TRACE,indices.recovery:TRACE,indices.cluster:TRACE")
public void testAckedIndexing() throws Exception { public void testAckedIndexing() throws Exception {
// TODO: add node count randomizaion
final List<String> nodes = startCluster(3); final List<String> nodes = startCluster(3);
assertAcked(prepareCreate("test") assertAcked(prepareCreate("test")
@ -874,6 +877,7 @@ public class DiscoveryWithServiceDisruptions extends ElasticsearchIntegrationTes
} }
private ServiceDisruptionScheme addRandomDisruptionScheme() { private ServiceDisruptionScheme addRandomDisruptionScheme() {
// TODO: add partial partitions
List<ServiceDisruptionScheme> list = Arrays.asList( List<ServiceDisruptionScheme> list = Arrays.asList(
new NetworkUnresponsivePartition(getRandom()), new NetworkUnresponsivePartition(getRandom()),
new NetworkDelaysPartition(getRandom()), new NetworkDelaysPartition(getRandom()),