Change the LincheckTest mask to include the new test

Author: dkhalanskyjb

kotlinx-coroutines-core/build.gradle

@@ -185,7 +185,7 @@ jvmTest {
     }
     // 'stress' is required to be able to run all subpackage tests like ":jvmTests --tests "*channels*" -Pstress=true"
     if (!Idea.active && rootProject.properties['stress'] == null) {
-        exclude '**/*LincheckTest.*'
+        exclude '**/*LincheckTest*'
         exclude '**/*StressTest.*'
     }
     if (Idea.active) {
@@ -229,7 +229,7 @@ task jvmStressTest(type: Test, dependsOn: compileTestKotlinJvm) {
 task jvmLincheckTest(type: Test, dependsOn: compileTestKotlinJvm) {
     classpath = files { jvmTest.classpath }
     testClassesDirs = files { jvmTest.testClassesDirs }
-    include '**/*LincheckTest.*'
+    include '**/*LincheckTest*'
     enableAssertions = true
     testLogging.showStandardStreams = true
     configureJvmForLincheck(jvmLincheckTest)

kotlinx-coroutines-core/common/src/internal/OnDemandAllocatingPool.kt

@@ -41,6 +41,8 @@ internal class OnDemandAllocatingPool<T>(
      * Returns `false` if the pool is closed.
      *
      * Note that it will still return `true` even if an element was not created due to reaching [maxCapacity].
+     *
+     * Rethrows the exceptions thrown from [create]. In this case, this operation has no effect.
      */
     fun allocate(): Boolean {
         controlState.loop { ctl ->
@@ -67,7 +69,7 @@ internal class OnDemandAllocatingPool<T>(
      */
     fun close(): List<T> {
         val elementsExisting = tryForbidNewElements()
-        val result = (0 until elementsExisting).map { i ->
+        return (0 until elementsExisting).map { i ->
             // we wait for the element to be created, because we know that eventually it is going to be there
             loop {
                 val element = elements[i].getAndSet(null)
@@ -76,14 +78,13 @@ internal class OnDemandAllocatingPool<T>(
                 }
             }
         }
-        return result
     }
 
     // for tests
     internal fun stateRepresentation(): String {
         val ctl = controlState.value
         val elementsStr = (0 until (ctl and IS_CLOSED_MASK.inv())).map { elements[it].value }.toString()
-        val closedStr = if (ctl and IS_CLOSED_MASK != 0) "[closed]" else ""
+        val closedStr = if (ctl.isClosed()) "[closed]" else ""
         return elementsStr + closedStr
     }
 

kotlinx-coroutines-core/jvm/test/internal/OnDemandAllocatingPoolLincheckTest.kt

@@ -52,7 +52,7 @@ abstract class OnDemandAllocatingSequentialPool(private val maxCapacity: Int) {
     }.sorted().toString()
 }
 
-class OnDemandAllocatingPoolLincheckTest3 : OnDemandAllocatingPoolLincheckTest(3) {
+class OnDemandAllocatingPool3LincheckTest : OnDemandAllocatingPoolLincheckTest(3) {
     override fun <O : Options<O, *>> O.customize(isStressTest: Boolean): O =
         this.sequentialSpecification(OnDemandAllocatingSequentialPool3::class.java)
 }