SERVER-38349 Disallow exchange passed to mongos

1 files changed, 29 insertions, 0 deletions

diff --git a/jstests/aggregation/sources/out/exchange_explain.js b/jstests/aggregation/sources/out/exchange_explain.js
index 7ccf35124cf..5a6b7a33ef7 100644
--- a/jstests/aggregation/sources/out/exchange_explain.js
+++ b/jstests/aggregation/sources/out/exchange_explain.js
@@ -128,5 +128,34 @@ load('jstests/aggregation/extras/utils.js');
                     }],
                     50905);
 
+    // SERVER-38349 Make sure mongos rejects specifying exchange directly.
+    assert.commandFailedWithCode(mongosDB.runCommand({
+        aggregate: inColl.getName(),
+        pipeline: [],
+        cursor: {},
+        exchange: {
+            policy: "keyRange",
+            bufferSize: NumberInt(1024),
+            boundaries: [{_id: 0}],
+            consumers: NumberInt(2),
+            consumerIds: [NumberInt(0), NumberInt(1)]
+        }
+    }),
+                                 51028);
+
+    assert.commandFailedWithCode(mongosDB.runCommand({
+        aggregate: inColl.getName(),
+        pipeline: [{$out: {to: outCollRange.getName(), mode: "replaceDocuments"}}],
+        cursor: {},
+        exchange: {
+            policy: "keyRange",
+            bufferSize: NumberInt(1024),
+            boundaries: [{_id: 0}],
+            consumers: NumberInt(2),
+            consumerIds: [NumberInt(0), NumberInt(1)]
+        }
+    }),
+                                 51028);
+
     st.stop();
 }());