summaryrefslogtreecommitdiff
path: root/src/mongo/s/sharding_task_executor.h
diff options
context:
space:
mode:
authorSpencer T Brody <spencer@mongodb.com>2018-09-26 15:00:10 -0400
committerSpencer T Brody <spencer@mongodb.com>2018-09-28 13:14:15 -0400
commit56aa77807e5ff288635b69c40bf4d201e715051d (patch)
tree4daa30697715b7c6f1c1c7cfb3e4ad084f36d202 /src/mongo/s/sharding_task_executor.h
parenta73b2fc77d72a06380826259620f105e179a4c5c (diff)
downloadmongo-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.h3
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;