mirror of
https://github.com/corda/corda.git
synced 2025-03-15 00:36:49 +00:00
New jitpacked version of quasar (#1452)
This commit is contained in:
parent
efa990728e
commit
d8ebde07d4
@ -16,8 +16,8 @@ buildscript {
|
||||
// TODO: Sort this alphabetically.
|
||||
ext.kotlin_version = constants.getProperty("kotlinVersion")
|
||||
|
||||
ext.quasar_group = 'co.paralleluniverse'
|
||||
ext.quasar_version = '0.7.10'
|
||||
ext.quasar_group = 'com.github.corda.quasar'
|
||||
ext.quasar_version = '73f5cef96ecf8b57e4184bc3a255d225b03d5600'
|
||||
|
||||
// gradle-capsule-plugin:1.0.2 contains capsule:1.0.1 by default.
|
||||
// We must configure it manually to use the latest capsule version.
|
||||
|
@ -1,7 +1,7 @@
|
||||
package net.corda.node.services.statemachine
|
||||
|
||||
import co.paralleluniverse.fibers.Fiber
|
||||
import co.paralleluniverse.fibers.Fiber.parkAndSerialize
|
||||
import co.paralleluniverse.fibers.Fiber.parkAndCustomSerialize
|
||||
import co.paralleluniverse.fibers.FiberScheduler
|
||||
import co.paralleluniverse.fibers.Suspendable
|
||||
import co.paralleluniverse.strands.Strand
|
||||
@ -361,7 +361,7 @@ class FlowStateMachineImpl<R>(override val id: StateMachineRunId,
|
||||
override fun <R : Any> suspend(ioRequest: FlowIORequest<R>, maySkipCheckpoint: Boolean): R {
|
||||
val serializationContext = TransientReference(getTransientField(TransientValues::checkpointSerializationContext))
|
||||
val transaction = extractThreadLocalTransaction()
|
||||
parkAndSerialize { _, _ ->
|
||||
parkAndCustomSerialize {
|
||||
setLoggingContext()
|
||||
logger.trace { "Suspended on $ioRequest" }
|
||||
|
||||
|
Loading…
x
Reference in New Issue
Block a user