diff options
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 ); }; |