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

wrap cluster heartbeat in a try-catch

Browse Source
This commit is contained in:
Alex Huang 2011-02-01 12:03:55 -08:00
parent 23b9a2452d
commit ade0097a0a
1 changed files with 150 additions and 97 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -170,9 +170,10 @@ public class ClusterManagerImpl implements ClusterManager {
public Answer[] execute(String strPeer, long agentId, Command [] cmds, boolean stopOnError) { public Answer[] execute(String strPeer, long agentId, Command [] cmds, boolean stopOnError) {
ClusterService peerService = null; ClusterService peerService = null;
if(s_logger.isDebugEnabled()) if(s_logger.isDebugEnabled()) {
s_logger.debug(getSelfPeerName() + " -> " + strPeer + "." + agentId + " " + s_logger.debug(getSelfPeerName() + " -> " + strPeer + "." + agentId + " " +
gson.toJson(cmds, Command[].class)); gson.toJson(cmds, Command[].class));
}
for(int i = 0; i < 2; i++) { for(int i = 0; i < 2; i++) {
try { try {
@ -183,14 +184,16 @@ public class ClusterManagerImpl implements ClusterManager {
if(peerService != null) { if(peerService != null) {
try { try {
if(s_logger.isDebugEnabled()) if(s_logger.isDebugEnabled()) {
s_logger.debug("Send " + getSelfPeerName() + " -> " + strPeer + "." + agentId + " to remote"); s_logger.debug("Send " + getSelfPeerName() + " -> " + strPeer + "." + agentId + " to remote");
}
long startTick = System.currentTimeMillis(); long startTick = System.currentTimeMillis();
String strResult = peerService.execute(getSelfPeerName(), agentId, gson.toJson(cmds, Command[].class), stopOnError); String strResult = peerService.execute(getSelfPeerName(), agentId, gson.toJson(cmds, Command[].class), stopOnError);
if(s_logger.isDebugEnabled()) if(s_logger.isDebugEnabled()) {
s_logger.debug("Completed " + getSelfPeerName() + " -> " + strPeer + "." + agentId + "in " + s_logger.debug("Completed " + getSelfPeerName() + " -> " + strPeer + "." + agentId + "in " +
(System.currentTimeMillis() - startTick) + " ms, result: " + strResult); (System.currentTimeMillis() - startTick) + " ms, result: " + strResult);
}
if(strResult != null) { if(strResult != null) {
try { try {
@ -204,9 +207,10 @@ public class ClusterManagerImpl implements ClusterManager {
} catch (RemoteException e) { } catch (RemoteException e) {
invalidatePeerService(strPeer); invalidatePeerService(strPeer);
if(s_logger.isInfoEnabled()) if(s_logger.isInfoEnabled()) {
s_logger.info("Exception on remote execution, peer: " + strPeer + ", iteration: " s_logger.info("Exception on remote execution, peer: " + strPeer + ", iteration: "
+ i + ", exception message :" + e.getMessage()); + i + ", exception message :" + e.getMessage());
}
} }
} }
} }
@ -219,9 +223,10 @@ public class ClusterManagerImpl implements ClusterManager {
ClusterService peerService = null; ClusterService peerService = null;
if(s_logger.isDebugEnabled()) if(s_logger.isDebugEnabled()) {
s_logger.debug("Async " + getSelfPeerName() + " -> " + strPeer + "." + agentId + " " + s_logger.debug("Async " + getSelfPeerName() + " -> " + strPeer + "." + agentId + " " +
gson.toJson(cmds, Command[].class)); gson.toJson(cmds, Command[].class));
}
for(int i = 0; i < 2; i++) { for(int i = 0; i < 2; i++) {
try { try {
@ -234,17 +239,19 @@ public class ClusterManagerImpl implements ClusterManager {
try { try {
long seq = 0; long seq = 0;
synchronized(String.valueOf(agentId).intern()) { synchronized(String.valueOf(agentId).intern()) {
if(s_logger.isDebugEnabled()) if(s_logger.isDebugEnabled()) {
s_logger.debug("Send Async " + getSelfPeerName() + " -> " + strPeer + "." + agentId + " to remote"); s_logger.debug("Send Async " + getSelfPeerName() + " -> " + strPeer + "." + agentId + " to remote");
}
long startTick = System.currentTimeMillis(); long startTick = System.currentTimeMillis();
seq = peerService.executeAsync(getSelfPeerName(), agentId, gson.toJson(cmds, Command[].class), stopOnError); seq = peerService.executeAsync(getSelfPeerName(), agentId, gson.toJson(cmds, Command[].class), stopOnError);
if(seq > 0) { if(seq > 0) {
if(s_logger.isDebugEnabled()) if(s_logger.isDebugEnabled()) {
s_logger.debug("Completed Async " + getSelfPeerName() + " -> " + strPeer + "." + agentId s_logger.debug("Completed Async " + getSelfPeerName() + " -> " + strPeer + "." + agentId
+ " in " + (System.currentTimeMillis() - startTick) + " ms" + " in " + (System.currentTimeMillis() - startTick) + " ms"
+ ", register local listener " + strPeer + "/" + seq); + ", register local listener " + strPeer + "/" + seq);
}
registerAsyncCall(strPeer, seq, listener); registerAsyncCall(strPeer, seq, listener);
} else { } else {
@ -256,8 +263,9 @@ public class ClusterManagerImpl implements ClusterManager {
} catch (RemoteException e) { } catch (RemoteException e) {
invalidatePeerService(strPeer); invalidatePeerService(strPeer);
if(s_logger.isInfoEnabled()) if(s_logger.isInfoEnabled()) {
s_logger.info("Exception on remote execution -> " + strPeer + ", iteration : " + i); s_logger.info("Exception on remote execution -> " + strPeer + ", iteration : " + i);
}
} }
} }
} }
@ -268,9 +276,10 @@ public class ClusterManagerImpl implements ClusterManager {
@Override @Override
public boolean onAsyncResult(String executingPeer, long agentId, long seq, Answer[] answers) { public boolean onAsyncResult(String executingPeer, long agentId, long seq, Answer[] answers) {
if(s_logger.isDebugEnabled()) if(s_logger.isDebugEnabled()) {
s_logger.debug("Process Async-call result from remote peer " + executingPeer + ", {" + s_logger.debug("Process Async-call result from remote peer " + executingPeer + ", {" +
agentId + "-" + seq + "} answers: " + (answers != null ? gson.toJson(answers, Answer[].class): "null")); agentId + "-" + seq + "} answers: " + (answers != null ? gson.toJson(answers, Answer[].class): "null"));
}
Listener listener = null; Listener listener = null;
synchronized(String.valueOf(agentId).intern()) { synchronized(String.valueOf(agentId).intern()) {
@ -282,31 +291,36 @@ public class ClusterManagerImpl implements ClusterManager {
if(listener != null) { if(listener != null) {
long startTick = System.currentTimeMillis(); long startTick = System.currentTimeMillis();
if(s_logger.isDebugEnabled()) if(s_logger.isDebugEnabled()) {
s_logger.debug("Processing answer {" + agentId + "-" + seq + "} from remote peer " + executingPeer); s_logger.debug("Processing answer {" + agentId + "-" + seq + "} from remote peer " + executingPeer);
}
listener.processAnswers(agentId, seq, answers); listener.processAnswers(agentId, seq, answers);
if(s_logger.isDebugEnabled()) if(s_logger.isDebugEnabled()) {
s_logger.debug("Answer {" + agentId + "-" + seq + "} is processed in " + s_logger.debug("Answer {" + agentId + "-" + seq + "} is processed in " +
(System.currentTimeMillis() - startTick) + " ms"); (System.currentTimeMillis() - startTick) + " ms");
}
if(!listener.isRecurring()) { if(!listener.isRecurring()) {
if(s_logger.isDebugEnabled()) if(s_logger.isDebugEnabled()) {
s_logger.debug("Listener is not recurring after async-result callback {" + s_logger.debug("Listener is not recurring after async-result callback {" +
agentId + "-" + seq + "}, unregister it"); agentId + "-" + seq + "}, unregister it");
}
unregisterAsyncCall(executingPeer, seq); unregisterAsyncCall(executingPeer, seq);
} else { } else {
if(s_logger.isDebugEnabled()) if(s_logger.isDebugEnabled()) {
s_logger.debug("Listener is recurring after async-result callback {" + agentId s_logger.debug("Listener is recurring after async-result callback {" + agentId
+"-" + seq + "}, will keep it"); +"-" + seq + "}, will keep it");
}
return true; return true;
} }
} else { } else {
if(s_logger.isInfoEnabled()) if(s_logger.isInfoEnabled()) {
s_logger.info("Async-call Listener has not been registered yet for {" + agentId s_logger.info("Async-call Listener has not been registered yet for {" + agentId
+"-" + seq + "}"); +"-" + seq + "}");
}
} }
return false; return false;
} }
@ -314,9 +328,10 @@ public class ClusterManagerImpl implements ClusterManager {
@Override @Override
public boolean forwardAnswer(String targetPeer, long agentId, long seq, Answer[] answers) { public boolean forwardAnswer(String targetPeer, long agentId, long seq, Answer[] answers) {
if(s_logger.isDebugEnabled()) if(s_logger.isDebugEnabled()) {
s_logger.debug("Forward -> " + targetPeer + " Async-call answer {" + agentId + "-" + seq + s_logger.debug("Forward -> " + targetPeer + " Async-call answer {" + agentId + "-" + seq +
"} " + (answers != null? gson.toJson(answers, Answer[].class):"")); "} " + (answers != null? gson.toJson(answers, Answer[].class):""));
}
final String targetPeerF = targetPeer; final String targetPeerF = targetPeer;
final Answer[] answersF = answers; final Answer[] answersF = answers;
@ -337,14 +352,16 @@ public class ClusterManagerImpl implements ClusterManager {
boolean result = false; boolean result = false;
long startTick = System.currentTimeMillis(); long startTick = System.currentTimeMillis();
if(s_logger.isDebugEnabled()) if(s_logger.isDebugEnabled()) {
s_logger.debug("Start forwarding Async-call answer {" + agentId + "-" + seq + "} to remote"); s_logger.debug("Start forwarding Async-call answer {" + agentId + "-" + seq + "} to remote");
}
result = peerService.onAsyncResult(getSelfPeerName(), agentIdF, seqF, gson.toJson(answersF, Answer[].class)); result = peerService.onAsyncResult(getSelfPeerName(), agentIdF, seqF, gson.toJson(answersF, Answer[].class));
if(s_logger.isDebugEnabled()) if(s_logger.isDebugEnabled()) {
s_logger.debug("Completed forwarding Async-call answer {" + agentId + "-" + seq + "} in " + s_logger.debug("Completed forwarding Async-call answer {" + agentId + "-" + seq + "} in " +
(System.currentTimeMillis() - startTick) + " ms, return result: " + result); (System.currentTimeMillis() - startTick) + " ms, return result: " + result);
}
return result; return result;
} catch (RemoteException e) { } catch (RemoteException e) {
@ -365,8 +382,9 @@ public class ClusterManagerImpl implements ClusterManager {
HostVO host = _hostDao.findById(agentHostId); HostVO host = _hostDao.findById(agentHostId);
if(host != null && host.getManagementServerId() != null) { if(host != null && host.getManagementServerId() != null) {
if(getSelfPeerName().equals(Long.toString(host.getManagementServerId()))) if(getSelfPeerName().equals(Long.toString(host.getManagementServerId()))) {
return null; return null;
}
return Long.toString(host.getManagementServerId()); return Long.toString(host.getManagementServerId());
} }
@ -427,8 +445,9 @@ public class ClusterManagerImpl implements ClusterManager {
public ClusterService getPeerService(String strPeer) throws RemoteException { public ClusterService getPeerService(String strPeer) throws RemoteException {
synchronized(clusterPeers) { synchronized(clusterPeers) {
if(clusterPeers.containsKey(strPeer)) if(clusterPeers.containsKey(strPeer)) {
return clusterPeers.get(strPeer); return clusterPeers.get(strPeer);
}
} }
ClusterService service = _currentServiceAdapter.getPeerService(strPeer); ClusterService service = _currentServiceAdapter.getPeerService(strPeer);
@ -437,8 +456,9 @@ public class ClusterManagerImpl implements ClusterManager {
synchronized(clusterPeers) { synchronized(clusterPeers) {
// re-check the peer map again to deal with the // re-check the peer map again to deal with the
// race conditions // race conditions
if(!clusterPeers.containsKey(strPeer)) if(!clusterPeers.containsKey(strPeer)) {
clusterPeers.put(strPeer, service); clusterPeers.put(strPeer, service);
}
} }
} }
@ -447,8 +467,9 @@ public class ClusterManagerImpl implements ClusterManager {
public void invalidatePeerService(String strPeer) { public void invalidatePeerService(String strPeer) {
synchronized(clusterPeers) { synchronized(clusterPeers) {
if(clusterPeers.containsKey(strPeer)) if(clusterPeers.containsKey(strPeer)) {
clusterPeers.remove(strPeer); clusterPeers.remove(strPeer);
}
} }
} }
@ -456,8 +477,9 @@ public class ClusterManagerImpl implements ClusterManager {
String key = strPeer + "/" + seq; String key = strPeer + "/" + seq;
synchronized(asyncCalls) { synchronized(asyncCalls) {
if(!asyncCalls.containsKey(key)) if(!asyncCalls.containsKey(key)) {
asyncCalls.put(key, listener); asyncCalls.put(key, listener);
}
} }
} }
@ -465,8 +487,9 @@ public class ClusterManagerImpl implements ClusterManager {
String key = strPeer + "/" + seq; String key = strPeer + "/" + seq;
synchronized(asyncCalls) { synchronized(asyncCalls) {
if(asyncCalls.containsKey(key)) if(asyncCalls.containsKey(key)) {
return asyncCalls.get(key); return asyncCalls.get(key);
}
} }
return null; return null;
@ -476,8 +499,9 @@ public class ClusterManagerImpl implements ClusterManager {
String key = strPeer + "/" + seq; String key = strPeer + "/" + seq;
synchronized(asyncCalls) { synchronized(asyncCalls) {
if(asyncCalls.containsKey(key)) if(asyncCalls.containsKey(key)) {
asyncCalls.remove(key); asyncCalls.remove(key);
}
} }
} }
@ -485,11 +509,16 @@ public class ClusterManagerImpl implements ClusterManager {
return new Runnable() { return new Runnable() {
@Override @Override
public void run() { public void run() {
if(s_logger.isTraceEnabled()) try {
s_logger.trace("Cluster manager heartbeat update, id:" + _mshostId); if(s_logger.isTraceEnabled()) {
s_logger.trace("Cluster manager heartbeat update, id:" + _mshostId);
_mshostDao.update(_mshostId, DateUtil.currentGMTTime()); }
peerScan();
_mshostDao.update(_mshostId, DateUtil.currentGMTTime());
peerScan();
} catch (Exception e) {
s_logger.error("Problem with the cluster heartbeat!", e);
}
} }
}; };
} }
@ -505,8 +534,9 @@ public class ClusterManagerImpl implements ClusterManager {
for(Map.Entry<Long, ManagementServerHostVO> entry : activePeers.entrySet()) { for(Map.Entry<Long, ManagementServerHostVO> entry : activePeers.entrySet()) {
if(!isIdInList(entry.getKey(), currentList)) { if(!isIdInList(entry.getKey(), currentList)) {
if(entry.getKey().longValue() != _mshostId.longValue()) { if(entry.getKey().longValue() != _mshostId.longValue()) {
if(s_logger.isDebugEnabled()) if(s_logger.isDebugEnabled()) {
s_logger.debug("Detected management node left, id:" + entry.getKey() + ", nodeIP:" + entry.getValue().getServiceIP()); s_logger.debug("Detected management node left, id:" + entry.getKey() + ", nodeIP:" + entry.getValue().getServiceIP());
}
removedNodeList.add(entry.getValue()); removedNodeList.add(entry.getValue());
} }
} }
@ -522,23 +552,27 @@ public class ClusterManagerImpl implements ClusterManager {
if(!activePeers.containsKey(mshost.getId())) { if(!activePeers.containsKey(mshost.getId())) {
activePeers.put(mshost.getId(), mshost); activePeers.put(mshost.getId(), mshost);
if(s_logger.isDebugEnabled()) if(s_logger.isDebugEnabled()) {
s_logger.debug("Detected management node joined, id:" + mshost.getId() + ", nodeIP:" + mshost.getServiceIP()); s_logger.debug("Detected management node joined, id:" + mshost.getId() + ", nodeIP:" + mshost.getServiceIP());
}
newNodeList.add(mshost); newNodeList.add(mshost);
} }
} }
if(newNodeList.size() > 0) if(newNodeList.size() > 0) {
notifyNodeJoined(newNodeList); notifyNodeJoined(newNodeList);
}
if(removedNodeList.size() > 0) if(removedNodeList.size() > 0) {
notifyNodeLeft(removedNodeList); notifyNodeLeft(removedNodeList);
}
} }
private static boolean isIdInList(Long id, List<ManagementServerHostVO> l) { private static boolean isIdInList(Long id, List<ManagementServerHostVO> l) {
for(ManagementServerHostVO mshost : l) { for(ManagementServerHostVO mshost : l) {
if(mshost.getId() != null && mshost.getId() == id) if(mshost.getId() != null && mshost.getId() == id) {
return true; return true;
}
} }
return false; return false;
} }
@ -550,8 +584,9 @@ public class ClusterManagerImpl implements ClusterManager {
@Override @DB @Override @DB
public boolean start() { public boolean start() {
if(s_logger.isInfoEnabled()) if(s_logger.isInfoEnabled()) {
s_logger.info("Starting cluster manager, msid : " + _id); s_logger.info("Starting cluster manager, msid : " + _id);
}
Transaction txn = Transaction.currentTxn(); Transaction txn = Transaction.currentTxn();
try { try {
@ -574,11 +609,13 @@ public class ClusterManagerImpl implements ClusterManager {
mshost.setAlertCount(0); mshost.setAlertCount(0);
_mshostDao.persist(mshost); _mshostDao.persist(mshost);
if(s_logger.isInfoEnabled()) if(s_logger.isInfoEnabled()) {
s_logger.info("New instance of management server msid " + _id + " is being started"); s_logger.info("New instance of management server msid " + _id + " is being started");
}
} else { } else {
if(s_logger.isInfoEnabled()) if(s_logger.isInfoEnabled()) {
s_logger.info("Management server " + _id + " is being started"); s_logger.info("Management server " + _id + " is being started");
}
_mshostDao.update(mshost.getId(), NetUtils.getHostName(), version, _mshostDao.update(mshost.getId(), NetUtils.getHostName(), version,
_clusterNodeIP, _currentServiceAdapter.getServicePort(), DateUtil.currentGMTTime()); _clusterNodeIP, _currentServiceAdapter.getServicePort(), DateUtil.currentGMTTime());
@ -587,8 +624,9 @@ public class ClusterManagerImpl implements ClusterManager {
txn.commit(); txn.commit();
_mshostId = mshost.getId(); _mshostId = mshost.getId();
if(s_logger.isInfoEnabled()) if(s_logger.isInfoEnabled()) {
s_logger.info("Management server (host id : " + _mshostId + ") is available at " + _clusterNodeIP + ":" + _currentServiceAdapter.getServicePort()); s_logger.info("Management server (host id : " + _mshostId + ") is available at " + _clusterNodeIP + ":" + _currentServiceAdapter.getServicePort());
}
_heartbeatScheduler.scheduleAtFixedRate(getHeartbeatTask(), heartbeatInterval, _heartbeatScheduler.scheduleAtFixedRate(getHeartbeatTask(), heartbeatInterval,
heartbeatInterval, TimeUnit.MILLISECONDS); heartbeatInterval, TimeUnit.MILLISECONDS);
@ -600,15 +638,17 @@ public class ClusterManagerImpl implements ClusterManager {
throw new CloudRuntimeException("Unable to initialize cluster info into database"); throw new CloudRuntimeException("Unable to initialize cluster info into database");
} }
if(s_logger.isInfoEnabled()) if(s_logger.isInfoEnabled()) {
s_logger.info("Cluster manager is started"); s_logger.info("Cluster manager is started");
}
return true; return true;
} }
@Override @Override
public boolean stop() { public boolean stop() {
if(_mshostId != null) if(_mshostId != null) {
_mshostDao.remove(_mshostId); _mshostDao.remove(_mshostId);
}
_heartbeatScheduler.shutdownNow(); _heartbeatScheduler.shutdownNow();
_executor.shutdownNow(); _executor.shutdownNow();
@ -619,29 +659,34 @@ public class ClusterManagerImpl implements ClusterManager {
} catch (InterruptedException e) { } catch (InterruptedException e) {
} }
if(s_logger.isInfoEnabled()) if(s_logger.isInfoEnabled()) {
s_logger.info("Cluster manager is stopped"); s_logger.info("Cluster manager is stopped");
}
return true; return true;
} }
@Override @Override
public boolean configure(String name, Map<String, Object> params) throws ConfigurationException { public boolean configure(String name, Map<String, Object> params) throws ConfigurationException {
if(s_logger.isInfoEnabled()) if(s_logger.isInfoEnabled()) {
s_logger.info("Start configuring cluster manager : " + name); s_logger.info("Start configuring cluster manager : " + name);
}
ComponentLocator locator = ComponentLocator.getCurrentLocator(); ComponentLocator locator = ComponentLocator.getCurrentLocator();
_agentMgr = locator.getManager(AgentManager.class); _agentMgr = locator.getManager(AgentManager.class);
if (_agentMgr == null) if (_agentMgr == null) {
throw new ConfigurationException("Unable to get " + AgentManager.class.getName()); throw new ConfigurationException("Unable to get " + AgentManager.class.getName());
}
_mshostDao = locator.getDao(ManagementServerHostDao.class); _mshostDao = locator.getDao(ManagementServerHostDao.class);
if(_mshostDao == null) if(_mshostDao == null) {
throw new ConfigurationException("Unable to get " + ManagementServerHostDao.class.getName()); throw new ConfigurationException("Unable to get " + ManagementServerHostDao.class.getName());
}
_hostDao = locator.getDao(HostDao.class); _hostDao = locator.getDao(HostDao.class);
if(_hostDao == null) if(_hostDao == null) {
throw new ConfigurationException("Unable to get " + HostDao.class.getName()); throw new ConfigurationException("Unable to get " + HostDao.class.getName());
}
ConfigurationDao configDao = locator.getDao(ConfigurationDao.class); ConfigurationDao configDao = locator.getDao(ConfigurationDao.class);
if (configDao == null) { if (configDao == null) {
@ -651,12 +696,14 @@ public class ClusterManagerImpl implements ClusterManager {
Map<String, String> configs = configDao.getConfiguration("management-server", params); Map<String, String> configs = configDao.getConfiguration("management-server", params);
String value = configs.get("cluster.heartbeat.interval"); String value = configs.get("cluster.heartbeat.interval");
if(value != null) if(value != null) {
heartbeatInterval = NumbersUtil.parseInt(value, ClusterManager.DEFAULT_HEARTBEAT_INTERVAL); heartbeatInterval = NumbersUtil.parseInt(value, ClusterManager.DEFAULT_HEARTBEAT_INTERVAL);
}
value = configs.get("cluster.heartbeat.threshold"); value = configs.get("cluster.heartbeat.threshold");
if(value != null) if(value != null) {
heartbeatThreshold = NumbersUtil.parseInt(value, ClusterManager.DEFAULT_HEARTBEAT_THRESHOLD); heartbeatThreshold = NumbersUtil.parseInt(value, ClusterManager.DEFAULT_HEARTBEAT_THRESHOLD);
}
_name = name; _name = name;
@ -670,27 +717,33 @@ public class ClusterManagerImpl implements ClusterManager {
throw new ConfigurationException("Unable to load db.properties content"); throw new ConfigurationException("Unable to load db.properties content");
} }
_clusterNodeIP = dbProps.getProperty("cluster.node.IP"); _clusterNodeIP = dbProps.getProperty("cluster.node.IP");
if(_clusterNodeIP == null) if(_clusterNodeIP == null) {
_clusterNodeIP = "127.0.0.1"; _clusterNodeIP = "127.0.0.1";
if(s_logger.isInfoEnabled()) }
s_logger.info("Cluster node IP : " + _clusterNodeIP); if(s_logger.isInfoEnabled()) {
s_logger.info("Cluster node IP : " + _clusterNodeIP);
}
if(!NetUtils.isLocalAddress(_clusterNodeIP)) if(!NetUtils.isLocalAddress(_clusterNodeIP)) {
throw new ConfigurationException("cluster node IP should be valid local address where the server is running, please check your configuration"); throw new ConfigurationException("cluster node IP should be valid local address where the server is running, please check your configuration");
}
Adapters<ClusterServiceAdapter> adapters = locator.getAdapters(ClusterServiceAdapter.class); Adapters<ClusterServiceAdapter> adapters = locator.getAdapters(ClusterServiceAdapter.class);
if (adapters == null || !adapters.isSet()) { if (adapters == null || !adapters.isSet()) {
throw new ConfigurationException("Unable to get cluster service adapters"); throw new ConfigurationException("Unable to get cluster service adapters");
} }
Enumeration<ClusterServiceAdapter> it = adapters.enumeration(); Enumeration<ClusterServiceAdapter> it = adapters.enumeration();
if(it.hasMoreElements()) if(it.hasMoreElements()) {
_currentServiceAdapter = it.nextElement(); _currentServiceAdapter = it.nextElement();
}
if(_currentServiceAdapter == null) if(_currentServiceAdapter == null) {
throw new ConfigurationException("Unable to set current cluster service adapter"); throw new ConfigurationException("Unable to set current cluster service adapter");
}
if(s_logger.isInfoEnabled()) if(s_logger.isInfoEnabled()) {
s_logger.info("Cluster manager is configured."); s_logger.info("Cluster manager is configured.");
}
return true; return true;
} }