|
@@ -42,6 +42,7 @@ import org.elasticsearch.threadpool.ThreadPool;
|
|
|
import org.elasticsearch.transport.AbstractSimpleTransportTestCase;
|
|
|
import org.elasticsearch.transport.TransportRequest;
|
|
|
import org.elasticsearch.transport.TransportService;
|
|
|
+import org.elasticsearch.transport.TransportSettings;
|
|
|
import org.elasticsearch.transport.nio.MockNioTransport;
|
|
|
import org.junit.After;
|
|
|
import org.junit.Before;
|
|
@@ -76,8 +77,12 @@ public abstract class TaskManagerTestCase extends ESTestCase {
|
|
|
public void setupTestNodes(Settings settings) {
|
|
|
nodesCount = randomIntBetween(2, 10);
|
|
|
testNodes = new TestNode[nodesCount];
|
|
|
+ final Settings reservedPortRangeSettings = Settings.builder()
|
|
|
+ .put(TransportSettings.PORT.getKey(), getPortRange())
|
|
|
+ .put(settings)
|
|
|
+ .build();
|
|
|
for (int i = 0; i < testNodes.length; i++) {
|
|
|
- testNodes[i] = new TestNode("node" + i, threadPool, settings);
|
|
|
+ testNodes[i] = new TestNode("node" + i, threadPool, reservedPortRangeSettings);
|
|
|
}
|
|
|
}
|
|
|
|