Review fixes

Signed-off-by: Nikita Koval <[email protected]>

Author: ndkoval

kotlinx-coroutines-core/common/src/channels/BufferedChannel.kt

@@ -2030,7 +2030,7 @@ internal open class BufferedChannel<E>(
                         // The cell stores a buffered element.
                         state === BUFFERED -> {
                             // Is the cell already covered by a receiver?
-                            if (globalIndex < receiversCounter) return
+                            if (globalIndex < receiversCounter) break@traverse
                             // Update the cell state to `CHANNEL_CLOSED`.
                             if (segment.casState(index, state, CHANNEL_CLOSED)) {
                                 // If `onUndeliveredElement` lambda is non-null, call it.
@@ -2057,7 +2057,7 @@ internal open class BufferedChannel<E>(
                         // The cell stores a suspended waiter.
                         state is Waiter || state is WaiterEB -> {
                             // Is the cell already covered by a receiver?
-                            if (globalIndex < receiversCounter) return
+                            if (globalIndex < receiversCounter) break@traverse
                             // Obtain the sender.
                             val sender: Waiter = if (state is WaiterEB) state.waiter
                                                  else state as Waiter
@@ -2908,8 +2908,7 @@ private val RESUMING_BY_EB = Symbol("RESUMING_BY_EB")
 private val POISONED = Symbol("POISONED")
 // When the element is successfully transferred
 // to a receiver, the cell changes to `DONE_RCV`.
-@JvmField
-internal val DONE_RCV = Symbol("DONE_RCV")
+private val DONE_RCV = Symbol("DONE_RCV")
 // Cancelled sender.
 private val INTERRUPTED_SEND = Symbol("INTERRUPTED_SEND")
 // Cancelled receiver.

kotlinx-coroutines-core/jvm/test/TestBase.kt

@@ -18,7 +18,7 @@ private val VERBOSE = systemProp("test.verbose", false)
 /**
  * Is `true` when running in a nightly stress test mode.
  */
-public actual val isStressTest = true // System.getProperty("stressTest")?.toBoolean() ?: false
+public actual val isStressTest = System.getProperty("stressTest")?.toBoolean() ?: false
 
 public actual val stressTestMultiplierSqrt = if (isStressTest) 5 else 1
 

kotlinx-coroutines-core/jvm/test/lincheck/ChannelsLincheckTest.kt

@@ -144,7 +144,7 @@ abstract class ChannelLincheckTestBase(
     @Operation(causesBlocking = true, blocking = true)
     fun close(@Param(name = "closeToken") token: Int): Boolean = c.close(NumberedCancellationException(token))
 
-//    @Operation(causesBlocking = true, blocking = true)
+    @Operation(causesBlocking = true, blocking = true)
     fun cancel(@Param(name = "closeToken") token: Int) = c.cancel(NumberedCancellationException(token))
 
     // @Operation TODO non-linearizable in BufferedChannel