From 66f48672bc7953e77364a9a7ae41f1e70d83534f Mon Sep 17 00:00:00 2001
From: gbellato <gbellato@localhost>
Date: Thu, 18 Sep 2008 06:40:07 +0000
Subject: [PATCH] Fix for issue 3477 : OpenDS runs out of synchronization or crashes
---
opends/src/server/org/opends/server/replication/server/ReplicationServer.java | 15 +++++++++++++--
1 files changed, 13 insertions(+), 2 deletions(-)
diff --git a/opends/src/server/org/opends/server/replication/server/ReplicationServer.java b/opends/src/server/org/opends/server/replication/server/ReplicationServer.java
index 393a531..5fe6a1e 100644
--- a/opends/src/server/org/opends/server/replication/server/ReplicationServer.java
+++ b/opends/src/server/org/opends/server/replication/server/ReplicationServer.java
@@ -134,7 +134,7 @@
// ID of the backend
private static final String backendId = "replicationChanges";
- // At startup, the listen thread wait on this flag for the connet
+ // At startup, the listen thread wait on this flag for the connect
// thread to look for other servers in the topology.
private boolean connectedInTopology = false;
private final Object connectedInTopologyLock = new Object();
@@ -554,7 +554,7 @@
public DbHandler newDbHandler(short id, DN baseDn)
throws DatabaseException
{
- return new DbHandler(id, baseDn, this, dbEnv);
+ return new DbHandler(id, baseDn, this, dbEnv, queueSize);
}
/**
@@ -827,6 +827,17 @@
}
/**
+ * Get the queueSize for this replication server.
+ *
+ * @return The maximum size of the queues for this Replication Server
+ *
+ */
+ public int getQueueSize()
+ {
+ return queueSize;
+ }
+
+ /**
* Creates the backend associated to this replication server.
* @throws ConfigException
*/
--
Gitblit v1.10.0