| | |
| | | * Portions copyright 2011-2013 ForgeRock AS |
| | | */ |
| | | package org.opends.server.replication.server; |
| | | |
| | | import static org.opends.messages.ReplicationMessages.*; |
| | | import static org.opends.server.loggers.ErrorLogger.logError; |
| | | import static org.opends.server.loggers.debug.DebugLogger.debugEnabled; |
| | | import static org.opends.server.loggers.debug.DebugLogger.getTracer; |
| | | import static org.opends.server.util.StaticUtils.stackTraceToSingleLineString; |
| | | import static org.opends.server.loggers.ErrorLogger.*; |
| | | import static org.opends.server.loggers.debug.DebugLogger.*; |
| | | import static org.opends.server.util.StaticUtils.*; |
| | | |
| | | import java.io.IOException; |
| | | import java.net.SocketException; |
| | |
| | | import org.opends.server.workflowelement.externalchangelog.ECLSearchOperation; |
| | | import org.opends.server.workflowelement.externalchangelog.ECLWorkflowElement; |
| | | |
| | | |
| | | /** |
| | | * This class defines a server writer, which is used to send changes to a |
| | | * directory server. |
| | |
| | | * Loops waiting for changes from the ReplicationServerDomain and |
| | | * forward them to the other servers |
| | | */ |
| | | @Override |
| | | public void run() |
| | | { |
| | | try |
| | |
| | | handler.getReplicationServerId(), |
| | | handler.getServerId(), |
| | | session.getReadableRemoteAddress(), |
| | | handler.getServiceId()); |
| | | handler.getBaseDN()); |
| | | } |
| | | else |
| | | { |
| | |
| | | handler.getReplicationServerId(), |
| | | handler.getServerId(), |
| | | session.getReadableRemoteAddress(), |
| | | handler.getServiceId()); |
| | | handler.getBaseDN()); |
| | | } |
| | | logError(errMessage); |
| | | } |
| | |
| | | // An unexpected error happened. |
| | | // Log an error and close the connection. |
| | | Message errMessage = ERR_WRITER_UNEXPECTED_EXCEPTION |
| | | .get(handler.toString() + " " |
| | | + stackTraceToSingleLineString(e)); |
| | | .get(handler + " " + stackTraceToSingleLineString(e)); |
| | | logError(errMessage); |
| | | } |
| | | finally |