[incubator-openwhisk] branch master updated: Increase the number of max open requests (#2951)

[je...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

jeremiaswerner pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-openwhisk.git


The following commit(s) were added to refs/heads/master by this push:
     new 0cb847c  Increase the number of max open requests (#2951)
0cb847c is described below

commit 0cb847c0906f58fee1166938977708d99261c1c5
Author: Vadim Raskin <ra...@gmail.com>
AuthorDate: Thu Nov 16 13:15:52 2017 +0100

    Increase the number of max open requests (#2951)
---
 common/scala/src/main/resources/application.conf                       | 2 +-
 common/scala/src/main/scala/whisk/core/database/CouchDbRestStore.scala | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/common/scala/src/main/resources/application.conf b/common/scala/src/main/resources/application.conf
index 683a804..1968e90 100644
--- a/common/scala/src/main/resources/application.conf
+++ b/common/scala/src/main/resources/application.conf
@@ -9,7 +9,7 @@ akka.http {
 
     host-connection-pool {
         max-connections = 128
-        max-open-requests = 128
+        max-open-requests = 512
     }
 }
 
diff --git a/common/scala/src/main/scala/whisk/core/database/CouchDbRestStore.scala b/common/scala/src/main/scala/whisk/core/database/CouchDbRestStore.scala
index 298cf09..2127f86 100644
--- a/common/scala/src/main/scala/whisk/core/database/CouchDbRestStore.scala
+++ b/common/scala/src/main/scala/whisk/core/database/CouchDbRestStore.scala
@@ -71,7 +71,7 @@ class CouchDbRestStore[DocumentAbstraction <: DocumentSerializer](dbProtocol: St
 
   // This the the amount of allowed parallel requests for each entity, before batching starts. If there are already maxOpenDbRequests
   // and more documents need to be stored, then all arriving documents will be put into batches (if enabled) to avoid a long queue.
-  private val maxOpenDbRequests = system.settings.config.getInt("akka.http.host-connection-pool.max-open-requests") / 2
+  private val maxOpenDbRequests = system.settings.config.getInt("akka.http.host-connection-pool.max-connections") / 2
 
   private val batcher: Batcher[JsObject, Either[ArtifactStoreException, DocInfo]] =
     new Batcher(500, maxOpenDbRequests)(put(_)(TransactionId.unknown))

-- 
To stop receiving notification emails like this one, please contact
['"commits@openwhisk.apache.org" <co...@openwhisk.apache.org>'].