Cross Reference: /forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/service/ReplicationDomainTest.java

Lines Matching refs:domain1
91     FakeReplicationDomain domain1 = null;
107       domain1 = new FakeReplicationDomain(
118        * Publish a message from domain1,
122       publish(domain1, test);
128       for (RSInfo replServerInfo : domain1.getRsInfos())
135       for (DSInfo serverInfo : domain1.getReplicaInfos().values())
140       domain1.setGenerationID(2);
141       domain1.resetReplicationLog();
144       for (RSInfo replServerInfo : domain1.getRsInfos())
156           assertExpectedServerStatuses(domain1.getReplicaInfos(),
161           Map<Integer, ServerState> states1 = domain1.getReplicaStates();
185       disable(domain1, domain2);
252     FakeReplicationDomain domain1 = null;
264       domain1 = new FakeReplicationDomain(
269        * Publish a message from domain1,
275       timeNow = publishRepeatedly(domain1, test, timeNow);
276       timeNow = publishRepeatedly(domain1, test, timeNow);
277       timeNow = publishRepeatedly(domain1, test, timeNow);
278       timeNow = publishRepeatedly(domain1, test, timeNow);
282       disable(domain1);
287   private long publishRepeatedly(FakeReplicationDomain domain1, byte[] test, long timeNow)
292       publish(domain1, test);
345     FakeReplicationDomain domain1 = null;
357       domain1 = new FakeReplicationDomain(
365        * Trigger a total update from domain1 to domain2.
370       assertExportSucessful(domain1, domain2, exportedData, importedData);
374       disable(domain1, domain2);
405     FakeReplicationDomain domain1 = null;
423       domain1 = new FakeReplicationDomain(
433       assertExportSucessful(domain1, domain2, exportedData, importedData);
437       disable(domain1, domain2);
462   private void assertExportSucessful(ReplicationDomain domain1,
466     assertEquals(getLeftEntryCount(domain1), 0, "Wrong LeftEntryCount for import");
510     FakeStressReplicationDomain domain1 = null;
521       domain1 = new FakeStressReplicationDomain(
529       disable(domain1);
543     FakeStressReplicationDomain domain1 = null;
554       domain1 = new FakeStressReplicationDomain(
557        * Trigger a total update from domain1 to domain2.
560       while (!initializeFromRemote(domain1))
570       disable(domain1);