honeymoose/OpenSearch
1
0
Fork 0
mirror of https://github.com/honeymoose/OpenSearch.git synced 2025-02-17 10:25:15 +00:00
Code Issues Packages Projects Releases Wiki Activity

Test: testRelocationWithBusyClusterUpdateThread - listener should wait for replicas to be created

Browse Source
This commit is contained in:
Boaz Leskes 2015-02-07 10:51:07 +01:00
parent e684d7fde4
commit 1167beed48
1 changed files with 12 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
src/test/java/org/elasticsearch/recovery/RelocationTests.java
View File

@ -488,15 +488,20 @@ public class RelocationTests extends ElasticsearchIntegrationTest {
internalCluster().getInstance(ClusterService.class, node1).addLast(new ClusterStateListener() {
@Override
public void clusterChanged(ClusterChangedEvent event) {
if (event.state().routingNodes().hasUnassignedShards() == false) {
allReplicasAssigned.countDown();
try {
releaseClusterState.await();
} catch (InterruptedException e) {
//
}
ClusterState state = event.state();
if (state.routingTable().allShards().size() == 1 || state.routingNodes().hasUnassignedShards()) {
// we have no replicas or they are not assigned yet
return;
}
allReplicasAssigned.countDown();
try {
releaseClusterState.await();
} catch (InterruptedException e) {
//
}
}
});
internalCluster().getInstance(ClusterService.class, master).addLast(new ClusterStateListener() {