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

add debug logging

This commit is contained in:
kimchy 2010-05-12 17:27:50 +03:00
parent 5b8dac3dd7
commit a11c7beef8
5 changed files with 11 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -105,6 +105,8 @@ public class ZenDiscovery extends AbstractLifecycleComponent<Discovery> implemen
this.initialPingTimeout = componentSettings.getAsTime("initial_ping_timeout", timeValueSeconds(3));
logger.debug("Using initial_ping_timeout [{}]", initialPingTimeout);
this.electMaster = new ElectMasterService(settings);
this.masterFD = new MasterFaultDetection(settings, threadPool, transportService, this);

2
modules/elasticsearch/src/main/java/org/elasticsearch/discovery/zen/fd/MasterFaultDetection.java
View File

@ -88,6 +88,8 @@ public class MasterFaultDetection extends AbstractComponent {
this.pingRetryTimeout = componentSettings.getAsTime("ping_timeout", timeValueSeconds(6));
this.pingRetryCount = componentSettings.getAsInt("ping_retries", 5);
logger.debug("Master FD uses ping_interval [{}], ping_timeout [{}], ping_retries [{}]", pingInterval, pingRetryTimeout, pingRetryCount);
this.connectionListener = new FDConnectionListener();
transportService.addConnectionListener(connectionListener);

2
modules/elasticsearch/src/main/java/org/elasticsearch/discovery/zen/fd/NodesFaultDetection.java
View File

@ -84,6 +84,8 @@ public class NodesFaultDetection extends AbstractComponent {
this.pingRetryTimeout = componentSettings.getAsTime("ping_timeout", timeValueSeconds(6));
this.pingRetryCount = componentSettings.getAsInt("ping_retries", 5);
logger.debug("Nodes FD uses ping_interval [{}], ping_timeout [{}], ping_retries [{}]", pingInterval, pingRetryTimeout, pingRetryCount);
transportService.registerHandler(PingRequestHandler.ACTION, new PingRequestHandler());
this.connectionListener = new FDConnectionListener();

2
modules/elasticsearch/src/main/java/org/elasticsearch/discovery/zen/ping/multicast/MulticastZenPing.java
View File

@ -112,6 +112,8 @@ public class MulticastZenPing extends AbstractLifecycleComponent<ZenPing> implem
this.bufferSize = componentSettings.getAsInt("buffer_size", 2048);
this.ttl = componentSettings.getAsInt("ttl", 3);
logger.debug("Using group [{}], with port [{}], ttl [{}], and address [{}]", group, port, ttl, address);
this.transportService.registerHandler(MulticastPingResponseRequestHandler.ACTION, new MulticastPingResponseRequestHandler());
}

3
modules/elasticsearch/src/main/java/org/elasticsearch/discovery/zen/ping/unicast/UnicastZenPing.java
View File

@ -94,6 +94,9 @@ public class UnicastZenPing extends AbstractLifecycleComponent<ZenPing> implemen
if (componentSettings.get("hosts") != null) {
hosts.addAll(Strings.commaDelimitedListToSet(componentSettings.get("hosts")));
}
logger.debug("Using hosts ", hosts);
List<DiscoveryNode> nodes = Lists.newArrayList();
int idCounter = 0;
for (String host : hosts) {