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

add more logging to jgroups disco

This commit is contained in:
kimchy 2010-04-01 23:38:23 +03:00
parent 10f96ba8f2
commit 0794c808b9
1 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
modules/elasticsearch/src/main/java/org/elasticsearch/discovery/jgroups/JgroupsDiscovery.java
View File

@ -250,6 +250,11 @@ public class JgroupsDiscovery extends AbstractLifecycleComponent<Discovery> impl
BytesStreamInput is = new BytesStreamInput(msg.getBuffer());
final Node newNode = Node.readNode(is);
is.close();
if (logger.isDebugEnabled()) {
logger.debug("Received node information from [{}], node [{}]", msg.getSrc(), newNode);
}
clusterService.submitStateUpdateTask("jgroups-disco-receive(from node[" + newNode + "])", new ClusterStateUpdateTask() {
@Override public ClusterState execute(ClusterState currentState) {
if (currentState.nodes().nodeExists(newNode.id())) {
@ -261,7 +266,7 @@ public class JgroupsDiscovery extends AbstractLifecycleComponent<Discovery> impl
}
});
} catch (Exception e) {
logger.warn("Can't read address from cluster member, message [" + msg.getClass().getName() + "/" + msg + "]", e);
logger.warn("Can't read address from cluster member [" + msg.getSrc() + "] message [" + msg.getClass().getName() + "/" + msg + "]", e);
}
return;