Skip to content

Commit 08e6bc2

Browse files
committed
tests: add double OpenSession check in stress tests;
1 parent e748a85 commit 08e6bc2

File tree

2 files changed

+11
-1
lines changed

2 files changed

+11
-1
lines changed

src/Ydb.Sdk/src/Ado/Session/ImplicitSessionSource.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@ namespace Ydb.Sdk.Ado.Session;
33
internal sealed class ImplicitSessionSource : ISessionSource
44
{
55
private readonly IDriver _driver;
6-
private readonly ManualResetEventSlim _allReleased = new(false);
6+
private readonly ManualResetEventSlim _allReleased = new(initialState: false);
77
private int _isDisposed;
88
private int _activeLeaseCount;
99

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

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -43,6 +43,9 @@ public async Task Dispose_WaitsForAllLeases_AndSignalsOnEmptyExactlyOnce()
4343

4444
s.Dispose();
4545
closed.Inc();
46+
47+
var s2 = await source.OpenSession(CancellationToken.None);
48+
s2.Dispose();
4649
}
4750
catch (ObjectDisposedException)
4851
{
@@ -88,6 +91,9 @@ public async Task Stress_Counts_AreBalanced()
8891

8992
s.Dispose();
9093
closed.Inc();
94+
95+
var s2 = await source.OpenSession(CancellationToken.None);
96+
s2.Dispose();
9197
}
9298
catch (ObjectDisposedException)
9399
{
@@ -118,6 +124,10 @@ public async Task Open_RacingWithDispose_StateRemainsConsistent()
118124
{
119125
var s = await source.OpenSession(CancellationToken.None);
120126
s.Dispose();
127+
128+
var s2 = await source.OpenSession(CancellationToken.None);
129+
s2.Dispose();
130+
121131
return 1;
122132
}
123133
catch (ObjectDisposedException)

0 commit comments

Comments
 (0)