Skip to content

Commit 0c60a36

Browse files
committed
Address review comment.
1 parent d4e9d6a commit 0c60a36

File tree

1 file changed

+9
-4
lines changed
  • beacon_node/network/src/network_beacon_processor

1 file changed

+9
-4
lines changed

beacon_node/network/src/network_beacon_processor/mod.rs

Lines changed: 9 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -928,6 +928,7 @@ impl<T: BeaconChainTypes> NetworkBeaconProcessor<T> {
928928
publish_blobs: bool,
929929
) {
930930
let custody_columns = self.network_globals.sampling_columns.clone();
931+
let is_supernode = self.network_globals.is_supernode();
931932
let self_cloned = self.clone();
932933
let publish_fn = move |blobs_or_data_column| {
933934
if publish_blobs {
@@ -936,10 +937,14 @@ impl<T: BeaconChainTypes> NetworkBeaconProcessor<T> {
936937
self_cloned.publish_blobs_gradually(blobs, block_root);
937938
}
938939
BlobsOrDataColumns::DataColumns(columns) => {
939-
let columns_to_publish = columns
940-
.into_iter()
941-
.filter(|c| custody_columns.contains(&c.index))
942-
.collect();
940+
let columns_to_publish = if is_supernode {
941+
columns
942+
} else {
943+
columns
944+
.into_iter()
945+
.filter(|c| custody_columns.contains(&c.index))
946+
.collect()
947+
};
943948
self_cloned.publish_data_columns_gradually(columns_to_publish, block_root);
944949
}
945950
};

0 commit comments

Comments
 (0)