diff --git a/pkg/events/filter/event.go b/pkg/events/filter/event.go index f80bd4fec3..ce46a95765 100644 --- a/pkg/events/filter/event.go +++ b/pkg/events/filter/event.go @@ -434,15 +434,15 @@ func (m *EventFilterManager) Remove(ctx context.Context, id types.FilterID) erro return nil } -func (m *EventFilterManager) loadExecutedMessages(ctx context.Context, msgTs, rctTs *types.TipSet) ([]executedMessage, error) { - msgs, err := m.MessageStore.MessagesForTipset(msgTs) +func (m *EventFilterManager) loadExecutedMessages(ctx context.Context, msgTS, rctTS *types.TipSet) ([]executedMessage, error) { + msgs, err := m.MessageStore.MessagesForTipset(msgTS) if err != nil { return nil, fmt.Errorf("read messages: %w", err) } st := adt.WrapStore(ctx, cbor.NewCborStore(m.ChainStore.Blockstore())) - arr, err := blockadt.AsArray(st, rctTs.Blocks()[0].ParentMessageReceipts) + arr, err := blockadt.AsArray(st, rctTS.Blocks()[0].ParentMessageReceipts) if err != nil { return nil, fmt.Errorf("load receipts amt: %w", err) } diff --git a/pkg/events/filter/index.go b/pkg/events/filter/index.go index 6bd161dbb0..9fcf913da4 100644 --- a/pkg/events/filter/index.go +++ b/pkg/events/filter/index.go @@ -225,19 +225,19 @@ func (ei *EventIndex) SubscribeUpdates() (chan EventIndexUpdated, func()) { } ei.mu.Lock() - subId := ei.subIDCounter + subID := ei.subIDCounter ei.subIDCounter++ - ei.updateSubs[subId] = tSub + ei.updateSubs[subID] = tSub ei.mu.Unlock() unSubscribeF := func() { ei.mu.Lock() - tSub, ok := ei.updateSubs[subId] + tSub, ok := ei.updateSubs[subID] if !ok { ei.mu.Unlock() return } - delete(ei.updateSubs, subId) + delete(ei.updateSubs, subID) ei.mu.Unlock() // cancel the subscription diff --git a/venus-devtool/api-gen/example.go b/venus-devtool/api-gen/example.go index 8a54d6e601..5109d4a45c 100644 --- a/venus-devtool/api-gen/example.go +++ b/venus-devtool/api-gen/example.go @@ -293,9 +293,9 @@ func init() { addExample(filterid) addExample(&filterid) - subid := types.EthSubscriptionID(ethhash) - addExample(subid) - addExample(&subid) + subID := types.EthSubscriptionID(ethhash) + addExample(subID) + addExample(&subID) pstring := func(s string) *string { return &s } addExample(&types.EthFilterSpec{