summaryrefslogtreecommitdiff
path: root/src/mongo/s/async_requests_sender.h
diff options
context:
space:
mode:
authorGregory Wlodarek <gregory.wlodarek@mongodb.com>2019-06-06 11:59:04 -0400
committerGregory Wlodarek <gregory.wlodarek@mongodb.com>2019-06-06 11:59:04 -0400
commit5cca4f2842fc4146604768ed8c95a20aaa955b9d (patch)
tree19fb4e34b39c9ef6f406cbd10b7af312862404ff /src/mongo/s/async_requests_sender.h
parent65daaae2ffa01cbb741db69922b5f7cd4ed7836b (diff)
downloadmongo-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.h20
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;
};