diff options
author | Jason Carey <jcarey@argv.me> | 2018-03-21 00:15:35 -0400 |
---|---|---|
committer | Jason Carey <jcarey@argv.me> | 2018-04-27 19:49:28 -0400 |
commit | 4ddf18bcf4d517c3dc0f005f9222ffaab9a86ffa (patch) | |
tree | 438865c1065d0a96c427b1ed3a89e5163d85699a /src/mongo/unittest | |
parent | 91eaa878c4feeebd9397c49180631fc719238aaf (diff) | |
download | mongo-4ddf18bcf4d517c3dc0f005f9222ffaab9a86ffa.tar.gz |
SERVER-34739 Migrate to 1 connpool in ARS
Migrate to 1 connection pool in mongos.
This change involves the introduction of a transport layer baton, which
improves perf for a particular transport layer when doing local
scatter/gather operations.
Diffstat (limited to 'src/mongo/unittest')
-rw-r--r-- | src/mongo/unittest/task_executor_proxy.cpp | 6 | ||||
-rw-r--r-- | src/mongo/unittest/task_executor_proxy.h | 4 |
2 files changed, 7 insertions, 3 deletions
diff --git a/src/mongo/unittest/task_executor_proxy.cpp b/src/mongo/unittest/task_executor_proxy.cpp index 03a9c90246e..b58d75a394e 100644 --- a/src/mongo/unittest/task_executor_proxy.cpp +++ b/src/mongo/unittest/task_executor_proxy.cpp @@ -99,8 +99,10 @@ StatusWith<executor::TaskExecutor::CallbackHandle> TaskExecutorProxy::scheduleWo } StatusWith<executor::TaskExecutor::CallbackHandle> TaskExecutorProxy::scheduleRemoteCommand( - const executor::RemoteCommandRequest& request, const RemoteCommandCallbackFn& cb) { - return _executor->scheduleRemoteCommand(request, cb); + const executor::RemoteCommandRequest& request, + const RemoteCommandCallbackFn& cb, + const transport::BatonHandle& baton) { + return _executor->scheduleRemoteCommand(request, cb, baton); } void TaskExecutorProxy::cancel(const CallbackHandle& cbHandle) { diff --git a/src/mongo/unittest/task_executor_proxy.h b/src/mongo/unittest/task_executor_proxy.h index fdcbc9c71d4..3c2bb935692 100644 --- a/src/mongo/unittest/task_executor_proxy.h +++ b/src/mongo/unittest/task_executor_proxy.h @@ -66,7 +66,9 @@ public: virtual StatusWith<CallbackHandle> scheduleWork(const CallbackFn& work) override; virtual StatusWith<CallbackHandle> scheduleWorkAt(Date_t when, const CallbackFn& work) override; virtual StatusWith<CallbackHandle> scheduleRemoteCommand( - const executor::RemoteCommandRequest& request, const RemoteCommandCallbackFn& cb) override; + const executor::RemoteCommandRequest& request, + const RemoteCommandCallbackFn& cb, + const transport::BatonHandle& baton = nullptr) override; virtual void cancel(const CallbackHandle& cbHandle) override; virtual void wait(const CallbackHandle& cbHandle) override; virtual void appendConnectionStats(executor::ConnectionPoolStats* stats) const override; |