mirrors/bitcoin-s
1
0
Fork 0
mirror of https://github.com/bitcoin-s/bitcoin-s.git synced 2025-03-03 18:47:38 +01:00
Code Issues Projects Releases Packages Wiki Activity

Increase the default db queue size (#2047)

Browse source
This commit is contained in:
rorp 2020-09-22 09:18:42 -07:00 • committed by GitHub
parent 2458b36232
commit 7d9f546bbb
1 changed files with 6 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
db-commons-test/src/test/scala/org/bitcoins/db/DBConfigTest.scala
View file

@ -34,18 +34,21 @@ class DBConfigTest extends AnyFlatSpec with Matchers {
assert(slickChainConfig.profileName == "slick.jdbc.SQLiteProfile") assert(slickChainConfig.profileName == "slick.jdbc.SQLiteProfile")
assert(slickChainConfig.config.hasPath("db.numThreads")) assert(slickChainConfig.config.hasPath("db.numThreads"))
assert(slickChainConfig.config.getInt("db.numThreads") == 1) assert(slickChainConfig.config.getInt("db.numThreads") == 1)
assert(slickChainConfig.config.getInt("db.queueSize") == 5000)
val nodeConfig = NodeAppConfig(dataDir) val nodeConfig = NodeAppConfig(dataDir)
val slickNodeConfig = nodeConfig.slickDbConfig val slickNodeConfig = nodeConfig.slickDbConfig
assert(slickNodeConfig.profileName == "slick.jdbc.SQLiteProfile") assert(slickNodeConfig.profileName == "slick.jdbc.SQLiteProfile")
assert(slickNodeConfig.config.hasPath("db.numThreads")) assert(slickNodeConfig.config.hasPath("db.numThreads"))
assert(slickNodeConfig.config.getInt("db.numThreads") == 1) assert(slickNodeConfig.config.getInt("db.numThreads") == 1)
assert(slickNodeConfig.config.getInt("db.queueSize") == 5000)
val walletConfig = WalletAppConfig(dataDir) val walletConfig = WalletAppConfig(dataDir)
val slickWalletConfig = walletConfig.slickDbConfig val slickWalletConfig = walletConfig.slickDbConfig
assert(slickWalletConfig.profileName == "slick.jdbc.SQLiteProfile") assert(slickWalletConfig.profileName == "slick.jdbc.SQLiteProfile")
assert(slickWalletConfig.config.hasPath("db.numThreads")) assert(slickWalletConfig.config.hasPath("db.numThreads"))
assert(slickWalletConfig.config.getInt("db.numThreads") == 1) assert(slickWalletConfig.config.getInt("db.numThreads") == 1)
assert(slickWalletConfig.config.getInt("db.queueSize") == 5000)
} }
} }
@ -58,6 +61,7 @@ class DBConfigTest extends AnyFlatSpec with Matchers {
assert(slickChainConfig.config.getInt("db.numThreads") == 3) assert(slickChainConfig.config.getInt("db.numThreads") == 3)
assert( assert(
slickChainConfig.config.getString("db.connectionPool") == "disabled") slickChainConfig.config.getString("db.connectionPool") == "disabled")
assert(slickChainConfig.config.getInt("db.queueSize") == 5000)
val nodeConfig = NodeAppConfig(dataDir) val nodeConfig = NodeAppConfig(dataDir)
val slickNodeConfig = nodeConfig.slickDbConfig val slickNodeConfig = nodeConfig.slickDbConfig
@ -66,6 +70,7 @@ class DBConfigTest extends AnyFlatSpec with Matchers {
assert(slickNodeConfig.config.getInt("db.numThreads") == 3) assert(slickNodeConfig.config.getInt("db.numThreads") == 3)
assert( assert(
slickNodeConfig.config.getString("db.connectionPool") == "disabled") slickNodeConfig.config.getString("db.connectionPool") == "disabled")
assert(slickNodeConfig.config.getInt("db.queueSize") == 5000)
val walletConfig = WalletAppConfig(dataDir) val walletConfig = WalletAppConfig(dataDir)
val slickWalletConfig = walletConfig.slickDbConfig val slickWalletConfig = walletConfig.slickDbConfig
@ -74,6 +79,7 @@ class DBConfigTest extends AnyFlatSpec with Matchers {
assert(slickWalletConfig.config.getInt("db.numThreads") == 3) assert(slickWalletConfig.config.getInt("db.numThreads") == 3)
assert( assert(
slickWalletConfig.config.getString("db.connectionPool") == "disabled") slickWalletConfig.config.getString("db.connectionPool") == "disabled")
assert(slickWalletConfig.config.getInt("db.queueSize") == 5000)
} }
} }