Skip to content

Commit

Permalink
Changed concurrencies to take distributed config into account
Browse files Browse the repository at this point in the history
renamed 'nb' into 'count'
  • Loading branch information
aurbroszniowski committed Aug 9, 2017
1 parent ce50e58 commit 24850f0
Showing 1 changed file with 1 addition and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,6 @@
import io.rainfall.AssertionEvaluator;
import io.rainfall.Configuration;
import io.rainfall.Execution;
import io.rainfall.Operation;
import io.rainfall.Scenario;
import io.rainfall.TestException;
import io.rainfall.WeightedOperation;
Expand All @@ -46,7 +45,7 @@ public class UntilCacheFull extends Execution {
public <E extends Enum<E>> void execute(final StatisticsHolder<E> statisticsHolder, final Scenario scenario, final Map<Class<? extends Configuration>, Configuration> configurations, final List<AssertionEvaluator> assertions) throws TestException {

ConcurrencyConfig concurrencyConfig = (ConcurrencyConfig)configurations.get(ConcurrencyConfig.class);
int nbThreads = concurrencyConfig.getNbThreads();
int nbThreads = concurrencyConfig.getThreadsCount();
ExecutorService executor = Executors.newFixedThreadPool(nbThreads);

CacheConfig cachesConfig = (CacheConfig)configurations.get(CacheConfig.class);
Expand Down

0 comments on commit 24850f0

Please sign in to comment.