honeymoose
/
OpenSearch
mirror of https://github.com/honeymoose/OpenSearch.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

also support direct discovery.zen.ping_timeout setting even when it gets extended (like in the case of ec2 disco)

This commit is contained in:
kimchy 2011-06-14 20:50:05 +03:00
parent 8bb448473d
commit fee1747947
1 changed files with 6 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
modules/elasticsearch/src/main/java/org/elasticsearch/discovery/zen/ZenDiscovery.java
View File

@ -84,7 +84,7 @@ public class ZenDiscovery extends AbstractLifecycleComponent<Discovery> implemen
private final MembershipAction membership; private final MembershipAction membership;
private final TimeValue initialPingTimeout; private final TimeValue pingTimeout;
// a flag that should be used only for testing // a flag that should be used only for testing
private final boolean sendLeaveRequest; private final boolean sendLeaveRequest;
@ -114,10 +114,11 @@ public class ZenDiscovery extends AbstractLifecycleComponent<Discovery> implemen
this.transportService = transportService; this.transportService = transportService;
this.pingService = pingService; this.pingService = pingService;
this.initialPingTimeout = componentSettings.getAsTime("ping_timeout", componentSettings.getAsTime("initial_ping_timeout", timeValueSeconds(3))); // also support direct discovery.zen settings, for cases when it gets extended
this.pingTimeout = settings.getAsTime("discovery.zen.ping_timeout", componentSettings.getAsTime("ping_timeout", componentSettings.getAsTime("initial_ping_timeout", timeValueSeconds(3))));
this.sendLeaveRequest = componentSettings.getAsBoolean("send_leave_request", true); this.sendLeaveRequest = componentSettings.getAsBoolean("send_leave_request", true);
logger.debug("using ping_timeout [{}]", initialPingTimeout); logger.debug("using ping_timeout [{}]", pingTimeout);
this.electMaster = new ElectMasterService(settings); this.electMaster = new ElectMasterService(settings);
@ -281,7 +282,7 @@ public class ZenDiscovery extends AbstractLifecycleComponent<Discovery> implemen
// send join request // send join request
ClusterState clusterState; ClusterState clusterState;
try { try {
clusterState = membership.sendJoinRequestBlocking(masterNode, localNode, initialPingTimeout); clusterState = membership.sendJoinRequestBlocking(masterNode, localNode, pingTimeout);
} catch (Exception e) { } catch (Exception e) {
if (e instanceof ElasticSearchException) { if (e instanceof ElasticSearchException) {
logger.info("failed to send join request to master [{}], reason [{}]", masterNode, ((ElasticSearchException) e).getDetailedMessage()); logger.info("failed to send join request to master [{}], reason [{}]", masterNode, ((ElasticSearchException) e).getDetailedMessage());
@ -497,7 +498,7 @@ public class ZenDiscovery extends AbstractLifecycleComponent<Discovery> implemen
} }
private DiscoveryNode findMaster() { private DiscoveryNode findMaster() {
ZenPing.PingResponse[] pingResponses = pingService.pingAndWait(initialPingTimeout); ZenPing.PingResponse[] pingResponses = pingService.pingAndWait(pingTimeout);
if (pingResponses == null) { if (pingResponses == null) {
return null; return null;
} }