diff options
| author | Eric Milkie <milkie@10gen.com> | 2012-11-05 14:51:06 -0500 |
|---|---|---|
| committer | Eric Milkie <milkie@10gen.com> | 2012-11-06 16:22:22 -0500 |
| commit | 742094a0024f5e62cd4d1ab01d1f0e4008199a73 (patch) | |
| tree | b60b9a88429f1d9b1e61d35fc3df36143ec73fff | |
| parent | 6e3c5b7d4f3b964d2529f4fb4fa110b5f316d45f (diff) | |
| download | mongo-742094a0024f5e62cd4d1ab01d1f0e4008199a73.tar.gz | |
SERVER-7516 do not swallow socket errors during cloner copies
| -rw-r--r-- | src/mongo/client/dbclientcursor.cpp | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/src/mongo/client/dbclientcursor.cpp b/src/mongo/client/dbclientcursor.cpp index e7e67a23a60..d0469839ae5 100644 --- a/src/mongo/client/dbclientcursor.cpp +++ b/src/mongo/client/dbclientcursor.cpp @@ -157,10 +157,11 @@ namespace mongo { verify( !haveLimit ); auto_ptr<Message> response(new Message()); verify( _client ); - if ( _client->recv(*response) ) { - batch.m = response; - dataReceived(); + if (!_client->recv(*response)) { + uasserted(16465, "recv failed while exhausting cursor"); } + batch.m = response; + dataReceived(); } void DBClientCursor::dataReceived( bool& retry, string& host ) { |