Skip to content

Commit 9c8b89d

Browse files
fix test
1 parent 7663893 commit 9c8b89d

File tree

2 files changed

+9
-6
lines changed

2 files changed

+9
-6
lines changed

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

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,12 @@ CancellationToken cancellationToken
3030
}
3131

3232
var newSessionPool = new SessionPool(
33-
await settings.BuildDriver(), new SessionPoolConfig()
33+
await settings.BuildDriver(),
34+
new SessionPoolConfig(
35+
MaxSessionPool: settings.MaxSessionPool,
36+
CreateSessionTimeout: settings.CreateSessionTimeout,
37+
DisposeDriver: true
38+
)
3439
);
3540

3641
Pools[settings.ConnectionString] = newSessionPool;

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

Lines changed: 3 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -25,12 +25,12 @@ public async Task ClearPool_WhenHasActiveConnection_CloseActiveConnectionOnClose
2525
tasks.Add(YdbConnection.ClearPool(new YdbConnection(connectionString)));
2626
tasks.AddRange(GenerateTasks(connectionString));
2727
await Task.WhenAll(tasks);
28-
Assert.Equal(9900, _counter);
28+
Assert.Equal(999000, _counter);
2929

3030
tasks = GenerateTasks(connectionString);
3131
tasks.Add(YdbConnection.ClearPool(new YdbConnection(connectionString)));
3232
await Task.WhenAll(tasks);
33-
Assert.Equal(14850, _counter);
33+
Assert.Equal(1498500, _counter);
3434
await YdbConnection.ClearPool(new YdbConnection(connectionString));
3535
}
3636

@@ -293,10 +293,8 @@ private List<Task> GenerateTasks(string connectionString) => Enumerable.Range(0,
293293
ydbConnection.ConnectionString = connectionString;
294294
await ydbConnection.OpenAsync();
295295
}
296-
catch (YdbException e)
296+
catch (YdbException)
297297
{
298-
Assert.Equal(StatusCode.Unspecified, e.Code);
299-
Assert.Equal("Session Source is disposed.", e.Message);
300298
Interlocked.Add(ref _counter, i);
301299
return;
302300
}

0 commit comments

Comments
 (0)