diff options
author | Spencer T Brody <spencer@mongodb.com> | 2018-09-26 15:00:10 -0400 |
---|---|---|
committer | Spencer T Brody <spencer@mongodb.com> | 2018-09-28 13:14:15 -0400 |
commit | 56aa77807e5ff288635b69c40bf4d201e715051d (patch) | |
tree | 4daa30697715b7c6f1c1c7cfb3e4ad084f36d202 /src/mongo/s/sharding_task_executor.h | |
parent | a73b2fc77d72a06380826259620f105e179a4c5c (diff) | |
download | mongo-56aa77807e5ff288635b69c40bf4d201e715051d.tar.gz |
SERVER-37329 Make ShardRemote interruptable while waiting for a response
Diffstat (limited to 'src/mongo/s/sharding_task_executor.h')
-rw-r--r-- | src/mongo/s/sharding_task_executor.h | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/src/mongo/s/sharding_task_executor.h b/src/mongo/s/sharding_task_executor.h index 92a78169549..25cb48cc4e6 100644 --- a/src/mongo/s/sharding_task_executor.h +++ b/src/mongo/s/sharding_task_executor.h @@ -72,7 +72,8 @@ public: const RemoteCommandCallbackFn& cb, const transport::BatonHandle& baton = nullptr) override; void cancel(const CallbackHandle& cbHandle) override; - void wait(const CallbackHandle& cbHandle) override; + void wait(const CallbackHandle& cbHandle, + Interruptible* interruptible = Interruptible::notInterruptible()) override; void appendConnectionStats(ConnectionPoolStats* stats) const override; |