summaryrefslogtreecommitdiff
path: root/src/mongo/executor/network_interface_asio.h
diff options
context:
space:
mode:
authorWaley Chen <waleycz@gmail.com>2016-03-30 17:36:37 -0400
committerWaley Chen <waleycz@gmail.com>2016-03-30 21:13:50 -0400
commitdfabadb09387a4236ee7675cd02d39b17affaf39 (patch)
treefca4ba78cd6bb9b96810f712b2b1abf64c55cfe2 /src/mongo/executor/network_interface_asio.h
parente45aba42f783cf2e2974b7ea6944a6c81b0a6be4 (diff)
downloadmongo-dfabadb09387a4236ee7675cd02d39b17affaf39.tar.gz
SERVER-21170 NetworkInterface::startCommand should be able to reject requests due to shutdown
Diffstat (limited to 'src/mongo/executor/network_interface_asio.h')
-rw-r--r--src/mongo/executor/network_interface_asio.h11
1 files changed, 5 insertions, 6 deletions
diff --git a/src/mongo/executor/network_interface_asio.h b/src/mongo/executor/network_interface_asio.h
index a38e778470a..62e441d7d92 100644
--- a/src/mongo/executor/network_interface_asio.h
+++ b/src/mongo/executor/network_interface_asio.h
@@ -130,21 +130,20 @@ public:
std::string getHostName() override;
void startup() override;
void shutdown() override;
+ bool inShutdown() const override;
void waitForWork() override;
void waitForWorkUntil(Date_t when) override;
void signalWorkAvailable() override;
Date_t now() override;
- void startCommand(const TaskExecutor::CallbackHandle& cbHandle,
- const RemoteCommandRequest& request,
- const RemoteCommandCompletionFn& onFinish) override;
+ Status startCommand(const TaskExecutor::CallbackHandle& cbHandle,
+ const RemoteCommandRequest& request,
+ const RemoteCommandCompletionFn& onFinish) override;
void cancelCommand(const TaskExecutor::CallbackHandle& cbHandle) override;
void cancelAllCommands() override;
- void setAlarm(Date_t when, const stdx::function<void()>& action) override;
+ Status setAlarm(Date_t when, const stdx::function<void()>& action) override;
bool onNetworkThread() override;
- bool inShutdown() const;
-
private:
using ResponseStatus = TaskExecutor::ResponseStatus;
using NetworkInterface::RemoteCommandCompletionFn;