voidlizard
/
hbs2
mirror of https://github.com/voidlizard/hbs2
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

removed-extra-spaces

This commit is contained in:
Dmitry Zuikov 2023-05-23 06:01:19 +03:00
parent 012eb5bc9f
commit 69abfcf7e5
1 changed files with 9 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
hbs2-peer/app/PeerMain.hs
View File

@ -729,19 +729,19 @@ runPeer opts = Exception.handle myException $ do
-- peerThread "tcpWorker" (tcpWorker conf) -- peerThread "tcpWorker" (tcpWorker conf)
peerThread "httpWorker " (httpWorker conf denv) peerThread "httpWorker" (httpWorker conf denv)
peerThread "checkMetrics " (checkMetrics metrics) peerThread "checkMetrics" (checkMetrics metrics)
peerThread "peerPingLoop " (peerPingLoop @e conf) peerThread "peerPingLoop" (peerPingLoop @e conf)
peerThread "knownPeersPingLoop " (knownPeersPingLoop @e conf) peerThread "knownPeersPingLoop" (knownPeersPingLoop @e conf)
peerThread "bootstrapDnsLoop " (bootstrapDnsLoop @e conf) peerThread "bootstrapDnsLoop" (bootstrapDnsLoop @e conf)
peerThread "pexLoop " (pexLoop @e) peerThread "pexLoop" (pexLoop @e)
peerThread "blockDownloadLoop " (blockDownloadLoop denv) peerThread "blockDownloadLoop" (blockDownloadLoop denv)
let tcpProbeWait :: Timeout 'Seconds let tcpProbeWait :: Timeout 'Seconds
tcpProbeWait = (fromInteger . fromMaybe 300) (cfgValue @PeerTcpProbeWaitKey conf) tcpProbeWait = (fromInteger . fromMaybe 300) (cfgValue @PeerTcpProbeWaitKey conf)
@ -751,13 +751,13 @@ runPeer opts = Exception.handle myException $ do
-- FIXME: clumsy-code -- FIXME: clumsy-code
-- Is it better now ? -- Is it better now ?
when useHttpDownload do when useHttpDownload do
peerThread "blockHttpDownloadLoop " (blockHttpDownloadLoop denv) peerThread "blockHttpDownloadLoop" (blockHttpDownloadLoop denv)
peerThread "postponedLoop" (postponedLoop denv) peerThread "postponedLoop" (postponedLoop denv)
peerThread "downloadQueue" (downloadQueue conf denv) peerThread "downloadQueue" (downloadQueue conf denv)
peerThread "reflogWorker " (reflogWorker @e conf rwa) peerThread "reflogWorker" (reflogWorker @e conf rwa)
peerThread "ping pong" $ forever $ do peerThread "ping pong" $ forever $ do
cmd <- liftIO $ atomically $ readTQueue rpcQ cmd <- liftIO $ atomically $ readTQueue rpcQ