Searched defs:changelogDB (Results 1 - 10 of 10) sorted by relevance

/forgerock/opendj2/src/server/org/opends/server/replication/server/changelog/je/
H A DChangeNumberIndexer.java77 private final ChangelogDB changelogDB; field in class:ChangeNumberIndexer
116 * @param changelogDB
117 * the changelogDB
121 public ChangeNumberIndexer(ChangelogDB changelogDB, ChangelogState changelogState) argument
123 this(changelogDB, changelogState, new ECLEnabledDomainPredicate());
129 * @param changelogDB
130 * the changelogDB
136 ChangeNumberIndexer(ChangelogDB changelogDB, ChangelogState changelogState, argument
140 this.changelogDB = changelogDB;
[all...]
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/changelog/je/
H A DChangeNumberIndexer.java77 private final ChangelogDB changelogDB; field in class:ChangeNumberIndexer
116 * @param changelogDB
117 * the changelogDB
121 public ChangeNumberIndexer(ChangelogDB changelogDB, ChangelogState changelogState) argument
123 this(changelogDB, changelogState, new ECLEnabledDomainPredicate());
129 * @param changelogDB
130 * the changelogDB
136 ChangeNumberIndexer(ChangelogDB changelogDB, ChangelogState changelogState, argument
140 this.changelogDB = changelogDB;
[all...]
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/changelog/file/
H A DChangeNumberIndexer.java75 private final ChangelogDB changelogDB; field in class:ChangeNumberIndexer
113 * @param changelogDB
114 * the changelogDB
118 public ChangeNumberIndexer(ChangelogDB changelogDB, ChangelogStateProvider changelogStateProvider) argument
120 this(changelogDB, changelogStateProvider, new ECLEnabledDomainPredicate());
125 * @param changelogDB
126 * the changelogDB
131 ChangeNumberIndexer(ChangelogDB changelogDB, ChangelogStateProvider changelogStateProvider, argument
135 this.changelogDB = changelogDB;
[all...]
H A DFileChangeNumberIndexDB.java123 private final FileChangelogDB changelogDB; field in class:FileChangeNumberIndexDB
132 FileChangeNumberIndexDB(FileChangelogDB changelogDB, ReplicationEnvironment replicationEnv) throws ChangelogException argument
134 this.changelogDB = changelogDB;
400 changelogDB.resetChangeNumberIndex(newFirstCN, baseDN, newFirstCSN);
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/server/changelog/je/
H A DChangeNumberIndexerTest.java124 private ChangelogDB changelogDB; field in class:ChangeNumberIndexerTest
165 when(changelogDB.getChangeNumberIndexDB()).thenReturn(cnIndexDB);
166 when(changelogDB.getReplicationDomainDB()).thenReturn(domainDB);
593 cnIndexer = new ChangeNumberIndexer(changelogDB, initialState, predicate)
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/server/changelog/je/
H A DChangeNumberIndexerTest.java124 private ChangelogDB changelogDB; field in class:ChangeNumberIndexerTest
165 when(changelogDB.getChangeNumberIndexDB()).thenReturn(cnIndexDB);
166 when(changelogDB.getReplicationDomainDB()).thenReturn(domainDB);
593 cnIndexer = new ChangeNumberIndexer(changelogDB, initialState, predicate)
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/server/changelog/file/
H A DChangeNumberIndexerTest.java132 private ChangelogDB changelogDB; field in class:ChangeNumberIndexerTest
168 when(changelogDB.getChangeNumberIndexDB()).thenReturn(cnIndexDB);
169 when(changelogDB.getReplicationDomainDB()).thenReturn(domainDB);
595 cnIndexer = new ChangeNumberIndexer(changelogDB, changeLogState, predicate)
/forgerock/opendj2/src/server/org/opends/server/replication/server/
H A DReplicationServer.java95 private final ChangelogDB changelogDB; field in class:ReplicationServer
175 this.changelogDB = dbImpl == ReplicationDBImplementation.JE
428 this.changelogDB.initializeDB();
825 this.changelogDB.shutdownDB();
902 this.changelogDB.setPurgeDelay(getPurgeDelay());
909 this.changelogDB.setComputeChangeNumber(computeCN);
1248 return this.changelogDB.getChangeNumberIndexDB();
1352 * Returns the changelogDB.
1354 * @return the changelogDB.
1358 return this.changelogDB;
[all...]
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/
H A DReplicationServer.java95 private final ChangelogDB changelogDB; field in class:ReplicationServer
175 this.changelogDB = dbImpl == ReplicationDBImplementation.JE
428 this.changelogDB.initializeDB();
825 this.changelogDB.shutdownDB();
902 this.changelogDB.setPurgeDelay(getPurgeDelay());
909 this.changelogDB.setComputeChangeNumber(computeCN);
1248 return this.changelogDB.getChangeNumberIndexDB();
1352 * Returns the changelogDB.
1354 * @return the changelogDB.
1358 return this.changelogDB;
[all...]
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/
H A DReplicationServer.java102 private final ChangelogDB changelogDB; field in class:ReplicationServer
174 this.changelogDB = new FileChangelogDB(this, config.getReplicationDBDirectory());
417 this.changelogDB.initializeDB();
793 this.changelogDB.shutdownDB();
865 this.changelogDB.setPurgeDelay(getPurgeDelay());
872 this.changelogDB.setComputeChangeNumber(computeCN);
1202 return this.changelogDB.getChangeNumberIndexDB();
1313 * Returns the changelogDB.
1315 * @return the changelogDB.
1319 return this.changelogDB;
[all...]

Completed in 64 milliseconds