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

Load test: add a notarisation test. Each node issues a dummy state and sends it for notarisation.

Browse Source 
Note that this only works with a non-validating notary.

Fixed transaction generation
This commit is contained in:
Andrius Dagys 2017-04-03 10:11:28 +01:00
parent 026ac6884a
commit 6f9b70520c
2 changed files with 56 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
tools/loadtest/src/main/kotlin/net/corda/loadtest/LoadTest.kt
View File

@ -4,7 +4,6 @@ import net.corda.client.mock.Generator
import net.corda.core.crypto.toBase58String
import net.corda.node.driver.PortAllocation
import net.corda.node.services.network.NetworkMapService
import net.corda.node.services.transactions.ValidatingNotaryService
import org.slf4j.LoggerFactory
import java.util.*
import java.util.concurrent.ConcurrentHashMap
@ -195,9 +194,9 @@ fun runLoadTests(configuration: LoadTestConfiguration, tests: List<Pair<LoadTest
notary = notaryNode.second,
networkMap = networkMapNode.second,
simpleNodes = hostNodeHandleMap.values.filter {
it.info.advertisedServices.filter {
it.info.type in setOf(NetworkMapService.type, ValidatingNotaryService.type)
}.isEmpty()
it.info.advertisedServices.none {
it.info.type == NetworkMapService.type || it.info.type.isNotary()
}
}
)

53
tools/loadtest/src/main/kotlin/net/corda/loadtest/tests/NotaryTest.kt Normal file
View File

@ -0,0 +1,53 @@
package net.corda.loadtest.tests
import net.corda.client.mock.Generator
import net.corda.client.mock.int
import net.corda.client.mock.pickOne
import net.corda.client.mock.replicate
import net.corda.contracts.asset.DUMMY_CASH_ISSUER
import net.corda.contracts.asset.DUMMY_CASH_ISSUER_KEY
import net.corda.core.contracts.DummyContract
import net.corda.core.flows.FlowException
import net.corda.core.messaging.startFlow
import net.corda.core.success
import net.corda.core.transactions.SignedTransaction
import net.corda.flows.FinalityFlow
import net.corda.loadtest.LoadTest
import net.corda.loadtest.NodeHandle
import org.slf4j.LoggerFactory
private val log = LoggerFactory.getLogger("NotaryTest")
data class NotariseCommand(val issueTx: SignedTransaction, val moveTx: SignedTransaction, val node: NodeHandle)
val dummyNotarisationTest = LoadTest<NotariseCommand, Unit>(
"Notarising dummy transactions",
generate = { _, _ ->
val generateTx = Generator.pickOne(simpleNodes).bind { node: NodeHandle ->
Generator.int().map {
val issueTx = DummyContract.generateInitial(it, notary.info.notaryIdentity, DUMMY_CASH_ISSUER).apply {
signWith(DUMMY_CASH_ISSUER_KEY)
}
val asset = issueTx.toWireTransaction().outRef<DummyContract.SingleOwnerState>(0)
val moveTx = DummyContract.move(asset, DUMMY_CASH_ISSUER.party.owningKey).apply {
signWith(DUMMY_CASH_ISSUER_KEY)
}
NotariseCommand(issueTx.toSignedTransaction(false), moveTx.toSignedTransaction(false), node)
}
}
Generator.replicate(10, generateTx)
},
interpret = { _, _ -> },
execute = { (issueTx, moveTx, node) ->
try {
val proxy = node.connection.proxy
val issueFlow = proxy.startFlow(::FinalityFlow, issueTx)
issueFlow.returnValue.success {
val moveFlow = proxy.startFlow(::FinalityFlow, moveTx)
}
} catch (e: FlowException) {
log.error("Failure", e)
}
},
gatherRemoteState = {}
)