diff --git a/eth/filters/filter_system.go b/eth/filters/filter_system.go index c28fe787b6..02a8238ffb 100644 --- a/eth/filters/filter_system.go +++ b/eth/filters/filter_system.go @@ -265,7 +265,7 @@ func NewEventSystem(sys *FilterSystem) *EventSystem { m.stateSyncSub = m.backend.SubscribeStateSyncEvent(m.stateSyncCh) // Make sure none of the subscriptions are empty - if m.txsSub == nil || m.logsSub == nil || m.rmLogsSub == nil || m.chainSub == nil { + if m.txsSub == nil || m.logsSub == nil || m.rmLogsSub == nil || m.chainSub == nil || m.pendingLogsSub == nil { log.Crit("Subscribe for event system failed") } @@ -458,6 +458,7 @@ func (es *EventSystem) eventLoop() { defer func() { es.txsSub.Unsubscribe() es.logsSub.Unsubscribe() + es.pendingLogsSub.Unsubscribe() es.rmLogsSub.Unsubscribe() es.chainSub.Unsubscribe() es.stateSyncSub.Unsubscribe() diff --git a/internal/cli/snapshot_test.go b/internal/cli/snapshot_test.go index 115f0b0599..51c1e30503 100644 --- a/internal/cli/snapshot_test.go +++ b/internal/cli/snapshot_test.go @@ -46,6 +46,7 @@ var ( ) func TestOfflineBlockPrune(t *testing.T) { + t.Skip("PBSS does not support ancient block pruning") t.Parallel() // Corner case for 0 remain in ancinetStore.