Added @NotThreadSafe annotation to DBCursors

Jean-Noel Rouvignac

19.23.2014 1c3d676fa098a69043aa69197cf453660aaeeae8

Added @NotThreadSafe annotation to DBCursors

 opendj-sdk/opends/src/server/org/opends/server/replication/server/changelog/api/DBCursor.java

@@ -54,6 +54,7 @@
 *
 * @param <T>
 *          type of the record being returned
 * \@NotThreadSafe
 */
public interface DBCursor<T> extends Closeable
{

 opendj-sdk/opends/src/server/org/opends/server/replication/server/changelog/file/FileChangeNumberIndexDBCursor.java

@@ -31,6 +31,8 @@

/**
 * A cursor on ChangeNumberIndexDB.
 *
 * \@NotThreadSafe
 */
class FileChangeNumberIndexDBCursor implements DBCursor<ChangeNumberIndexRecord>
{

 opendj-sdk/opends/src/server/org/opends/server/replication/server/changelog/file/FileReplicaDBCursor.java

@@ -54,6 +54,8 @@
 * 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>
{

 opendj-sdk/opends/src/server/org/opends/server/replication/server/changelog/je/CompositeDBCursor.java

@@ -41,6 +41,7 @@
 *
 * @param <Data>
 *          The type of data associated with each cursor
 * \@NotThreadSafe
 */
abstract class CompositeDBCursor<Data> implements DBCursor<UpdateMsg>
{

 opendj-sdk/opends/src/server/org/opends/server/replication/server/changelog/je/DomainDBCursor.java

@@ -37,6 +37,8 @@

/**
 * Cursor iterating over a replication domain's replica DBs.
 *
 * \@NotThreadSafe
 */
public class DomainDBCursor extends CompositeDBCursor<Void>
{

 opendj-sdk/opends/src/server/org/opends/server/replication/server/changelog/je/JEChangeNumberIndexDBCursor.java

@@ -34,8 +34,9 @@
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>

 opendj-sdk/opends/src/server/org/opends/server/replication/server/changelog/je/JEReplicaDBCursor.java

@@ -34,6 +34,8 @@

/**
 * Berkeley DB JE implementation of {@link DBCursor}.
 *
 * \@NotThreadSafe
 */
public class JEReplicaDBCursor implements DBCursor<UpdateMsg>
{

 opendj-sdk/opends/src/server/org/opends/server/replication/server/changelog/je/MultiDomainDBCursor.java

@@ -38,6 +38,8 @@

/**
 * Cursor iterating over a all the replication domain known to the changelog DB.
 *
 * \@NotThreadSafe
 */
public class MultiDomainDBCursor extends CompositeDBCursor<DN>
{