fix bug in blob fetcher

This commit is contained in:
healthykim 2026-03-19 14:11:54 +09:00
parent 07d3ae1d80
commit cc1fde37a4

View file

@ -318,7 +318,7 @@ func (f *BlobFetcher) loop() {
reschedule[peer] = struct{}{} reschedule[peer] = struct{}{}
} }
delete(f.waitlist, hash) delete(f.waitlist, hash)
//todo delete(f.waittime, hash) delete(f.waittime, hash)
} }
continue continue
} }
@ -419,7 +419,7 @@ func (f *BlobFetcher) loop() {
addedCells := make([][]kzg4844.Cell, 0) addedCells := make([][]kzg4844.Cell, 0)
var requestId int var requestId int
request := new(cellRequest) var request *cellRequest
for _, hash := range delivery.txs { for _, hash := range delivery.txs {
// Find the request // Find the request
for i, req := range f.requests[delivery.origin] { for i, req := range f.requests[delivery.origin] {