Allow use of Netty in unified test runner

Skip SDAM integration tests in async TLS unless using Netty

Author: jyemin

driver-core/src/test/functional/com/mongodb/ClusterFixture.java

@@ -28,8 +28,10 @@
 import com.mongodb.connection.SocketStreamFactory;
 import com.mongodb.connection.SslSettings;
 import com.mongodb.connection.StreamFactory;
+import com.mongodb.connection.StreamFactoryFactory;
 import com.mongodb.connection.TlsChannelStreamFactoryFactory;
 import com.mongodb.connection.netty.NettyStreamFactory;
+import com.mongodb.connection.netty.NettyStreamFactoryFactory;
 import com.mongodb.internal.async.AsyncBatchCursor;
 import com.mongodb.internal.async.SingleResultCallback;
 import com.mongodb.internal.binding.AsyncClusterBinding;
@@ -106,6 +108,8 @@ public final class ClusterFixture {
 
     private static ServerVersion serverVersion;
 
+    private static NettyStreamFactoryFactory nettyStreamFactoryFactory;
+
     static {
         Runtime.getRuntime().addShutdownHook(new ShutdownHook());
     }

driver-reactive-streams/src/test/functional/com/mongodb/reactivestreams/client/MainTransactionsTest.java

@@ -16,9 +16,11 @@
 
 package com.mongodb.reactivestreams.client;
 
+import com.mongodb.ClusterFixture;
 import com.mongodb.MongoClientSettings;
 import com.mongodb.client.AbstractMainTransactionsTest;
 import com.mongodb.client.MongoClient;
+import com.mongodb.connection.StreamFactoryFactory;
 import com.mongodb.reactivestreams.client.syncadapter.SyncMongoClient;
 import org.bson.BsonArray;
 import org.bson.BsonDocument;
@@ -33,4 +35,9 @@ public MainTransactionsTest(final String filename, final String description, fin
     protected MongoClient createMongoClient(final MongoClientSettings settings) {
         return new SyncMongoClient(MongoClients.create(settings));
     }
+
+    @Override
+    protected StreamFactoryFactory getStreamFactoryFactory() {
+        return ClusterFixture.getOverriddenStreamFactoryFactory();
+    }
 }

driver-reactive-streams/src/test/functional/com/mongodb/reactivestreams/client/ServerDiscoveryAndMonitoringTest.java

@@ -19,10 +19,13 @@
 import com.mongodb.MongoClientSettings;
 import com.mongodb.client.AbstractServerDiscoveryAndMonitoringTest;
 import com.mongodb.client.MongoClient;
+import com.mongodb.connection.StreamFactoryFactory;
 import com.mongodb.reactivestreams.client.syncadapter.SyncMongoClient;
 import org.bson.BsonArray;
 import org.bson.BsonDocument;
 
+import static com.mongodb.ClusterFixture.getOverriddenStreamFactoryFactory;
+
 public class ServerDiscoveryAndMonitoringTest extends AbstractServerDiscoveryAndMonitoringTest {
     public ServerDiscoveryAndMonitoringTest(final String filename, final String description, final String databaseName,
                                             final String collectionName, final BsonArray data, final BsonDocument definition,
@@ -34,4 +37,9 @@ public ServerDiscoveryAndMonitoringTest(final String filename, final String desc
     protected MongoClient createMongoClient(final MongoClientSettings settings) {
         return new SyncMongoClient(MongoClients.create(settings));
     }
+
+    @Override
+    protected StreamFactoryFactory getStreamFactoryFactory() {
+        return getOverriddenStreamFactoryFactory();
+    }
 }

driver-sync/src/test/functional/com/mongodb/client/AbstractUnifiedTest.java

@@ -38,6 +38,7 @@
 import com.mongodb.connection.ServerSettings;
 import com.mongodb.connection.ServerType;
 import com.mongodb.connection.SocketSettings;
+import com.mongodb.connection.StreamFactoryFactory;
 import com.mongodb.event.CommandEvent;
 import com.mongodb.event.CommandStartedEvent;
 import com.mongodb.event.ConnectionPoolClearedEvent;
@@ -131,6 +132,11 @@ public AbstractUnifiedTest(final String filename, final String description, fina
 
     protected abstract MongoClient createMongoClient(MongoClientSettings settings);
 
+    @Nullable
+    protected StreamFactoryFactory getStreamFactoryFactory() {
+        return null;
+    }
+
     @Before
     public void setUp() {
         assumeFalse(skipTest);
@@ -201,7 +207,7 @@ public void apply(final ConnectionPoolSettings.Builder builder) {
                 .applyToServerSettings(new Block<ServerSettings.Builder>() {
                     @Override
                     public void apply(final ServerSettings.Builder builder) {
-//                        builder.heartbeatFrequency(5, MILLISECONDS);
+                        builder.heartbeatFrequency(50, MILLISECONDS);
                         builder.minHeartbeatFrequency(MIN_HEARTBEAT_FREQUENCY_MS, MILLISECONDS);
                         builder.addServerListener(serverListener);
                     }
@@ -224,6 +230,10 @@ public void apply(final ServerSettings.Builder builder) {
                 builder.writeConcern(new WriteConcern(clientOptions.getNumber("w").intValue()));
             }
         }
+        StreamFactoryFactory streamFactoryFactory = getStreamFactoryFactory();
+        if (streamFactoryFactory != null) {
+            builder.streamFactoryFactory(streamFactoryFactory);
+        }
         mongoClient = createMongoClient(builder.build());
 
         database = mongoClient.getDatabase(databaseName);