summaryrefslogtreecommitdiff
path: root/client/parallel.h
diff options
context:
space:
mode:
authorEliot Horowitz <eliot@10gen.com>2009-11-03 11:40:00 -0500
committerEliot Horowitz <eliot@10gen.com>2009-11-03 11:40:00 -0500
commit6d5e43755d739b526d5b56c7a6c457e8f019a74b (patch)
treecd929539e73fb9f46129ad9bd1c4a9fa016a41cd /client/parallel.h
parent3a1c9831c135fbef4bf02ac3458772196bd88038 (diff)
downloadmongo-6d5e43755d739b526d5b56c7a6c457e8f019a74b.tar.gz
sharded map-reduce basic test works SHARDING-37
Diffstat (limited to 'client/parallel.h')
-rw-r--r--client/parallel.h4
1 files changed, 4 insertions, 0 deletions
diff --git a/client/parallel.h b/client/parallel.h
index e7d39a89ba9..a2189c6c745 100644
--- a/client/parallel.h
+++ b/client/parallel.h
@@ -87,10 +87,14 @@ namespace mongo {
class ParallelSortClusteredCursor : public ClusteredCursor {
public:
ParallelSortClusteredCursor( set<ServerAndQuery> servers , QueryMessage& q , const BSONObj& sortKey );
+ ParallelSortClusteredCursor( set<ServerAndQuery> servers , const string& ns ,
+ const Query& q , int options=0, const BSONObj& fields=BSONObj() );
virtual ~ParallelSortClusteredCursor();
virtual bool more();
virtual BSONObj next();
private:
+ void _init();
+
void advance();
int _numServers;