Just use ReentrantLock

Author: rozza

driver-core/src/main/com/mongodb/internal/operation/AsyncCommandBatchCursor.java

@@ -45,7 +45,6 @@
 import java.util.List;
 import java.util.concurrent.atomic.AtomicBoolean;
 import java.util.concurrent.atomic.AtomicInteger;
-import java.util.concurrent.locks.ReentrantLock;
 
 import static com.mongodb.assertions.Assertions.assertNotNull;
 import static com.mongodb.assertions.Assertions.assertTrue;
@@ -55,9 +54,9 @@
 import static com.mongodb.internal.operation.CommandBatchCursorHelper.MESSAGE_IF_CONCURRENT_OPERATION;
 import static com.mongodb.internal.operation.CommandBatchCursorHelper.NEXT_BATCH;
 import static com.mongodb.internal.operation.CommandBatchCursorHelper.NO_OP_FIELD_NAME_VALIDATOR;
-import static com.mongodb.internal.operation.CommandBatchCursorHelper.logCommandCursorResult;
 import static com.mongodb.internal.operation.CommandBatchCursorHelper.getKillCursorsCommand;
 import static com.mongodb.internal.operation.CommandBatchCursorHelper.getMoreCommandDocument;
+import static com.mongodb.internal.operation.CommandBatchCursorHelper.logCommandCursorResult;
 import static com.mongodb.internal.operation.CommandBatchCursorHelper.translateCommandException;
 import static java.util.Collections.emptyList;
 
@@ -252,7 +251,7 @@ private static final class ResourceManager extends CursorResourceManager<AsyncCo
                 final AsyncConnectionSource connectionSource,
                 @Nullable final AsyncConnection connectionToPin,
                 @Nullable final ServerCursor serverCursor) {
-            super(new ReentrantLock(), namespace, connectionSource, connectionToPin, serverCursor);
+            super(namespace, connectionSource, connectionToPin, serverCursor);
         }
 
         /**

driver-core/src/main/com/mongodb/internal/operation/CommandBatchCursor.java

@@ -39,7 +39,6 @@
 
 import java.util.List;
 import java.util.NoSuchElementException;
-import java.util.concurrent.locks.StampedLock;
 import java.util.function.Consumer;
 import java.util.function.Supplier;
 
@@ -53,8 +52,8 @@
 import static com.mongodb.internal.operation.CommandBatchCursorHelper.NEXT_BATCH;
 import static com.mongodb.internal.operation.CommandBatchCursorHelper.NO_OP_FIELD_NAME_VALIDATOR;
 import static com.mongodb.internal.operation.CommandBatchCursorHelper.getKillCursorsCommand;
-import static com.mongodb.internal.operation.CommandBatchCursorHelper.logCommandCursorResult;
 import static com.mongodb.internal.operation.CommandBatchCursorHelper.getMoreCommandDocument;
+import static com.mongodb.internal.operation.CommandBatchCursorHelper.logCommandCursorResult;
 import static com.mongodb.internal.operation.CommandBatchCursorHelper.translateCommandException;
 
 class CommandBatchCursor<T> implements AggregateResponseBatchCursor<T> {
@@ -292,7 +291,7 @@ private static final class ResourceManager extends CursorResourceManager<Connect
                 final ConnectionSource connectionSource,
                 @Nullable final Connection connectionToPin,
                 @Nullable final ServerCursor serverCursor) {
-            super(new StampedLock().asWriteLock(), namespace, connectionSource, connectionToPin, serverCursor);
+            super(namespace, connectionSource, connectionToPin, serverCursor);
         }
 
         /**

driver-core/src/main/com/mongodb/internal/operation/CursorResourceManager.java

@@ -25,6 +25,7 @@
 import com.mongodb.lang.Nullable;
 
 import java.util.concurrent.locks.Lock;
+import java.util.concurrent.locks.ReentrantLock;
 
 import static com.mongodb.assertions.Assertions.assertNotNull;
 import static com.mongodb.assertions.Assertions.assertNull;
@@ -65,12 +66,11 @@ abstract class CursorResourceManager<CS extends ReferenceCounted, C extends Refe
     private volatile boolean skipReleasingServerResourcesOnClose;
 
     CursorResourceManager(
-            final Lock lock,
             final MongoNamespace namespace,
             final CS connectionSource,
             @Nullable final C connectionToPin,
             @Nullable final ServerCursor serverCursor) {
-        this.lock = notNull("lock", lock);
+        this.lock = new ReentrantLock();
         this.namespace = notNull("mongoNamespace", namespace);
         this.state = State.IDLE;
         if (serverCursor != null) {