diff options
| author | clang-format-7.0.1 <adam.martin@10gen.com> | 2019-07-26 18:20:35 -0400 |
|---|---|---|
| committer | ADAM David Alan Martin <adam.martin@10gen.com> | 2019-07-27 11:02:23 -0400 |
| commit | 134a4083953270e8a11430395357fb70a29047ad (patch) | |
| tree | dd428e1230e31d92b20b393dfdc17ffe7fa79cb6 /src/mongo/db/exhaust_cursor_currentop_integration_test.cpp | |
| parent | 1e46b5049003f427047e723ea5fab15b5a9253ca (diff) | |
| download | mongo-134a4083953270e8a11430395357fb70a29047ad.tar.gz | |
SERVER-41772 Apply clang-format 7.0.1 to the codebase
Diffstat (limited to 'src/mongo/db/exhaust_cursor_currentop_integration_test.cpp')
| -rw-r--r-- | src/mongo/db/exhaust_cursor_currentop_integration_test.cpp | 14 |
1 files changed, 4 insertions, 10 deletions
diff --git a/src/mongo/db/exhaust_cursor_currentop_integration_test.cpp b/src/mongo/db/exhaust_cursor_currentop_integration_test.cpp index 7adf5c74dcd..ad98dcfdc35 100644 --- a/src/mongo/db/exhaust_cursor_currentop_integration_test.cpp +++ b/src/mongo/db/exhaust_cursor_currentop_integration_test.cpp @@ -51,9 +51,7 @@ std::unique_ptr<DBClientBase> connect(StringData appName) { void setWaitWithPinnedCursorDuringGetMoreBatchFailpoint(DBClientBase* conn, bool enable) { auto cmdObj = BSON("configureFailPoint" << "waitWithPinnedCursorDuringGetMoreBatch" - << "mode" - << (enable ? "alwaysOn" : "off") - << "data" + << "mode" << (enable ? "alwaysOn" : "off") << "data" << BSON("shouldNotdropLock" << true)); auto reply = conn->runCommand(OpMsgRequest::fromDBAndBody("admin", cmdObj)); ASSERT_OK(getStatusFromCommandResult(reply->getCommandReply())); @@ -63,8 +61,7 @@ void setWaitBeforeUnpinningOrDeletingCursorAfterGetMoreBatchFailpoint(DBClientBa bool enable) { auto cmdObj = BSON("configureFailPoint" << "waitBeforeUnpinningOrDeletingCursorAfterGetMoreBatch" - << "mode" - << (enable ? "alwaysOn" : "off")); + << "mode" << (enable ? "alwaysOn" : "off")); auto reply = conn->runCommand(OpMsgRequest::fromDBAndBody("admin", cmdObj)); ASSERT_OK(getStatusFromCommandResult(reply->getCommandReply())); } @@ -158,12 +155,9 @@ TEST(CurrentOpExhaustCursorTest, CanSeeEachExhaustCursorPseudoGetMoreInCurrentOp // Generate a currentOp filter based on the cursorId and the cumulative nDocsReturned. const auto curOpMatch = BSON("command.collection" << "exhaust_cursor_currentop" - << "command.getMore" - << queryCursor->getCursorId() - << "msg" + << "command.getMore" << queryCursor->getCursorId() << "msg" << "waitWithPinnedCursorDuringGetMoreBatch" - << "cursor.nDocsReturned" - << i); + << "cursor.nDocsReturned" << i); // Confirm that the exhaust getMore appears in the $currentOp output. ASSERT(confirmCurrentOpContents(conn.get(), curOpMatch, parallelWaitTimeoutMS)); |