Skip to content

Commit e4a4fab

Browse files
author
olme04
authored
Update code after new MM (#209)
* remove SharedImmutable annotations * rewrite IntMap to not use atomics on native * remove synchronization from IntMap code at all, and move it to StreamsStorage * remove expect/actual from FrameHandler * drop TrackingSet and move set directly to buffer poll
1 parent 9b5c73e commit e4a4fab

File tree

24 files changed

+252
-775
lines changed

24 files changed

+252
-775
lines changed

rsocket-core/src/commonMain/kotlin/io/rsocket/kotlin/RequestStrategy.kt

-2
Original file line numberDiff line numberDiff line change
@@ -19,9 +19,7 @@ package io.rsocket.kotlin
1919
import kotlinx.atomicfu.*
2020
import kotlinx.coroutines.channels.*
2121
import kotlin.coroutines.*
22-
import kotlin.native.concurrent.*
2322

24-
@SharedImmutable
2523
@ExperimentalStreamsApi
2624
private val DefaultStrategy: RequestStrategy = PrefetchStrategy(64, 16)
2725

rsocket-core/src/commonMain/kotlin/io/rsocket/kotlin/frame/io/Dump.kt

-4
Original file line numberDiff line numberDiff line change
@@ -18,15 +18,11 @@ package io.rsocket.kotlin.frame.io
1818

1919
import io.ktor.utils.io.core.*
2020
import io.rsocket.kotlin.payload.*
21-
import kotlin.native.concurrent.*
2221

23-
@SharedImmutable
2422
private val digits = "0123456789abcdef".toCharArray()
2523

26-
@SharedImmutable
2724
private const val divider = "+--------+-------------------------------------------------+----------------+"
2825

29-
@SharedImmutable
3026
private const val header = """
3127
+-------------------------------------------------+
3228
| 0 1 2 3 4 5 6 7 8 9 a b c d e f |

rsocket-core/src/commonMain/kotlin/io/rsocket/kotlin/internal/CloseOperations.kt

-2
Original file line numberDiff line numberDiff line change
@@ -18,7 +18,6 @@ package io.rsocket.kotlin.internal
1818

1919
import io.ktor.utils.io.core.*
2020
import kotlinx.coroutines.channels.*
21-
import kotlin.native.concurrent.*
2221

2322
internal inline fun <T : Closeable, R> T.closeOnError(block: (T) -> R): R {
2423
try {
@@ -29,7 +28,6 @@ internal inline fun <T : Closeable, R> T.closeOnError(block: (T) -> R): R {
2928
}
3029
}
3130

32-
@SharedImmutable
3331
private val onUndeliveredCloseable: (Closeable) -> Unit = Closeable::close
3432

3533
@Suppress("FunctionName")

0 commit comments

Comments
 (0)