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

Lines Matching defs:FakeReplicationServer

126   private FakeReplicationServer replicationServer;
271   private class FakeReplicationServer extends Thread
314     public FakeReplicationServer(byte groupId, int port, int serverId, boolean assured,
330     public FakeReplicationServer(byte groupId, int port, int serverId, int safeDataLevel,
722       replicationServer = new FakeReplicationServer(rsGroupId, replServerPort, RS_SERVER_ID,
833       replicationServer = new FakeReplicationServer(rsGroupId, replServerPort, RS_SERVER_ID,
916       replicationServer = new FakeReplicationServer((byte)1, replServerPort, RS_SERVER_ID,
945   private void waitForConnectionToRs(String testCase, FakeReplicationServer rs) throws Exception
963   private void waitForScenarioExecutedOnRs(String testCase, FakeReplicationServer rs) throws Exception
1001       replicationServer = new FakeReplicationServer((byte)1, replServerPort, RS_SERVER_ID,
1046       replicationServer = new FakeReplicationServer((byte)1, replServerPort, RS_SERVER_ID,
1091       replicationServer = new FakeReplicationServer(rsGroupId, replServerPort, RS_SERVER_ID,
1178       replicationServer = new FakeReplicationServer(rsGroupId, replServerPort, RS_SERVER_ID,
1221       replicationServer = new FakeReplicationServer((byte)1, replServerPort, RS_SERVER_ID,
1329       replicationServer = new FakeReplicationServer((byte)1, replServerPort, RS_SERVER_ID,