This repository was archived by the owner on Aug 18, 2020. It is now read-only.
File tree 3 files changed +6
-13
lines changed
lib/Ouroboros/Byron/Proxy/Index 3 files changed +6
-13
lines changed Original file line number Diff line number Diff line change @@ -129,7 +129,5 @@ withDB dbOptions dbTracer indexTracer rr nodeConfig extLedgerState k = do
129
129
}
130
130
bracket (ChainDB. openDB chainDBArgs) ChainDB. closeDB $ \ cdb ->
131
131
Sqlite. withIndexAuto epochSlots indexTracer (indexFilePath dbOptions) $ \ idx -> do
132
- -- TBD do we need withRegistry in there or not?
133
- -- _ <- ResourceRegistry.forkLinkedThread rr $ ResourceRegistry.withRegistry $ \rr' -> Index.trackChainDB rr' idx cdb
134
- _ <- ResourceRegistry. forkLinkedThread rr $ Index. trackChainDB rr idx cdb
132
+ _ <- ResourceRegistry. forkLinkedThread rr $ Index. trackChainDB rr idx cdb (protocolSecurityParam nodeConfig)
135
133
k idx cdb
Original file line number Diff line number Diff line change @@ -55,7 +55,6 @@ import qualified Pos.Infra.Network.CLI as CSL (NetworkConfigOpts (..),
55
55
launchStaticConfigMonitoring ,
56
56
listenNetworkAddressOption )
57
57
import Pos.Infra.Network.Types (NetworkConfig (.. ))
58
- import qualified Pos.Infra.Network.Policy as Policy
59
58
import qualified Pos.Launcher.Configuration as CSL (Configuration (.. ),
60
59
ConfigurationOptions (.. ))
61
60
import qualified Pos.Client.CLI.Options as CSL (configurationOptionsParser )
@@ -388,7 +387,7 @@ runByron tracer byronOptions genesisConfig blockConfig updateConfig nodeConfig e
388
387
blockConfig
389
388
updateConfig
390
389
nodeConfig
391
- networkConfig'
390
+ networkConfig
392
391
64 -- Batch size.
393
392
trace
394
393
genesisBlock = CSL. genesisBlock0 (CSL. configProtocolMagic genesisConfig)
Original file line number Diff line number Diff line change @@ -68,14 +68,13 @@ trackReader idx reader = do
68
68
-- ChainDB. If none are in it, then the entire index will be rebuild (rollback
69
69
-- to Origin).
70
70
trackChainDB
71
- :: forall blk t .
71
+ :: forall blk void .
72
72
ResourceRegistry IO
73
73
-> Index IO (Header blk )
74
74
-> ChainDB IO blk
75
75
-> SecurityParam
76
- -> IO t
77
- -> IO t
78
- trackChainDB rr idx cdb k act = bracket acquireReader releaseReader $ \ rdr -> do
76
+ -> IO void
77
+ trackChainDB rr idx cdb k = bracket acquireReader releaseReader $ \ rdr -> do
79
78
checkpoints <- Index. streamFromTip idx checkpointsFold
80
79
mPoint <- ChainDB. readerForward rdr checkpoints
81
80
case mPoint of
@@ -91,10 +90,7 @@ trackChainDB rr idx cdb k act = bracket acquireReader releaseReader $ \rdr -> do
91
90
-- First, block until the index is caught up to the tip ...
92
91
trackReader idx rdr
93
92
-- ... then attempt to stay in sync.
94
- outcome <- race (trackReaderBlocking idx rdr) act
95
- case outcome of
96
- Left impossible -> impossible
97
- Right t -> pure t
93
+ trackReaderBlocking idx rdr
98
94
where
99
95
acquireReader :: IO (Reader IO blk (Header blk ))
100
96
acquireReader = ChainDB. newHeaderReader cdb rr
You can’t perform that action at this time.
0 commit comments