IO: added linearizability test

Author: Sergey Mashkov

core/kotlinx-coroutines-io/src/test/kotlin/kotlinx/coroutines/experimental/io/ByteChannelJoinLinearizabilityTest.kt

@@ -6,7 +6,7 @@ import com.devexperts.dxlab.lincheck.stress.*
 import kotlinx.coroutines.experimental.*
 import org.junit.*
 
-@StressCTest(iterations = 200, actorsPerThread = arrayOf("1:1", "1:1", "1:1"), verifier = LinVerifier::class)
+@StressCTest(iterations = 200, invocationsPerIteration = 2_000, actorsPerThread = arrayOf("1:1", "1:1", "1:1"), verifier = LinVerifier::class)
 @OpGroupConfigs(
         OpGroupConfig(name = "write", nonParallel = true),
         OpGroupConfig(name = "read1", nonParallel = true),

core/kotlinx-coroutines-io/src/test/kotlin/kotlinx/coroutines/experimental/io/ByteChannelJoinNoAutoFlushLinearizabilityTest.kt

@@ -0,0 +1,51 @@
+package kotlinx.coroutines.experimental.io
+
+import com.devexperts.dxlab.lincheck.*
+import com.devexperts.dxlab.lincheck.annotations.*
+import com.devexperts.dxlab.lincheck.stress.*
+import kotlinx.coroutines.experimental.*
+import org.junit.*
+
+@StressCTest(iterations = 200, invocationsPerIteration = 2_000, actorsPerThread = arrayOf("1:2", "1:1", "1:1"), verifier = LinVerifier::class)
+@OpGroupConfigs(
+        OpGroupConfig(name = "write", nonParallel = true),
+        OpGroupConfig(name = "read1", nonParallel = true),
+        OpGroupConfig(name = "read2", nonParallel = true)
+)
+class ByteChannelJoinNoAutoFlushLinearizabilityTest {
+    private lateinit var from: ByteChannel
+    private lateinit var to: ByteChannel
+
+    private val lr = LinTesting()
+
+    @Reset
+    fun reset() {
+        from = ByteChannel(false)
+        to = ByteChannel(false)
+    }
+
+    @Operation(runOnce = true, group = "read1")
+    fun read() = lr.run("read") {
+        to.readLong()
+    }
+
+    @Operation(runOnce = true, group = "write")
+    fun write() = lr.run("write") {
+        from.writeLong(0x1122334455667788L)
+    }
+
+    @Operation(group = "write")
+    fun flush() = lr.run("flush") {
+        from.flush()
+    }
+
+    @Operation(runOnce = true, group = "read2")
+    fun joinTo() = lr.run("join") {
+        from.joinTo(to, true)
+    }
+
+    @Test
+    fun test() {
+        LinChecker.check(ByteChannelJoinNoAutoFlushLinearizabilityTest::class.java)
+    }
+}