From 5349c97806bb0a00038d8dc3dee4254fad187649 Mon Sep 17 00:00:00 2001
From: gbellato <gbellato@localhost>
Date: Wed, 25 Apr 2007 16:35:36 +0000
Subject: [PATCH] Second set of renaming for issue 1090 Rename org.opends.server.replication.changelog into org.opends.server.synchronization.changelog Use replication instead of synchronization in many places in the code/comment/file names
---
opends/src/server/org/opends/server/replication/server/ServerHandler.java | 12 ++++++------
1 files changed, 6 insertions(+), 6 deletions(-)
diff --git a/opends/src/server/org/opends/server/replication/changelog/ServerHandler.java b/opends/src/server/org/opends/server/replication/server/ServerHandler.java
similarity index 98%
rename from opends/src/server/org/opends/server/replication/changelog/ServerHandler.java
rename to opends/src/server/org/opends/server/replication/server/ServerHandler.java
index 4a90410..0f918a1 100644
--- a/opends/src/server/org/opends/server/replication/changelog/ServerHandler.java
+++ b/opends/src/server/org/opends/server/replication/server/ServerHandler.java
@@ -24,13 +24,13 @@
*
* Portions Copyright 2006-2007 Sun Microsystems, Inc.
*/
-package org.opends.server.replication.changelog;
+package org.opends.server.replication.server;
import static org.opends.server.loggers.Error.logError;
import static org.opends.server.loggers.debug.DebugLogger.debugEnabled;
import static org.opends.server.loggers.debug.DebugLogger.debugInfo;
import static org.opends.server.messages.MessageHandler.getMessage;
-import static org.opends.server.messages.SynchronizationMessages.*;
+import static org.opends.server.messages.ReplicationMessages.*;
import static org.opends.server.util.StaticUtils.stackTraceToSingleLineString;
import java.io.IOException;
@@ -55,7 +55,7 @@
import org.opends.server.replication.protocol.ProtocolSession;
import org.opends.server.replication.protocol.RoutableMessage;
import org.opends.server.replication.protocol.ServerStartMessage;
-import org.opends.server.replication.protocol.SynchronizationMessage;
+import org.opends.server.replication.protocol.ReplicationMessage;
import org.opends.server.replication.protocol.UpdateMessage;
import org.opends.server.replication.protocol.WindowMessage;
import org.opends.server.types.Attribute;
@@ -114,7 +114,7 @@
private short changelogId;
/**
- * The time in milliseconds between heartbeats from the synchronization
+ * The time in milliseconds between heartbeats from the replication
* server. Zero means heartbeats are off.
*/
private long heartbeatInterval = 0;
@@ -177,7 +177,7 @@
session.publish(msg);
}
- SynchronizationMessage msg = session.receive();
+ ReplicationMessage msg = session.receive();
if (msg instanceof ServerStartMessage)
{
ServerStartMessage receivedMsg = (ServerStartMessage) msg;
@@ -284,7 +284,7 @@
// Create a thread to send heartbeat messages.
if (heartbeatInterval > 0)
{
- heartbeatThread = new HeartbeatThread("Synchronization Heartbeat",
+ heartbeatThread = new HeartbeatThread("replication Heartbeat",
session, heartbeatInterval);
heartbeatThread.start();
}
--
Gitblit v1.10.0