CSHARP-2026: All writes retryable support.

Author: rstam

build.cake

@@ -73,6 +73,14 @@ Task("BuildNet45")
                 CopyFile(outputFile, artifactFile);
             }
         }
+
+        foreach (var dnsClientFileName in new[] { "DnsClient.dll", "DnsClient.xml"})
+        {
+            var sourceDirectory = srcDirectory.Combine("MongoDB.Driver.Core").Combine("bin").Combine("Release");
+            var sourceFile = sourceDirectory.CombineWithFilePath(dnsClientFileName);
+            var destinationFile = artifactsBinNet45Directory.CombineWithFilePath(dnsClientFileName);
+            CopyFile(sourceFile, destinationFile);
+        }
     })
     .Finally(() =>
     {

src/MongoDB.Bson/IO/BsonBinaryWriter.cs

@@ -92,7 +92,9 @@ public override long Position
             get { return _baseStream.Position; }
         }
 
-        /// <inheritdoc />
+        /// <summary>
+        /// Gets the settings of the writer.
+        /// </summary>
         public new BsonBinaryWriterSettings Settings
         {
             get {  return (BsonBinaryWriterSettings)base.Settings; }

src/MongoDB.Bson/IO/JsonWriter.cs

@@ -74,7 +74,9 @@ public TextWriter BaseTextWriter
         /// <inheritdoc />
         public override long Position => 0L;
 
-        /// <inheritdoc />
+        /// <summary>
+        /// Gets the settings of the writer.
+        /// </summary>
         public new JsonWriterSettings Settings
         {
             get { return (JsonWriterSettings)base.Settings; }

src/MongoDB.Driver.Core/ChangeStreamDocument.cs

@@ -21,6 +21,7 @@ namespace MongoDB.Driver
     /// <summary>
     /// An output document from a $changeStream pipeline stage.
     /// </summary>
+    /// <typeparam name="TDocument">The type of the document.</typeparam>
     public sealed class ChangeStreamDocument<TDocument>
     {
         // private fields

src/MongoDB.Driver.Core/Core/Bindings/ICoreSession.cs

@@ -77,6 +77,12 @@ public interface ICoreSession : IDisposable
         /// <param name="newOperationTime">The new operation time.</param>
         void AdvanceOperationTime(BsonTimestamp newOperationTime);
 
+        /// <summary>
+        /// Advances the transaction id.
+        /// </summary>
+        /// <returns>The transaction id.</returns>
+        long AdvanceTransactionNumber();
+
         /// <summary>
         /// Called by the driver when the session is used (i.e. sent to the server).
         /// </summary>

src/MongoDB.Driver.Core/Core/Bindings/NoCoreSession.cs

@@ -40,7 +40,7 @@ public sealed class NoCoreSession : ICoreSession
         /// <summary>
         /// Returns a new handle to a NoCoreSession object.
         /// </summary>
-        /// <returns></returns>
+        /// <returns>A new handle to the NoCoreSession object.</returns>
         public static ICoreSessionHandle NewHandle()
         {
             return new CoreSessionHandle(__instance);
@@ -73,6 +73,12 @@ public void AdvanceOperationTime(BsonTimestamp newOperationTime)
         {
         }
 
+        /// <inheritdoc />
+        public long AdvanceTransactionNumber()
+        {
+            return -1;
+        }
+
         /// <inheritdoc />
         public void Dispose()
         {

src/MongoDB.Driver.Core/Core/Bindings/WrappingCoreSession.cs

@@ -123,6 +123,12 @@ public virtual void AdvanceOperationTime(BsonTimestamp newOperationTime)
             _wrapped.AdvanceOperationTime(newOperationTime);
         }
 
+        /// <inheritdoc />
+        public long AdvanceTransactionNumber()
+        {
+            return _wrapped.AdvanceTransactionNumber();
+        }
+
         /// <inheritdoc />
         public void Dispose()
         {
@@ -138,7 +144,10 @@ public virtual void WasUsed()
         }
 
         // protected methods
-        /// <inheritdoc />
+        /// <summary>
+        /// Releases unmanaged and - optionally - managed resources.
+        /// </summary>
+        /// <param name="disposing"><c>true</c> to release both managed and unmanaged resources; <c>false</c> to release only unmanaged resources.</param>
         protected virtual void Dispose(bool disposing)
         {
             if (!_disposed)

src/MongoDB.Driver.Core/Core/Configuration/ConnectionString.cs

@@ -86,6 +86,7 @@ public sealed class ConnectionString
         private ReadPreferenceMode? _readPreference;
         private IReadOnlyList<TagSet> _readPreferenceTags;
         private string _replicaSet;
+        private bool? _retryWrites;
         private ConnectionStringScheme _scheme;
         private TimeSpan? _serverSelectionTimeout;
         private TimeSpan? _socketTimeout;
@@ -327,6 +328,14 @@ public IReadOnlyList<TagSet> ReadPreferenceTags
         }
 
         /// <summary>
+        /// Gets a value indicating whether or not to retry writes.
+        /// </summary>
+        public bool? RetryWrites
+        {
+            get { return _retryWrites; }
+        }
+
+       /// <summary>
         /// Gets the scheme.
         /// </summary>
         public ConnectionStringScheme Scheme
@@ -464,6 +473,7 @@ public ConnectionString Resolve()
         /// Resolves a connection string. If the connection string indicates more information is available
         /// in the DNS system, it will acquire that information as well.
         /// </summary>
+        /// <param name="cancellationToken">The cancellation token.</param>
         /// <returns>A resolved ConnectionString.</returns>
         public async Task<ConnectionString> ResolveAsync(CancellationToken cancellationToken = default(CancellationToken))
         {
@@ -764,6 +774,9 @@ private void ParseOption(string name, string value)
                 case "replicaset":
                     _replicaSet = value;
                     break;
+                case "retrywrites":
+                    _retryWrites = ParseBoolean(name, value);
+                    break;
                 case "safe":
                     var safe = ParseBoolean(name, value);
                     if (_w == null)

src/MongoDB.Driver.Core/Core/Connections/CommandEventHelper.cs

@@ -1,4 +1,4 @@
-/* Copyright 2015-2016 MongoDB Inc.
+/* Copyright 2015-2017 MongoDB Inc.
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
@@ -377,7 +377,7 @@ private void ProcessInsertMessage(RequestMessage message, Queue<RequestMessage>
                 // Plus, for this we really want BsonDocuments, not whatever the generic type is.
                 var decodedMessage = encoder.ReadMessage();
 
-                var documents = decodedMessage.DocumentSource.GetRemainingItems().ToList();
+                var documents = decodedMessage.DocumentSource.GetBatchItems();
                 numberOfDocuments = documents.Count;
                 try
                 {
@@ -409,7 +409,10 @@ private void ProcessInsertMessage(RequestMessage message, Queue<RequestMessage>
                 }
                 finally
                 {
-                    documents.ForEach(d => d.Dispose());
+                    foreach (var document in documents)
+                    {
+                        document.Dispose();
+                    }
                 }
             }