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

CORDA-3597 add missed data to checkpoint class (#5995)

Browse Source 
* Add extra fields to StateMachineState

* Move structures into checkpoint as this is a more natural place.
This commit is contained in:
williamvigorr3 2020-02-26 10:48:52 +00:00 committed by GitHub
parent 8d1b6cf499
commit 9d4d128f4e
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 14 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
node/src/main/kotlin/net/corda/node/services/persistence/DBCheckpointStorage.kt
View File

@ -7,6 +7,7 @@ import net.corda.core.utilities.ProgressTracker
import net.corda.core.utilities.debug import net.corda.core.utilities.debug
import net.corda.node.services.api.CheckpointStorage import net.corda.node.services.api.CheckpointStorage
import net.corda.node.services.statemachine.Checkpoint import net.corda.node.services.statemachine.Checkpoint
import net.corda.node.services.statemachine.Checkpoint.FlowStatus
import net.corda.nodeapi.internal.persistence.NODE_DATABASE_PREFIX import net.corda.nodeapi.internal.persistence.NODE_DATABASE_PREFIX
import net.corda.nodeapi.internal.persistence.currentDBSession import net.corda.nodeapi.internal.persistence.currentDBSession
import org.apache.commons.lang3.ArrayUtils.EMPTY_BYTE_ARRAY import org.apache.commons.lang3.ArrayUtils.EMPTY_BYTE_ARRAY
@ -33,15 +34,6 @@ import javax.persistence.OneToOne
class DBCheckpointStorage : CheckpointStorage { class DBCheckpointStorage : CheckpointStorage {
val log: Logger = LoggerFactory.getLogger(this::class.java) val log: Logger = LoggerFactory.getLogger(this::class.java)
enum class FlowStatus {
RUNNABLE,
FAILED,
COMPLETED,
HOSPITALIZED,
KILLED,
PAUSED
}
enum class StartReason { enum class StartReason {
RPC, FLOW, SERVICE, SCHEDULED, INITIATED RPC, FLOW, SERVICE, SCHEDULED, INITIATED
} }

14
node/src/main/kotlin/net/corda/node/services/statemachine/StateMachineState.kt
View File

@ -54,8 +54,20 @@ data class Checkpoint(
val checkpointState: CheckpointState, val checkpointState: CheckpointState,
val flowState: FlowState, val flowState: FlowState,
val errorState: ErrorState, val errorState: ErrorState,
val result: Any? = null val result: Any? = null,
val status: FlowStatus = FlowStatus.RUNNABLE,
val progressStep: String? = null,
val flowIoRequest: FlowIORequest<*>? = null,
val compatible: Boolean = true
) { ) {
enum class FlowStatus {
RUNNABLE,
FAILED,
COMPLETED,
HOSPITALIZED,
KILLED,
PAUSED
}
val timestamp: Instant = Instant.now() // This will get updated every time a Checkpoint object is created/ created by copy. val timestamp: Instant = Instant.now() // This will get updated every time a Checkpoint object is created/ created by copy.