Update CHANGELOG.md

Author: KirillKurdyukov

src/Ydb.Sdk/CHANGELOG.md

@@ -1,6 +1,7 @@
+- Feat ADO.NET: Mark `YdbConnection.State` as `Broken` when the underlying session is broken, including background deactivation.
 - Feat ADO.NET: Added  YdbDataSource `ExecuteAsync` and `ExecuteInTransaction` convenience methods.
 - **Breaking Change**: moved and renamed `Ydb.Sdk.Services.Query.TxMode` -> `Ydb.Sdk.Ado.TransactionMode`.
-- Feat ADO.NET: cache gRPC transport by `gRPCConnectionString` to reuse channels.
+- Feat ADO.NET: Cache gRPC transport by `gRPCConnectionString` to reuse channels.
 - Fix bug wrap-around ADO.NET: Big parameterized Decimal — `((ulong)bits[1] << 32)` -> `((ulong)(uint)bits[1] << 32)`.
 - Feat ADO.NET: Parameterized Decimal overflow check: `Precision` and `Scale`.
 - Feat ADO.NET: Deleted support for `DateTimeOffset` was a mistake.

src/Ydb.Sdk/src/Ado/YdbConnection.cs

@@ -109,6 +109,7 @@ public override async Task CloseAsync()
                 return;
             case ConnectionState.Broken:
                 ConnectionState = ConnectionState.Closed;
+                _session.Close();
                 return;
             default:
                 try

src/Ydb.Sdk/src/IDriver.cs

@@ -210,14 +210,14 @@ protected async ValueTask<CallOptions> GetCallOptions(GrpcRequestSettings settin
     }
 
     public ILoggerFactory LoggerFactory { get; }
-    public void RegisterOwner() => Interlocked.Increment(ref _ownerCount);
+    public void RegisterOwner() => ++_ownerCount;
     public bool IsDisposed => Disposed == 1;
 
     public void Dispose() => DisposeAsync().AsTask().GetAwaiter().GetResult();
 
     public async ValueTask DisposeAsync()
     {
-        if (Interlocked.Decrement(ref _ownerCount) <= 0 && Interlocked.CompareExchange(ref Disposed, 1, 0) == 0)
+        if (--_ownerCount <= 0 && Interlocked.CompareExchange(ref Disposed, 1, 0) == 0)
         {
             await ChannelPool.DisposeAsync();
 

src/Ydb.Sdk/test/Ydb.Sdk.Ado.Tests/PoolManagerTests.cs

@@ -1,12 +1,20 @@
 using System.Collections.Immutable;
 using Xunit;
+using Xunit.Abstractions;
 
 namespace Ydb.Sdk.Ado.Tests;
 
 [Collection("PoolManagerTests")]
 [CollectionDefinition("PoolManagerTests", DisableParallelization = true)]
 public class PoolManagerTests
 {
+    private readonly ITestOutputHelper _testOutputHelper;
+
+    public PoolManagerTests(ITestOutputHelper testOutputHelper)
+    {
+        _testOutputHelper = testOutputHelper;
+    }
+
     [Theory]
     [InlineData(new[]
     {
@@ -55,16 +63,17 @@ public async Task PoolManager_CachingAndCleanup(string[] connectionStrings, int
         await ClearAllConnections(connections);
     }
 
-    private static async Task ClearAllConnections(IReadOnlyCollection<YdbConnection> connections)
+    private async Task ClearAllConnections(IReadOnlyCollection<YdbConnection> connections)
     {
         foreach (var connection in connections)
             await connection.CloseAsync();
 
         await YdbConnection.ClearAllPools();
         Assert.Empty(PoolManager.Pools);
 
-        foreach (var (_, driver) in PoolManager.Drivers)
+        foreach (var (str, driver) in PoolManager.Drivers)
         {
+            _testOutputHelper.WriteLine(str);
             Assert.True(driver.IsDisposed);
         }
     }