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

SERVER-1790 WIP: use initLazy but still in separate thread

Browse Source
This commit is contained in:
Mathias Stearn
2011-05-31 16:30:15 -04:00
parent 51701b56b4
commit 8a2bdb812c
2 changed files with 11 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
client/parallel.cpp
View File

@@ -576,7 +576,16 @@ namespace mongo {
conn = myconn->get();
}
res->_ok = conn->runCommand( res->_db , res->_cmd , res->_res );
res->_cursor.reset( new DBClientCursor(conn, res->_db + ".$cmd", res->_cmd, -1/*limit*/, 0, NULL, 0, 0));
res->_cursor->initLazy();
//TODO: return here and resume later
bool finished = res->_cursor->initLazyFinish();
uassert(14812, str::stream() << "Error running command on server: " << res->_server, finished);
massert(14813, "Command returned nothing", res->_cursor->more());
res->_res = res->_cursor->nextSafe();
res->_ok = res->_res["ok"].trueValue();
if ( myconn )
myconn->done();