diff options
Diffstat (limited to 'db/db.cpp')
| -rw-r--r-- | db/db.cpp | 12 |
1 files changed, 9 insertions, 3 deletions
diff --git a/db/db.cpp b/db/db.cpp index 7fcbebd211a..7f7bc0c6ec1 100644 --- a/db/db.cpp +++ b/db/db.cpp @@ -193,7 +193,7 @@ namespace mongo { DbResponse dbresponse; if ( !assembleResponse( m, dbresponse, dbMsgPort->farEnd ) ) { - out() << curTimeMillis() % 10000 << " end msg " << dbMsgPort->farEnd.toString() << endl; + log() << curTimeMillis() % 10000 << " end msg " << dbMsgPort->farEnd.toString() << endl; /* todo: we may not wish to allow this, even on localhost: very low priv accounts could stop us. */ if ( dbMsgPort->farEnd.isLocalHost() ) { dbMsgPort->shutdown(); @@ -202,12 +202,18 @@ namespace mongo { dbexit(EXIT_CLEAN); } else { - out() << " (not from localhost, ignoring end msg)" << endl; + log() << " (not from localhost, ignoring end msg)" << endl; } } - if ( dbresponse.response ) + if ( dbresponse.response ) { dbMsgPort->reply(m, *dbresponse.response, dbresponse.responseTo); + if( dbresponse.exhaust ) { + while( 1 ) { + log() << "exhausting" << endl; + } + } + } } } |