Searched refs:replicationServer (Results 1 - 25 of 228) sorted by relevance

12345678910

/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/server/
H A DReplicationServerDynamicConfTest.java39 * Tests that we can dynamically modify the configuration of replicationServer.
53 ReplicationServer replicationServer = null;
59 replicationServer = new ReplicationServer(conf);
67 replicationServer.applyConfigurationChange(newconf);
78 remove(replicationServer);
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/plugin/
H A DReplicationServerListener.java53 ReplicationServer replicationServer = null; field in class:ReplicationServerListener
60 * for replicationServer configuration changes.
76 replicationServer = new ReplicationServer(server);
88 replicationServer = new ReplicationServer(configuration);
113 if (replicationServer != null)
114 replicationServer.shutdown();
123 // There can be only one replicationServer, just shutdown the
124 // replicationServer currently configured.
125 if (replicationServer != null)
127 replicationServer
[all...]
/forgerock/opendj2/src/server/org/opends/server/replication/plugin/
H A DReplicationServerListener.java52 private ReplicationServer replicationServer; field in class:ReplicationServerListener
59 * for replicationServer configuration changes.
76 replicationServer = new ReplicationServer(cfg, dsrsShutdownSync);
86 replicationServer = new ReplicationServer(cfg, dsrsShutdownSync);
110 if (replicationServer != null)
112 replicationServer.shutdown();
120 // There can be only one replicationServer, just shutdown the
121 // replicationServer currently configured.
122 if (replicationServer != null)
124 replicationServer
[all...]
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/plugin/
H A DReplicationServerListener.java53 ReplicationServer replicationServer = null; field in class:ReplicationServerListener
60 * for replicationServer configuration changes.
76 replicationServer = new ReplicationServer(server);
88 replicationServer = new ReplicationServer(configuration);
113 if (replicationServer != null)
114 replicationServer.shutdown();
123 // There can be only one replicationServer, just shutdown the
124 // replicationServer currently configured.
125 if (replicationServer != null)
127 replicationServer
[all...]
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/plugin/
H A DReplicationServerListener.java53 ReplicationServer replicationServer = null; field in class:ReplicationServerListener
60 * for replicationServer configuration changes.
76 replicationServer = new ReplicationServer(server);
88 replicationServer = new ReplicationServer(configuration);
113 if (replicationServer != null)
114 replicationServer.shutdown();
123 // There can be only one replicationServer, just shutdown the
124 // replicationServer currently configured.
125 if (replicationServer != null)
127 replicationServer
[all...]
/forgerock/opendj2-hg/src/server/org/opends/server/replication/plugin/
H A DReplicationServerListener.java52 private ReplicationServer replicationServer; field in class:ReplicationServerListener
59 * for replicationServer configuration changes.
76 replicationServer = new ReplicationServer(cfg, dsrsShutdownSync);
86 replicationServer = new ReplicationServer(cfg, dsrsShutdownSync);
110 if (replicationServer != null)
112 replicationServer.shutdown();
120 // There can be only one replicationServer, just shutdown the
121 // replicationServer currently configured.
122 if (replicationServer != null)
124 replicationServer
[all...]
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/plugin/
H A DReplicationServerListener.java52 private ReplicationServer replicationServer; field in class:ReplicationServerListener
59 * for replicationServer configuration changes.
76 replicationServer = new ReplicationServer(cfg, dsrsShutdownSync);
87 replicationServer = new ReplicationServer(cfg, dsrsShutdownSync);
111 if (replicationServer != null)
113 replicationServer.shutdown();
121 // There can be only one replicationServer, just shutdown the
122 // replicationServer currently configured.
123 if (replicationServer != null)
125 replicationServer
[all...]
/forgerock/opendj2/src/server/org/opends/server/replication/common/
H A DFirstChangeNumberVirtualAttributeProvider.java52 private final ReplicationServer replicationServer; field in class:FirstChangeNumberVirtualAttributeProvider
57 * @param replicationServer
60 public FirstChangeNumberVirtualAttributeProvider(ReplicationServer replicationServer) argument
63 this.replicationServer = replicationServer;
88 if (replicationServer != null)
90 final long[] limits = replicationServer.getECLChangeNumberLimits();
H A DLastChangeNumberVirtualAttributeProvider.java52 private final ReplicationServer replicationServer; field in class:LastChangeNumberVirtualAttributeProvider
57 * @param replicationServer
60 public LastChangeNumberVirtualAttributeProvider(ReplicationServer replicationServer) argument
63 this.replicationServer = replicationServer;
88 if (replicationServer != null)
90 final long[] limits = replicationServer.getECLChangeNumberLimits();
H A DLastCookieVirtualProvider.java58 private final ReplicationServer replicationServer; field in class:LastCookieVirtualProvider
63 * @param replicationServer
66 public LastCookieVirtualProvider(ReplicationServer replicationServer) argument
69 this.replicationServer = replicationServer;
94 if (replicationServer != null)
96 String newestCookie = replicationServer.getNewestECLCookie(getExcludedChangelogDomains()).toString();
/forgerock/opendj2-hg/src/server/org/opends/server/replication/common/
H A DFirstChangeNumberVirtualAttributeProvider.java52 private final ReplicationServer replicationServer; field in class:FirstChangeNumberVirtualAttributeProvider
57 * @param replicationServer
60 public FirstChangeNumberVirtualAttributeProvider(ReplicationServer replicationServer) argument
63 this.replicationServer = replicationServer;
88 if (replicationServer != null)
90 final long[] limits = replicationServer.getECLChangeNumberLimits();
H A DLastChangeNumberVirtualAttributeProvider.java52 private final ReplicationServer replicationServer; field in class:LastChangeNumberVirtualAttributeProvider
57 * @param replicationServer
60 public LastChangeNumberVirtualAttributeProvider(ReplicationServer replicationServer) argument
63 this.replicationServer = replicationServer;
88 if (replicationServer != null)
90 final long[] limits = replicationServer.getECLChangeNumberLimits();
H A DLastCookieVirtualProvider.java58 private final ReplicationServer replicationServer; field in class:LastCookieVirtualProvider
63 * @param replicationServer
66 public LastCookieVirtualProvider(ReplicationServer replicationServer) argument
69 this.replicationServer = replicationServer;
94 if (replicationServer != null)
96 String newestCookie = replicationServer.getNewestECLCookie(getExcludedChangelogDomains()).toString();
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/
H A DFirstChangeNumberVirtualAttributeProvider.java49 private final ReplicationServer replicationServer; field in class:FirstChangeNumberVirtualAttributeProvider
54 * @param replicationServer
57 public FirstChangeNumberVirtualAttributeProvider(ReplicationServer replicationServer) argument
59 this.replicationServer = replicationServer;
84 if (replicationServer != null)
86 value = String.valueOf(replicationServer.getOldestChangeNumber());
H A DLastChangeNumberVirtualAttributeProvider.java49 private final ReplicationServer replicationServer; field in class:LastChangeNumberVirtualAttributeProvider
54 * @param replicationServer
57 public LastChangeNumberVirtualAttributeProvider(ReplicationServer replicationServer) argument
59 this.replicationServer = replicationServer;
84 if (replicationServer != null)
86 value = String.valueOf(replicationServer.getNewestChangeNumber());
H A DLastCookieVirtualProvider.java51 private final ReplicationServer replicationServer; field in class:LastCookieVirtualProvider
56 * @param replicationServer
59 public LastCookieVirtualProvider(ReplicationServer replicationServer) argument
61 this.replicationServer = replicationServer;
85 if (replicationServer != null)
87 String newestCookie = replicationServer.getNewestECLCookie(getExcludedChangelogDomains()).toString();
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/server/
H A DReplicationServerDynamicConfTest.java41 * Tests that we can dynamically modify the configuration of replicationServer
53 ReplicationServer replicationServer = null;
70 replicationServer = new ReplicationServer(conf);
81 replicationServer.applyConfigurationChange(newconf);
93 replicationServer.remove();
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/server/
H A DReplicationServerDynamicConfTest.java39 * Tests that we can dynamically modify the configuration of replicationServer
53 ReplicationServer replicationServer = null;
61 replicationServer = new ReplicationServer(conf);
72 replicationServer.applyConfigurationChange(newconf);
83 remove(replicationServer);
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/server/
H A DReplicationServerDynamicConfTest.java41 * Tests that we can dynamically modify the configuration of replicationServer
53 ReplicationServer replicationServer = null;
70 replicationServer = new ReplicationServer(conf);
81 replicationServer.applyConfigurationChange(newconf);
93 replicationServer.remove();
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/server/
H A DReplicationServerDynamicConfTest.java39 * Tests that we can dynamically modify the configuration of replicationServer
53 ReplicationServer replicationServer = null;
61 replicationServer = new ReplicationServer(conf);
72 replicationServer.applyConfigurationChange(newconf);
83 remove(replicationServer);
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/server/
H A DReplicationServerDynamicConfTest.java41 * Tests that we can dynamically modify the configuration of replicationServer
53 ReplicationServer replicationServer = null;
70 replicationServer = new ReplicationServer(conf);
81 replicationServer.applyConfigurationChange(newconf);
93 replicationServer.remove();
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/server/changelog/file/
H A DFileReplicaDBTest.java116 ReplicationServer replicationServer = null;
121 replicationServer = configureReplicationServer(100, 5000);
123 replicaDB = newReplicaDB(replicationServer);
133 remove(replicationServer);
140 ReplicationServer replicationServer = null;
145 replicationServer = configureReplicationServer(100, 5000);
147 replicaDB = newReplicaDB(replicationServer);
171 remove(replicationServer);
178 ReplicationServer replicationServer = null;
183 replicationServer
[all...]
H A DFileChangeNumberIndexDBTest.java80 ReplicationServer replicationServer = null;
83 replicationServer = newReplicationServer();
84 final ChangelogDB changelogDB = replicationServer.getChangelogDB();
86 final FileChangeNumberIndexDB cnIndexDB = getCNIndexDB(replicationServer);
111 remove(replicationServer);
118 ReplicationServer replicationServer = null;
121 replicationServer = newReplicationServer();
122 final ChangelogDB changelogDB = replicationServer.getChangelogDB();
124 final FileChangeNumberIndexDB cnIndexDB = getCNIndexDB(replicationServer);
136 remove(replicationServer);
[all...]
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/server/changelog/file/
H A DFileReplicaDBTest.java116 ReplicationServer replicationServer = null;
121 replicationServer = configureReplicationServer(100, 5000);
123 replicaDB = newReplicaDB(replicationServer);
133 remove(replicationServer);
140 ReplicationServer replicationServer = null;
145 replicationServer = configureReplicationServer(100, 5000);
147 replicaDB = newReplicaDB(replicationServer);
171 remove(replicationServer);
178 ReplicationServer replicationServer = null;
183 replicationServer
[all...]
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/server/changelog/file/
H A DFileReplicaDBTest.java110 ReplicationServer replicationServer = null;
115 replicationServer = configureReplicationServer(100, 5000);
117 replicaDB = newReplicaDB(replicationServer);
127 remove(replicationServer);
134 ReplicationServer replicationServer = null;
139 replicationServer = configureReplicationServer(100, 5000);
141 replicaDB = newReplicaDB(replicationServer);
165 remove(replicationServer);
172 ReplicationServer replicationServer = null;
177 replicationServer
[all...]

Completed in 84 milliseconds

12345678910