diff options
author | Gregory Wlodarek <gregory.wlodarek@mongodb.com> | 2019-06-06 11:59:04 -0400 |
---|---|---|
committer | Gregory Wlodarek <gregory.wlodarek@mongodb.com> | 2019-06-06 11:59:04 -0400 |
commit | 5cca4f2842fc4146604768ed8c95a20aaa955b9d (patch) | |
tree | 19fb4e34b39c9ef6f406cbd10b7af312862404ff /src/mongo/s/async_requests_sender.h | |
parent | 65daaae2ffa01cbb741db69922b5f7cd4ed7836b (diff) | |
download | mongo-5cca4f2842fc4146604768ed8c95a20aaa955b9d.tar.gz |
Revert "SERVER-41132 Opportunistic targeting for ARS"
This reverts commit f3d9452220039ba74c68fe58b382a237d4e07ad1.
Diffstat (limited to 'src/mongo/s/async_requests_sender.h')
-rw-r--r-- | src/mongo/s/async_requests_sender.h | 20 |
1 files changed, 7 insertions, 13 deletions
diff --git a/src/mongo/s/async_requests_sender.h b/src/mongo/s/async_requests_sender.h index 3fc8a50fe8f..86387d01bbe 100644 --- a/src/mongo/s/async_requests_sender.h +++ b/src/mongo/s/async_requests_sender.h @@ -168,9 +168,6 @@ private: */ class RemoteData { public: - using RemoteCommandOnAnyCallbackArgs = - executor::TaskExecutor::RemoteCommandOnAnyCallbackArgs; - /** * Creates a new uninitialized remote state with a command to send. */ @@ -213,25 +210,24 @@ private: * * for the given shard. */ - SemiFuture<RemoteCommandOnAnyCallbackArgs> scheduleRequest(); + SemiFuture<executor::RemoteCommandResponse> scheduleRequest(); /** - * Given a read preference, selects a lists of hosts on which the command can run. + * Given a read preference, selects a host on which the command should be run. */ - SemiFuture<std::vector<HostAndPort>> resolveShardIdToHostAndPorts( - const ReadPreferenceSetting& readPref); + SemiFuture<HostAndPort> resolveShardIdToHostAndPort(const ReadPreferenceSetting& readPref); /** * Schedules the remote command on the ARS's TaskExecutor */ - SemiFuture<RemoteCommandOnAnyCallbackArgs> scheduleRemoteCommand( - std::vector<HostAndPort>&& hostAndPort); + SemiFuture<executor::RemoteCommandResponse> scheduleRemoteCommand( + HostAndPort&& hostAndPort); /** * Handles the remote response */ - SemiFuture<RemoteCommandOnAnyCallbackArgs> handleResponse( - RemoteCommandOnAnyCallbackArgs&& rcr); + SemiFuture<executor::RemoteCommandResponse> handleResponse( + executor::RemoteCommandResponse&& rcr); private: bool _done = false; @@ -248,8 +244,6 @@ private: // sent. boost::optional<HostAndPort> _shardHostAndPort; - std::vector<HostAndPort> _eligibleHosts; - // The number of times we've retried sending the command to this remote. int _retryCount = 0; }; |