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

CORDA-1564 Clean up old sessions when retrying flows. (#3278)

Browse Source
This commit is contained in:
Rick Parker 2018-05-31 18:43:50 +01:00 committed by GitHub
parent 74fd5b9e9d
commit 51c359c48d
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
node/src/main/kotlin/net/corda/node/services/statemachine/SingleThreadedStateMachineManager.kt
View File

@ -354,6 +354,10 @@ class SingleThreadedStateMachineManager(
null null
} }
externalEventMutex.withLock { externalEventMutex.withLock {
// Remove any sessions the old flow has.
for (sessionId in getFlowSessionIds(currentState.checkpoint)) {
sessionToFlow.remove(sessionId)
}
if (flow != null) addAndStartFlow(flowId, flow) if (flow != null) addAndStartFlow(flowId, flow)
// Deliver all the external events from the old flow instance. // Deliver all the external events from the old flow instance.
val unprocessedExternalEvents = mutableListOf<ExternalEvent>() val unprocessedExternalEvents = mutableListOf<ExternalEvent>()