Skip to content

Commit

Permalink
fixup! BlobSidecarsByRange rpc handler
Browse files Browse the repository at this point in the history
  • Loading branch information
kasey committed Jun 14, 2023
1 parent 99ff163 commit f97a668
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 3 deletions.
2 changes: 1 addition & 1 deletion beacon-chain/sync/rpc_blob_sidecars_by_range.go
Original file line number Diff line number Diff line change
Expand Up @@ -86,7 +86,7 @@ func (s *Service) blobSidecarsByRangeRPCHandler(ctx context.Context, msg interfa
batcher, err := newBlockRangeBatcher(rp, s.cfg.beaconDB, s.rateLimiter, s.cfg.chain.IsCanonical, ticker)

var batch blockBatch
wQuota := params.BeaconNetworkConfig().MaxRequestBlobsSidecars
wQuota := params.BeaconNetworkConfig().MaxRequestBlobSidecars
for batch, ok = batcher.next(ctx, stream); ok; batch, ok = batcher.next(ctx, stream) {
batchStart := time.Now()
wQuota, err = s.streamBlobBatch(ctx, batch, wQuota, stream)
Expand Down
4 changes: 2 additions & 2 deletions beacon-chain/sync/rpc_blob_sidecars_by_range_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -53,7 +53,7 @@ func (c *blobsTestCase) filterExpectedByRange(t *testing.T, scs []*ethpb.BlobSid
if sc.Slot < rreq.StartSlot || sc.Slot > rreq.StartSlot+types.Slot(rreq.Count)-1 {
continue
}
if writes == params.BeaconNetworkConfig().MaxRequestBlobsSidecars {
if writes == params.BeaconNetworkConfig().MaxRequestBlobSidecars {
continue
}
expect = append(expect, &expectedBlobChunk{
Expand Down Expand Up @@ -136,7 +136,7 @@ func TestBlobByRangeOK(t *testing.T) {
Count: params.BeaconNetworkConfig().MaxRequestBlocksDeneb + 1,
}
},
total: func() *int { x := int(params.BeaconNetworkConfig().MaxRequestBlobsSidecars); return &x }(),
total: func() *int { x := int(params.BeaconNetworkConfig().MaxRequestBlobSidecars); return &x }(),
},
}
for _, c := range cases {
Expand Down

0 comments on commit f97a668

Please sign in to comment.