|
33 | 33 | import org.elasticsearch.test.EqualsHashCodeTestUtils.CopyFunction; |
34 | 34 | import org.elasticsearch.test.transport.CapturingTransport; |
35 | 35 | import org.elasticsearch.test.transport.MockTransport; |
36 | | -import org.elasticsearch.threadpool.ThreadPool; |
37 | 36 | import org.elasticsearch.threadpool.ThreadPool.Names; |
38 | 37 | import org.elasticsearch.transport.ConnectTransportException; |
39 | 38 | import org.elasticsearch.transport.TransportException; |
|
73 | 72 | import static org.hamcrest.Matchers.not; |
74 | 73 | import static org.hamcrest.Matchers.nullValue; |
75 | 74 | import static org.hamcrest.core.IsInstanceOf.instanceOf; |
76 | | -import static org.mockito.Mockito.mock; |
77 | 75 |
|
78 | 76 | public class FollowersCheckerTests extends ESTestCase { |
79 | 77 |
|
@@ -548,14 +546,16 @@ public String executor() { |
548 | 546 | } |
549 | 547 | } |
550 | 548 |
|
551 | | - private void testPreferMasterNodes() { |
| 549 | + public void testPreferMasterNodes() { |
552 | 550 | List<DiscoveryNode> nodes = randomNodes(10); |
553 | 551 | DiscoveryNodes.Builder discoNodesBuilder = DiscoveryNodes.builder(); |
554 | 552 | nodes.forEach(dn -> discoNodesBuilder.add(dn)); |
555 | 553 | DiscoveryNodes discoveryNodes = discoNodesBuilder.localNodeId(nodes.get(0).getId()).build(); |
556 | 554 | CapturingTransport capturingTransport = new CapturingTransport(); |
557 | | - TransportService transportService = capturingTransport.createTransportService(Settings.EMPTY, mock(ThreadPool.class), |
558 | | - TransportService.NOOP_TRANSPORT_INTERCEPTOR, x -> nodes.get(0), null, emptySet()); |
| 555 | + final Settings settings = Settings.builder().put(NODE_NAME_SETTING.getKey(), nodes.get(0).getName()).build(); |
| 556 | + final DeterministicTaskQueue deterministicTaskQueue = new DeterministicTaskQueue(settings, random()); |
| 557 | + TransportService transportService = capturingTransport.createTransportService(Settings.EMPTY, |
| 558 | + deterministicTaskQueue.getThreadPool(), TransportService.NOOP_TRANSPORT_INTERCEPTOR, x -> nodes.get(0), null, emptySet()); |
559 | 559 | final FollowersChecker followersChecker = new FollowersChecker(Settings.EMPTY, transportService, fcr -> { |
560 | 560 | assert false : fcr; |
561 | 561 | }, (node, reason) -> { |
|
0 commit comments