blob: 7cceb60e848f2ecc9a2b420f31ffbd66449823e2 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
|
/*
* Test that aggregation's $out stage serializes behind a drop database and fails.
*
* @tags: [
* requires_fcv_51,
* does_not_support_stepdowns, # DropDatabaseCoordinator drops the input collection on step-up
* ]
*/
"use strict";
load("jstests/libs/fail_point_util.js");
load('jstests/libs/parallel_shell_helpers.js');
let st = new ShardingTest({shards: {rs0: {nodes: 1}}});
const dbName = "test";
db = st.getDB(dbName);
assert.commandWorked(st.s.adminCommand({enableSharding: dbName}));
// Setup and populate input collection.
const inputCollName = "input_coll";
const inputColl = db[inputCollName];
assert.commandWorked(inputColl.insert({_id: 0}));
const outputCollName = "output_coll";
let failpoint =
configureFailPoint(st.rs0.getPrimary(), 'blockBeforeInternalRenameIfOptionsAndIndexesMatch');
function aggOut(inputCollName, outputCollName) {
// Make sure the aggregation fails because the database has been dropped
assert.commandFailedWithCode(
db.runCommand({aggregate: inputCollName, pipeline: [{$out: outputCollName}], cursor: {}}),
ErrorCodes.NamespaceNotFound);
}
// Start an aggregation with $out stage, will block before renaming the tmp collection
const awaitShell =
startParallelShell(funWithArgs(aggOut, inputCollName, outputCollName), st.s.port);
// Wait for the aggregation to arrive right before the rename
failpoint.wait();
// Drop the database and unblock the aggregation
assert.commandWorked(db.dropDatabase());
failpoint.off();
awaitShell();
st.stop();
|
