KT-37232 workaround

Author: elizarov

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

@@ -31,6 +31,8 @@ internal open class CompletedExceptionally(
     @JvmField public val cause: Throwable,
     handled: Boolean = false
 ) {
+    init { cause.fixupForSharing() } // KT-37232 workaround
+
     private val _handled = atomic(handled)
     val handled: Boolean get() = _handled.value
     fun makeHandled(): Boolean = _handled.compareAndSet(false, true)

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

@@ -1092,6 +1092,8 @@ public open class JobSupport constructor(active: Boolean) : Job, ChildJob, Paren
         isCompleting: Boolean,
         rootCause: Throwable?
     ) : SynchronizedObject(), Incomplete {
+        init { rootCause.fixupForSharing() } // KT-37232 workaround
+
         private val _isCompleting = atomic(isCompleting)
         var isCompleting: Boolean
             get() = _isCompleting.value
@@ -1135,6 +1137,7 @@ public open class JobSupport constructor(active: Boolean) : Job, ChildJob, Paren
 
         // guarded by `synchronized(this)`
         fun addExceptionLocked(exception: Throwable) {
+            exception.fixupForSharing() // KT-37232 workaround
             val rootCause = this.rootCause // volatile read
             if (rootCause == null) {
                 this.rootCause = exception

kotlinx-coroutines-core/common/src/channels/AbstractChannel.kt

@@ -1067,6 +1067,8 @@ internal class SendElement(
 internal class Closed<in E>(
     @JvmField val closeCause: Throwable?
 ) : Send(), ReceiveOrClosed<E> {
+    init { closeCause.fixupForSharing() } // KT-37232 workaround
+
     val sendException: Throwable get() = closeCause ?: ClosedSendChannelException(DEFAULT_CLOSE_MESSAGE)
     val receiveException: Throwable get() = closeCause ?: ClosedReceiveChannelException(DEFAULT_CLOSE_MESSAGE)
 

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

@@ -1,5 +1,5 @@
 /*
- * Copyright 2016-2019 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
+ * Copyright 2016-2020 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
  */
 
 package kotlinx.coroutines.internal
@@ -24,3 +24,4 @@ internal expect fun <T> ArrayList<T>.addOrUpdate(element: T, update: (ArrayList<
 internal expect fun <T> ArrayList<T>.addOrUpdate(index: Int, element: T, update: (ArrayList<T>) -> Unit)
 internal expect fun Any.weakRef(): Any
 internal expect fun Any?.unweakRef(): Any?
+internal expect fun Throwable?.fixupForSharing() // KT-37232 workaround

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

@@ -1,5 +1,5 @@
 /*
- * Copyright 2016-2019 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
+ * Copyright 2016-2020 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
  */
 
 package kotlinx.coroutines.internal
@@ -65,3 +65,6 @@ internal actual inline fun Any.weakRef(): Any = this
 
 @Suppress("NOTHING_TO_INLINE") // Should be NOP
 internal actual inline fun Any?.unweakRef(): Any? = this
+
+@Suppress("NOTHING_TO_INLINE") // Should be NOP
+internal actual inline fun Throwable?.fixupForSharing() {} // KT-37232 workaround

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

@@ -1,5 +1,5 @@
 /*
- * Copyright 2016-2019 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
+ * Copyright 2016-2020 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
  */
 
 @file:Suppress("INVISIBLE_REFERENCE", "INVISIBLE_MEMBER")
@@ -83,3 +83,7 @@ internal actual inline fun Any.weakRef(): Any = this
 @InlineOnly
 @Suppress("NOTHING_TO_INLINE") // Should be NOP
 internal actual inline fun Any?.unweakRef(): Any? = this
+
+@InlineOnly
+@Suppress("NOTHING_TO_INLINE") // Should be NOP
+internal actual inline fun Throwable?.fixupForSharing() {} // KT-37232 workaround

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

@@ -1,5 +1,5 @@
 /*
- * Copyright 2016-2019 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
+ * Copyright 2016-2020 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
  */
 
 package kotlinx.coroutines.internal
@@ -112,7 +112,13 @@ internal actual inline fun <T> ArrayList<T>.addOrUpdate(index: Int, element: T,
 @Suppress("NOTHING_TO_INLINE")
 internal actual inline fun Any.weakRef(): Any = WeakReference(this)
 
-internal actual fun Any?.unweakRef(): Any? = (this as WeakReference<Any>?)?.get()
+@Suppress("NOTHING_TO_INLINE")
+internal actual inline fun Any?.unweakRef(): Any? = (this as WeakReference<Any>?)?.get()
+
+@Suppress("NOTHING_TO_INLINE")
+internal actual inline fun Throwable?.fixupForSharing() {
+    this?.getStackTrace() // KT-37232 workaround
+}
 
 internal open class ShareableObject<T : Any>(obj: T) {
     val thread: Thread = currentThread()