+3 −2

TransportClientNodesService.java

...ch/client/transport/TransportClientNodesService.java

+1 −7

UnicastZenPing.java

...earch/discovery/zen/ping/unicast/UnicastZenPing.java

+128 −5

TransportService.java

...va/org/elasticsearch/transport/TransportService.java

+3 −2

TaskManagerTestCase.java

...on/admin/cluster/node/tasks/TaskManagerTestCase.java

+1 −1

TransportBulkActionTookTests.java

...search/action/bulk/TransportBulkActionTookTests.java

+1 −1

TransportBroadcastByNodeActionTests.java

...adcast/node/TransportBroadcastByNodeActionTests.java

+1 −1

TransportMasterNodeActionTests.java

...n/support/master/TransportMasterNodeActionTests.java

+1 −1

TransportNodesActionTests.java

.../action/support/nodes/TransportNodesActionTests.java

+1 −1

BroadcastReplicationTests.java

...n/support/replication/BroadcastReplicationTests.java

+1 −1

TransportReplicationActionTests.java

...ort/replication/TransportReplicationActionTests.java

+1 −1

TransportInstanceSingleOperationActionTests.java

...nce/TransportInstanceSingleOperationActionTests.java

+11 −2

FailAndRetryMockTransport.java

...arch/client/transport/FailAndRetryMockTransport.java

+2 −2

TransportClientHeadersTests.java

...ch/client/transport/TransportClientHeadersTests.java

+10 −8

TransportClientNodesServiceTests.java

...ient/transport/TransportClientNodesServiceTests.java

+1 −1

NodeConnectionsServiceTests.java

...asticsearch/cluster/NodeConnectionsServiceTests.java

+1 −1

ShardStateActionTests.java

...arch/cluster/action/shard/ShardStateActionTests.java

+1 −1

ClusterStateHealthTests.java

...icsearch/cluster/health/ClusterStateHealthTests.java

+1 −1

NetworkModuleTests.java

...elasticsearch/common/network/NetworkModuleTests.java

+6 −2

ZenFaultDetectionTests.java

.../elasticsearch/discovery/ZenFaultDetectionTests.java

+114 −24

UnicastZenPingIT.java

...rch/discovery/zen/ping/unicast/UnicastZenPingIT.java

+12 −9

PublishClusterStateActionTests.java

...very/zen/publish/PublishClusterStateActionTests.java

+3 −3

DynamicMappingDisabledTests.java

...search/index/mapper/DynamicMappingDisabledTests.java

+1 −1

IndicesStoreTests.java

...g/elasticsearch/indices/store/IndicesStoreTests.java

+10 −9

AbstractSimpleTransportTestCase.java

...earch/transport/AbstractSimpleTransportTestCase.java

+3 −1

NettySizeHeaderFrameDecoderTests.java

...arch/transport/NettySizeHeaderFrameDecoderTests.java

+206 −0

NettyTransportServiceHandshakeTests.java

...h/transport/NettyTransportServiceHandshakeTests.java

+3 −2

TransportModuleTests.java

...rg/elasticsearch/transport/TransportModuleTests.java

+3 −2

SimpleLocalTransportTests.java

...earch/transport/local/SimpleLocalTransportTests.java

+5 −2

NettyScheduledPingTests.java

...csearch/transport/netty/NettyScheduledPingTests.java

+3 −2

SimpleNettyTransportTests.java

...earch/transport/netty/SimpleNettyTransportTests.java

+3 −2

IndicesRequestTests.java

...g/elasticsearch/messy/tests/IndicesRequestTests.java

+2 −1

Ec2DiscoveryTests.java

...g/elasticsearch/discovery/ec2/Ec2DiscoveryTests.java

+2 −1

GceDiscoveryTests.java

...g/elasticsearch/discovery/gce/GceDiscoveryTests.java

+13 −6

MockTransportService.java

...asticsearch/test/transport/MockTransportService.java