fix lint

Author: LiamHamsters

src/Ydb.Sdk/src/Ado/PoolManager.cs

@@ -36,8 +36,17 @@ CancellationToken cancellationToken
 
             driver.RegisterOwner();
 
-            var factory = new PoolingSessionFactory(driver, settings);
-            var newSessionPool = new PoolingSessionSource<PoolingSession>(factory, settings);
+            ISessionSource newSessionPool;
+
+            if (settings.MaxSessionPool > 0)
+            {
+                var factory = new PoolingSessionFactory(driver, settings);
+                newSessionPool = new PoolingSessionSource<PoolingSession>(factory, settings);
+            }
+            else
+            {
+                newSessionPool = new ImplicitSessionSource(driver);
+            }
 
             Pools[settings.ConnectionString] = newSessionPool;
 

src/Ydb.Sdk/src/Ado/YdbDataSource.cs

@@ -391,6 +391,7 @@ public async ValueTask<YdbConnection> OpenRetryableConnectionAsync(CancellationT
         try
         {
             await ydbConnection.OpenAsync(_retryPolicyExecutor, cancellationToken);
+
             return ydbConnection;
         }
         catch
@@ -408,7 +409,8 @@ public async ValueTask<YdbConnection> OpenRetryableConnectionAsync(
         var ydbConnection = CreateDbConnection();
         try
         {
-            await ydbConnection.OpenAsync(_retryPolicyExecutor, cancellationToken);
+            await ydbConnection.OpenAsync(GetExecutor(ydbRetryPolicyConfig), cancellationToken);
+
             return ydbConnection;
         }
         catch
@@ -426,7 +428,8 @@ public async ValueTask<YdbConnection> OpenRetryableConnectionAsync(
         var ydbConnection = CreateDbConnection();
         try
         {
-            await ydbConnection.OpenAsync(_retryPolicyExecutor, cancellationToken);
+            await ydbConnection.OpenAsync(new YdbRetryPolicyExecutor(retryPolicy), cancellationToken);
+
             return ydbConnection;
         }
         catch

src/Ydb.Sdk/test/Ydb.Sdk.Ado.Tests/Session/YdbImplicitStressTests.cs

@@ -29,19 +29,17 @@ public async Task Dispose_WaitsForAllLeases_AndSignalsOnEmptyExactlyOnce()
 
         var source = new ImplicitSessionSource(driver);
 
-        using var cts = new CancellationTokenSource(TimeSpan.FromSeconds(10));
-
         var workers = Enumerable.Range(0, 200).Select(async _ =>
         {
             var rnd = Random.Shared;
             for (var j = 0; j < 10; j++)
             {
                 try
                 {
-                    var s = await source.OpenSession(cts.Token);
+                    var s = await source.OpenSession(CancellationToken.None);
                     opened.Inc();
 
-                    await Task.Delay(rnd.Next(0, 5), cts.Token);
+                    await Task.Delay(rnd.Next(0, 5));
 
                     s.Dispose();
                     closed.Inc();
@@ -54,9 +52,9 @@ public async Task Dispose_WaitsForAllLeases_AndSignalsOnEmptyExactlyOnce()
 
         var disposer = Task.Run(async () =>
         {
-            await Task.Delay(10, cts.Token);
+            await Task.Delay(10);
             await source.DisposeAsync();
-        }, cts.Token);
+        });
 
         await Task.WhenAll(workers.Append(disposer));
 
@@ -76,19 +74,17 @@ public async Task Stress_Counts_AreBalanced()
 
         var source = new ImplicitSessionSource(driver);
 
-        using var cts = new CancellationTokenSource(TimeSpan.FromSeconds(10));
-
         var workers = Enumerable.Range(0, 200).Select(async _ =>
         {
             var rnd = Random.Shared;
             for (var j = 0; j < 10; j++)
             {
                 try
                 {
-                    var s = await source.OpenSession(cts.Token);
+                    var s = await source.OpenSession(CancellationToken.None);
                     opened.Inc();
 
-                    await Task.Delay(rnd.Next(0, 3), cts.Token);
+                    await Task.Delay(rnd.Next(0, 3));
 
                     s.Dispose();
                     closed.Inc();
@@ -99,7 +95,7 @@ public async Task Stress_Counts_AreBalanced()
             }
         }).ToArray();
 
-        var disposer = Task.Run(async () => await source.DisposeAsync(), cts.Token);
+        var disposer = Task.Run(async () => await source.DisposeAsync());
 
         await Task.WhenAll(workers.Append(disposer));
 
@@ -116,13 +112,11 @@ public async Task Open_RacingWithDispose_StateRemainsConsistent()
 
         var source = new ImplicitSessionSource(driver);
 
-        using var cts = new CancellationTokenSource(TimeSpan.FromSeconds(10));
-
         var opens = Enumerable.Range(0, 1000).Select(async _ =>
         {
             try
             {
-                var s = await source.OpenSession(cts.Token);
+                var s = await source.OpenSession(CancellationToken.None);
                 s.Dispose();
                 return 1;
             }
@@ -136,7 +130,7 @@ public async Task Open_RacingWithDispose_StateRemainsConsistent()
         {
             await Task.Yield();
             await source.DisposeAsync();
-        }, cts.Token);
+        });
 
         await Task.WhenAll(opens.Append(disposeTask));