revert Writer

KirillKurdyukov · KirillKurdyukov · commit 9664c5b23d2f · 2025-02-06T18:54:13.000+03:00
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -1,4 +1,3 @@
-* Fixed TopicSession.ReconnectSession(): CompareExchange returns the original value in location1.
 * Fixed: YdbDataReader.GetDataTypeName for optional values.
 * Added support for "Columns" collectionName in YdbConnection.GetSchema(Async).
 
diff --git a/src/Ydb.Sdk/src/Services/Topic/TopicSession.cs b/src/Ydb.Sdk/src/Services/Topic/TopicSession.cs
@@ -28,7 +28,7 @@ protected TopicSession(
 
     protected async void ReconnectSession()
     {
-        if (Interlocked.CompareExchange(ref _isActive, 0, 1) == 1)
+        if (Interlocked.CompareExchange(ref _isActive, 0, 1) == 0)
         {
             Logger.LogDebug("Skipping reconnect. A reconnect session has already been initiated");
 

Original file line number	Diff line number	Diff line change
`@@ -1,4 +1,3 @@`
`1`		`-* Fixed TopicSession.ReconnectSession(): CompareExchange returns the original value in location1.`
`2`	`1`	`* Fixed: YdbDataReader.GetDataTypeName for optional values.`
`3`	`2`	`* Added support for "Columns" collectionName in YdbConnection.GetSchema(Async).`
`4`	`3`
Original file line number	Diff line number	Diff line change
`@@ -28,7 +28,7 @@ protected TopicSession(`
`28`	`28`
`29`	`29`	`protected async void ReconnectSession()`
`30`	`30`	`{`
`31`		`- if (Interlocked.CompareExchange(ref _isActive, 0, 1) == 1)`
	`31`	`+ if (Interlocked.CompareExchange(ref _isActive, 0, 1) == 0)`
`32`	`32`	`{`
`33`	`33`	`Logger.LogDebug("Skipping reconnect. A reconnect session has already been initiated");`
`34`	`34`