Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
23 changes: 23 additions & 0 deletions dmq-node/changelog.d/20260622_194001_crocodile-dentist.md
Original file line number Diff line number Diff line change
@@ -0,0 +1,23 @@
<!--
A new scriv changelog fragment.

Uncomment the section that is right (remove the HTML comment wrapper).
For top level release notes, leave all the headers commented out.
-->

<!--
### Breaking

- A bullet item for the Breaking category.

-->
### Non-Breaking

- Bugfix: don't set block point slot to maxBound for big ledger peers in local state query client

<!--
### Patch

- A bullet item for the Patch category.

-->
10 changes: 3 additions & 7 deletions dmq-node/src/DMQ/NodeToClient/LocalStateQueryClient.hs
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,6 @@ import Control.Monad.Class.MonadTime.SI
import Control.Monad.Class.MonadTimer.SI
import Control.Monad.Trans.Except
import "contra-tracer" Control.Tracer (Tracer, traceWith)
import Data.Functor ((<&>))
import Data.List.NonEmpty qualified as NonEmpty
import Data.Void

Expand All @@ -46,8 +45,7 @@ import Ouroboros.Consensus.Shelley.Ledger.Query
import Ouroboros.Consensus.Shelley.Ledger.SupportsProtocol ()
import Ouroboros.Network.Block
import Ouroboros.Network.PeerSelection.LedgerPeers (LedgerPeersKind (..),
RawBlockHash, accumulateBigLedgerStake)
import Ouroboros.Network.Point (Block (..))
accumulateBigLedgerStake)
import Ouroboros.Network.Protocol.LocalStateQuery.Client
import Ouroboros.Network.Protocol.LocalStateQuery.Type

Expand Down Expand Up @@ -259,9 +257,7 @@ cardanoLocalStateQueryClient tracer ledgerPeers
relays
, not (null relays')
]
pt' :: Point RawBlockHash
pt' = Point $ getPoint pt <&>
\blk -> blk { blockPointSlot = maxBound }

srvRelays = force
[ (stake, NonEmpty.fromList relays')
| (stake, relays) <- peers
Expand All @@ -276,7 +272,7 @@ cardanoLocalStateQueryClient tracer ledgerPeers

atomically do
writeTMVar ledgerPeersVar $ LedgerAllPeerSnapshotV23 pt magic srvRelays
writeTVar ledgerBigPeersVar . Just $! LedgerBigPeerSnapshotV23 pt' magic bigSrvRelays
writeTVar ledgerBigPeersVar . Just $! LedgerBigPeerSnapshotV23 pt magic bigSrvRelays

pure $ release systemStart nextEpoch

Expand Down
Loading