From f5923403a14e8d601740fa33742db65656090891 Mon Sep 17 00:00:00 2001
From: Boaz Leskes <b.leskes@gmail.com>
Date: Mon, 23 Mar 2015 21:58:44 +0100
Subject: [PATCH] Test: RecoveryFromGatewayTests.testReusePeerRecovery -
 increase concurrent recoveries

To speed up the test and prevent ensureGreen() from timing out.
---
 .../org/elasticsearch/gateway/RecoveryFromGatewayTests.java     | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/src/test/java/org/elasticsearch/gateway/RecoveryFromGatewayTests.java b/src/test/java/org/elasticsearch/gateway/RecoveryFromGatewayTests.java
index fe11f3459ec..84d213cd57d 100644
--- a/src/test/java/org/elasticsearch/gateway/RecoveryFromGatewayTests.java
+++ b/src/test/java/org/elasticsearch/gateway/RecoveryFromGatewayTests.java
@@ -25,6 +25,7 @@ import org.elasticsearch.action.admin.indices.recovery.ShardRecoveryResponse;
 import org.elasticsearch.client.Client;
 import org.elasticsearch.cluster.ClusterState;
 import org.elasticsearch.cluster.routing.allocation.decider.EnableAllocationDecider;
+import org.elasticsearch.cluster.routing.allocation.decider.ThrottlingAllocationDecider;
 import org.elasticsearch.common.settings.ImmutableSettings;
 import org.elasticsearch.common.settings.Settings;
 import org.elasticsearch.common.xcontent.XContentFactory;
@@ -348,6 +349,7 @@ public class RecoveryFromGatewayTests extends ElasticsearchIntegrationTest {
                 .put("action.admin.cluster.node.shutdown.delay", "10ms")
                 .put(MockFSDirectoryService.CHECK_INDEX_ON_CLOSE, false)
                 .put("gateway.recover_after_nodes", 4)
+                .put(ThrottlingAllocationDecider.CLUSTER_ROUTING_ALLOCATION_CONCURRENT_RECOVERIES, 4)
                 .put(MockDirectoryHelper.CRASH_INDEX, false).build();
 
         internalCluster().startNodesAsync(4, settings).get();