ExternalVendorCode/corda
1
0
Fork 0
mirror of https://github.com/corda/corda.git synced 2024-12-28 00:38:55 +00:00
Code Issues Actions 2 Packages Projects Releases Wiki Activity

Switch checkpoints on for retryable sends, add back confirmationWindowSize setting

Browse Source
This commit is contained in:
Andras Slemmer 2018-03-09 10:18:39 +00:00
parent 6bed95c02b
commit 4e16c2a06a
2 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
core/src/main/kotlin/net/corda/core/flows/FlowLogic.kt
View File

@ -153,7 +153,7 @@ abstract class FlowLogic<out T> {
sessionToMessage = mapOf(this to payload.serialize(context = SerializationDefaults.P2P_CONTEXT)),
shouldRetrySend = true
)
return stateMachine.suspend(request, maySkipCheckpoint = true)[this]!!.checkPayloadIs(receiveType)
return stateMachine.suspend(request, maySkipCheckpoint = false)[this]!!.checkPayloadIs(receiveType)
}
@Suspendable

1
node/src/main/kotlin/net/corda/node/services/messaging/P2PMessagingClient.kt
View File

@ -225,6 +225,7 @@ class P2PMessagingClient(val config: NodeConfiguration,
clientFailureCheckPeriod = -1
minLargeMessageSize = maxMessageSize
isUseGlobalPools = nodeSerializationEnv != null
confirmationWindowSize = config.enterpriseConfiguration.tuning.p2pConfirmationWindowSize
}
val sessionFactory = locator!!.createSessionFactory()
// Login using the node username. The broker will authenticate us as its node (as opposed to another peer)