| | |
| | | package org.opends.server.replication.server; |
| | | |
| | | import java.io.IOException; |
| | | import org.forgerock.i18n.slf4j.LocalizedLogger; |
| | | import java.util.List; |
| | | import java.util.Random; |
| | | import java.util.concurrent.Semaphore; |
| | |
| | | import org.opends.server.replication.protocol.*; |
| | | import org.opends.server.types.*; |
| | | import static org.opends.messages.ReplicationMessages.*; |
| | | import static org.opends.server.loggers.ErrorLogger.*; |
| | | |
| | | /** |
| | | * This class defines a server handler : |
| | |
| | | */ |
| | | public abstract class ServerHandler extends MessageHandler |
| | | { |
| | | |
| | | private static final LocalizedLogger logger = LocalizedLogger.getLoggerForThisClass(); |
| | | |
| | | /** |
| | | * Time during which the server will wait for existing thread to stop |
| | | * during the shutdownWriter. |
| | |
| | | logger.trace("In " + |
| | | ((handler != null) ? handler.toString() : "Replication Server") + |
| | | " closing session with err=" + providedMsg); |
| | | logError(providedMsg); |
| | | logger.error(providedMsg); |
| | | } |
| | | |
| | | if (providedSession != null) |