Skip to content

Commit

Permalink
createSingleScheduleTaskRPCIndividual
Browse files Browse the repository at this point in the history
  • Loading branch information
man-zhang committed Nov 26, 2024
1 parent 351a079 commit d22222d
Showing 1 changed file with 4 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -167,17 +167,18 @@ class RPCSampler: ApiWsSampler<RPCIndividual>() {
}
}
}

// create a test with one schedule task
scheduleActionCluster.asSequence()
.filter { it.value is ScheduleTaskAction }
.forEach { a->
val copy = a.value.copy() as ScheduleTaskAction
copy.doInitialize(randomness)

val ind = createSingleScheduleTaskRPCIndividual(SampleType.RANDOM, mutableListOf(copy))
adHocInitialIndividuals.add(ind)
}
}

private fun createRPCIndividual(sampleType: SampleType, scheduleTaskActions: MutableList<ScheduleTaskAction>) : RPCIndividual{
private fun createSingleScheduleTaskRPCIndividual(sampleType: SampleType, scheduleTaskActions: MutableList<ScheduleTaskAction>) : RPCIndividual{
return RPCIndividual(
sampleType = sampleType,
trackOperator = if(config.trackingEnabled()) this else null,
Expand Down

0 comments on commit d22222d

Please sign in to comment.