mirrors/bitcoin-s
1
0
Fork 0
mirror of https://github.com/bitcoin-s/bitcoin-s.git synced 2025-01-19 05:43:51 +01:00
Code Issues Packages Projects Releases Wiki Activity

Parallelize some startup on startBitcoinSBackend() to increase performance (#4217)

Browse Source 
* Parallelize some startup on startBitcoinSBackend() to increase performance

* Fix compile on 2.12.x
This commit is contained in:
Chris Stewart 2022-04-19 08:31:53 -05:00 committed by GitHub
parent f42d7ae8e7
commit e3e59923c4
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 26 additions and 19 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

45
app/server/src/main/scala/org/bitcoins/server/BitcoinSServerMain.scala
View File

@ -166,41 +166,35 @@ class BitcoinSServerMain(override val serverArgParser: ServerArgParser)(implicit
val wsQueue: SourceQueueWithComplete[Message] = tuple._1
val wsSource: Source[Message, NotUsed] = tuple._2
val callbacksF =
chainApiF.map(chainApi => buildNeutrinoCallbacks(wsQueue, chainApi))
val startedNodeF = configuredNodeF.flatMap(_.start())
val startedWalletF = configuredWalletF.flatMap(_.start())
val startedDLCNodeF = dlcNodeF
.flatMap(_.start())
.flatMap(_ => dlcNodeF)
//start our http server now that we are synced
for {
node <- configuredNodeF
wallet <- configuredWalletF
_ <- node.start()
_ <- wallet.start().recoverWith {
//https://github.com/bitcoin-s/bitcoin-s/issues/2917
//https://github.com/bitcoin-s/bitcoin-s/pull/2918
case err: IllegalArgumentException
if err.getMessage.contains("If we have spent a spendinginfodb") =>
handleMissingSpendingInfoDb(err, wallet)
}
node <- startedNodeF
_ <- startedWalletF
cachedChainApi <- node.chainApiFromDb()
chainApi = ChainHandler.fromChainHandlerCached(cachedChainApi)
dlcNode <- dlcNodeF
_ <- dlcNode.start()
dlcNode <- startedDLCNodeF
_ <- startHttpServer(nodeApi = node,
chainApi = chainApi,
wallet = wallet,
dlcNode = dlcNode,
serverCmdLineArgs = serverArgParser,
wsSource = wsSource)
chainCallbacks = WebsocketUtil.buildChainCallbacks(wsQueue, chainApi)
_ = chainConf.addCallbacks(chainCallbacks)
walletCallbacks = WebsocketUtil.buildWalletCallbacks(wsQueue)
_ = walletConf.addCallbacks(walletCallbacks)
dlcWalletCallbacks = WebsocketUtil.buildDLCWalletCallbacks(wsQueue)
_ = dlcConf.addCallbacks(dlcWalletCallbacks)
_ = {
logger.info(
s"Starting ${nodeConf.nodeType.shortName} node sync, it took=${System
.currentTimeMillis() - start}ms")
}
//make sure callbacks are registered before we start sync
_ <- callbacksF
_ <- node.sync()
} yield {
logger.info(
@ -209,6 +203,19 @@ class BitcoinSServerMain(override val serverArgParser: ServerArgParser)(implicit
}
}
private def buildNeutrinoCallbacks(
wsQueue: SourceQueueWithComplete[Message],
chainApi: ChainApi): Unit = {
val chainCallbacks = WebsocketUtil.buildChainCallbacks(wsQueue, chainApi)
chainConf.addCallbacks(chainCallbacks)
val walletCallbacks = WebsocketUtil.buildWalletCallbacks(wsQueue)
walletConf.addCallbacks(walletCallbacks)
val dlcWalletCallbacks = WebsocketUtil.buildDLCWalletCallbacks(wsQueue)
dlcConf.addCallbacks(dlcWalletCallbacks)
()
}
/** Returns blockchain info, in case of [[InWarmUp]] exception it retries.
*/
private def getBlockChainInfo(