-
Notifications
You must be signed in to change notification settings - Fork 25
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
chore(papyrus_p2p_sync): add block data receiver to p2psyncclient #2617
base: main
Are you sure you want to change the base?
chore(papyrus_p2p_sync): add block data receiver to p2psyncclient #2617
Conversation
dc1c438
to
a27919f
Compare
ee0e600
to
583173e
Compare
Codecov ReportAttention: Patch coverage is
Additional details and impacted files@@ Coverage Diff @@
## main #2617 +/- ##
===========================================
+ Coverage 40.10% 77.39% +37.28%
===========================================
Files 26 395 +369
Lines 1895 42649 +40754
Branches 1895 42649 +40754
===========================================
+ Hits 760 33008 +32248
- Misses 1100 7345 +6245
- Partials 35 2296 +2261 ☔ View full report in Codecov by Sentry. |
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.
Reviewed 6 of 6 files at r1, all commit messages.
Reviewable status: all files reviewed, 2 unresolved discussions (waiting on @eitanm-starkware)
crates/papyrus_node/src/run.rs
line 307 at r1 (raw file):
storage_writer, p2p_sync_client_channels, Box::pin(futures::stream::pending()),
use .boxed() instead
crates/papyrus_p2p_sync/src/client/mod.rs
line 233 at r1 (raw file):
p2p_sync_channels: P2PSyncClientChannels, #[allow(dead_code)] block_data_receiver: BoxStream<'static, SyncBlock>,
rename to internal_blocks_receiver
583173e
to
138ae92
Compare
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.
Reviewable status: 2 of 6 files reviewed, 2 unresolved discussions (waiting on @ShahakShama)
crates/papyrus_node/src/run.rs
line 307 at r1 (raw file):
Previously, ShahakShama wrote…
use .boxed() instead
Done.
crates/papyrus_p2p_sync/src/client/mod.rs
line 233 at r1 (raw file):
Previously, ShahakShama wrote…
rename to internal_blocks_receiver
Done.
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.
Reviewed 4 of 4 files at r2, all commit messages.
Reviewable status: complete! all files reviewed, all discussions resolved (waiting on @eitanm-starkware)
138ae92
to
f4eab0f
Compare
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.
Reviewed 1 of 1 files at r3, all commit messages.
Reviewable status: complete! all files reviewed, all discussions resolved (waiting on @eitanm-starkware)
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.
Reviewable status: all files reviewed, 1 unresolved discussion (waiting on @eitanm-starkware)
crates/papyrus_p2p_sync/src/client/mod.rs
line 233 at r3 (raw file):
p2p_sync_channels: P2PSyncClientChannels, #[allow(dead_code)] internal_blocks_receiver: BoxStream<'static, SyncBlock>,
Should be (BlockNumber, SyncBlock)
f4eab0f
to
fd7a70e
Compare
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.
Reviewed 1 of 1 files at r4, all commit messages.
Reviewable status: all files reviewed, 1 unresolved discussion (waiting on @eitanm-starkware)
crates/papyrus_p2p_sync/src/client/mod.rs
line 233 at r3 (raw file):
Previously, ShahakShama wrote…
Should be (BlockNumber, SyncBlock)
Could you put BlockNumber first? That's the convention in other places in the code (Including your previous PR)
7f54bd2
to
eb62875
Compare
Benchmark movements: |
eb62875
to
14e0b30
Compare
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.
Reviewed 2 of 2 files at r5, all commit messages.
Reviewable status: complete! all files reviewed, all discussions resolved (waiting on @eitanm-starkware)
14e0b30
to
573a7a2
Compare
No description provided.