-
Notifications
You must be signed in to change notification settings - Fork 752
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Implement PeerDAS RPC handlers #6237
Conversation
dc6a186
to
42de037
Compare
Oops I thought this was the first PR in the conga line and incorrectly set the base branch to |
I've merged latest base branch into this branch so i can extend the conga line. |
@@ -320,14 +320,53 @@ impl<T: BeaconChainTypes> NetworkBeaconProcessor<T> { | |||
pub fn handle_data_columns_by_root_request( |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
should this use terminate_response_stream
like we use in other similar methods?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Added in aa0b903
self.log, | ||
"Received DataColumnsByRoot Request"; | ||
"peer" => %peer_id, | ||
"request" => ?request.group_by_ordered_block_root(), |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
what is the benefit of ordering by block roots in this log?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I introduced group_by_ordered_block_root
originally to handle the reprocessing of requests. I left it here as it produces a more succint output. The raw request repeats the root for every column. Usually peers requests multiple indexes for the same root, so the output of this is nicer.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
one small suggestion and one question but looks good
25c1647
to
34f796d
Compare
@jimmygchen I have forced push a rebase of this branch against unstable, as the commit from #6238 had leaked into this PR |
…erdas-network-rpc-handler
@mergify queue |
🛑 The pull request has been removed from the queue
|
@mergify refresh |
✅ Pull request refreshed |
@mergify queue |
🛑 The pull request has been removed from the queue
|
@mergify dequeue |
☑️ The pull request is not queued |
@mergify queue |
🛑 The pull request has been removed from the queue
|
@mergify requeue |
✅ This pull request will be re-embarked automaticallyThe followup |
✅ The pull request has been merged automaticallyThe pull request has been merged automatically at 6566705 |
* Implement PeerDAS RPC handlers * use terminate_response_stream * Merge branch 'unstable' of https://github.com/sigp/lighthouse into peerdas-network-rpc-handler * cargo fmt
Issue Addressed
Continue porting network changes of
das
branch. Extends #6238Part of
all branches are on the sipg/lighthouse repo to start another PR conga :)
Proposed Changes
data_columns_by_root
anddata_columns_by_range
.Upstream PRs:
DataColumnSidecarsByRoot
req/resp protocol #5196