Upgrade infra, benchmarks, introduce common benchmarks

Author: orangy

benchmarks/commonMain/src/kotlinx/io/benchmarks/PacketReadBenchmark.kt

@@ -0,0 +1,77 @@
+package kotlinx.io.benchmarks
+
+import kotlinx.io.core.*
+import org.jetbrains.gradle.benchmarks.*
+import kotlin.random.*
+
+@State(Scope.Benchmark)
+class PacketReadBenchmark {
+    private final val size = 32 * 1024 * 1024
+    private final val array = ByteArray(size)
+    private final val packet: ByteReadPacket
+
+    init {
+        Random.nextBytes(array)
+        packet = BytePacketBuilder().apply {
+            writeFully(array)
+        }.build()
+    }
+    
+    
+    @Benchmark
+    fun copyAndRelease() {
+        val input = packet.copy()
+        input.release()
+    }
+
+    @Benchmark
+    fun myInput(): Long {
+        val input = packet.copy()
+        var c = 0L
+
+        repeat(size) {
+            c += input.readByte().toLong() and 0xff
+        }
+
+        return c
+    }
+
+    @Benchmark
+    fun myInputTakeWhile(): Long {
+        val input = packet.copy()
+        var c = 0L
+
+        input.takeWhile { buffer ->
+            repeat(buffer.readRemaining) {
+                c += buffer.readByte().toLong() and 0xff
+            }
+            true
+        }
+
+        return c
+    }
+
+    @Benchmark
+    fun directArrayAccess(): Long {
+        val input = array
+        var c = 0L
+
+        for (i in 0 until size - 1) {
+            c += input[i].toLong() and 0xff
+        }
+
+        return c
+    }
+    
+    @Benchmark
+    fun myInputReadLong(): Long {
+        val input = packet.copy()
+        var c = 0L
+
+        repeat(input.remaining.toInt() / 8) {
+            c += input.readLong()
+        }
+
+        return c
+    }
+}

benchmarks/commonMain/src/kotlinx/io/benchmarks/TextDecodeBenchmark.kt

@@ -0,0 +1,49 @@
+package kotlinx.io.benchmarks
+
+import kotlinx.io.charsets.*
+import kotlinx.io.core.*
+import org.jetbrains.gradle.benchmarks.*
+
+@State(Scope.Benchmark)
+class TextDecodeBenchmark {
+    @Benchmark
+    fun smallMbKt() = smallTextPacket.copy().readText()
+
+    @Benchmark
+    fun smallMbStringCtor() = String(smallTextBytes, charset = Charsets.UTF_8)
+
+    @Benchmark
+    fun largeMbKt() = largeTextPacket.copy().readText()
+
+    @Benchmark
+    fun largeMbStringCtor() = String(largeTextBytes, charset = Charsets.UTF_8)
+
+    @Benchmark
+    fun smallASCIIKt() = smallTextPacketASCII.copy().readText()
+
+    @Benchmark
+    fun smallASCIIStringCtor() = String(smallTextBytesASCII, charset = Charsets.UTF_8)
+
+    @Benchmark
+    fun largeASCIIKt() = largeTextPacketASCII.copy().readText()
+
+    @Benchmark
+    fun largeASCIIStringCtor() = String(largeTextBytesASCII, charset = Charsets.UTF_8)
+
+    companion object {
+        private val smallTextBytes = "\u0422\u0432\u0437.".toByteArray(Charsets.UTF_8)
+        private val smallTextBytesASCII = "ABC.".toByteArray(Charsets.UTF_8)
+        private val largeTextBytes = ByteArray(smallTextBytes.size * 10000) {
+            smallTextBytes[it % smallTextBytes.size]
+        }
+        private val largeTextBytesASCII = ByteArray(smallTextBytesASCII.size * 10000) {
+            smallTextBytesASCII[it % smallTextBytesASCII.size]
+        }
+
+        private val smallTextPacket = buildPacket { writeFully(smallTextBytes) }
+        private val smallTextPacketASCII = buildPacket { writeFully(smallTextBytesASCII) }
+        private val largeTextPacket = buildPacket { writeFully(largeTextBytes) }
+        private val largeTextPacketASCII = buildPacket { writeFully(largeTextBytesASCII) }
+    }
+
+}

benchmarks/jvmMain/src/kotlinx/io/benchmarks/PacketReadBenchmark.kt renamed to benchmarks/jvmMain/src/kotlinx/io/benchmarks/JvmPacketReadBenchmark.kt

@@ -1,20 +1,13 @@
 package kotlinx.io.benchmarks
 
 import kotlinx.io.core.*
-import org.openjdk.jmh.annotations.*
+import org.jetbrains.gradle.benchmarks.*
 import java.io.*
 import java.nio.*
 import java.util.*
-import java.util.concurrent.*
 
 @State(Scope.Benchmark)
-@Fork(1)
-@Warmup(iterations = 10)
-@Measurement(iterations = 15)
-//@BenchmarkMode(Mode.Throughput, Mode.AverageTime)
-@BenchmarkMode(Mode.AverageTime)
-@OutputTimeUnit(TimeUnit.MILLISECONDS)
-class PacketReadBenchmark {
+class JvmPacketReadBenchmark {
     private final val size = 32 * 1024 * 1024
     private final val array = ByteArray(size)
     private final val packet: ByteReadPacket

benchmarks/jvmMain/src/kotlinx/io/benchmarks/TextDecodeBenchmark.kt renamed to benchmarks/jvmMain/src/kotlinx/io/benchmarks/JvmTextDecodeBenchmark.kt

@@ -1,19 +1,10 @@
 package kotlinx.io.benchmarks
 
 import kotlinx.io.core.*
-import org.openjdk.jmh.annotations.*
-import java.util.concurrent.*
+import org.jetbrains.gradle.benchmarks.*
 
 @State(Scope.Benchmark)
-@Fork(1)
-@Warmup(iterations = 10)
-@Measurement(iterations = 15)
-//@BenchmarkMode(Mode.Throughput, Mode.AverageTime)
-@BenchmarkMode(Mode.Throughput)
-@OutputTimeUnit(TimeUnit.MILLISECONDS)
-class TextDecodeBenchmark {
-
-
+class JvmTextDecodeBenchmark {
     /*
 # Results on unit 660
 # Run complete. Total time: 00:05:04

gradle.properties

@@ -3,16 +3,16 @@ version=0.2.0
 org.gradle.parallel=true
 
 # kotlin
-kotlin_version=1.3.21
+kotlin_version=1.3.30
 kotlin.incremental.multiplatform=true
 kotlin.code.style=official
 org.jetbrains.kotlin.native.jvmArgs=-XX:TieredStopAtLevel=1
 
 # publishing
 bintray_plugin_version=1.8.4-jetbrains-5
 # kotlin libraries
-atomic_fu_version=0.12.1
-coroutines_version=1.1.1
+atomic_fu_version=0.12.3
+coroutines_version=1.2.0
 
 # js
 node_version = 10.14.1
@@ -21,8 +21,7 @@ mocha_version=4.1.0
 mocha_headless_chrome_version=1.8.2
 mocha_teamcity_reporter_version=2.2.2
 source_map_support_version=0.5.3
-gradle_node_version=1.2.0
 
 #infra
-infra_version=0.1.0-dev-42
-benchmarks_version=0.1.7-dev-14
+infra_version=0.1.0-dev-44
+benchmarks_version=0.1.7-dev-20