Skip to content

Commit 8c2fbe0

Browse files
committed
parallelCollectionScan is not available in a sharded cluster
1 parent 10ef3f6 commit 8c2fbe0

File tree

2 files changed

+8
-5
lines changed

2 files changed

+8
-5
lines changed

spec/mongo/collection/view/readable_spec.rb

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -434,7 +434,7 @@
434434
end
435435
end
436436

437-
describe '#parallel_scan' do
437+
describe '#parallel_scan', unless: sharded? do
438438

439439
let(:documents) do
440440
(1..200).map do |i|

spec/spec_helper.rb

Lines changed: 7 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -91,12 +91,13 @@ def replica_set?
9191
$replica_set ||= $mongo_client.cluster.replica_set?
9292
end
9393

94-
# Determine whether the test clients are connecting to a sharded cluster.
94+
# Determine whether the test clients are connecting to a sharded cluster
95+
# or a single mongos.
9596
#
9697
# @since 2.0.0
9798
def sharded?
9899
$mongo_client ||= initialize_scanned_client!
99-
$sharded ||= $mongo_client.cluster.sharded?
100+
$sharded ||= ($mongo_client.cluster.sharded? || single_mongos?)
100101
end
101102

102103
# Determine whether the single address provided is a replica set member.
@@ -107,7 +108,8 @@ def sharded?
107108
# @since 2.0.0
108109
def single_rs_member?
109110
$mongo_client ||= initialize_scanned_client!
110-
single_seed? && $mongo_client.cluster.servers.first.replica_set_name
111+
$single_rs_member ||= (single_seed? &&
112+
$mongo_client.cluster.servers.first.replica_set_name)
111113
end
112114

113115
# Determine whether the single address provided is a mongos.
@@ -118,7 +120,8 @@ def single_rs_member?
118120
# @since 2.0.0
119121
def single_mongos?
120122
$mongo_client ||= initialize_scanned_client!
121-
single_seed? && $mongo_client.cluster.servers.first.mongos?
123+
$single_mongos ||= (single_seed? &&
124+
$mongo_client.cluster.servers.first.mongos?)
122125
end
123126

124127
# Determine whether a single address was provided.

0 commit comments

Comments
 (0)