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

Add issue and pay sampler

Browse Source
This commit is contained in:
Christian Sailer 2017-11-23 15:30:19 +00:00
parent c1c42c98e4
commit 936d25db16
1 changed files with 41 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

47
tools/jmeter/src/main/kotlin/com/r3/corda/jmeter/Samplers.kt
View File

@ -1,6 +1,8 @@
package com.r3.corda.jmeter package com.r3.corda.jmeter
import com.r3.corda.enterprise.perftestcordapp.DOLLARS import com.r3.corda.enterprise.perftestcordapp.DOLLARS
import com.r3.corda.enterprise.perftestcordapp.POUNDS
import com.r3.corda.enterprise.perftestcordapp.flows.CashIssueAndPaymentFlow
import com.r3.corda.enterprise.perftestcordapp.flows.CashIssueFlow import com.r3.corda.enterprise.perftestcordapp.flows.CashIssueFlow
import net.corda.core.identity.CordaX500Name import net.corda.core.identity.CordaX500Name
import net.corda.core.identity.Party import net.corda.core.identity.Party
@ -19,12 +21,16 @@ abstract class AbstractSampler : BaseFlowSampler() {
val notary = Argument("notaryName", "", "<meta>", "The X500 name of the notary.") val notary = Argument("notaryName", "", "<meta>", "The X500 name of the notary.")
} }
protected fun getIdentities(rpc: CordaRPCOps, testContext: JavaSamplerContext) { protected fun getIdentity( rpc: CordaRPCOps, testContext: JavaSamplerContext, arg: Argument):Party{
if (!testContext.containsParameter(notary.name)) { if (!testContext.containsParameter(arg.name)) {
throw IllegalStateException("You must specify the '${notary.name}' property.") throw IllegalStateException("You must specify the '${arg.name}' property.")
} }
val notaryName = CordaX500Name.parse(testContext.getParameter(notary.name)) val argName = CordaX500Name.parse(testContext.getParameter(arg.name))
notaryIdentity = rpc.wellKnownPartyFromX500Name(notaryName) ?: throw IllegalStateException("Don't know $notaryName") return rpc.wellKnownPartyFromX500Name(argName) ?: throw IllegalStateException("Don't know $argName")
}
protected fun getNotaryIdentity(rpc: CordaRPCOps, testContext: JavaSamplerContext) {
notaryIdentity = getIdentity(rpc,testContext, notary)
} }
} }
@ -37,7 +43,7 @@ class CashIssueSampler : AbstractSampler() {
override val additionalArgs: Set<Argument> = setOf(notary) override val additionalArgs: Set<Argument> = setOf(notary)
override fun setupTest(rpcProxy: CordaRPCOps, testContext: JavaSamplerContext) { override fun setupTest(rpcProxy: CordaRPCOps, testContext: JavaSamplerContext) {
getIdentities(rpcProxy, testContext) getNotaryIdentity(rpcProxy, testContext)
} }
override fun teardownTest(rpcProxy: CordaRPCOps, testContext: JavaSamplerContext) { override fun teardownTest(rpcProxy: CordaRPCOps, testContext: JavaSamplerContext) {
@ -47,5 +53,34 @@ class CashIssueSampler : AbstractSampler() {
val amount = 1_100_000_000_000.DOLLARS val amount = 1_100_000_000_000.DOLLARS
return FlowInvoke<CashIssueFlow>(CashIssueFlow::class.java, arrayOf(amount, OpaqueBytes.of(1), notaryIdentity)) return FlowInvoke<CashIssueFlow>(CashIssueFlow::class.java, arrayOf(amount, OpaqueBytes.of(1), notaryIdentity))
} }
}
/**
* A sampler that issues cash and pays it to a specified party, thus invoking the notary and the payee
* via P2P
*/
class CashIssueAndPaySampler : AbstractSampler() {
companion object JMeterProperties{
val otherParty = Argument("otherPartyName", "", "<meta>", "The X500 name of the payee.")
}
lateinit var counterParty: Party
override fun setupTest(rpcProxy: CordaRPCOps, testContext: JavaSamplerContext) {
getNotaryIdentity(rpcProxy,testContext)
counterParty = getIdentity(rpcProxy, testContext, otherParty)
}
override fun createFlowInvoke(rpcProxy: CordaRPCOps, testContext: JavaSamplerContext): FlowInvoke<*> {
val amount = 2_000_000.POUNDS
return FlowInvoke<CashIssueAndPaymentFlow>(CashIssueAndPaymentFlow::class.java, arrayOf(amount, OpaqueBytes.of(1), notaryIdentity, counterParty))
}
override fun teardownTest(rpcProxy: CordaRPCOps, testContext: JavaSamplerContext) {
}
override val additionalArgs: Set<Argument>
get() = setOf(notary, otherParty)
} }