| | |
| | | package org.opends.server.replication.service; |
| | | |
| | | import static org.opends.messages.ReplicationMessages.*; |
| | | import static org.opends.server.TestCaseUtils.*; |
| | | import static org.opends.server.util.CollectionUtils.*; |
| | | import static org.testng.Assert.*; |
| | | |
| | |
| | | replServer2 = createReplicationServer(replServerID2, replServerPort2, |
| | | "ReplicationDomainTestDb2", 100, "localhost:" + replServerPort1); |
| | | |
| | | SortedSet<String> servers = newSortedSet("localhost:" + replServerPort1); |
| | | SortedSet<String> servers = newTreeSet("localhost:" + replServerPort1); |
| | | BlockingQueue<UpdateMsg> rcvQueue1 = new LinkedBlockingQueue<>(); |
| | | domain1 = new FakeReplicationDomain( |
| | | testService, domain1ServerId, servers, 100, 1000, rcvQueue1); |
| | | |
| | | SortedSet<String> servers2 = newSortedSet("localhost:" + replServerPort2); |
| | | SortedSet<String> servers2 = newTreeSet("localhost:" + replServerPort2); |
| | | BlockingQueue<UpdateMsg> rcvQueue2 = new LinkedBlockingQueue<>(); |
| | | domain2 = new FakeReplicationDomain( |
| | | testService, domain2ServerId, servers2, 100, 1000, rcvQueue2); |
| | |
| | | replServer1 = createReplicationServer(replServerID1, replServerPort, |
| | | "ReplicationDomainTestDb", 100000, "localhost:" + replServerPort); |
| | | |
| | | SortedSet<String> servers = newSortedSet("localhost:" + replServerPort); |
| | | SortedSet<String> servers = newTreeSet("localhost:" + replServerPort); |
| | | BlockingQueue<UpdateMsg> rcvQueue1 = new LinkedBlockingQueue<>(); |
| | | domain1 = new FakeReplicationDomain( |
| | | testService, domain1ServerId, servers, 1000, 100000, rcvQueue1); |
| | |
| | | |
| | | replServer = createReplicationServer(replServerID, replServerPort, |
| | | "exportAndImportData", 100); |
| | | SortedSet<String> servers = newSortedSet("localhost:" + replServerPort); |
| | | SortedSet<String> servers = newTreeSet("localhost:" + replServerPort); |
| | | |
| | | String exportedData = buildExportedData(ENTRYCOUNT); |
| | | domain1 = new FakeReplicationDomain( |
| | |
| | | replServer2 = createReplicationServer(replServerID2, replServerPort2, |
| | | "exportAndImportservice2", 100, "localhost:" + replServerPort1); |
| | | |
| | | SortedSet<String> servers1 = newSortedSet("localhost:" + replServerPort1); |
| | | SortedSet<String> servers2 = newSortedSet("localhost:" + replServerPort2); |
| | | SortedSet<String> servers1 = newTreeSet("localhost:" + replServerPort1); |
| | | SortedSet<String> servers2 = newTreeSet("localhost:" + replServerPort2); |
| | | |
| | | String exportedData = buildExportedData(ENTRYCOUNT); |
| | | domain1 = new FakeReplicationDomain( |
| | |
| | | try |
| | | { |
| | | SortedSet<String> servers = |
| | | newSortedSet(HOST1 + SENDERPORT, HOST2 + RECEIVERPORT); |
| | | newTreeSet(HOST1 + SENDERPORT, HOST2 + RECEIVERPORT); |
| | | |
| | | replServer = createReplicationServer(replServerID, SENDERPORT, |
| | | "ReplicationDomainTestDb", 100, servers); |
| | |
| | | try |
| | | { |
| | | SortedSet<String> servers = |
| | | newSortedSet(HOST1 + SENDERPORT, HOST2 + RECEIVERPORT); |
| | | newTreeSet(HOST1 + SENDERPORT, HOST2 + RECEIVERPORT); |
| | | |
| | | replServer = createReplicationServer(replServerID, RECEIVERPORT, |
| | | "ReplicationDomainTestDb", 100, servers); |