mirror of https://github.com/OpenIdentityPlatform/OpenDJ.git

gbellato
26.31.2007 71ebb3724c79a7d1218c36f080acd6ee162b9cd2
opends/tests/unit-tests-testng/src/server/org/opends/server/replication/server/dbHandlerTest.java
@@ -34,8 +34,8 @@
import org.opends.server.replication.common.ChangeNumber;
import org.opends.server.replication.common.ChangeNumberGenerator;
import org.opends.server.replication.protocol.DeleteMsg;
import org.opends.server.replication.server.Changelog;
import org.opends.server.replication.server.ChangelogDbEnv;
import org.opends.server.replication.server.ReplicationServer;
import org.opends.server.replication.server.ReplicationDbEnv;
import org.opends.server.replication.server.DbHandler;
import org.opends.server.types.DN;
import org.testng.annotations.Test;
@@ -51,16 +51,16 @@
  {
    TestCaseUtils.startServer();
    //  find  a free port for the changelog server
    //  find  a free port for the replicationServer
    ServerSocket socket = TestCaseUtils.bindFreePort();
    int changelogPort = socket.getLocalPort();
    socket.close();
    // configure a Changelog server.
    ChangelogFakeConfiguration conf =
      new ChangelogFakeConfiguration(changelogPort, null, 0,
    // configure a ReplicationServer.
    ReplServerFakeConfiguration conf =
      new ReplServerFakeConfiguration(changelogPort, null, 0,
                                     2, 0, 100, null);
    Changelog changelog = new Changelog(conf);
    ReplicationServer replicationServer = new ReplicationServer(conf);
    // create or clean a directory for the dbHandler
    String buildRoot = System.getProperty(TestCaseUtils.PROPERTY_BUILD_ROOT);
@@ -73,10 +73,10 @@
    }
    testRoot.mkdirs();
    ChangelogDbEnv dbEnv = new ChangelogDbEnv(path, changelog);
    ReplicationDbEnv dbEnv = new ReplicationDbEnv(path, replicationServer);
    DbHandler handler =
      new DbHandler((short) 1, DN.decode("o=test"), changelog, dbEnv);
      new DbHandler((short) 1, DN.decode("o=test"), replicationServer, dbEnv);
    ChangeNumberGenerator gen = new ChangeNumberGenerator((short)1, 0);
    ChangeNumber changeNumber1 = gen.NewChangeNumber();
@@ -116,7 +116,7 @@
    handler.shutdown();
    dbEnv.shutdown();
    changelog.shutdown();
    replicationServer.shutdown();
    TestCaseUtils.deleteDirectory(testRoot);
  }