diff options
| author | Randolph Tan <randolph@10gen.com> | 2014-04-02 11:02:08 -0400 |
|---|---|---|
| committer | Randolph Tan <randolph@10gen.com> | 2014-04-08 14:27:01 -0400 |
| commit | f35da2d63ff53c494e02ac727399763081f1fcfd (patch) | |
| tree | f31d589b2b5030cc90e1cb5561ed278414fbf1db /src/mongo/client/parallel.h | |
| parent | b4a2cc96b18cacdfece81215d9d8c7a3a84ba20a (diff) | |
| download | mongo-f35da2d63ff53c494e02ac727399763081f1fcfd.tar.gz | |
SERVER-13437 Cannot wait for write concern for createIndexes command on mongos
Diffstat (limited to 'src/mongo/client/parallel.h')
| -rw-r--r-- | src/mongo/client/parallel.h | 18 |
1 files changed, 15 insertions, 3 deletions
diff --git a/src/mongo/client/parallel.h b/src/mongo/client/parallel.h index df1e1577980..b75ef115dc9 100644 --- a/src/mongo/client/parallel.h +++ b/src/mongo/client/parallel.h @@ -326,7 +326,12 @@ namespace mongo { private: - CommandResult( const string& server , const string& db , const BSONObj& cmd , int options , DBClientBase * conn ); + CommandResult( const string& server, + const string& db, + const BSONObj& cmd, + int options, + DBClientBase * conn, + bool useShardedConn ); void init(); string _server; @@ -334,7 +339,8 @@ namespace mongo { int _options; BSONObj _cmd; DBClientBase * _conn; - scoped_ptr<ScopedDbConnection> _connHolder; // used if not provided a connection + scoped_ptr<AScopedConnection> _connHolder; // used if not provided a connection + bool _useShardConn; scoped_ptr<DBClientCursor> _cursor; @@ -351,8 +357,14 @@ namespace mongo { * @param db db name * @param cmd cmd to exec * @param conn optional connection to use. will use standard pooled if non-specified + * @param useShardConn use ShardConnection */ - static shared_ptr<CommandResult> spawnCommand( const string& server , const string& db , const BSONObj& cmd , int options , DBClientBase * conn = 0 ); + static shared_ptr<CommandResult> spawnCommand( const string& server, + const string& db, + const BSONObj& cmd, + int options, + DBClientBase * conn = 0, + bool useShardConn = false ); }; |