| | |
| | | * |
| | | * |
| | | * Copyright 2006-2010 Sun Microsystems, Inc. |
| | | * Portions copyright 2011 ForgeRock AS |
| | | * Portions copyright 2011-2012 ForgeRock AS |
| | | */ |
| | | package org.opends.server.replication.server; |
| | | |
| | |
| | | |
| | | // look for the dbHandler that is responsible for the LDAP server which |
| | | // generated the change. |
| | | DbHandler dbHandler = null; |
| | | DbHandler dbHandler; |
| | | synchronized (sourceDbHandlers) |
| | | { |
| | | dbHandler = sourceDbHandlers.get(id); |
| | |
| | | if (i==2) |
| | | { |
| | | Message message = ERR_EXCEPTION_SENDING_TOPO_INFO.get( |
| | | baseDn.toString(), |
| | | baseDn, |
| | | "directory", |
| | | Integer.toString(handler.getServerId()), |
| | | e.getMessage()); |
| | |
| | | if (i==2) |
| | | { |
| | | Message message = ERR_EXCEPTION_SENDING_TOPO_INFO.get( |
| | | baseDn.toString(), |
| | | baseDn, |
| | | "replication", |
| | | Integer.toString(handler.getServerId()), |
| | | e.getMessage()); |
| | |
| | | } |
| | | } catch (IOException e) |
| | | { |
| | | logError(ERR_EXCEPTION_FORWARDING_RESET_GEN_ID.get(baseDn.toString(), |
| | | logError(ERR_EXCEPTION_FORWARDING_RESET_GEN_ID.get(baseDn, |
| | | e.getMessage())); |
| | | } |
| | | } |
| | |
| | | dsHandler.changeStatusForResetGenId(newGenId); |
| | | } catch (IOException e) |
| | | { |
| | | logError(ERR_EXCEPTION_CHANGING_STATUS_AFTER_RESET_GEN_ID.get(baseDn. |
| | | toString(), |
| | | logError(ERR_EXCEPTION_CHANGING_STATUS_AFTER_RESET_GEN_ID.get(baseDn, |
| | | Integer.toString(dsHandler.getServerId()), |
| | | e.getMessage())); |
| | | } |
| | |
| | | catch (IOException e) |
| | | { |
| | | logError(ERR_EXCEPTION_CHANGING_STATUS_FROM_STATUS_ANALYZER |
| | | .get(baseDn.toString(), |
| | | .get(baseDn, |
| | | Integer.toString(serverHandler.getServerId()), |
| | | e.getMessage())); |
| | | } |
| | |
| | | |
| | | // Publish to monitor the generation ID by replicationServerDomain |
| | | builder = new AttributeBuilder("generation-id"); |
| | | builder.add(baseDn.toString() + " " + generationId); |
| | | builder.add(baseDn + " " + generationId); |
| | | attributes.add(builder.toAttribute()); |
| | | |
| | | MonitorData md = getDomainMonitorData(); |