Fix non-linearizability in BufferedChannel.expandBuffer() (#3730)

Signed-off-by: Nikita Koval <ndkoval@ya.ru>
Kotlin · May 5, 2023 · 6165533 · 6165533
1 parent a027d68
commit 6165533
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/kotlinx-coroutines-core/common/src/channels/BufferedChannel.kt b/kotlinx-coroutines-core/common/src/channels/BufferedChannel.kt
@@ -1220,9 +1220,9 @@ internal open class BufferedChannel<E>(
                 incCompletedExpandBufferAttempts()
                 return
             }
-            // Is `bufferEndSegment` outdated?
+            // Is `bufferEndSegment` outdated or is the segment with the required id already removed?
             // Find the required segment, creating new ones if needed.
-            if (segment.id < id) {
+            if (segment.id != id) {
                 segment = findSegmentBufferEnd(id, segment, b)
                     // Restart if the required segment is removed, or
                     // the linked list of segments is already closed,