Skip to content

Commit 2261c30

Browse files
committed
fix cache
1 parent 69410c0 commit 2261c30

1 file changed

Lines changed: 8 additions & 8 deletions

File tree

block/retriever_da.go

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -30,9 +30,9 @@ type daRetriever struct {
3030

3131
// pendingDAEvent represents a DA event waiting for processing
3232
type pendingDAEvent struct {
33-
header *types.SignedHeader
34-
data *types.Data
35-
daHeight uint64
33+
Header *types.SignedHeader
34+
Data *types.Data
35+
DaHeight uint64
3636
}
3737

3838
// newDARetriever creates a new DA retriever
@@ -306,9 +306,9 @@ func (dr *daRetriever) queuePendingEvent(header *types.SignedHeader, data *types
306306

307307
height := header.Height()
308308
event := pendingDAEvent{
309-
header: header,
310-
data: data,
311-
daHeight: daHeight,
309+
Header: header,
310+
Data: data,
311+
DaHeight: daHeight,
312312
}
313313
dr.manager.pendingEventsCache.SetItem(height, &event)
314314

@@ -381,9 +381,9 @@ func (dr *daRetriever) processPendingEvents(ctx context.Context) {
381381
if height <= currentHeight+1 {
382382
dr.manager.logger.Debug().
383383
Uint64("height", height).
384-
Uint64("daHeight", event.daHeight).
384+
Uint64("daHeight", event.DaHeight).
385385
Msg("processing previously queued DA event")
386-
go dr.processEvent(ctx, event.header, event.data, event.daHeight)
386+
go dr.processEvent(ctx, event.Header, event.Data, event.DaHeight)
387387
toDelete = append(toDelete, height)
388388
}
389389
return true

0 commit comments

Comments
 (0)