| | |
| | | // monitor data. |
| | | // |
| | | // Guarded by pendingMonitorLock. |
| | | private Set<Integer> monitorDataLateServers = new HashSet<Integer>(); |
| | | private final Set<Integer> monitorDataLateServers = new HashSet<Integer>(); |
| | | |
| | | // This lock serializes updates to the pending monitor data. |
| | | private final Object pendingMonitorDataLock = new Object(); |
| | |
| | | buildAndSendTopoInfoToDSs(null); |
| | | buildAndSendTopoInfoToRSs(); |
| | | |
| | | Message message = NOTE_RESET_GENERATION_ID.get(baseDn.toString(), |
| | | Long.toString(newGenId)); |
| | | Message message = NOTE_RESET_GENERATION_ID.get(baseDn, newGenId); |
| | | logError(message); |
| | | |
| | | } |
| | |
| | | buildAndSendTopoInfoToRSs(); |
| | | |
| | | Message message = NOTE_DIRECTORY_SERVER_CHANGED_STATUS.get( |
| | | Integer.toString(senderHandler.getServerId()), |
| | | baseDn.toString(), |
| | | newStatus.toString()); |
| | | senderHandler.getServerId(), baseDn, newStatus.toString()); |
| | | logError(message); |
| | | |
| | | } |
| | |
| | | |
| | | if (generationId > 0 && (generationId != handler.getGenerationId())) |
| | | { |
| | | Message message = NOTE_BAD_GENERATION_ID_FROM_RS.get( |
| | | baseDn, |
| | | Integer.toString(handler.getServerId()), |
| | | Long.toString(handler.getGenerationId()), |
| | | Long.toString(generationId)); |
| | | Message message = WARN_BAD_GENERATION_ID_FROM_RS.get(handler |
| | | .getServerId(), handler.session |
| | | .getReadableRemoteAddress(), handler.getGenerationId(), |
| | | baseDn, getReplicationServer().getServerId(), |
| | | generationId); |
| | | logError(message); |
| | | |
| | | ErrorMsg errorMsg = new ErrorMsg( |
| | |
| | | // error log with repeated messages. |
| | | if (!monitorDataLateServers.contains(serverId)) |
| | | { |
| | | logError(ERR_MISSING_REMOTE_MONITOR_DATA.get(baseDn, |
| | | logError(WARN_MISSING_REMOTE_MONITOR_DATA.get(baseDn, |
| | | serverId)); |
| | | } |
| | | } |