/forgerock/opendj2/src/server/org/opends/server/replication/server/changelog/je/ |
H A D | DomainDBCursor.java | 47 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 D | MultiDomainDBCursor.java | 45 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 D | ReplicaCursor.java | 55 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 D | ChangeNumberIndexer.java | 309 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 D | DomainDBCursor.java | 47 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 D | MultiDomainDBCursor.java | 45 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 D | ReplicaCursor.java | 55 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 D | ChangeNumberIndexer.java | 309 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 D | DomainDBCursor.java | 49 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 D | MultiDomainDBCursor.java | 45 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 D | ReplicaCursor.java | 52 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 D | ChangeNumberIndexer.java | 304 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 D | ECLMultiDomainDBCursorTest.java | 53 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 D | ChangeNumberIndexerTest.java | 128 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 D | ECLMultiDomainDBCursorTest.java | 53 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 D | ChangeNumberIndexerTest.java | 128 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 D | ECLMultiDomainDBCursorTest.java | 57 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 D | ChangeNumberIndexerTest.java | 136 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 D | ReplicationServerDomain.java | 146 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 D | ReplicationServerDomain.java | 146 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 D | ReplicationServerDomain.java | 136 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());
|