apache/cloudstack
1
0
Fork 0
mirror of https://github.com/apache/cloudstack.git synced 2025-11-02 11:52:28 +01:00
Code Issues Packages Projects Releases Wiki Activity

add logging to clustering notification

Browse Source
This commit is contained in:
Kelven Yang 2011-07-11 17:16:23 -07:00
parent 6bea2f7c2b
commit 6d8eb45bad
2 changed files with 25 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
server/src/com/cloud/alert/ClusterAlertAdapter.java
View File

@ -61,7 +61,9 @@ public class ClusterAlertAdapter implements AlertAdapter {
private void onClusterNodeJoined(Object sender, ClusterNodeJoinEventArgs args) {
if (s_logger.isDebugEnabled()) {
s_logger.debug("Handle cluster node join alert, self node: " + args.getSelf());
for(ManagementServerHostVO mshost: args.getJoinedNodes()) {
s_logger.debug("Handle cluster node join alert, joined node: " + mshost.getServiceIP());
}
}
for (ManagementServerHostVO mshost : args.getJoinedNodes()) {
@ -79,7 +81,9 @@ public class ClusterAlertAdapter implements AlertAdapter {
private void onClusterNodeLeft(Object sender, ClusterNodeLeftEventArgs args) {
if (s_logger.isDebugEnabled()) {
s_logger.debug("Handle cluster node left alert, self node: " + args.getSelf());
for(ManagementServerHostVO mshost: args.getLeftNodes()) {
s_logger.debug("Handle cluster node left alert, leaving node: " + mshost.getServiceIP());
}
}
for (ManagementServerHostVO mshost : args.getLeftNodes()) {

19
server/src/com/cloud/cluster/ClusterManagerImpl.java
View File

@ -470,6 +470,14 @@ public class ClusterManagerImpl implements ClusterManager {
}
public void notifyNodeJoined(List<ManagementServerHostVO> nodeList) {
if(s_logger.isDebugEnabled()) {
s_logger.debug("Notify management server node join to listeners.");
for(ManagementServerHostVO mshost : nodeList) {
s_logger.debug("Joining node, IP: " + mshost.getServiceIP() + ", msid: " + mshost.getMsid());
}
}
synchronized(listeners) {
for(ClusterManagerListener listener : listeners) {
listener.onManagementNodeJoined(nodeList, _mshostId);
@ -481,6 +489,14 @@ public class ClusterManagerImpl implements ClusterManager {
}
public void notifyNodeLeft(List<ManagementServerHostVO> nodeList) {
if(s_logger.isDebugEnabled()) {
s_logger.debug("Notify management server node left to listeners.");
for(ManagementServerHostVO mshost : nodeList) {
s_logger.debug("Leaving node, IP: " + mshost.getServiceIP() + ", msid: " + mshost.getMsid());
}
}
synchronized(listeners) {
for(ClusterManagerListener listener : listeners) {
listener.onManagementNodeLeft(nodeList, _mshostId);
@ -492,6 +508,9 @@ public class ClusterManagerImpl implements ClusterManager {
}
public void notifyNodeIsolated() {
if(s_logger.isDebugEnabled())
s_logger.debug("Notify management server node isolation to listeners");
synchronized(listeners) {
for(ClusterManagerListener listener : listeners) {
listener.onManagementNodeIsolated();