Skip to content

Commit 376ab85

Browse files
committed
Split peer sampling spec from das-core.md
1 parent 4bd2f92 commit 376ab85

File tree

3 files changed

+127
-120
lines changed

3 files changed

+127
-120
lines changed

specs/_features/eip7594/das-core.md

Lines changed: 5 additions & 113 deletions
Original file line numberDiff line numberDiff line change
@@ -23,21 +23,14 @@
2323
- [`compute_extended_matrix`](#compute_extended_matrix)
2424
- [`recover_matrix`](#recover_matrix)
2525
- [`get_data_column_sidecars`](#get_data_column_sidecars)
26-
- [`get_extended_sample_count`](#get_extended_sample_count)
2726
- [Custody](#custody)
2827
- [Custody requirement](#custody-requirement)
2928
- [Public, deterministic selection](#public-deterministic-selection)
30-
- [Peer discovery](#peer-discovery)
29+
- [Subnet sampling](#subnet-sampling)
3130
- [Extended data](#extended-data)
3231
- [Column gossip](#column-gossip)
3332
- [Parameters](#parameters)
34-
- [Peer sampling](#peer-sampling)
35-
- [Sample selection](#sample-selection)
36-
- [Sample queries](#sample-queries)
37-
- [Peer scoring](#peer-scoring)
3833
- [Reconstruction and cross-seeding](#reconstruction-and-cross-seeding)
39-
- [DAS providers](#das-providers)
40-
- [A note on fork choice](#a-note-on-fork-choice)
4134
- [FAQs](#faqs)
4235
- [Row (blob) custody](#row-blob-custody)
4336
- [Subnet stability](#subnet-stability)
@@ -75,15 +68,14 @@ The following values are (non-configurable) constants used throughout the specif
7568

7669
| Name | Value | Description |
7770
| - | - | - |
78-
| `DATA_COLUMN_SIDECAR_SUBNET_COUNT` | `32` | The number of data column sidecar subnets used in the gossipsub protocol |
71+
| `DATA_COLUMN_SIDECAR_SUBNET_COUNT` | `128` | The number of data column sidecar subnets used in the gossipsub protocol |
7972

8073
### Custody setting
8174

8275
| Name | Value | Description |
8376
| - | - | - |
8477
| `SAMPLES_PER_SLOT` | `8` | Number of `DataColumnSidecar` random samples a node queries per slot |
85-
| `CUSTODY_REQUIREMENT` | `1` | Minimum number of subnets an honest node custodies and serves samples from |
86-
| `TARGET_NUMBER_OF_PEERS` | `70` | Suggested minimum peer count |
78+
| `CUSTODY_REQUIREMENT` | `4` | Minimum number of subnets an honest node custodies and serves samples from |
8779

8880
### Containers
8981

@@ -227,48 +219,6 @@ def get_data_column_sidecars(signed_block: SignedBeaconBlock,
227219
return sidecars
228220
```
229221

230-
#### `get_extended_sample_count`
231-
232-
```python
233-
def get_extended_sample_count(allowed_failures: uint64) -> uint64:
234-
assert 0 <= allowed_failures <= NUMBER_OF_COLUMNS // 2
235-
"""
236-
Return the sample count if allowing failures.
237-
238-
This helper demonstrates how to calculate the number of columns to query per slot when
239-
allowing given number of failures, assuming uniform random selection without replacement.
240-
Nested functions are direct replacements of Python library functions math.comb and
241-
scipy.stats.hypergeom.cdf, with the same signatures.
242-
"""
243-
244-
def math_comb(n: int, k: int) -> int:
245-
if not 0 <= k <= n:
246-
return 0
247-
r = 1
248-
for i in range(min(k, n - k)):
249-
r = r * (n - i) // (i + 1)
250-
return r
251-
252-
def hypergeom_cdf(k: uint64, M: uint64, n: uint64, N: uint64) -> float:
253-
# NOTE: It contains float-point computations.
254-
# Convert uint64 to Python integers before computations.
255-
k = int(k)
256-
M = int(M)
257-
n = int(n)
258-
N = int(N)
259-
return sum([math_comb(n, i) * math_comb(M - n, N - i) / math_comb(M, N)
260-
for i in range(k + 1)])
261-
262-
worst_case_missing = NUMBER_OF_COLUMNS // 2 + 1
263-
false_positive_threshold = hypergeom_cdf(0, NUMBER_OF_COLUMNS,
264-
worst_case_missing, SAMPLES_PER_SLOT)
265-
for sample_count in range(SAMPLES_PER_SLOT, NUMBER_OF_COLUMNS + 1):
266-
if hypergeom_cdf(allowed_failures, NUMBER_OF_COLUMNS,
267-
worst_case_missing, sample_count) <= false_positive_threshold:
268-
break
269-
return sample_count
270-
```
271-
272222
## Custody
273223

274224
### Custody requirement
@@ -285,17 +235,9 @@ The particular columns that a node custodies are selected pseudo-randomly as a f
285235

286236
*Note*: increasing the `custody_size` parameter for a given `node_id` extends the returned list (rather than being an entirely new shuffle) such that if `custody_size` is unknown, the default `CUSTODY_REQUIREMENT` will be correct for a subset of the node's custody.
287237

288-
## Peer discovery
289-
290-
At each slot, a node needs to be able to readily sample from *any* set of columns. To this end, a node SHOULD find and maintain a set of diverse and reliable peers that can regularly satisfy their sampling demands.
238+
## Subnet sampling
291239

292-
A node runs a background peer discovery process, maintaining at least `TARGET_NUMBER_OF_PEERS` of various custody distributions (both `custody_size` and column assignments). The combination of advertised `custody_size` size and public node-id make this readily and publicly accessible.
293-
294-
`TARGET_NUMBER_OF_PEERS` should be tuned upward in the event of failed sampling.
295-
296-
*Note*: while high-capacity and super-full nodes are high value with respect to satisfying sampling requirements, a node SHOULD maintain a distribution across node capacities as to not centralize the p2p graph too much (in the extreme becomes hub/spoke) and to distribute sampling load better across all nodes.
297-
298-
*Note*: A DHT-based peer discovery mechanism is expected to be utilized in the above. The beacon-chain network currently utilizes discv5 in a similar method as described for finding peers of particular distributions of attestation subnets. Additional peer discovery methods are valuable to integrate (e.g., latent peer discovery via libp2p gossipsub) to add a defense in breadth against one of the discovery methods being attacked.
240+
At each slot, a node advertising `custody_subnet_count` downloads a minimum of `subnet_sampling_size = max(SAMPLES_PER_SLOT, custody_subnet_count)` total subnets. The corresponding set of columns is selected by `get_custody_columns(node_id, subnet_sampling_size)`, so that in particular the subset of columns to custody is consistent with the output of `get_custody_columns(node_id, custody_subnet_count)`. Sampling is considered successful if the node manages to retrieve all selected columns.
299241

300242
## Extended data
301243

@@ -309,36 +251,6 @@ For each column -- use `data_column_sidecar_{subnet_id}` subnets, where `subnet_
309251

310252
Verifiable samples from their respective column are distributed on the assigned subnet. To custody a particular column, a node joins the respective gossipsub subnet. If a node fails to get a column on the column subnet, a node can also utilize the Req/Resp protocol to query the missing column from other peers.
311253

312-
## Peer sampling
313-
314-
### Sample selection
315-
316-
At each slot, a node SHOULD select at least `SAMPLES_PER_SLOT` column IDs for sampling. It is recommended to use uniform random selection without replacement based on local randomness. Sampling is considered successful if the node manages to retrieve all selected columns.
317-
318-
Alternatively, a node MAY use a method that selects more than `SAMPLES_PER_SLOT` columns while allowing some missing, respecting the same target false positive threshold (the probability of successful sampling of an unavailable block) as dictated by the `SAMPLES_PER_SLOT` parameter. If using uniform random selection without replacement, a node can use the `get_extended_sample_count(allowed_failures) -> sample_count` helper function to determine the sample count (number of unique column IDs) for any selected number of allowed failures. Sampling is then considered successful if any `sample_count - allowed_failures` columns are retrieved successfully.
319-
320-
For reference, the table below shows the number of samples and the number of allowed missing columns assuming `NUMBER_OF_COLUMNS = 128` and `SAMPLES_PER_SLOT = 16`.
321-
322-
| Allowed missing | 0| 1| 2| 3| 4| 5| 6| 7| 8|
323-
|-----------------|--|--|--|--|--|--|--|--|--|
324-
| Sample count |16|20|24|27|29|32|35|37|40|
325-
326-
### Sample queries
327-
328-
A node SHOULD maintain a diverse set of peers for each column and each slot by verifying responsiveness to sample queries.
329-
330-
A node SHOULD query for samples from selected peers via `DataColumnSidecarsByRoot` request. A node utilizes `get_custody_columns` helper to determine which peer(s) it could request from, identifying a list of candidate peers for each selected column.
331-
332-
If more than one candidate peer is found for a given column, a node SHOULD randomize its peer selection to distribute sample query load in the network. Nodes MAY use peer scoring to tune this selection (for example, by using weighted selection or by using a cut-off threshold). If possible, it is also recommended to avoid requesting many columns from the same peer in order to avoid relying on and exposing the sample selection to a single peer.
333-
334-
If a node already has a column because of custody, it is not required to send out queries for that column.
335-
336-
If a node has enough good/honest peers across all columns, and the data is being made available, the above procedure has a high chance of success.
337-
338-
## Peer scoring
339-
340-
Due to the deterministic custody functions, a node knows exactly what a peer should be able to respond to. In the event that a peer does not respond to samples of their custodied rows/columns, a node may downscore or disconnect from a peer.
341-
342254
## Reconstruction and cross-seeding
343255

344256
If the node obtains 50%+ of all the columns, it SHOULD reconstruct the full data matrix via `recover_matrix` helper. Nodes MAY delay this reconstruction allowing time for other columns to arrive over the network. If delaying reconstruction, nodes may use a random delay in order to desynchronize reconstruction among nodes, thus reducing overall CPU load.
@@ -351,26 +263,6 @@ Once the node obtains a column through reconstruction, the node MUST expose the
351263

352264
*Note*: There may be anti-DoS and quality-of-service considerations around how to send samples and consider samples -- is each individual sample a message or are they sent in aggregate forms.
353265

354-
## DAS providers
355-
356-
A DAS provider is a consistently-available-for-DAS-queries, super-full (or high capacity) node. To the p2p, these look just like other nodes but with high advertised capacity, and they should generally be able to be latently found via normal discovery.
357-
358-
DAS providers can also be found out-of-band and configured into a node to connect to directly and prioritize. Nodes can add some set of these to their local configuration for persistent connection to bolster their DAS quality of service.
359-
360-
Such direct peering utilizes a feature supported out of the box today on all nodes and can complement (and reduce attackability and increase quality-of-service) alternative peer discovery mechanisms.
361-
362-
## A note on fork choice
363-
364-
*Fork choice spec TBD, but it will just be a replacement of `is_data_available()` call in Deneb with column sampling instead of full download. Note the `is_data_available(slot_N)` will likely do a `-1` follow distance so that you just need to check the availability of slot `N-1` for slot `N` (starting with the block proposer of `N`).*
365-
366-
The fork choice rule (essentially a DA filter) is *orthogonal to a given DAS design*, other than the efficiency of a particular design impacting it.
367-
368-
In any DAS design, there are probably a few degrees of freedom around timing, acceptability of short-term re-orgs, etc.
369-
370-
For example, the fork choice rule might require validators to do successful DAS on slot `N` to be able to include block of slot `N` in its fork choice. That's the tightest DA filter. But trailing filters are also probably acceptable, knowing that there might be some failures/short re-orgs but that they don't hurt the aggregate security. For example, the rule could be — DAS must be completed for slot N-1 for a child block in N to be included in the fork choice.
371-
372-
Such trailing techniques and their analysis will be valuable for any DAS construction. The question is — can you relax how quickly you need to do DA and in the worst case not confirm unavailable data via attestations/finality, and what impact does it have on short-term re-orgs and fast confirmation rules.
373-
374266
## FAQs
375267

376268
### Row (blob) custody

specs/_features/eip7594/fork-choice.md

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -8,13 +8,9 @@
88
- [Introduction](#introduction)
99
- [Helpers](#helpers)
1010
- [Modified `is_data_available`](#modified-is_data_available)
11-
- [New `is_chain_available`](#new-is_chain_available)
1211
- [Modified `get_head`](#modified-get_head)
13-
- [New `is_peer_sampling_required`](#new-is_peer_sampling_required)
1412
- [Updated fork-choice handlers](#updated-fork-choice-handlers)
1513
- [Modified `on_block`](#modified-on_block)
16-
- [Pull-up tip helpers](#pull-up-tip-helpers)
17-
- [Modified `compute_pulled_up_tip`](#modified-compute_pulled_up_tip)
1814

1915
<!-- END doctoc generated TOC please keep comment here to allow auto update -->
2016
<!-- /TOC -->
@@ -29,8 +25,11 @@ This is the modification of the fork choice accompanying EIP-7594.
2925

3026
```python
3127
def is_data_available(beacon_block_root: Root) -> bool:
32-
# `retrieve_column_sidecars` is implementation and context dependent, replacing `retrieve_blobs_and_proofs`.
33-
# For the given block root, it returns all column sidecars to custody, or raises an exception if they are not available. # The p2p network does not guarantee sidecar retrieval outside of `MIN_EPOCHS_FOR_DATA_COLUMN_SIDECARS_REQUESTS` epochs.
28+
# `retrieve_column_sidecars` is implementation and context dependent, replacing
29+
# `retrieve_blobs_and_proofs`. For the given block root, it returns all column
30+
# sidecars to custody, or raises an exception if they are not available.
31+
# The p2p network does not guarantee sidecar retrieval outside of
32+
# `MIN_EPOCHS_FOR_DATA_COLUMN_SIDECARS_REQUESTS` epochs.
3433
column_sidecars = retrieve_column_sidecars(beacon_block_root)
3534
return all(
3635
verify_data_column_sidecar_kzg_proofs(column_sidecar)
@@ -68,7 +67,8 @@ def get_head(store: Store) -> Root:
6867

6968
### Modified `on_block`
7069

71-
*Note*: The blob data availability check is removed.
70+
*Note*: The blob data availability check is removed. We import blocks regardless
71+
of their availability status, and move all filtering to the fork-choice (`get_head`).
7272

7373
```python
7474
def on_block(store: Store, signed_block: SignedBeaconBlock) -> None:

0 commit comments

Comments
 (0)