diff options
| author | Amirsaman Memaripour <amirsaman.memaripour@mongodb.com> | 2020-11-02 17:38:29 +0000 |
|---|---|---|
| committer | Evergreen Agent <no-reply@evergreen.mongodb.com> | 2020-11-24 18:37:06 +0000 |
| commit | 40c3bac93c2091cea665de686cae93ef90429775 (patch) | |
| tree | ce51224ab1bce9a17d9b62d095d03c0bb16de9fa /src/mongo/s/commands/strategy.h | |
| parent | 5e82f974f44a822753ad0656692a1011a6611b3c (diff) | |
| download | mongo-40c3bac93c2091cea665de686cae93ef90429775.tar.gz | |
SERVER-51690 Add support for async command execution to Mongos
Diffstat (limited to 'src/mongo/s/commands/strategy.h')
| -rw-r--r-- | src/mongo/s/commands/strategy.h | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/src/mongo/s/commands/strategy.h b/src/mongo/s/commands/strategy.h index 3807a63a7f6..95f3f8c9449 100644 --- a/src/mongo/s/commands/strategy.h +++ b/src/mongo/s/commands/strategy.h @@ -33,6 +33,7 @@ #include "mongo/client/connection_string.h" #include "mongo/db/query/explain_options.h" +#include "mongo/db/request_execution_context.h" #include "mongo/s/client/shard.h" namespace mongo { @@ -74,7 +75,7 @@ public: * with the result from the operation. Doesn't send any response back and does not throw on * errors. */ - static void writeOp(OperationContext* opCtx, DbMessage* dbm); + static void writeOp(std::shared_ptr<RequestExecutionContext> rec); /** * Executes a command from either OP_QUERY or OP_MSG wire protocols. @@ -82,7 +83,7 @@ public: * Catches StaleConfigException errors and retries the command automatically after refreshing * the metadata for the failing namespace. */ - static DbResponse clientCommand(OperationContext* opCtx, const Message& message); + static Future<DbResponse> clientCommand(std::shared_ptr<RequestExecutionContext> rec); /** * Helper to run an explain of a find operation on the shards. Fills 'out' with the result of |