diff options
author | Suganthi Mani <suganthi.mani@mongodb.com> | 2020-11-13 00:28:52 -0500 |
---|---|---|
committer | Evergreen Agent <no-reply@evergreen.mongodb.com> | 2020-11-17 03:49:20 +0000 |
commit | 46c084101824ece9c6376c1b04f32511ac3c6ba4 (patch) | |
tree | 1d9dc50ca53c0d284b5c956e5271c51ee5032717 /src/mongo/unittest | |
parent | 7aa2cf8d9f28e7d45674c1917079e4be40268de1 (diff) | |
download | mongo-46c084101824ece9c6376c1b04f32511ac3c6ba4.tar.gz |
SERVER-52699 oplog fetcher should be able to handle task executor shutdown case while running query.
Diffstat (limited to 'src/mongo/unittest')
-rw-r--r-- | src/mongo/unittest/task_executor_proxy.cpp | 4 | ||||
-rw-r--r-- | src/mongo/unittest/task_executor_proxy.h | 1 |
2 files changed, 5 insertions, 0 deletions
diff --git a/src/mongo/unittest/task_executor_proxy.cpp b/src/mongo/unittest/task_executor_proxy.cpp index 823328acd1c..4c2804db3b8 100644 --- a/src/mongo/unittest/task_executor_proxy.cpp +++ b/src/mongo/unittest/task_executor_proxy.cpp @@ -62,6 +62,10 @@ SharedSemiFuture<void> TaskExecutorProxy::joinAsync() { return _executor.load()->joinAsync(); } +bool TaskExecutorProxy::isShuttingDown() const { + return _executor.load()->isShuttingDown(); +} + void TaskExecutorProxy::appendDiagnosticBSON(mongo::BSONObjBuilder* builder) const { _executor.load()->appendDiagnosticBSON(builder); } diff --git a/src/mongo/unittest/task_executor_proxy.h b/src/mongo/unittest/task_executor_proxy.h index 0e9f56bf892..05a2a11a2a3 100644 --- a/src/mongo/unittest/task_executor_proxy.h +++ b/src/mongo/unittest/task_executor_proxy.h @@ -55,6 +55,7 @@ public: void shutdown() override; void join() override; SharedSemiFuture<void> joinAsync() override; + bool isShuttingDown() const override; void appendDiagnosticBSON(BSONObjBuilder* builder) const override; Date_t now() override; StatusWith<EventHandle> makeEvent() override; |