ExternalVendorCode/corda
1
0
Fork 0
mirror of https://github.com/corda/corda.git synced 2025-06-16 22:28:15 +00:00
Code Issues Actions 2 Packages Projects Releases Wiki Activity

CORDA-3837: When delivering a lifecycle event, copy the database context into the lifecycle event thread (#6331)

Browse Source
This commit is contained in:
Joseph Zuniga-Daly
2020-06-11 11:14:51 +01:00
committed by GitHub
parent cf8cd8e004
commit d7e55ed4e5
1 changed files with 9 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
node-api/src/main/kotlin/net/corda/nodeapi/internal/lifecycle/NodeLifecycleEventsDistributor.kt
View File

@ -7,6 +7,8 @@ import net.corda.core.internal.concurrent.openFuture
import net.corda.core.node.services.CordaServiceCriticalFailureException import net.corda.core.node.services.CordaServiceCriticalFailureException
import net.corda.core.utilities.Try import net.corda.core.utilities.Try
import net.corda.core.utilities.contextLogger import net.corda.core.utilities.contextLogger
import net.corda.nodeapi.internal.persistence.contextDatabase
import net.corda.nodeapi.internal.persistence.contextDatabaseOrNull
import java.io.Closeable import java.io.Closeable
import java.util.Collections.singleton import java.util.Collections.singleton
import java.util.LinkedList import java.util.LinkedList
@ -93,7 +95,14 @@ class NodeLifecycleEventsDistributor : Closeable {
log.warn("Not distributing $event as executor been already shutdown. Double close() case?") log.warn("Not distributing $event as executor been already shutdown. Double close() case?")
result.set(null) result.set(null)
} else { } else {
val passTheDbToTheThread = contextDatabaseOrNull
executor.execute { executor.execute {
if (passTheDbToTheThread != null)
contextDatabase = passTheDbToTheThread
val orderedSnapshot = if (event.reversedPriority) snapshot.reversed() else snapshot val orderedSnapshot = if (event.reversedPriority) snapshot.reversed() else snapshot
orderedSnapshot.forEach { orderedSnapshot.forEach {
log.debug("Distributing event $event to: $it") log.debug("Distributing event $event to: $it")