diff --git a/src/main/kotlin/jp/co/soramitsu/load/Iroha2SetUp.kt b/src/main/kotlin/jp/co/soramitsu/load/Iroha2SetUp.kt index 8084719..8d4de7f 100644 --- a/src/main/kotlin/jp/co/soramitsu/load/Iroha2SetUp.kt +++ b/src/main/kotlin/jp/co/soramitsu/load/Iroha2SetUp.kt @@ -35,9 +35,9 @@ class Iroha2SetUp : Wrench13() { val iroha2SetUpScn = scenario("Iroha2SetUp") .exec { Session -> - val randomIndex = (0 until peers.size).random() + /*val randomIndex = (0 until peers.size).random() val randomPeer = peers[randomIndex] - Iroha2Client = buildClient(randomPeer) + Iroha2Client = buildClient(randomPeer)*/ timer = CustomHistogram.subscriptionToBlockStreamTimer.labels( "gatling" @@ -92,9 +92,9 @@ class Iroha2SetUp : Wrench13() { //accounts on each domain = threads * anotherDevDomainIdList.size * setUpUsersOnEachDomain repeat(SimulationConfig.simulation.setUpUsersOnEachDomain).on( exec { Session -> - val randomIndex = (0 until peers.size).random() + /*val randomIndex = (0 until peers.size).random() val randomPeer = peers[randomIndex] - Iroha2Client = buildClient(randomPeer) + Iroha2Client = buildClient(randomPeer)*/ timer = CustomHistogram.subscriptionToBlockStreamTimer.labels( "gatling" , System.getProperty("user.dir").substringAfterLast("/").substringAfterLast("\\") diff --git a/src/main/kotlin/jp/co/soramitsu/load/TransactionOnly.kt b/src/main/kotlin/jp/co/soramitsu/load/TransactionOnly.kt index 59ce5aa..dd5ae85 100644 --- a/src/main/kotlin/jp/co/soramitsu/load/TransactionOnly.kt +++ b/src/main/kotlin/jp/co/soramitsu/load/TransactionOnly.kt @@ -45,9 +45,9 @@ class TransactionOnly: Wrench13() { Session } .exec { Session -> - val randomIndex = (0 until peers.size).random() + /*val randomIndex = (0 until peers.size).random() val randomPeer = peers[randomIndex] - val Iroha2Client: Iroha2Client = buildClient(randomPeer) + val Iroha2Client: Iroha2Client = buildClient(randomPeer)*/ timer = CustomHistogram.subscriptionToBlockStreamTimer.labels( "gatling", System.getProperty("user.dir").substringAfterLast("/").substringAfterLast("\\"), diff --git a/src/main/kotlin/jp/co/soramitsu/load/toolbox/Wrench13.kt b/src/main/kotlin/jp/co/soramitsu/load/toolbox/Wrench13.kt index f21b4b5..b7bb3b0 100644 --- a/src/main/kotlin/jp/co/soramitsu/load/toolbox/Wrench13.kt +++ b/src/main/kotlin/jp/co/soramitsu/load/toolbox/Wrench13.kt @@ -34,7 +34,7 @@ open class Wrench13 { var attemptsPersentage: Int = 2 var attempt: Int = -1 var anotherDevDomainIdList: MutableList = mutableListOf() - lateinit var Iroha2Client: Iroha2Client + var Iroha2Client: Iroha2Client = buildClient("peer-0/api") var pushGateway = PushGateway("0.0.0.0:9091"); diff --git a/src/test/java/jp/co/soramitsu/load/simulation/MaximumSearchSimulation.java b/src/test/java/jp/co/soramitsu/load/simulation/MaximumSearchSimulation.java index e2674a8..5baa15a 100644 --- a/src/test/java/jp/co/soramitsu/load/simulation/MaximumSearchSimulation.java +++ b/src/test/java/jp/co/soramitsu/load/simulation/MaximumSearchSimulation.java @@ -19,7 +19,7 @@ public class MaximumSearchSimulation extends Simulation { setUp( jp.co.soramitsu.load.SetUp.Companion.apply().injectOpen(OpenInjectionStep.atOnceUsers(1)) .andThen(Iroha2SetUp.Companion.apply().injectOpen(LoadProfiles.setupModel()) - .andThen(TransferAssetsQueryStatus.Companion.apply().injectClosed(LoadProfiles.getMaxPerformanceClosedProfile())) + .andThen(TransactionOnly.Companion.apply().injectClosed(LoadProfiles.getMaxPerformanceClosedProfile())) ).andThen(CleanUp.Companion.apply().injectOpen(OpenInjectionStep.atOnceUsers(1))) ).protocols(Protocols.httpProtocol); }