summaryrefslogtreecommitdiff
path: root/src/mongo/executor/task_executor_test_common.cpp
diff options
context:
space:
mode:
authorMark Benvenuto <mark.benvenuto@mongodb.com>2016-05-28 17:55:12 -0400
committerMark Benvenuto <mark.benvenuto@mongodb.com>2016-05-28 17:55:12 -0400
commit6dcdd23dd37ef12c87e71cf59ef01cd82432efe0 (patch)
treec8cfb5acb62c80f375bc37e7d4350382deea6a37 /src/mongo/executor/task_executor_test_common.cpp
parentd4ac5673ea3f6cef4ce9dbcec90e31813997a528 (diff)
downloadmongo-6dcdd23dd37ef12c87e71cf59ef01cd82432efe0.tar.gz
SERVER-23971 Clang-Format code
Diffstat (limited to 'src/mongo/executor/task_executor_test_common.cpp')
-rw-r--r--src/mongo/executor/task_executor_test_common.cpp50
1 files changed, 26 insertions, 24 deletions
diff --git a/src/mongo/executor/task_executor_test_common.cpp b/src/mongo/executor/task_executor_test_common.cpp
index d6c479a1a32..ed956b93567 100644
--- a/src/mongo/executor/task_executor_test_common.cpp
+++ b/src/mongo/executor/task_executor_test_common.cpp
@@ -90,20 +90,20 @@ public:
}
};
-#define COMMON_EXECUTOR_TEST(TEST_NAME) \
- class CET_##TEST_NAME : public CommonTaskExecutorTestFixture { \
- public: \
- CET_##TEST_NAME(ExecutorFactory makeExecutor) \
- : CommonTaskExecutorTestFixture(std::move(makeExecutor)) {} \
- \
- private: \
- void _doTest() override; \
- static const CetRegistrationAgent _agent; \
- }; \
- const CetRegistrationAgent CET_##TEST_NAME::_agent(#TEST_NAME, \
- [](ExecutorFactory makeExecutor) { \
- return stdx::make_unique<CET_##TEST_NAME>(std::move(makeExecutor)); \
- }); \
+#define COMMON_EXECUTOR_TEST(TEST_NAME) \
+ class CET_##TEST_NAME : public CommonTaskExecutorTestFixture { \
+ public: \
+ CET_##TEST_NAME(ExecutorFactory makeExecutor) \
+ : CommonTaskExecutorTestFixture(std::move(makeExecutor)) {} \
+ \
+ private: \
+ void _doTest() override; \
+ static const CetRegistrationAgent _agent; \
+ }; \
+ const CetRegistrationAgent CET_##TEST_NAME::_agent( \
+ #TEST_NAME, [](ExecutorFactory makeExecutor) { \
+ return stdx::make_unique<CET_##TEST_NAME>(std::move(makeExecutor)); \
+ }); \
void CET_##TEST_NAME::_doTest()
void setStatus(const TaskExecutor::CallbackArgs& cbData, Status* target) {
@@ -132,9 +132,10 @@ void scheduleSetStatusAndShutdown(const TaskExecutor::CallbackArgs& cbData,
*outStatus1 = cbData.status;
return;
}
- *outStatus1 = cbData.executor->scheduleWork(stdx::bind(setStatusAndShutdown,
- stdx::placeholders::_1,
- outStatus2)).getStatus();
+ *outStatus1 =
+ cbData.executor
+ ->scheduleWork(stdx::bind(setStatusAndShutdown, stdx::placeholders::_1, outStatus2))
+ .getStatus();
}
COMMON_EXECUTOR_TEST(RunOne) {
@@ -180,10 +181,10 @@ COMMON_EXECUTOR_TEST(OneSchedulesAnother) {
TaskExecutor& executor = getExecutor();
Status status1 = getDetectableErrorStatus();
Status status2 = getDetectableErrorStatus();
- ASSERT_OK(executor.scheduleWork(stdx::bind(scheduleSetStatusAndShutdown,
- stdx::placeholders::_1,
- &status1,
- &status2)).getStatus());
+ ASSERT_OK(executor
+ .scheduleWork(stdx::bind(
+ scheduleSetStatusAndShutdown, stdx::placeholders::_1, &status1, &status2))
+ .getStatus());
launchExecutorThread();
joinExecutorThread();
ASSERT_OK(status1);
@@ -360,9 +361,10 @@ static void setStatusOnRemoteCommandCompletion(
Status* outStatus) {
if (cbData.request != expectedRequest) {
*outStatus = Status(ErrorCodes::BadValue,
- mongoutils::str::stream()
- << "Actual request: " << getRequestDescription(cbData.request)
- << "; expected: " << getRequestDescription(expectedRequest));
+ mongoutils::str::stream() << "Actual request: "
+ << getRequestDescription(cbData.request)
+ << "; expected: "
+ << getRequestDescription(expectedRequest));
return;
}
*outStatus = cbData.response.getStatus();