CSHARP-5608: CSOT: Command Execution

Author: Oleksandr Poliakov

src/MongoDB.Driver/Core/Clusters/Cluster.cs

@@ -22,9 +22,9 @@ namespace MongoDB.Driver.Core.Clusters.ServerSelectors
 {
     internal sealed class OperationsCountServerSelector : IServerSelector
     {
-        private readonly IEnumerable<IClusterableServer> _clusterableServers;
+        private readonly IReadOnlyList<IClusterableServer> _clusterableServers;
 
-        public OperationsCountServerSelector(IEnumerable<IClusterableServer> clusterableServers)
+        public OperationsCountServerSelector(IReadOnlyList<IClusterableServer> clusterableServers)
         {
             _clusterableServers = clusterableServers;
         }

src/MongoDB.Driver/Core/Clusters/ServerSelectors/OperationsCountServerSelector.cs

@@ -289,7 +289,7 @@ private IServerSelector CreateWritableServerAndEndPointSelector(EndPoint endPoin
         private void ForceClusterId(MultiServerCluster cluster, ClusterId clusterId)
         {
             Reflector.SetFieldValue(cluster, "_clusterId", clusterId);
-            Reflector.SetFieldValue(cluster, "_descriptionWithChangedTaskCompletionSource", new Cluster.ClusterDescriptionChangeSource(ClusterDescription.CreateInitial(clusterId, __directConnection)));
+            Reflector.SetFieldValue(cluster, "_descriptionWithChangedTaskCompletionSource", new Cluster.ClusterDescriptionChangeSource(cluster, ClusterDescription.CreateInitial(clusterId, __directConnection)));
         }
 
         private void SetupServerMonitorConnection(

src/MongoDB.Driver/Core/Clusters/ServerSelectors/RandomServerSelector.cs

@@ -270,7 +270,7 @@ private IServerSelector CreateWritableServerAndEndPointSelector(EndPoint endPoin
         private void ForceClusterId(MultiServerCluster cluster, ClusterId clusterId)
         {
             Reflector.SetFieldValue(cluster, "_clusterId", clusterId);
-            Reflector.SetFieldValue(cluster, "_descriptionWithChangedTaskCompletionSource", new Cluster.ClusterDescriptionChangeSource(ClusterDescription.CreateInitial(clusterId, __directConnection)));
+            Reflector.SetFieldValue(cluster, "_descriptionWithChangedTaskCompletionSource", new Cluster.ClusterDescriptionChangeSource(cluster, ClusterDescription.CreateInitial(clusterId, __directConnection)));
         }
 
         private void SetupServerMonitorConnection(

tests/MongoDB.Driver.Tests/Core/Clusters/ServerSelectors/RandomServerSelectorTests.cs

@@ -94,7 +94,7 @@ private static IEnumerable<object[]> EventsData()
                 (new LogCategories.Command(), new CommandStartedEvent("test", new Bson.BsonDocument(), new DatabaseNamespace("test"), 1, 1, connectionId)),
                 (new LogCategories.Connection(), new ConnectionCreatedEvent(connectionId, null, 1)),
                 (new LogCategories.SDAM(), new ServerHeartbeatStartedEvent(connectionId, true)),
-                (new LogCategories.ServerSelection(), new ClusterSelectingServerEvent(clusterDescription, new RandomServerSelector(), default, default))
+                (new LogCategories.ServerSelection(), new ClusterSelectingServerEvent(clusterDescription, Mock.Of<IServerSelector>(), default, default))
             };
 
             var booleanValues = new[] { true, false };