From 32a236a80b7a7a537ffbd5f10e4a4348c417d3cb Mon Sep 17 00:00:00 2001
From: "Brian S. O'Neill" <bronee@gmail.com>
Date: Tue, 19 Sep 2006 05:47:29 +0000
Subject: Restored synchronization and added comment for doing so.

---
 src/main/java/com/amazon/carbonado/cursor/AbstractCursor.java | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

(limited to 'src/main/java')

diff --git a/src/main/java/com/amazon/carbonado/cursor/AbstractCursor.java b/src/main/java/com/amazon/carbonado/cursor/AbstractCursor.java
index fb34617..cf64a24 100644
--- a/src/main/java/com/amazon/carbonado/cursor/AbstractCursor.java
+++ b/src/main/java/com/amazon/carbonado/cursor/AbstractCursor.java
@@ -64,7 +64,10 @@ public abstract class AbstractCursor<S> implements Cursor<S> {
         return list;
     }
 
-    public int skipNext(int amount) throws FetchException {
+    public synchronized int skipNext(int amount) throws FetchException {
+        // This method is synchronized to avoid potential race conditions
+        // between calls to hasNext and next in the loop below.
+
         if (amount <= 0) {
             if (amount < 0) {
                 throw new IllegalArgumentException("Cannot skip negative amount: " + amount);
-- 
cgit v1.2.3