From cdffa1f30459e91334523f966798cedf68515180 Mon Sep 17 00:00:00 2001 From: Sergio Bossa Date: Thu, 7 Jun 2012 11:16:37 +0100 Subject: [PATCH] Fixed problem with excessive number of threads waiting on the connection pool by setting MaxBlockedThreadsPerHost equal to the max number of connections per host. --- .../com/netflix/jmeter/connections/a6x/AstyanaxConnection.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/src/main/java/com/netflix/jmeter/connections/a6x/AstyanaxConnection.java b/src/main/java/com/netflix/jmeter/connections/a6x/AstyanaxConnection.java index 90599e4..52de000 100644 --- a/src/main/java/com/netflix/jmeter/connections/a6x/AstyanaxConnection.java +++ b/src/main/java/com/netflix/jmeter/connections/a6x/AstyanaxConnection.java @@ -78,6 +78,7 @@ public Keyspace keyspace() String maxConnection = com.netflix.jmeter.properties.Properties.instance.cassandra.getMaxConnsPerHost(); ConnectionPoolConfigurationImpl poolConfig = new ConnectionPoolConfigurationImpl(getClusterName()).setPort(port); poolConfig.setMaxConnsPerHost(Integer.parseInt(maxConnection)); + poolConfig.setMaxBlockedThreadsPerHost(Integer.parseInt(maxConnection)); poolConfig.setSeeds(StringUtils.join(endpoints, ":" + port + ",")); poolConfig.setLatencyScoreStrategy(latencyScoreStrategy); @@ -91,7 +92,7 @@ public Keyspace keyspace() builder.withConnectionPoolConfiguration(poolConfig); builder.withConnectionPoolMonitor(connectionPoolMonitor); builder.withConnectionPoolMonitor(new CountingConnectionPoolMonitor()); - + AstyanaxContext context = builder.buildKeyspace(ThriftFamilyFactory.getInstance()); context.start(); keyspace = context.getEntity();