Check result object of command for stale config in ParallelSortClusteredCursor. SERVER-6684 SERVER-6685

1 files changed, 11 insertions, 0 deletions

diff --git a/src/mongo/client/parallel.cpp b/src/mongo/client/parallel.cpp
index b6b9bc1981b..a2badf085c0 100644
--- a/src/mongo/client/parallel.cpp
+++ b/src/mongo/client/parallel.cpp
@@ -96,6 +96,17 @@ namespace mongo {
             BSONObj o = cursor->next();
             throw UserException( o["code"].numberInt() , o["$err"].String() );
         }
+
+        BSONObj res = cursor->peekFirst();
+        // For backwards compatibility with v2.0 mongods because in 2.0 commands that care about
+        // versioning (like the count command) will return with the stale config error code, but
+        // don't set the ShardConfigStale result flag on the cursor.
+        // NOTE: This could potentially cause problems if the user's document has a "code" field.
+        // TODO: This should probably be removed for 2.3, as we'll no longer need to support running
+        // with a 2.0 mongod.
+        if ( res.hasField( "code" ) && res["code"].Number() == SendStaleConfigCode ) {
+            throw RecvStaleConfigException( "ClusteredCursor::_checkCursor", res );
+        }
     }
 
     auto_ptr<DBClientCursor> ClusteredCursor::query( const string& server , int num , BSONObj extra , int skipLeft , bool lazy ) {