This is a full implementation of Erlay. Its purpose is to check the integrity and correctness of the implementation against changes/additions that may originate from the review process and/or rebases on top of newer functionality.
This is not to be merged. Functionality will be spread across multiple smaller PRs to ease the review process.
Approach
This approach uses Erlay as a fallback mechanism for transaction propagation. Instead of mixing fanout and reconciliation into a single connection type, the current approach leaves the existing connections as they are, and adds additional low-bandwidth connections to be used in case the node is being eclipsed. This connections should have minimal cost under normal circumstances, and only undergo real traffic in case other 8 full-outbound connections are being captured.
outbound-full-reconciliation connections
For now, we are adding 4 additional reconciliation-only connections to the node while we test it's impact on real node running the approach. Further analysis may be needed to pick a meaningful value for this. The number of inbound connections should also be scaled based on how many connections we are adding.
DrahtBot
commented at 12:40 PM on June 23, 2026:
contributor
<!--e57a25ab6845829454e8d69fc972939a-->
The following sections might be updated with supplementary metadata relevant to reviewers and maintainers.
See the guideline for information on the review process.
A summary of reviews will appear here.
<!--174a7506f384e20aa4161008e828411d-->
Conflicts
Reviewers, this pull request conflicts with the following ones:
#35561 (net: move some CNodeState fields to Peer by Crypt-iQ)
#35522 (refactor: Extract per-message helpers from SendMessages() (move-only) by pablomartin4btc)
#35502 (refactor: extract per-message helpers from ProcessMessage (move-only) by w0xlt)
#34824 (net: encapsulate TxRelay state and replace recursive mutexes by w0xlt)
#34628 (p2p: Replace per-peer transaction rate-limiting with global rate limits by ajtowns)
#34565 (refactor: extract BlockDownloadManager from PeerManagerImpl by w0xlt)
#28690 (build: Introduce internal kernel library by sedited)
#28463 (p2p: Increase inbound capacity for block-relay only connections by mzumsande)
If you consider this pull request important, please also help to review the conflicting pull requests. Ideally, start with the one that should be merged first.
<!--5faf32d7da4f0f540f40219e4f7537a3-->
LLM Linter (✨ experimental)
Possible typos and grammar issues:
based on it's char[] representation -> based on its char[] representation [“it's” should be the possessive “its”]
the peer have no transactions for us -> the peer has no transactions for us [subject-verb agreement is broken]
Possible places where comparison-specific test macros should replace generic comparisons:
[test/functional/p2p_txrecon_disabled.py] assert self.nodes[0].process.poll() is None, f"node crashed handling {msgname}" -> replace with assert_equal(self.nodes[0].process.poll(), None)
<sup>2026-06-24 18:52:05</sup>
refactor: redesigns txreconciliation file split and namespace
Splits the txreconciliation logic in three files instead of two, allowing the
TxreconciliationState to be properly tested, instead of being internal to
txreconciliation.cpp.
Also includes everything in the node namespace, instead of being part
of an anonymous one.
accbc3a133
refactor: remove legacy comments
These comments became irrelevant in one of the previous code changes.
They simply don't make sense anymore.
be09a3faa5
sr-gi force-pushed on Jun 23, 2026
sr-gi
commented at 1:13 PM on June 23, 2026:
member
Rebased on master.
Opening this so it can be tested against CI and to make sure nothing obvious is missing. Next step will be testing with real nodes (most likely in Warnet).
Things to consider/add:
This is currently using sendtxrcncl as a way, for outbound nodes, to signal they want to establish a full-reconciliation connection, plus adding a limit on the number of full-reconcilition inbounds that will be accepted by a node. This is not the originally intended way of using sendtxrcncl. It may be worth considering an approach based on BIP-434.
The extension phase was designed so peers with an ongoing reconciliation that had underpredicted the sketch capacity could still reconcile without having to directly fallback to fanout. Given reconciliation is now used as fallback, and the extra bandwidth may not be as problematic, it may be worth considering overshooting the initial sketch capacity and getting rid of the extension phase.
Fuzz tests are missing
DrahtBot added the label CI failed on Jun 23, 2026
sr-gi force-pushed on Jun 23, 2026
sr-gi force-pushed on Jun 23, 2026
refactor: Defines generic error to be used in several reconciliation methods33bedee44b
refactor: add full stop in existing txreconciliation LogDebug lines64c79875a7
p2p: Allows inbound reconciliation connections up to a limit
Set the current limit to 32.
d7b3c606b0
net, gui, test: adds new connection type (OUTBOUND_FULL_RECONCILIATION)
Adds a new connection type that will be used for reconciliation only.
Defines the default max number of this type of connections to 4.
46e0a20008
p2p: send SENDTXRCNCL messages only over OUTBOUND_FULL_RECONCILIATION connection2e7e258fff
DrahtBot removed the label CI failed on Jun 23, 2026
p2p: Functions to add/remove wtxids to tx reconciliation sets
They will be used later on.
Co-authored-by: Gleb Naumenko <naumenko.gs@gmail.com>
0a9d1583e1
sr-gi force-pushed on Jun 23, 2026
sr-gi
commented at 11:04 PM on June 23, 2026:
member
Fixed some typos and addressed some of the linter suggestions
Transactions are added to the reconciliation sets of reconciling peers, and processed normally for fanout peers.
26e24a6b6f
p2p: Add helper to compute reconciliation tx short ids and a cache of short ids to wtxids92362ea119
p2p: Deal with shortid collisions for reconciliation sets
If a transaction to be added to a peer's recon set has a shot id collisions (a previously
added wtxid maps to the same short id), both transaction should be fanout, given
our peer may have added the opposite transaction to our recon set, and these two
transaction won't be reconciled.
cc75da584a
p2p: Add peers to reconciliation queue on negotiation
When we're finalizing negotiation, we should add the peers
for which we will initiate reconciliations to the queue.
Co-authored-by: Gleb Naumenko <naumenko.gs@gmail.com>
3c79bd552c
p2p: Track reconciliation requests schedule
We initiate reconciliation by looking at the queue periodically
with equal intervals between peers to achieve efficiency.
This will be later used to see whether it's time to initiate.
Co-authored-by: Gleb Naumenko <naumenko.gs@gmail.com>
3cd454ee09
p2p: Initiate reconciliation round
When the time comes for the peer, we send a
reconciliation request with the parameters which
will help the peer to construct a (hopefully) sufficient
reconciliation sketch for us. We will then use that
sketch to find missing transactions.
Co-authored-by: Gleb Naumenko <naumenko.gs@gmail.com>
When the time comes, we should send a sketch of our
local reconciliation set to the reconciliation initiator.
Co-authored-by: Gleb Naumenko <naumenko.gs@gmail.com>
1e97945af6
p2p: Add a function to identify local/remote missing txs
When the sketches from both sides are combined successfully,
the diff is produced. Then this diff can (together with the local txs)
be used to identified which transactions are missing locally and remotely.
Co-authored-by: Gleb Naumenko <naumenko.gs@gmail.com>
d36c828992
Use txid/uint256 in CompareInvMempoolOrder
This will help to reuse the code later on in the function to announce transactions.
Co-authored-by: Gleb Naumenko <naumenko.gs@gmail.com>
688e1011af
p2p: Handle reconciliation sketch and successful decoding
If after decoding a reconciliation sketch it turned out
to be insufficient to find set difference, request extension.
Co-authored-by: Gleb Naumenko <naumenko.gs@gmail.com>
cfb997098b
p2p: Be ready to receive sketch extension
Store the initial sketches so that we are able to process
extension sketch while avoiding transmitting the same data.
Co-authored-by: Gleb Naumenko <naumenko.gs@gmail.com>
0b9de161fe
p2p: Prepare for sketch extension request
To be ready to respond to a sketch extension request
from our peer, we should store a snapshot of our state
and capacity of the initial sketch, so that we compute
extension of the same size and over the exact same
transactions.
Transactions arriving during this reconciliation will
be instead stored in the regular set.
Co-authored-by: Gleb Naumenko <naumenko.gs@gmail.com>
53930c2076
p2p: Keep track of announcements during txrcncl extension
If peer failed to reconcile based on our initial response sketch,
they will ask us for a sketch extension. Store this request to respond later.
Co-authored-by: Gleb Naumenko <naumenko.gs@gmail.com>
dd4c7d6e29
p2p: Respond to sketch extension request
Sending an extension may allow the peer to reconcile
transactions, because now the full sketch has twice
as much capacity.
Co-authored-by: Gleb Naumenko <naumenko.gs@gmail.com>
25b173bd80
p2p: Handle sketch extension
If a peer sent us an extension sketch, we should
reconstruct a full sketch from it with the snapshot
we stored initially, and attempt to decode the difference.
Co-authored-by: Gleb Naumenko <naumenko.gs@gmail.com>
8c133ac067
p2p: Add a finalize incoming reconciliation function
This currently unused function is supposed to be used once
a reconciliation round is done. It cleans the state corresponding
to the passed reconciliation.
Co-authored-by: Gleb Naumenko <naumenko.gs@gmail.com>
896aaf07c8
p2p: Handle reconciliation finalization message
Once a peer tells us reconciliation is done, we should behave as follows:
- if it was successful, just respond them with the transactions they asked
by short ID.
- if it was a full failure, respond with all local transactions from the reconciliation
set snapshot
- if it was a partial failure (only low or high part was failed after a bisection),
respond with all transactions which were asked for by short id,
and announce local txs which belong to the failed chunk.
Co-authored-by: Gleb Naumenko <naumenko.gs@gmail.com>
fa7b5404fe
sr-gi force-pushed on Jun 24, 2026
p2p, test: Add tx reconciliation functional tests
We may still need to add more tests, specially around extensions (if we keep them)
Co-authored-by: Gleb Naumenko <naumenko.gs@gmail.com>
d08f127a77
sr-gi force-pushed on Jun 24, 2026
DrahtBot removed the label CI failed on Jun 24, 2026
sr-gi
commented at 8:57 PM on June 24, 2026:
member
brunoerg
commented at 4:23 PM on June 29, 2026:
contributor
**Testing report (LLM/experimental) based on the results of an incremental mutation testing run for this PR - full result is avaliable at: https://bitcoincore.space**
The overall result is mixed. The PR already has useful coverage for the happy-path reconciliation flow, basic protocol violations, and some queue/timer behavior. However, the survivors show that the tests still leave several important behaviors only weakly specified, especially where reconciliation falls back, extends, or interacts with INV relay bookkeeping.
What the current tests do well
The existing tests cover the basic handshake and some normal flows reasonably well:
unit coverage for peer registration, queue rotation, set insertion/removal, and non-extension reconciliation in src/test/txreconciliation_tests.cpp
protocol-violation checks for clearly invalid message ordering and unsupported peers
That baseline is good enough to kill most straightforward mutations. The survivors are mostly about what happens around the edges of the protocol, not the central flow.
Main gaps exposed by the surviving mutants
1. Extension handling is under-tested
This is the clearest gap. Several survivors change extension behavior without being detected:
not sending REQSKETCHEXT after an undecodable sketch in net_processing
add end-to-end functional tests that force an extension round and assert the exact message sequence: REQTXRCNCL -> SKETCH -> REQSKETCHEXT -> SKETCH -> RECONCILDIFF
assert both extension success and extension failure behavior
verify that extension failure falls back to announcing the snapshotted set, not the live set
verify that state is cleared after extension completion and that a second reconciliation starts cleanly
2. Boundary conditions are not pinned down tightly enough
Several survivors change strict inequalities to inclusive ones and still pass:
remote_sketch_capacity > MAX_SKETCH_CAPACITY changed to >=
extended_capacity > MAX_SKETCH_CAPACITY * 2 changed to >=
peer_q > Q_PRECISION changed to >=
This means the tests exercise invalid-above-limit cases, but not the exact boundary values that should remain valid. There is already a good example of this style for rounded q formatting in src/test/txreconciliation_tests.cpp, but the same precision is missing for protocol acceptance thresholds.
What should be improved:
add exact-boundary tests for MAX_SKETCH_CAPACITY, 2 * MAX_SKETCH_CAPACITY, and Q_PRECISION
check both sides of each threshold: limit must pass, limit + 1 must fail
3. INV relay side effects are only partially asserted
Many survivors in PeerManagerImpl::AnnounceTxs() and the send path in SendMessages() remove or alter important side effects without breaking tests:
skipping heap construction/pop order
changing continue to break when one candidate should not be sent
not inserting into m_tx_inventory_known_filter
not erasing from m_tx_inventory_to_send
not flushing INV batches at MAX_INV_SZ
not clearing the batch after sending
The current tests mostly check that transactions eventually arrive. They do not strongly check how they are batched, filtered, or suppressed from future re-announcement. That leaves a lot of bookkeeping mutations alive.
What should be improved:
add tests with a mix of sendable and unsendable transactions and assert that later eligible transactions are still announced
assert that transactions already known to the peer are not re-announced in the next round
add a case above MAX_INV_SZ and verify the number and sizes of INV messages
verify that reconciliation and fanout paths do not duplicate announcements after internal state should have been cleared
4. Some state-management behaviors are observable in principle, but not asserted
Survivors also show weak checking around reconciliation state transitions:
not clearing m_short_id_mapping
not clearing peer state after handling a result
always taking the “removed” branch in TryRemovingFromSet
not recording m_announced_while_reconciling
returning success from queue-selection paths that should be false
These are not all equally severe, but together they indicate that the tests often validate the final external effect of a single round without checking the follow-up round that would expose stale state.
What should be improved:
add two-step tests that perform one reconciliation round and then immediately start another to detect stale snapshots, stale mappings, or stale queue state
specifically verify the “received while reconciling” behavior across the extension path, not just the non-extension path
Bottom line
The current tests are good at proving that the basic txreconciliation flow works. They are not yet strong enough to fully specify the extension path, the exact protocol boundaries, or the internal bookkeeping that prevents duplicate, truncated, or stale announcements.
If I had to prioritize follow-up work, I would do it in this order:
Add full initiator/responder extension-path functional tests.
Add exact boundary tests for sketch capacity and q.
Add stronger assertions around INV batching, filtering, and duplicate suppression.
Add second-round/state-cleanup tests to catch stale reconciliation state.
That would likely eliminate most of the meaningful survivors from this run and materially improve confidence in the PR’s tests.
This is a metadata mirror of the GitHub repository
bitcoin/bitcoin.
This site is not affiliated with GitHub.
Content is generated from a GitHub metadata backup.
generated: 2026-07-09 06:47 UTC