Reduce flakiness in CSOT tests using withTransaction, by forcing an immediate retry without backoff.

Author: nhachicha

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

@@ -47,14 +47,11 @@
 import com.mongodb.event.ConnectionClosedEvent;
 import com.mongodb.event.ConnectionCreatedEvent;
 import com.mongodb.event.ConnectionReadyEvent;
-
-import static com.mongodb.internal.connection.CommandHelper.HELLO;
-import static com.mongodb.internal.connection.CommandHelper.LEGACY_HELLO;
-
 import com.mongodb.internal.connection.InternalStreamConnection;
 import com.mongodb.internal.connection.ServerHelper;
 import com.mongodb.internal.connection.TestCommandListener;
 import com.mongodb.internal.connection.TestConnectionPoolListener;
+import com.mongodb.internal.time.ExponentialBackoff;
 import com.mongodb.test.FlakyTest;
 import org.bson.BsonDocument;
 import org.bson.BsonInt32;
@@ -90,6 +87,8 @@
 import static com.mongodb.ClusterFixture.sleep;
 import static com.mongodb.client.Fixture.getDefaultDatabaseName;
 import static com.mongodb.client.Fixture.getPrimary;
+import static com.mongodb.internal.connection.CommandHelper.HELLO;
+import static com.mongodb.internal.connection.CommandHelper.LEGACY_HELLO;
 import static java.lang.Long.MAX_VALUE;
 import static java.lang.String.join;
 import static java.util.Arrays.asList;
@@ -1121,6 +1120,11 @@ public void setUp() {
         filesCollectionHelper = new CollectionHelper<>(new BsonDocumentCodec(), gridFsFileNamespace);
         chunksCollectionHelper = new CollectionHelper<>(new BsonDocumentCodec(), gridFsChunksNamespace);
         commandListener = new TestCommandListener();
+
+        // setting jitter to 0 to make test using withTransaction deterministic (i.e retries immediately) otherwise we might get
+        // MongoCommandException setup in the failpoint instead of MongoOperationTimeoutException depending on the random jitter value.
+        ExponentialBackoff.setTestJitterSupplier(() -> 1.0);
+
     }
 
     @AfterEach
@@ -1146,6 +1150,8 @@ public void tearDown() throws InterruptedException {
             //noinspection ResultOfMethodCallIgnored
             executor.awaitTermination(MAX_VALUE, NANOSECONDS);
         }
+
+        ExponentialBackoff.clearTestJitterSupplier();
     }
 
     @AfterAll