Searched defs:domainDB (Results 1 - 21 of 21) sorted by relevance

/forgerock/opendj2/src/server/org/opends/server/replication/server/changelog/je/
H A DDomainDBCursor.java47 private final ReplicationDomainDB domainDB; field in class:DomainDBCursor
63 * @param domainDB
72 public DomainDBCursor(final DN baseDN, final ReplicationDomainDB domainDB, final KeyMatchingStrategy matchingStrategy, argument
76 this.domainDB = domainDB;
117 domainDB.getCursorFrom(baseDN, serverId, startCSN, matchingStrategy, positionStrategy);
128 domainDB.unregisterCursor(this);
H A DMultiDomainDBCursor.java45 private final ReplicationDomainDB domainDB; field in class:MultiDomainDBCursor
57 * @param domainDB
64 public MultiDomainDBCursor(final ReplicationDomainDB domainDB, final KeyMatchingStrategy matchingStrategy, argument
67 this.domainDB = domainDB;
97 domainDB.getCursorFrom(baseDN, serverState, matchingStrategy, positionStrategy);
121 domainDB.unregisterCursor(this);
H A DReplicaCursor.java55 private final ReplicationDomainDB domainDB; field in class:ReplicaCursor
69 * @param domainDB
73 Pair<DN, Integer> replicaID, ReplicationDomainDB domainDB)
77 this.domainDB = domainDB;
157 domainDB.unregisterCursor(this);
72 ReplicaCursor(DBCursor<UpdateMsg> cursor, CSN offlineCSN, Pair<DN, Integer> replicaID, ReplicationDomainDB domainDB) argument
H A DChangeNumberIndexer.java309 final ReplicationDomainDB domainDB = changelogDB.getReplicationDomainDB();
311 initializeLastAliveCSNs(domainDB);
312 initializeNextChangeCursor(domainDB);
319 private void initializeNextChangeCursor(final ReplicationDomainDB domainDB) throws ChangelogException argument
324 domainDB.getCursorFrom(cookieWithNewestCSN, LESS_THAN_OR_EQUAL_TO_KEY, AFTER_MATCHING_KEY);
346 private void initializeLastAliveCSNs(final ReplicationDomainDB domainDB) argument
362 final ServerState latestKnownState = domainDB.getDomainNewestCSNs(baseDN);
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/changelog/je/
H A DDomainDBCursor.java47 private final ReplicationDomainDB domainDB; field in class:DomainDBCursor
63 * @param domainDB
72 public DomainDBCursor(final DN baseDN, final ReplicationDomainDB domainDB, final KeyMatchingStrategy matchingStrategy, argument
76 this.domainDB = domainDB;
117 domainDB.getCursorFrom(baseDN, serverId, startCSN, matchingStrategy, positionStrategy);
128 domainDB.unregisterCursor(this);
H A DMultiDomainDBCursor.java45 private final ReplicationDomainDB domainDB; field in class:MultiDomainDBCursor
57 * @param domainDB
64 public MultiDomainDBCursor(final ReplicationDomainDB domainDB, final KeyMatchingStrategy matchingStrategy, argument
67 this.domainDB = domainDB;
97 domainDB.getCursorFrom(baseDN, serverState, matchingStrategy, positionStrategy);
121 domainDB.unregisterCursor(this);
H A DReplicaCursor.java55 private final ReplicationDomainDB domainDB; field in class:ReplicaCursor
69 * @param domainDB
73 Pair<DN, Integer> replicaID, ReplicationDomainDB domainDB)
77 this.domainDB = domainDB;
157 domainDB.unregisterCursor(this);
72 ReplicaCursor(DBCursor<UpdateMsg> cursor, CSN offlineCSN, Pair<DN, Integer> replicaID, ReplicationDomainDB domainDB) argument
H A DChangeNumberIndexer.java309 final ReplicationDomainDB domainDB = changelogDB.getReplicationDomainDB();
311 initializeLastAliveCSNs(domainDB);
312 initializeNextChangeCursor(domainDB);
319 private void initializeNextChangeCursor(final ReplicationDomainDB domainDB) throws ChangelogException argument
324 domainDB.getCursorFrom(cookieWithNewestCSN, LESS_THAN_OR_EQUAL_TO_KEY, AFTER_MATCHING_KEY);
346 private void initializeLastAliveCSNs(final ReplicationDomainDB domainDB) argument
362 final ServerState latestKnownState = domainDB.getDomainNewestCSNs(baseDN);
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/changelog/file/
H A DDomainDBCursor.java49 private final ReplicationDomainDB domainDB; field in class:DomainDBCursor
58 * @param domainDB
62 public DomainDBCursor(final DN baseDN, final ReplicationDomainDB domainDB, CursorOptions options) argument
65 this.domainDB = domainDB;
104 final DBCursor<UpdateMsg> cursor = domainDB.getCursorFrom(baseDN, serverId, startCSN, options);
115 domainDB.unregisterCursor(this);
H A DMultiDomainDBCursor.java45 private final ReplicationDomainDB domainDB; field in class:MultiDomainDBCursor
52 * @param domainDB
56 public MultiDomainDBCursor(final ReplicationDomainDB domainDB, CursorOptions options) argument
58 this.domainDB = domainDB;
86 final DBCursor<UpdateMsg> domainDBCursor = domainDB.getCursorFrom(baseDN, serverState, options);
110 domainDB.unregisterCursor(this);
H A DReplicaCursor.java52 private final ReplicationDomainDB domainDB; field in class:ReplicaCursor
66 * @param domainDB
69 public ReplicaCursor(DBCursor<UpdateMsg> cursor, CSN offlineCSN, ReplicaId replicaId, ReplicationDomainDB domainDB) argument
73 this.domainDB = domainDB;
153 domainDB.unregisterCursor(this);
H A DChangeNumberIndexer.java304 final ReplicationDomainDB domainDB = changelogDB.getReplicationDomainDB();
306 initializeLastAliveCSNs(domainDB);
307 initializeNextChangeCursor(domainDB);
311 private void initializeNextChangeCursor(final ReplicationDomainDB domainDB) throws ChangelogException argument
319 MultiDomainDBCursor cursorInitializedToMediumConsistencyPoint = domainDB.getCursorFrom(unused, options);
325 private void initializeLastAliveCSNs(final ReplicationDomainDB domainDB) argument
341 final ServerState latestKnownState = domainDB.getDomainNewestCSNs(baseDN);
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/server/changelog/je/
H A DECLMultiDomainDBCursorTest.java53 private ReplicationDomainDB domainDB; field in class:ECLMultiDomainDBCursorTest
71 multiDomainCursor = new MultiDomainDBCursor(domainDB, GREATER_THAN_OR_EQUAL_TO_KEY, ON_MATCHING_KEY);
79 domainDB = null;
168 when(domainDB.getCursorFrom(baseDN, state, GREATER_THAN_OR_EQUAL_TO_KEY, ON_MATCHING_KEY)).thenReturn(cursor);
H A DChangeNumberIndexerTest.java128 private ReplicationDomainDB domainDB; field in class:ChangeNumberIndexerTest
159 multiDomainCursor = new MultiDomainDBCursor(domainDB, LESS_THAN_OR_EQUAL_TO_KEY, AFTER_MATCHING_KEY);
166 when(changelogDB.getReplicationDomainDB()).thenReturn(domainDB);
167 when(domainDB.getCursorFrom(any(MultiDomainServerState.class),
555 domainDBCursor = new DomainDBCursor(baseDN, domainDB, LESS_THAN_OR_EQUAL_TO_KEY, AFTER_MATCHING_KEY);
559 when(domainDB.getCursorFrom(eq(baseDN), any(ServerState.class), eq(LESS_THAN_OR_EQUAL_TO_KEY),
563 when(domainDB.getCursorFrom(eq(baseDN), eq(serverId), any(CSN.class), eq(LESS_THAN_OR_EQUAL_TO_KEY),
567 when(domainDB.getDomainNewestCSNs(baseDN)).thenReturn(
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/server/changelog/je/
H A DECLMultiDomainDBCursorTest.java53 private ReplicationDomainDB domainDB; field in class:ECLMultiDomainDBCursorTest
71 multiDomainCursor = new MultiDomainDBCursor(domainDB, GREATER_THAN_OR_EQUAL_TO_KEY, ON_MATCHING_KEY);
79 domainDB = null;
168 when(domainDB.getCursorFrom(baseDN, state, GREATER_THAN_OR_EQUAL_TO_KEY, ON_MATCHING_KEY)).thenReturn(cursor);
H A DChangeNumberIndexerTest.java128 private ReplicationDomainDB domainDB; field in class:ChangeNumberIndexerTest
159 multiDomainCursor = new MultiDomainDBCursor(domainDB, LESS_THAN_OR_EQUAL_TO_KEY, AFTER_MATCHING_KEY);
166 when(changelogDB.getReplicationDomainDB()).thenReturn(domainDB);
167 when(domainDB.getCursorFrom(any(MultiDomainServerState.class),
555 domainDBCursor = new DomainDBCursor(baseDN, domainDB, LESS_THAN_OR_EQUAL_TO_KEY, AFTER_MATCHING_KEY);
559 when(domainDB.getCursorFrom(eq(baseDN), any(ServerState.class), eq(LESS_THAN_OR_EQUAL_TO_KEY),
563 when(domainDB.getCursorFrom(eq(baseDN), eq(serverId), any(CSN.class), eq(LESS_THAN_OR_EQUAL_TO_KEY),
567 when(domainDB.getDomainNewestCSNs(baseDN)).thenReturn(
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/server/changelog/file/
H A DECLMultiDomainDBCursorTest.java57 private ReplicationDomainDB domainDB; field in class:ECLMultiDomainDBCursorTest
78 multiDomainCursor = new MultiDomainDBCursor(domainDB, options);
86 domainDB = null;
206 when(domainDB.getCursorFrom(baseDN, state, options)).thenReturn(cursor);
H A DChangeNumberIndexerTest.java136 private ReplicationDomainDB domainDB; field in class:ChangeNumberIndexerTest
162 multiDomainCursor = new MultiDomainDBCursor(domainDB, options);
169 when(changelogDB.getReplicationDomainDB()).thenReturn(domainDB);
170 when(domainDB.getCursorFrom(any(MultiDomainServerState.class), eq(options))).thenReturn(multiDomainCursor);
558 domainDBCursor = new DomainDBCursor(baseDN, domainDB, options);
562 when(domainDB.getCursorFrom(eq(baseDN), any(ServerState.class), eq(options))).thenReturn(domainDBCursor);
565 when(domainDB.getCursorFrom(eq(baseDN), eq(serverId), any(CSN.class), eq(options))).thenReturn(replicaDBCursor);
568 when(domainDB.getDomainNewestCSNs(baseDN)).thenReturn(getDomainNewestCSNs(baseDN));
/forgerock/opendj2/src/server/org/opends/server/replication/server/
H A DReplicationServerDomain.java146 private final ReplicationDomainDB domainDB; field in class:ReplicationServerDomain
306 this.domainDB =
523 this.domainDB.notifyReplicaOffline(baseDN, offlineMsg.getCSN());
527 if (this.domainDB.publishUpdateMsg(baseDN, updateMsg))
1320 return domainDB.getCursorFrom(baseDN, startAfterServerState, GREATER_THAN_OR_EQUAL_TO_KEY, AFTER_MATCHING_KEY);
1670 return domainDB.getDomainNewestCSNs(baseDN);
2071 domainDB.removeDomain(baseDN);
2388 return domainDB.getDomainOldestCSNs(baseDN);
2433 domainDB.replicaHeartbeat(baseDN, msg.getCSN());
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/
H A DReplicationServerDomain.java146 private final ReplicationDomainDB domainDB; field in class:ReplicationServerDomain
306 this.domainDB =
523 this.domainDB.notifyReplicaOffline(baseDN, offlineMsg.getCSN());
527 if (this.domainDB.publishUpdateMsg(baseDN, updateMsg))
1320 return domainDB.getCursorFrom(baseDN, startAfterServerState, GREATER_THAN_OR_EQUAL_TO_KEY, AFTER_MATCHING_KEY);
1670 return domainDB.getDomainNewestCSNs(baseDN);
2071 domainDB.removeDomain(baseDN);
2388 return domainDB.getDomainOldestCSNs(baseDN);
2433 domainDB.replicaHeartbeat(baseDN, msg.getCSN());
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/
H A DReplicationServerDomain.java136 private final ReplicationDomainDB domainDB; field in class:ReplicationServerDomain
294 this.domainDB =
509 this.domainDB.notifyReplicaOffline(baseDN, offlineMsg.getCSN());
513 if (this.domainDB.publishUpdateMsg(baseDN, updateMsg))
1280 return domainDB.getCursorFrom(baseDN, startAfterServerState, options);
1624 return domainDB.getDomainNewestCSNs(baseDN);
2011 domainDB.removeDomain(baseDN);
2319 return domainDB.getDomainOldestCSNs(baseDN);
2362 domainDB.replicaHeartbeat(baseDN, msg.getCSN());

Completed in 106 milliseconds