From 71ebb3724c79a7d1218c36f080acd6ee162b9cd2 Mon Sep 17 00:00:00 2001
From: gbellato <gbellato@localhost>
Date: Thu, 26 Apr 2007 06:31:01 +0000
Subject: [PATCH] Rename the class with names containing synchronization or changelog. Replace most of the changelog occurences with replication server. (issue 1090)
---
opends/src/server/org/opends/server/replication/server/ServerWriter.java | 14 +++++++-------
1 files changed, 7 insertions(+), 7 deletions(-)
diff --git a/opends/src/server/org/opends/server/replication/server/ServerWriter.java b/opends/src/server/org/opends/server/replication/server/ServerWriter.java
index b5af7cc..53154ee 100644
--- a/opends/src/server/org/opends/server/replication/server/ServerWriter.java
+++ b/opends/src/server/org/opends/server/replication/server/ServerWriter.java
@@ -49,7 +49,7 @@
{
private ProtocolSession session;
private ServerHandler handler;
- private ChangelogCache changelogCache;
+ private ReplicationCache replicationCache;
/**
* Create a ServerWriter.
@@ -59,21 +59,21 @@
* @param session the ProtocolSession that will be used to send updates.
* @param serverId the Identifier of the server.
* @param handler handler for which the ServerWriter is created.
- * @param changelogCache The ChangelogCache of this ServerWriter.
+ * @param replicationCache The ReplicationCache of this ServerWriter.
*/
public ServerWriter(ProtocolSession session, short serverId,
- ServerHandler handler, ChangelogCache changelogCache)
+ ServerHandler handler, ReplicationCache replicationCache)
{
super(handler.toString() + " writer");
this.session = session;
this.handler = handler;
- this.changelogCache = changelogCache;
+ this.replicationCache = replicationCache;
}
/**
* Run method for the ServerWriter.
- * Loops waiting for changes from the ChangelogCache and forward them
+ * Loops waiting for changes from the ReplicationCache and forward them
* to the other servers
*/
public void run()
@@ -81,7 +81,7 @@
try {
while (true)
{
- UpdateMessage update = changelogCache.take(this.handler);
+ UpdateMessage update = replicationCache.take(this.handler);
if (update == null)
return; /* this connection is closing */
session.publish(update);
@@ -131,7 +131,7 @@
{
// Can't do much more : ignore
}
- changelogCache.stopServer(handler);
+ replicationCache.stopServer(handler);
}
}
}
--
Gitblit v1.10.0