~ disposeLockFreeLinkedList

Author: elizarov

kotlinx-coroutines-core/common/src/JobSupport.kt

@@ -237,6 +237,7 @@ public open class JobSupport constructor(active: Boolean) : Job, ChildJob, Paren
         assert { casSuccess }
         // And process all post-completion actions
         completeStateFinalization(state, finalState)
+        disposeLockFreeLinkedList { state.list } // only needed on Kotlin/Native
         return finalState
     }
 
@@ -292,6 +293,7 @@ public open class JobSupport constructor(active: Boolean) : Job, ChildJob, Paren
         onCancelling(null) // simple state is not a failure
         onCompletionInternal(update)
         completeStateFinalization(state, update)
+        disposeLockFreeLinkedList { state as? JobNode<*> } // only needed on Kotlin/Native
         return true
     }
 

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

@@ -0,0 +1,7 @@
+/*
+ * Copyright 2016-2019 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
+ */
+
+package kotlinx.coroutines.internal
+
+internal expect fun disposeLockFreeLinkedList(list: () -> LockFreeLinkedListNode?) // only needed on Kotlin/Native

kotlinx-coroutines-core/concurrent/src/internal/LockFreeLinkedList.kt

@@ -668,6 +668,20 @@ public actual open class LockFreeLinkedListNode {
         assert { next === this._next.value }
     }
 
+    /**
+     * Only needed on Kotlin/Native. See [disposeLockFreeLinkedList].
+     */
+    internal fun unlinkRefs(nullRef: Node) {
+        _next.value = nullRef
+        _prev.value = nullRef
+        _removedRef.value = nullRef.removed()
+    }
+
+    /**
+     * Only needed on Kotlin/Native. See [disposeLockFreeLinkedList].
+     */
+    internal fun initRemoved() { removed() }
+
     override fun toString(): String = "$classSimpleName@$hexAddress"
 }
 

kotlinx-coroutines-core/js/src/internal/ManualMemoryManagement.kt

@@ -0,0 +1,8 @@
+/*
+ * Copyright 2016-2019 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
+ */
+
+package kotlinx.coroutines.internal
+
+@Suppress("NOTHING_TO_INLINE")
+internal actual inline fun disposeLockFreeLinkedList(list: () -> LockFreeLinkedListNode?) {} // only needed on Kotlin/Native

kotlinx-coroutines-core/jvm/src/internal/ManualMemoryManagement.kt

@@ -0,0 +1,13 @@
+/*
+ * Copyright 2016-2019 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
+ */
+
+@file:Suppress("INVISIBLE_REFERENCE", "INVISIBLE_MEMBER")
+
+package kotlinx.coroutines.internal
+
+import kotlin.internal.InlineOnly
+
+@InlineOnly
+@Suppress("NOTHING_TO_INLINE") // Should be NOP
+internal actual inline fun disposeLockFreeLinkedList(list: () -> LockFreeLinkedListNode?) {} // only needed on Kotlin/Native

kotlinx-coroutines-core/jvm/src/internal/Sharing.kt

@@ -2,46 +2,60 @@
  * Copyright 2016-2019 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
  */
 
+@file:Suppress("INVISIBLE_REFERENCE", "INVISIBLE_MEMBER")
+
 package kotlinx.coroutines.internal
 
 import kotlinx.coroutines.*
 import kotlin.coroutines.*
 import kotlin.coroutines.intrinsics.*
+import kotlin.internal.InlineOnly
 
+@InlineOnly
 @Suppress("NOTHING_TO_INLINE") // Should be NOP
 internal actual inline fun DisposableHandle.asShareable(): DisposableHandle = this
 
+@InlineOnly
 @Suppress("NOTHING_TO_INLINE") // Should be NOP
 internal actual inline fun CoroutineDispatcher.asShareable(): CoroutineDispatcher = this
 
+@InlineOnly
 @Suppress("NOTHING_TO_INLINE") // Should be NOP
 internal actual inline fun <T> Continuation<T>.asShareable() : Continuation<T> = this
 
+@InlineOnly
 @Suppress("NOTHING_TO_INLINE") // Should be NOP
 internal actual inline fun <T> Continuation<T>.asLocal() : Continuation<T> = this
 
+@InlineOnly
 @Suppress("NOTHING_TO_INLINE") // Should be NOP
 internal actual inline fun <T> Continuation<T>.asLocalOrNull() : Continuation<T>? = this
 
+@InlineOnly
 @Suppress("NOTHING_TO_INLINE") // Should be NOP
 internal actual inline fun <T> Continuation<T>.useLocal() : Continuation<T> = this
 
+@InlineOnly
 @Suppress("NOTHING_TO_INLINE") // Should be NOP
 internal actual inline fun <T> Continuation<T>.shareableInterceptedResumeCancellableWith(result: Result<T>) {
     intercepted().resumeCancellableWith(result)
 }
 
+@InlineOnly
 @Suppress("NOTHING_TO_INLINE") // Save an entry on call stack
 internal actual inline fun <T> CancellableContinuationImpl<T>.shareableResume(delegate: Continuation<T>, useMode: Int) =
     resumeImpl(delegate, useMode)
 
+@InlineOnly
 @Suppress("NOTHING_TO_INLINE") // Save an entry on call stack
 internal actual inline fun isReuseSupportedInPlatform() = true
 
+@InlineOnly
 internal actual inline fun <T> ArrayList<T>.addOrUpdate(element: T, update: (ArrayList<T>) -> Unit) {
     add(element)
 }
 
+@InlineOnly
 internal actual inline fun <T> ArrayList<T>.addOrUpdate(index: Int, element: T, update: (ArrayList<T>) -> Unit) {
     add(index, element)
 }

kotlinx-coroutines-core/native/src/internal/ManualMemoryManagement.kt

@@ -0,0 +1,26 @@
+/*
+ * Copyright 2016-2019 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
+ */
+
+package kotlinx.coroutines.internal
+
+import kotlin.native.concurrent.*
+
+@Suppress("NOTHING_TO_INLINE")
+internal actual inline fun disposeLockFreeLinkedList(list: () -> LockFreeLinkedListNode?) {
+    // only needed on Kotlin/Native
+    val head = list() ?: return
+    var cur = head
+    do {
+        val next = cur.nextNode
+        cur.unlinkRefs(NullNodeRef)
+        cur = next
+    } while (cur !== head)
+}
+
+private object NullNodeRef : LockFreeLinkedListNode() {
+    init {
+        initRemoved()
+        freeze()
+    }
+}