Skip to content

Commit 66e8e79

Browse files
committed
JAVA-2830: Re-enable tailable cursor tests
Re-enable tailable cursor tests that were disabled due to a server bug that has since been fixed.
1 parent a55d172 commit 66e8e79

File tree

3 files changed

+1
-7
lines changed

3 files changed

+1
-7
lines changed

driver-core/src/test/functional/com/mongodb/operation/AsyncQueryBatchCursorFunctionalSpecification.groovy

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -52,11 +52,10 @@ import static com.mongodb.ClusterFixture.getReadConnectionSource
5252
import static com.mongodb.ClusterFixture.getReferenceCountAfterTimeout
5353
import static com.mongodb.ClusterFixture.isDiscoverableReplicaSet
5454
import static com.mongodb.ClusterFixture.isSharded
55-
import static com.mongodb.ClusterFixture.serverVersionAtLeast
5655
import static com.mongodb.connection.ServerHelper.waitForLastRelease
5756
import static com.mongodb.connection.ServerHelper.waitForRelease
58-
import static com.mongodb.operation.OperationHelper.cursorDocumentToQueryResult
5957
import static com.mongodb.internal.operation.ServerVersionHelper.serverIsAtLeastVersionThreeDotTwo
58+
import static com.mongodb.operation.OperationHelper.cursorDocumentToQueryResult
6059
import static java.util.Arrays.asList
6160
import static java.util.concurrent.TimeUnit.SECONDS
6261
import static org.junit.Assert.assertEquals
@@ -262,7 +261,6 @@ class AsyncQueryBatchCursorFunctionalSpecification extends OperationFunctionalSp
262261
}
263262

264263
@Category(Slow)
265-
@IgnoreIf({ serverVersionAtLeast(3, 7) && isSharded() })
266264
def 'should block waiting for next batch on a tailable cursor'() {
267265
collectionHelper.create(collectionName, new CreateCollectionOptions().capped(true).sizeInBytes(1000))
268266
collectionHelper.insertDocuments(new DocumentCodec(), new Document('_id', 1).append('ts', new BsonTimestamp(5, 0)))

driver-core/src/test/functional/com/mongodb/operation/ChangeStreamOperationSpecification.groovy

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -40,7 +40,6 @@ import spock.lang.IgnoreIf
4040

4141
import static com.mongodb.ClusterFixture.getAsyncCluster
4242
import static com.mongodb.ClusterFixture.getCluster
43-
import static com.mongodb.ClusterFixture.isSharded
4443
import static com.mongodb.ClusterFixture.isStandalone
4544
import static com.mongodb.ClusterFixture.serverVersionAtLeast
4645
import static com.mongodb.connection.ServerHelper.waitForLastRelease
@@ -293,7 +292,6 @@ class ChangeStreamOperationSpecification extends OperationFunctionalSpecificatio
293292
async << [true, false]
294293
}
295294

296-
@IgnoreIf({ serverVersionAtLeast(3, 7) && isSharded() })
297295
def 'should act like a tailable cursor'() {
298296
given:
299297
def helper = getHelper()

driver-core/src/test/functional/com/mongodb/operation/QueryBatchCursorFunctionalSpecification.groovy

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -187,7 +187,6 @@ class QueryBatchCursorFunctionalSpecification extends OperationFunctionalSpecifi
187187

188188
@SuppressWarnings('EmptyCatchBlock')
189189
@Category(Slow)
190-
@IgnoreIf({ serverVersionAtLeast(3, 7) && isSharded() })
191190
def 'should block waiting for next batch on a tailable cursor'() {
192191
given:
193192
def connection = connectionSource.getConnection()
@@ -236,7 +235,6 @@ class QueryBatchCursorFunctionalSpecification extends OperationFunctionalSpecifi
236235
}
237236

238237
@Category(Slow)
239-
@IgnoreIf({ serverVersionAtLeast(3, 7) && isSharded() })
240238
def 'test try next with tailable'() {
241239
collectionHelper.create(collectionName, new CreateCollectionOptions().capped(true).sizeInBytes(1000))
242240
collectionHelper.insertDocuments(new DocumentCodec(), new Document('_id', 1).append('ts', new BsonTimestamp(5, 0)))

0 commit comments

Comments
 (0)