From 5c29fd8e8b12e987285e08dbc66568fbf8ce42ac Mon Sep 17 00:00:00 2001
From: Jean-Noel Rouvignac <jean-noel.rouvignac@forgerock.com>
Date: Mon, 18 Aug 2014 15:28:27 +0000
Subject: [PATCH] Added @NotThreadSafe annotation to DBCursors
---
opendj-sdk/opendj3-server-dev/src/server/org/opends/server/replication/server/changelog/je/MultiDomainDBCursor.java | 2 ++
opendj-sdk/opendj3-server-dev/src/server/org/opends/server/replication/server/changelog/je/DomainDBCursor.java | 2 ++
opendj-sdk/opendj3-server-dev/src/server/org/opends/server/replication/server/changelog/api/DBCursor.java | 1 +
opendj-sdk/opendj3-server-dev/src/server/org/opends/server/replication/server/changelog/je/JEChangeNumberIndexDBCursor.java | 5 +++--
opendj-sdk/opendj3-server-dev/src/server/org/opends/server/replication/server/changelog/je/JEReplicaDBCursor.java | 2 ++
opendj-sdk/opendj3-server-dev/src/server/org/opends/server/replication/server/changelog/je/CompositeDBCursor.java | 1 +
6 files changed, 11 insertions(+), 2 deletions(-)
diff --git a/opendj-sdk/opendj3-server-dev/src/server/org/opends/server/replication/server/changelog/api/DBCursor.java b/opendj-sdk/opendj3-server-dev/src/server/org/opends/server/replication/server/changelog/api/DBCursor.java
index 6970a9e..ad658e4 100644
--- a/opendj-sdk/opendj3-server-dev/src/server/org/opends/server/replication/server/changelog/api/DBCursor.java
+++ b/opendj-sdk/opendj3-server-dev/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
{
diff --git a/opendj-sdk/opendj3-server-dev/src/server/org/opends/server/replication/server/changelog/je/CompositeDBCursor.java b/opendj-sdk/opendj3-server-dev/src/server/org/opends/server/replication/server/changelog/je/CompositeDBCursor.java
index e0305cd..ae54930 100644
--- a/opendj-sdk/opendj3-server-dev/src/server/org/opends/server/replication/server/changelog/je/CompositeDBCursor.java
+++ b/opendj-sdk/opendj3-server-dev/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>
{
diff --git a/opendj-sdk/opendj3-server-dev/src/server/org/opends/server/replication/server/changelog/je/DomainDBCursor.java b/opendj-sdk/opendj3-server-dev/src/server/org/opends/server/replication/server/changelog/je/DomainDBCursor.java
index 3cf8b5d..c249a78 100644
--- a/opendj-sdk/opendj3-server-dev/src/server/org/opends/server/replication/server/changelog/je/DomainDBCursor.java
+++ b/opendj-sdk/opendj3-server-dev/src/server/org/opends/server/replication/server/changelog/je/DomainDBCursor.java
@@ -38,6 +38,8 @@
/**
* Cursor iterating over a replication domain's replica DBs.
+ *
+ * \@NotThreadSafe
*/
public class DomainDBCursor extends CompositeDBCursor<Void>
{
diff --git a/opendj-sdk/opendj3-server-dev/src/server/org/opends/server/replication/server/changelog/je/JEChangeNumberIndexDBCursor.java b/opendj-sdk/opendj3-server-dev/src/server/org/opends/server/replication/server/changelog/je/JEChangeNumberIndexDBCursor.java
index 93ec81a..c937e90 100644
--- a/opendj-sdk/opendj3-server-dev/src/server/org/opends/server/replication/server/changelog/je/JEChangeNumberIndexDBCursor.java
+++ b/opendj-sdk/opendj3-server-dev/src/server/org/opends/server/replication/server/changelog/je/JEChangeNumberIndexDBCursor.java
@@ -31,8 +31,9 @@
import org.opends.server.replication.server.changelog.je.DraftCNDB.*;
/**
- * 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>
diff --git a/opendj-sdk/opendj3-server-dev/src/server/org/opends/server/replication/server/changelog/je/JEReplicaDBCursor.java b/opendj-sdk/opendj3-server-dev/src/server/org/opends/server/replication/server/changelog/je/JEReplicaDBCursor.java
index d5ed710..c3ef1c3 100644
--- a/opendj-sdk/opendj3-server-dev/src/server/org/opends/server/replication/server/changelog/je/JEReplicaDBCursor.java
+++ b/opendj-sdk/opendj3-server-dev/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>
{
diff --git a/opendj-sdk/opendj3-server-dev/src/server/org/opends/server/replication/server/changelog/je/MultiDomainDBCursor.java b/opendj-sdk/opendj3-server-dev/src/server/org/opends/server/replication/server/changelog/je/MultiDomainDBCursor.java
index 9f78065..cf88679 100644
--- a/opendj-sdk/opendj3-server-dev/src/server/org/opends/server/replication/server/changelog/je/MultiDomainDBCursor.java
+++ b/opendj-sdk/opendj3-server-dev/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>
{
--
Gitblit v1.10.0