xuemingqiang/mongo
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

towards QueryOption_Exhaust

Browse Source
This commit is contained in:
dwight
2010-06-06 15:46:55 -04:00
parent a3e03d7fe8
commit 3f8da3805a
11 changed files with 97 additions and 50 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
db/instance.cpp
View File

@@ -490,24 +490,28 @@ namespace mongo {
int ntoreturn = d.pullInt();
long long cursorid = d.pullInt64();
ss << ns << " cid:" << cursorid << " ntoreturn:" << ntoreturn;;
ss << ns << " cid:" << cursorid;
if( ntoreturn )
ss << " ntoreturn:" << ntoreturn;
int pass = 0;
int pass = 0;
bool exhaust = false;
QueryResult* msgdata;
while( 1 ) {
try {
mongolock lk(false);
Client::Context ctx(ns);
msgdata = processGetMore(ns, ntoreturn, cursorid, curop, pass );
msgdata = processGetMore(ns, ntoreturn, cursorid, curop, pass, exhaust);
}
catch ( GetMoreWaitException& ) {
exhaust = false;
massert(13073, "shutting down", !inShutdown() );
pass++;
sleepmillis(2);
continue;
}
catch ( AssertionException& e ) {
exhaust = false;
ss << " exception " << e.toString();
msgdata = emptyMoreResult(cursorid);
ok = false;
@@ -521,7 +525,8 @@ namespace mongo {
ss << " nreturned:" << msgdata->nReturned;
dbresponse.response = resp;
dbresponse.responseTo = m.header()->id;
if( exhaust ) { ss << " exhaust ";
dbresponse.exhaust = ns;}
return ok;
}