-
Notifications
You must be signed in to change notification settings - Fork 298
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
Move storage to new BlobSidecar #7737
Conversation
@@ -76,7 +76,7 @@ | |||
public void handleRequest(RestApiRequest request) throws JsonProcessingException { | |||
final List<UInt64> indices = request.getQueryParameterList(BLOB_INDICES_PARAMETER); | |||
final SafeFuture<Optional<List<BlobSidecarOld>>> future = | |||
chainDataProvider.getBlobSidecars(request.getPathParameter(PARAMETER_BLOCK_ID), indices); | |||
chainDataProvider.getBlobSidecarsOld(request.getPathParameter(PARAMETER_BLOCK_ID), indices); |
Check notice
Code scanning / CodeQL
Deprecated method or constructor invocation Note
ChainDataProvider.getBlobSidecarsOld
@@ -59,7 +59,7 @@ | |||
void shouldReturnAllBlobSidecarsAtSlot() throws JsonProcessingException { | |||
final List<BlobSidecarOld> nonCanonicalBlobSidecars = | |||
dataStructureUtil.randomBlobSidecarsOld(4); | |||
when(chainDataProvider.getAllBlobSidecarsAtSlot(eq(UInt64.ONE), eq(indices))) | |||
when(chainDataProvider.getAllBlobSidecarsAtSlotOld(eq(UInt64.ONE), eq(indices))) |
Check notice
Code scanning / CodeQL
Deprecated method or constructor invocation Note test
ChainDataProvider.getAllBlobSidecarsAtSlotOld
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.
LGTM. just one thing
final Eth2Peer peer, final UInt64 from, final UInt64 count) | ||
throws InterruptedException, ExecutionException, TimeoutException { | ||
final List<BlobSidecar> blobSidecars = new ArrayList<>(); | ||
waitFor( | ||
peer.requestBlobSidecarsByRange(from, count, RpcResponseListener.from(blobSidecars::add))); | ||
waitFor(() -> assertThat(peer.getOutstandingRequests()).isEqualTo(0)); |
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.
is it ok to remove this waitFor
?
@tbenr great catch. Accidentally removed with repack removing, checking other places now. |
Looks good now, merging |
PR Description
Part of #7654
Fixed Issue(s)
Documentation
doc-change-required
label to this PR if updates are required.Changelog