From b07dd3c9cf16b40636b797aeb801aafa73d21fa0 Mon Sep 17 00:00:00 2001
From: Jean-Noël Rouvignac <jean-noel.rouvignac@forgerock.com>
Date: Tue, 02 Aug 2016 08:47:41 +0000
Subject: [PATCH] ReplicationCliMain.java: various code cleanups
---
opendj-server-legacy/src/main/java/org/opends/server/tools/dsreplication/ReplicationCliMain.java | 59 ++++++++++++++++++++++++++++-------------------------------
1 files changed, 28 insertions(+), 31 deletions(-)
diff --git a/opendj-server-legacy/src/main/java/org/opends/server/tools/dsreplication/ReplicationCliMain.java b/opendj-server-legacy/src/main/java/org/opends/server/tools/dsreplication/ReplicationCliMain.java
index d787959..5a3947e 100644
--- a/opendj-server-legacy/src/main/java/org/opends/server/tools/dsreplication/ReplicationCliMain.java
+++ b/opendj-server-legacy/src/main/java/org/opends/server/tools/dsreplication/ReplicationCliMain.java
@@ -4608,7 +4608,7 @@
filter.setSearchMonitoringInformation(false);
filter.addBaseDNToSearch(ADSContext.getAdministrationSuffixDN());
filter.addBaseDNToSearch(Constants.SCHEMA_DN);
- addBaseDNs(filter, uData.getBaseDNs());
+ filter.addBaseDNsToSearch(uData.getBaseDNs());
ServerDescriptor serverDesc1 = createStandalone(conn1, filter);
ServerDescriptor serverDesc2 = createStandalone(conn2, filter);
@@ -5179,7 +5179,7 @@
TopologyCache cache = new TopologyCache(adsCtx, getTrustManager(sourceServerCI), getConnectTimeout());
cache.setPreferredConnections(cnx);
cache.getFilter().setSearchMonitoringInformation(false);
- addBaseDNs(cache.getFilter(), uData.getBaseDNs());
+ cache.getFilter().addBaseDNsToSearch(uData.getBaseDNs());
cache.reloadTopology();
return cache;
}
@@ -5220,7 +5220,7 @@
if (!uData.disableAll())
{
filter.addBaseDNToSearch(ADSContext.getAdministrationSuffixDN());
- addBaseDNs(filter, uData.getBaseDNs());
+ filter.addBaseDNsToSearch(uData.getBaseDNs());
}
ServerDescriptor server = createStandalone(conn, filter);
@@ -5239,7 +5239,7 @@
cache.getFilter().setSearchMonitoringInformation(false);
if (!uData.disableAll())
{
- addBaseDNs(cache.getFilter(), uData.getBaseDNs());
+ cache.getFilter().addBaseDNsToSearch(uData.getBaseDNs());
}
cache.reloadTopology();
}
@@ -5614,14 +5614,6 @@
return false;
}
- private void addBaseDNs(TopologyCacheFilter filter, List<DN> baseDNs)
- {
- for (DN dn : baseDNs)
- {
- filter.addBaseDNToSearch(dn);
- }
- }
-
/**
* Displays the replication status of the different base DNs in the servers registered in the ADS.
*
@@ -5637,21 +5629,7 @@
StatusReplicationUserData uData) throws ReplicationCliException
{
ADSContext adsCtx = new ADSContext(conn);
-
- TopologyCache cache;
- try
- {
- cache = new TopologyCache(adsCtx, getTrustManager(sourceServerCI), getConnectTimeout());
- cache.setPreferredConnections(getPreferredConnections(conn));
- addBaseDNs(cache.getFilter(), uData.getBaseDNs());
- cache.reloadTopology();
- }
- catch (TopologyCacheException tce)
- {
- throw new ReplicationCliException(
- ERR_REPLICATION_READING_ADS.get(tce.getMessage()),
- ERROR_READING_TOPOLOGY_CACHE, tce);
- }
+ TopologyCache cache = createTopologyCache(conn, uData, adsCtx);
if (mustPrintCommandBuilder())
{
printNewCommandBuilder(STATUS_REPLICATION_SUBCMD_NAME, uData);
@@ -5754,6 +5732,25 @@
}
}
+ private TopologyCache createTopologyCache(ConnectionWrapper conn, StatusReplicationUserData uData, ADSContext adsCtx)
+ throws ReplicationCliException
+ {
+ try
+ {
+ TopologyCache cache = new TopologyCache(adsCtx, getTrustManager(sourceServerCI), getConnectTimeout());
+ cache.setPreferredConnections(getPreferredConnections(conn));
+ cache.getFilter().addBaseDNsToSearch(uData.getBaseDNs());
+ cache.reloadTopology();
+ return cache;
+ }
+ catch (TopologyCacheException tce)
+ {
+ throw new ReplicationCliException(
+ ERR_REPLICATION_READING_ADS.get(tce.getMessage()),
+ ERROR_READING_TOPOLOGY_CACHE, tce);
+ }
+ }
+
private Set<ReplicaDescriptor> findNonReplicatedReplicasForSuffixDn(List<Set<ReplicaDescriptor>> replicaLists,
DN suffixDn)
{
@@ -8799,7 +8796,7 @@
{
TopologyCache cache = new TopologyCache(adsCtx, getTrustManager(sourceServerCI), getConnectTimeout());
cache.getFilter().setSearchMonitoringInformation(false);
- addBaseDNs(cache.getFilter(), uData.getBaseDNs());
+ cache.getFilter().addBaseDNsToSearch(uData.getBaseDNs());
cache.reloadTopology();
suffixes.addAll(cache.getSuffixes());
}
@@ -9103,13 +9100,13 @@
private ConnectionWrapper getConnection(TopologyCache cache, ServerDescriptor server) throws NamingException
{
ConnectionWrapper conn = cache.getAdsContext().getConnection();
- DN dn = conn.getBindDn();
- String pwd = conn.getBindPassword();
+
TopologyCacheFilter filter = new TopologyCacheFilter();
filter.setSearchMonitoringInformation(false);
filter.setSearchBaseDNInformation(false);
+
ServerLoader loader = new ServerLoader(server.getAdsProperties(),
- dn, pwd, getTrustManager(sourceServerCI), getConnectTimeout(),
+ conn.getBindDn(), conn.getBindPassword(), getTrustManager(sourceServerCI), getConnectTimeout(),
cache.getPreferredConnections(), filter);
return loader.createConnectionWrapper();
}
--
Gitblit v1.10.0