| | |
| | | * |
| | | * @param <T> |
| | | * type of the record being returned |
| | | * \@NotThreadSafe |
| | | */ |
| | | public interface DBCursor<T> extends Closeable |
| | | { |
| | |
| | | |
| | | /** |
| | | * A cursor on ChangeNumberIndexDB. |
| | | * |
| | | * \@NotThreadSafe |
| | | */ |
| | | class FileChangeNumberIndexDBCursor implements DBCursor<ChangeNumberIndexRecord> |
| | | { |
| | |
| | | * record is newly available, a subsequent call to the {@code next()} method will |
| | | * return {@code true} and the record will be available by calling {@code getRecord()} |
| | | * method. |
| | | * |
| | | * \@NotThreadSafe |
| | | */ |
| | | class FileReplicaDBCursor implements DBCursor<UpdateMsg> |
| | | { |
| | |
| | | * |
| | | * @param <Data> |
| | | * The type of data associated with each cursor |
| | | * \@NotThreadSafe |
| | | */ |
| | | abstract class CompositeDBCursor<Data> implements DBCursor<UpdateMsg> |
| | | { |
| | |
| | | |
| | | /** |
| | | * Cursor iterating over a replication domain's replica DBs. |
| | | * |
| | | * \@NotThreadSafe |
| | | */ |
| | | public class DomainDBCursor extends CompositeDBCursor<Void> |
| | | { |
| | |
| | | import static org.opends.server.loggers.debug.DebugLogger.*; |
| | | |
| | | /** |
| | | * This class allows to iterate through the changes received from a given |
| | | * LDAP Server Identifier. |
| | | * This class allows to iterate through the changes comming from the change number index DB. |
| | | * |
| | | * \@NotThreadSafe |
| | | */ |
| | | public class JEChangeNumberIndexDBCursor implements |
| | | DBCursor<ChangeNumberIndexRecord> |
| | |
| | | |
| | | /** |
| | | * Berkeley DB JE implementation of {@link DBCursor}. |
| | | * |
| | | * \@NotThreadSafe |
| | | */ |
| | | public class JEReplicaDBCursor implements DBCursor<UpdateMsg> |
| | | { |
| | |
| | | |
| | | /** |
| | | * Cursor iterating over a all the replication domain known to the changelog DB. |
| | | * |
| | | * \@NotThreadSafe |
| | | */ |
| | | public class MultiDomainDBCursor extends CompositeDBCursor<DN> |
| | | { |