raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 11

Change defaults for Netty pools, see #3346

Browse source 
server-socket-worker-pool.pool-size-max = 2
client-socket-worker-pool.pool-size-max = 2
This commit is contained in:
Patrik Nordwall 2013-05-17 12:05:03 +02:00
parent e6b4e64211
commit 3d2db10787
7 changed files with 4 additions and 14 deletions
Download patch file Download diff file Expand all files Collapse all files

2
akka-docs/rst/scala/code/docs/remoting/RemoteDeploymentDocSpec.scala
View file

@ -22,8 +22,6 @@ class RemoteDeploymentDocSpec extends AkkaSpec("""
akka.actor.provider = "akka.remote.RemoteActorRefProvider" akka.actor.provider = "akka.remote.RemoteActorRefProvider"
akka.remote.netty.tcp { akka.remote.netty.tcp {
port = 0 port = 0
server-socket-worker-pool.pool-size-max = 2
client-socket-worker-pool.pool-size-max = 2
} }
""") with ImplicitSender { """) with ImplicitSender {

4
akka-remote/src/main/resources/reference.conf
View file

@ -370,7 +370,7 @@ akka {
pool-size-factor = 1.0 pool-size-factor = 1.0
# Max number of threads to cap factor-based number to # Max number of threads to cap factor-based number to
pool-size-max = 8 pool-size-max = 2
} }
# Used to configure the number of I/O worker threads on client sockets # Used to configure the number of I/O worker threads on client sockets
@ -385,7 +385,7 @@ akka {
pool-size-factor = 1.0 pool-size-factor = 1.0
# Max number of threads to cap factor-based number to # Max number of threads to cap factor-based number to
pool-size-max = 8 pool-size-max = 2
} }

4
akka-remote/src/test/scala/akka/remote/RemoteConfigSpec.scala
View file

@ -93,7 +93,7 @@ class RemoteConfigSpec extends AkkaSpec(
pool.getInt("pool-size-min") must equal(2) pool.getInt("pool-size-min") must equal(2)
pool.getDouble("pool-size-factor") must equal(1.0) pool.getDouble("pool-size-factor") must equal(1.0)
pool.getInt("pool-size-max") must equal(8) pool.getInt("pool-size-max") must equal(2)
} }
// client-socket-worker-pool // client-socket-worker-pool
@ -101,7 +101,7 @@ class RemoteConfigSpec extends AkkaSpec(
val pool = c.getConfig("client-socket-worker-pool") val pool = c.getConfig("client-socket-worker-pool")
pool.getInt("pool-size-min") must equal(2) pool.getInt("pool-size-min") must equal(2)
pool.getDouble("pool-size-factor") must equal(1.0) pool.getDouble("pool-size-factor") must equal(1.0)
pool.getInt("pool-size-max") must equal(8) pool.getInt("pool-size-max") must equal(2)
} }
} }

2
akka-remote/src/test/scala/akka/remote/RemoteDeathWatchSpec.scala
View file

@ -21,8 +21,6 @@ akka {
remote.netty.tcp { remote.netty.tcp {
hostname = "localhost" hostname = "localhost"
port = 0 port = 0
server-socket-worker-pool.pool-size-max = 2
client-socket-worker-pool.pool-size-max = 2
} }
} }
""")) with ImplicitSender with DefaultTimeout with DeathWatchSpec { """)) with ImplicitSender with DefaultTimeout with DeathWatchSpec {

2
akka-remote/src/test/scala/akka/remote/RemoteRouterSpec.scala
View file

@ -24,8 +24,6 @@ akka {
remote.netty.tcp { remote.netty.tcp {
hostname = localhost hostname = localhost
port = 0 port = 0
server-socket-worker-pool.pool-size-max = 2
client-socket-worker-pool.pool-size-max = 2
} }
actor.deployment { actor.deployment {
/blub { /blub {

2
akka-remote/src/test/scala/akka/remote/RemotingSpec.scala
View file

@ -72,8 +72,6 @@ object RemotingSpec {
common-netty-settings { common-netty-settings {
port = 0 port = 0
hostname = "localhost" hostname = "localhost"
server-socket-worker-pool.pool-size-max = 2
client-socket-worker-pool.pool-size-max = 2
} }
akka { akka {

2
akka-remote/src/test/scala/akka/remote/transport/AkkaProtocolStressTest.scala
View file

@ -30,8 +30,6 @@ object AkkaProtocolStressTest {
remote.netty.tcp { remote.netty.tcp {
applied-adapters = ["gremlin"] applied-adapters = ["gremlin"]
port = 0 port = 0
server-socket-worker-pool.pool-size-max = 2
client-socket-worker-pool.pool-size-max = 2
} }
} }