Repository: usergrid Updated Branches: refs/heads/master 0dc7d031b -> a8b3e7910
Better tune connection pool with the datastax driver. Project: http://git-wip-us.apache.org/repos/asf/usergrid/repo Commit: http://git-wip-us.apache.org/repos/asf/usergrid/commit/a8b3e791 Tree: http://git-wip-us.apache.org/repos/asf/usergrid/tree/a8b3e791 Diff: http://git-wip-us.apache.org/repos/asf/usergrid/diff/a8b3e791 Branch: refs/heads/master Commit: a8b3e7910a94ece2f65064c85f87501dc6adcdc5 Parents: 0dc7d03 Author: Michael Russo <[email protected]> Authored: Fri Nov 11 22:52:23 2016 -0800 Committer: Michael Russo <[email protected]> Committed: Fri Nov 11 22:52:23 2016 -0800 ---------------------------------------------------------------------- .../persistence/core/datastax/impl/DataStaxClusterImpl.java | 4 +++- stack/corepersistence/queue/src/test/resources/qakka.properties | 3 +++ 2 files changed, 6 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/usergrid/blob/a8b3e791/stack/corepersistence/common/src/main/java/org/apache/usergrid/persistence/core/datastax/impl/DataStaxClusterImpl.java ---------------------------------------------------------------------- diff --git a/stack/corepersistence/common/src/main/java/org/apache/usergrid/persistence/core/datastax/impl/DataStaxClusterImpl.java b/stack/corepersistence/common/src/main/java/org/apache/usergrid/persistence/core/datastax/impl/DataStaxClusterImpl.java index 65d4e27..df09a7c 100644 --- a/stack/corepersistence/common/src/main/java/org/apache/usergrid/persistence/core/datastax/impl/DataStaxClusterImpl.java +++ b/stack/corepersistence/common/src/main/java/org/apache/usergrid/persistence/core/datastax/impl/DataStaxClusterImpl.java @@ -208,7 +208,9 @@ public class DataStaxClusterImpl implements DataStaxCluster { .setCoreConnectionsPerHost(HostDistance.LOCAL, cassandraConfig.getConnections()) .setMaxConnectionsPerHost(HostDistance.LOCAL, cassandraConfig.getConnections()) .setIdleTimeoutSeconds( cassandraConfig.getTimeout() / 1000) - .setPoolTimeoutMillis( cassandraConfig.getPoolTimeout()); + .setPoolTimeoutMillis( cassandraConfig.getPoolTimeout()) + .setMaxRequestsPerConnection(HostDistance.LOCAL, 20000) + .setMaxRequestsPerConnection(HostDistance.REMOTE, 2000); // purposely add a couple seconds to the driver's lower level socket timeouts vs. cassandra timeouts final SocketOptions socketOptions = new SocketOptions() http://git-wip-us.apache.org/repos/asf/usergrid/blob/a8b3e791/stack/corepersistence/queue/src/test/resources/qakka.properties ---------------------------------------------------------------------- diff --git a/stack/corepersistence/queue/src/test/resources/qakka.properties b/stack/corepersistence/queue/src/test/resources/qakka.properties index 3d1888e..3c000c2 100644 --- a/stack/corepersistence/queue/src/test/resources/qakka.properties +++ b/stack/corepersistence/queue/src/test/resources/qakka.properties @@ -63,3 +63,6 @@ cassandra.keyspace.application=qakka_test_application cassandra.keyspace.queue-message=qakka_test_queue_messages cassandra.keyspace-drop-and-create=true + +cassandra.connections=50 +cassandra.timeout.pool=10000
