pr

Author: sanych-sun

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

@@ -317,7 +317,7 @@ void ICoreSessionInternal.CommitTransaction(CommitTransactionOptions options, Ca
 
                 try
                 {
-                    var firstAttempt = CreateCommitTransactionOperation(operationContext,IsFirstCommitAttemptRetry());
+                    var firstAttempt = CreateCommitTransactionOperation(operationContext, IsFirstCommitAttemptRetry());
                     ExecuteEndTransactionOnPrimary(operationContext, firstAttempt);
                     return;
                 }
@@ -327,7 +327,7 @@ void ICoreSessionInternal.CommitTransaction(CommitTransactionOptions options, Ca
                     TransactionHelper.UnpinServerIfNeededOnRetryableCommitException(_currentTransaction, exception);
                 }
 
-                var secondAttempt = CreateCommitTransactionOperation(operationContext,isCommitRetry: true);
+                var secondAttempt = CreateCommitTransactionOperation(operationContext, isCommitRetry: true);
                 ExecuteEndTransactionOnPrimary(operationContext, secondAttempt);
             }
             finally

src/MongoDB.Driver/Core/Compression/SnappyCompressor.cs

@@ -34,7 +34,7 @@ public void Compress(Stream input, Stream output)
         {
             var uncompressedSize = (int)(input.Length - input.Position);
             var uncompressedBytes = new byte[uncompressedSize]; // does not include uncompressed message headers
-            input.ReadBytes(OperationContext.NoTimeout, uncompressedBytes, offset: 0, count: uncompressedSize, Timeout.InfiniteTimeSpan);
+            input.ReadBytes(OperationContext.NoTimeout, uncompressedBytes, offset: 0, count: uncompressedSize, socketTimeout: Timeout.InfiniteTimeSpan);
             var maxCompressedSize = Snappy.GetMaxCompressedLength(uncompressedSize);
             var compressedBytes = new byte[maxCompressedSize];
             var compressedSize = Snappy.Compress(uncompressedBytes, compressedBytes);
@@ -50,7 +50,7 @@ public void Decompress(Stream input, Stream output)
         {
             var compressedSize = (int)(input.Length - input.Position);
             var compressedBytes = new byte[compressedSize];
-            input.ReadBytes(OperationContext.NoTimeout, compressedBytes, offset: 0, count: compressedSize, Timeout.InfiniteTimeSpan);
+            input.ReadBytes(OperationContext.NoTimeout, compressedBytes, offset: 0, count: compressedSize, socketTimeout: Timeout.InfiniteTimeSpan);
             var uncompressedSize = Snappy.GetUncompressedLength(compressedBytes);
             var decompressedBytes = new byte[uncompressedSize];
             var decompressedSize = Snappy.Decompress(compressedBytes, decompressedBytes);

tests/MongoDB.Driver.Tests/Specifications/UnifiedTestSpecRunner.cs

@@ -69,7 +69,7 @@ public void ClientSideOperationsTimeout(JsonDrivenTestCase testCase)
             SkipNotSupportedTestCases("timeoutMS applies to whole operation, not individual attempts"); // blocked by DRIVERS-3247
             SkipNotSupportedTestCases("WaitQueueTimeoutError does not clear the pool"); // TODO: CSOT: TimeoutMS is not implemented yet for runCommand
             SkipNotSupportedTestCases("write concern error MaxTimeMSExpired is transformed"); // TODO: CSOT: investigate error transformation, implementing the requirement might be breaking change
-            SkipNotSupportedTestCases("operation succeeds after one socket timeout - listDatabases on client"); // TODO: listDatabases is not retryable in CSharp Driver, NEED TICKET!!!
+            SkipNotSupportedTestCases("operation succeeds after one socket timeout - listDatabases on client"); // TODO: listDatabases is not retryable in CSharp Driver, CSHARP-5714
 
             Run(testCase);
 

tests/MongoDB.Driver.Tests/UnifiedTestOperations/UnifiedWithTransactionOperation.cs

@@ -122,7 +122,7 @@ public UnifiedWithTransactionOperation Build(string targetSessionId, BsonDocumen
                         maxCommitTime = TimeSpan.FromMilliseconds(argument.Value.AsInt32);
                         break;
                     case "readConcern":
-                        readConcern =ReadConcern.FromBsonDocument(argument.Value.AsBsonDocument);
+                        readConcern = ReadConcern.FromBsonDocument(argument.Value.AsBsonDocument);
                         break;
                     case "readPreference":
                         readPreference = ReadPreference.FromBsonDocument(argument.Value.AsBsonDocument);