CSHARP-1531: Force GetMores to use a new connection every time.

Author: rstam

src/MongoDB.Driver.Core/Core/Operations/AggregateOperation.cs

@@ -258,8 +258,9 @@ private AsyncCursor<TResult> CreateCursor(IChannelSourceHandle channelSource, IC
 
         private AsyncCursor<TResult> CreateCursorFromCursorResult(IChannelSourceHandle channelSource, BsonDocument command, AggregateResult result)
         {
+            var getMoreChannelSource = new ServerChannelSource(channelSource.Server);
             return new AsyncCursor<TResult>(
-                channelSource.Fork(),
+                getMoreChannelSource,
                 CollectionNamespace,
                 command,
                 result.Results,

src/MongoDB.Driver.Core/Core/Operations/FindCommandOperation.cs

@@ -440,8 +440,9 @@ private BsonDocument CreateCommand(ServerDescription serverDescription, ReadPref
 
         private AsyncCursor<TDocument> CreateCursor(IChannelSourceHandle channelSource, CursorBatch<TDocument> batch, bool slaveOk)
         {
+            var getMoreChannelSource = new ServerChannelSource(channelSource.Server);
             return new AsyncCursor<TDocument>(
-                channelSource.Fork(),
+                getMoreChannelSource,
                 _collectionNamespace,
                 _filter ?? new BsonDocument(),
                 batch.Documents,

src/MongoDB.Driver.Core/Core/Operations/FindOpcodeOperation.cs

@@ -523,8 +523,9 @@ public IReadOperation<BsonDocument> ToExplainOperation(ExplainVerbosity verbosit
         // private methods
         private IAsyncCursor<TDocument> CreateCursor(IChannelSourceHandle channelSource, BsonDocument query, CursorBatch<TDocument> batch)
         {
+            var getMoreChannelSource = new ServerChannelSource(channelSource.Server);
             return new AsyncCursor<TDocument>(
-                channelSource.Fork(),
+                getMoreChannelSource,
                 _collectionNamespace,
                 query,
                 batch.Documents,

src/MongoDB.Driver.Core/Core/Operations/ListCollectionsUsingCommandOperation.cs

@@ -128,9 +128,10 @@ private ReadCommandOperation<BsonDocument> CreateOperation()
 
         private IAsyncCursor<BsonDocument> CreateCursor(IChannelSourceHandle channelSource, BsonDocument command, BsonDocument result)
         {
+            var getMoreChannelSource = new ServerChannelSource(channelSource.Server);
             var cursorDocument = result["cursor"].AsBsonDocument;
             var cursor = new AsyncCursor<BsonDocument>(
-                channelSource.Fork(),
+                getMoreChannelSource,
                 CollectionNamespace.FromFullName(cursorDocument["ns"].AsString),
                 command,
                 cursorDocument["firstBatch"].AsBsonArray.OfType<BsonDocument>().ToList(),

src/MongoDB.Driver.Core/Core/Operations/ListIndexesUsingCommandOperation.cs

@@ -134,9 +134,10 @@ private ReadCommandOperation<BsonDocument> CreateOperation()
 
         private IAsyncCursor<BsonDocument> CreateCursor(IChannelSourceHandle channelSource, BsonDocument result, BsonDocument command)
         {
+            var getMoreChannelSource = new ServerChannelSource(channelSource.Server);
             var cursorDocument = result["cursor"].AsBsonDocument;
             var cursor = new AsyncCursor<BsonDocument>(
-                channelSource.Fork(),
+                getMoreChannelSource,
                 CollectionNamespace.FromFullName(cursorDocument["ns"].AsString),
                 command,
                 cursorDocument["firstBatch"].AsBsonArray.OfType<BsonDocument>().ToList(),

src/MongoDB.Driver.Core/Core/Operations/ParallelScanOperation.cs

@@ -155,33 +155,36 @@ private IReadOnlyList<IAsyncCursor<TDocument>> CreateCursors(IChannelSourceHandl
         {
             var cursors = new List<AsyncCursor<TDocument>>();
 
-            foreach (var cursorDocument in result["cursors"].AsBsonArray.Select(v => v["cursor"].AsBsonDocument))
+            using (var getMoreChannelSource = new ChannelSourceHandle(new ServerChannelSource(channelSource.Server)))
             {
-                var cursorId = cursorDocument["id"].ToInt64();
-                var firstBatch = cursorDocument["firstBatch"].AsBsonArray.Select(v =>
+                foreach (var cursorDocument in result["cursors"].AsBsonArray.Select(v => v["cursor"].AsBsonDocument))
                 {
-                    var bsonDocument = (BsonDocument)v;
-                    using (var reader = new BsonDocumentReader(bsonDocument))
+                    var cursorId = cursorDocument["id"].ToInt64();
+                    var firstBatch = cursorDocument["firstBatch"].AsBsonArray.Select(v =>
                     {
-                        var context = BsonDeserializationContext.CreateRoot(reader);
-                        var document = _serializer.Deserialize(context);
-                        return document;
-                    }
-                })
-                    .ToList();
-
-                var cursor = new AsyncCursor<TDocument>(
-                    channelSource.Fork(),
-                    _collectionNamespace,
-                    command,
-                    firstBatch,
-                    cursorId,
-                    _batchSize ?? 0,
-                    0, // limit
-                    _serializer,
-                    _messageEncoderSettings);
-
-                cursors.Add(cursor);
+                        var bsonDocument = (BsonDocument)v;
+                        using (var reader = new BsonDocumentReader(bsonDocument))
+                        {
+                            var context = BsonDeserializationContext.CreateRoot(reader);
+                            var document = _serializer.Deserialize(context);
+                            return document;
+                        }
+                    })
+                        .ToList();
+
+                    var cursor = new AsyncCursor<TDocument>(
+                        getMoreChannelSource.Fork(),
+                        _collectionNamespace,
+                        command,
+                        firstBatch,
+                        cursorId,
+                        _batchSize ?? 0,
+                        0, // limit
+                        _serializer,
+                        _messageEncoderSettings);
+
+                    cursors.Add(cursor);
+                }
             }
 
             return cursors;