Aggregate can be sent to mongos

estolfo · estolfo · commit ae1a95a7bca8 · 2015-03-25T15:57:39.000+01:00
diff --git a/lib/mongo/operation/aggregate.rb b/lib/mongo/operation/aggregate.rb
@@ -62,7 +62,7 @@ class Aggregate
       #
       # @since 2.0.0
       def execute(context)
-        unless context.standalone? || context.primary? || secondary_ok?
+        unless context.standalone? || context.mongos? || context.primary? || secondary_ok?
           raise Error::NeedPrimaryServer.new(ERROR_MESSAGE)
         end
         execute_message(context)

Original file line number	Diff line number	Diff line change
`@@ -62,7 +62,7 @@ class Aggregate`
`62`	`62`	`#`
`63`	`63`	`# @since 2.0.0`
`64`	`64`	`def execute(context)`
`65`		`- unless context.standalone? \|\| context.primary? \|\| secondary_ok?`
	`65`	`+ unless context.standalone? \|\| context.mongos? \|\| context.primary? \|\| secondary_ok?`
`66`	`66`	`raise Error::NeedPrimaryServer.new(ERROR_MESSAGE)`
`67`	`67`	`end`
`68`	`68`	`execute_message(context)`