From a5f828cdb6549933c9f49783f99be1de1085a75e Mon Sep 17 00:00:00 2001
From: Jean-Noel Rouvignac <jean-noel.rouvignac@forgerock.com>
Date: Tue, 27 Aug 2013 09:57:22 +0000
Subject: [PATCH] Made code more encapsulated and more explicit. Removed parameters obscuring the code.
---
opends/src/server/org/opends/server/replication/server/changelog/je/ReplicationDbEnv.java | 10 ++--------
1 files changed, 2 insertions(+), 8 deletions(-)
diff --git a/opends/src/server/org/opends/server/replication/server/changelog/je/ReplicationDbEnv.java b/opends/src/server/org/opends/server/replication/server/changelog/je/ReplicationDbEnv.java
index d6d5707..3f8e346 100644
--- a/opends/src/server/org/opends/server/replication/server/changelog/je/ReplicationDbEnv.java
+++ b/opends/src/server/org/opends/server/replication/server/changelog/je/ReplicationDbEnv.java
@@ -203,8 +203,7 @@
+ this.replicationServer.getMonitorInstanceName()
+ " Has read baseDn=" + baseDn + " generationId=" + generationId);
- replicationServer.getReplicationServerDomain(baseDn, true)
- .initGenerationID(generationId);
+ replicationServer.initDomainGenerationID(baseDn, generationId);
}
status = cursor.getNext(key, data, LockMode.DEFAULT);
}
@@ -236,12 +235,7 @@
+ this.replicationServer.getMonitorInstanceName()
+ " Has read: baseDn=" + baseDn + " serverId=" + serverId);
- DbHandler dbHandler =
- new DbHandler(serverId, baseDn, replicationServer, this,
- replicationServer.getQueueSize());
-
- replicationServer.getReplicationServerDomain(baseDn, true)
- .setDbHandler(serverId, dbHandler);
+ replicationServer.addServerIdToDomain(serverId, baseDn);
}
status = cursor.getNext(key, data, LockMode.DEFAULT);
--
Gitblit v1.10.0