summaryrefslogtreecommitdiff
path: root/src/mongo/executor/network_interface_asio.h
diff options
context:
space:
mode:
authorWaley Chen <waleycz@gmail.com>2016-04-04 11:18:16 -0400
committerWaley Chen <waleycz@gmail.com>2016-04-04 11:18:39 -0400
commit6ee50d2d7a762d5dc9b8767e796df97e90f6d0ba (patch)
treef5a988db9f2dac5fa38bd961fd635a8e04c8434d /src/mongo/executor/network_interface_asio.h
parentae3ee1ceddc8af4a123090f6819d082058f3ea94 (diff)
downloadmongo-6ee50d2d7a762d5dc9b8767e796df97e90f6d0ba.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;