| | |
| | | logError(ERR_ERROR_MSG_RECEIVED.get(errorMsg.getDetails())); |
| | | } else if (msg instanceof MonitorRequestMsg) |
| | | { |
| | | replyWithMonitorMsg(msg, msgEmitter); |
| | | replyWithTopologyMonitorMsg(msg, msgEmitter); |
| | | } else if (msg instanceof MonitorMsg) |
| | | { |
| | | MonitorMsg monitorMsg = (MonitorMsg) msg; |
| | |
| | | } |
| | | } |
| | | |
| | | private void replyWithMonitorMsg(RoutableMsg msg, ServerHandler msgEmitter) |
| | | private void replyWithTopologyMonitorMsg(RoutableMsg msg, |
| | | ServerHandler msgEmitter) |
| | | { |
| | | /* |
| | | * If the request comes from a Directory Server we need to build the full |
| | |
| | | throws InterruptedException |
| | | { |
| | | return createGlobalTopologyMonitorMsg(sender, destination, |
| | | domainMonitor.computeDomainMonitorData()); |
| | | domainMonitor.recomputeMonitorData()); |
| | | } |
| | | |
| | | private MonitorMsg createGlobalTopologyMonitorMsg(int sender, |