Skip to content
This repository was archived by the owner on Aug 18, 2020. It is now read-only.

Commit 5cdad07

Browse files
committed
fixes after rebase conflicts
1 parent 4df5009 commit 5cdad07

File tree

4 files changed

+7
-16
lines changed

4 files changed

+7
-16
lines changed

src/exec/DB.hs

Lines changed: 2 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -27,8 +27,7 @@ import qualified Ouroboros.Consensus.Ledger.Byron as Byron
2727
import Ouroboros.Consensus.Ledger.Byron.Config (ByronConfig)
2828
import Ouroboros.Consensus.Ledger.Extended (ExtLedgerState)
2929
import Ouroboros.Consensus.Protocol (NodeConfig)
30-
import Ouroboros.Consensus.Protocol.Abstract (SecurityParam (..),
31-
protocolSecurityParam)
30+
import Ouroboros.Consensus.Protocol.Abstract (protocolSecurityParam)
3231
import Ouroboros.Consensus.Util.ResourceRegistry (ResourceRegistry)
3332
import qualified Ouroboros.Consensus.Util.ResourceRegistry as ResourceRegistry
3433
import Ouroboros.Storage.ChainDB.API (ChainDB)
@@ -130,7 +129,5 @@ withDB dbOptions dbTracer indexTracer rr nodeConfig extLedgerState k = do
130129
}
131130
bracket (ChainDB.openDB chainDBArgs) ChainDB.closeDB $ \cdb ->
132131
Sqlite.withIndexAuto epochSlots indexTracer (indexFilePath dbOptions) $ \idx -> do
133-
-- TBD do we need withRegistry in there or not?
134-
-- _ <- ResourceRegistry.forkLinkedThread rr $ ResourceRegistry.withRegistry $ \rr' -> Index.trackChainDB rr' idx cdb
135-
_ <- ResourceRegistry.forkLinkedThread rr $ Index.trackChainDB rr idx cdb
132+
_ <- ResourceRegistry.forkLinkedThread rr $ Index.trackChainDB rr idx cdb (protocolSecurityParam nodeConfig)
136133
k idx cdb

src/exec/Main.hs

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -55,7 +55,6 @@ import qualified Pos.Infra.Network.CLI as CSL (NetworkConfigOpts (..),
5555
launchStaticConfigMonitoring,
5656
listenNetworkAddressOption)
5757
import Pos.Infra.Network.Types (NetworkConfig (..))
58-
import qualified Pos.Infra.Network.Policy as Policy
5958
import qualified Pos.Launcher.Configuration as CSL (Configuration (..),
6059
ConfigurationOptions (..))
6160
import qualified Pos.Client.CLI.Options as CSL (configurationOptionsParser)
@@ -387,7 +386,7 @@ runByron tracer byronOptions genesisConfig blockConfig updateConfig nodeConfig e
387386
blockConfig
388387
updateConfig
389388
nodeConfig
390-
networkConfig'
389+
networkConfig
391390
64 -- Batch size.
392391
trace
393392
genesisBlock = CSL.genesisBlock0 (CSL.configProtocolMagic genesisConfig)

src/lib/Ouroboros/Byron/Proxy/Block.hs

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,6 @@ module Ouroboros.Byron.Proxy.Block
2424
) where
2525

2626
import qualified Codec.CBOR.Write as CBOR (toStrictByteString)
27-
import qualified Data.ByteString.Lazy as Lazy
2827
import Data.Word (Word64)
2928

3029
import qualified Pos.Chain.Block as CSL (HeaderHash)

src/lib/Ouroboros/Byron/Proxy/Index/ChainDB.hs

Lines changed: 4 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -67,14 +67,13 @@ trackReader idx reader = do
6767
-- ChainDB. If none are in it, then the entire index will be rebuild (rollback
6868
-- to Origin).
6969
trackChainDB
70-
:: forall blk t .
70+
:: forall blk void .
7171
ResourceRegistry IO
7272
-> Index IO (Header blk)
7373
-> ChainDB IO blk
7474
-> SecurityParam
75-
-> IO t
76-
-> IO t
77-
trackChainDB rr idx cdb k act = bracket acquireReader releaseReader $ \rdr -> do
75+
-> IO void
76+
trackChainDB rr idx cdb k = bracket acquireReader releaseReader $ \rdr -> do
7877
checkpoints <- Index.streamFromTip idx checkpointsFold
7978
mPoint <- ChainDB.readerForward rdr checkpoints
8079
case mPoint of
@@ -90,10 +89,7 @@ trackChainDB rr idx cdb k act = bracket acquireReader releaseReader $ \rdr -> do
9089
-- First, block until the index is caught up to the tip ...
9190
trackReader idx rdr
9291
-- ... then attempt to stay in sync.
93-
outcome <- race (trackReaderBlocking idx rdr) act
94-
case outcome of
95-
Left impossible -> impossible
96-
Right t -> pure t
92+
trackReaderBlocking idx rdr
9793
where
9894
acquireReader :: IO (Reader IO blk (Header blk))
9995
acquireReader = ChainDB.newHeaderReader cdb rr

0 commit comments

Comments
 (0)