ExternalVendorCode/corda
1
0
Fork 0
mirror of https://github.com/corda/corda.git synced 2025-02-21 09:51:57 +00:00
Code Issues Actions 2 Packages Projects Releases Wiki Activity

Merge pull request #7551 from corda/colljos/finality_flow_force_recover_flowids

Browse Source 
ENT-11036 Add "forceRecoverFlowIds" parameter to FinalityRecoveryFlow
This commit is contained in:
Adel El-Beik 2023-10-27 18:17:31 +01:00 committed by GitHub
commit 8ab92f0ee3
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 8 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
core/src/main/kotlin/net/corda/core/flows/FinalityRecoveryFlow.kt
View File

@ -21,6 +21,7 @@ class FinalityRecoveryFlow(
private val matchingCriteria: FlowRecoveryQuery? = null,
private val forceRecover: Boolean = false,
private val recoverAll: Boolean = false,
private val forceRecoverFlowIds: Collection<StateMachineRunId> = emptySet(),
override val progressTracker: ProgressTracker = ProgressTracker()) : FlowLogic<Map<FlowTransactionInfo, Boolean>>() {
@CordaInternal
@ -28,16 +29,17 @@ class FinalityRecoveryFlow(
val flowIds: Collection<StateMachineRunId>,
val matchingCriteria: FlowRecoveryQuery?,
val forceRecover: Boolean,
val recoverAll: Boolean)
val recoverAll: Boolean,
val forceRecoverFlowIds: Collection<StateMachineRunId>)
@CordaInternal
fun getExtraConstructorArgs() = ExtraConstructorArgs(txIds, flowIds, matchingCriteria, forceRecover, recoverAll)
fun getExtraConstructorArgs() = ExtraConstructorArgs(txIds, flowIds, matchingCriteria, forceRecover, recoverAll, forceRecoverFlowIds)
constructor(txId: SecureHash, forceRecover: Boolean = false) : this(setOf(txId), forceRecover)
constructor(txIds: Collection<SecureHash>, forceRecover: Boolean = false, recoverAll: Boolean = false) : this(txIds, emptySet(), null, forceRecover, recoverAll, tracker())
constructor(txIds: Collection<SecureHash>, forceRecover: Boolean = false, recoverAll: Boolean = false) : this(txIds, emptySet(), null, forceRecover, recoverAll, emptySet(), tracker())
constructor(flowId: StateMachineRunId, forceRecover: Boolean = false) : this(emptySet(), setOf(flowId), null, forceRecover)
constructor(flowIds: Collection<StateMachineRunId>, forceRecover: Boolean = false) : this(emptySet(), flowIds, null, forceRecover, false, tracker())
constructor(recoverAll: Boolean, forceRecover: Boolean = false) : this(emptySet(), emptySet(), null, forceRecover, recoverAll, tracker())
constructor(matchingCriteria: FlowRecoveryQuery, forceRecover: Boolean = false) : this(emptySet(), emptySet(), matchingCriteria, forceRecover, false, tracker())
constructor(flowIds: Collection<StateMachineRunId>, forceRecover: Boolean = false) : this(emptySet(), flowIds, null, forceRecover, false, emptySet(), tracker())
constructor(recoverAll: Boolean, forceRecover: Boolean = false) : this(emptySet(), emptySet(), null, forceRecover, recoverAll, emptySet(), tracker())
constructor(matchingCriteria: FlowRecoveryQuery, forceRecover: Boolean = false) : this(emptySet(), emptySet(), matchingCriteria, forceRecover, false, emptySet(), tracker())
@Suspendable
@Throws(FlowRecoveryException::class)