| | |
| | | package org.opends.server.replication.server; |
| | | |
| | | import java.io.IOException; |
| | | import org.forgerock.i18n.slf4j.LocalizedLogger; |
| | | import java.util.List; |
| | | import java.util.Map; |
| | | import java.util.Set; |
| | |
| | | import org.opends.server.replication.protocol.*; |
| | | import org.opends.server.types.*; |
| | | import static org.opends.messages.ReplicationMessages.*; |
| | | import static org.opends.server.loggers.ErrorLogger.*; |
| | | import static org.opends.server.replication.protocol.ProtocolVersion.*; |
| | | |
| | | /** |
| | |
| | | public class ReplicationServerHandler extends ServerHandler |
| | | { |
| | | |
| | | private static final LocalizedLogger logger = LocalizedLogger.getLoggerForThisClass(); |
| | | |
| | | |
| | | /** |
| | | * Properties filled only if remote server is a RS. |
| | | */ |
| | |
| | | replicationServerDomain.receiveTopoInfoFromRS(inTopoMsg, this, false); |
| | | } |
| | | |
| | | LocalizableMessage message = INFO_REPLICATION_SERVER_CONNECTION_TO_RS |
| | | .get(getReplicationServerId(), getServerId(), |
| | | logger.debug(INFO_REPLICATION_SERVER_CONNECTION_TO_RS, getReplicationServerId(), getServerId(), |
| | | replicationServerDomain.getBaseDN().toNormalizedString(), |
| | | session.getReadableRemoteAddress()); |
| | | logError(message); |
| | | |
| | | super.finalizeStart(); |
| | | } |
| | |
| | | if (inTopoMsg!=null) |
| | | replicationServerDomain.receiveTopoInfoFromRS(inTopoMsg, this, false); |
| | | |
| | | LocalizableMessage message = INFO_REPLICATION_SERVER_CONNECTION_FROM_RS |
| | | .get(getReplicationServerId(), getServerId(), |
| | | logger.debug(INFO_REPLICATION_SERVER_CONNECTION_FROM_RS, getReplicationServerId(), getServerId(), |
| | | replicationServerDomain.getBaseDN().toNormalizedString(), |
| | | session.getReadableRemoteAddress()); |
| | | logError(message); |
| | | |
| | | super.finalizeStart(); |
| | | } |
| | |
| | | * and we have a null state ? |
| | | * replicationServerDomain.setGenerationId(generationId, false); |
| | | */ |
| | | LocalizableMessage message = WARN_BAD_GENERATION_ID_FROM_RS.get( |
| | | serverId, session.getReadableRemoteAddress(), generationId, |
| | | logger.warn(WARN_BAD_GENERATION_ID_FROM_RS, serverId, session.getReadableRemoteAddress(), generationId, |
| | | getBaseDNString(), getReplicationServerId(), localGenerationId); |
| | | logError(message); |
| | | } |
| | | } |
| | | |