mirror of
https://github.com/ethereum/go-ethereum.git
synced 2026-07-27 15:16:43 +00:00
skip: testcase
This commit is contained in:
parent
cec3ee18d8
commit
693d8aebcd
2 changed files with 3 additions and 1 deletions
|
|
@ -265,7 +265,7 @@ func NewEventSystem(sys *FilterSystem) *EventSystem {
|
||||||
m.stateSyncSub = m.backend.SubscribeStateSyncEvent(m.stateSyncCh)
|
m.stateSyncSub = m.backend.SubscribeStateSyncEvent(m.stateSyncCh)
|
||||||
|
|
||||||
// Make sure none of the subscriptions are empty
|
// 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")
|
log.Crit("Subscribe for event system failed")
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
@ -458,6 +458,7 @@ func (es *EventSystem) eventLoop() {
|
||||||
defer func() {
|
defer func() {
|
||||||
es.txsSub.Unsubscribe()
|
es.txsSub.Unsubscribe()
|
||||||
es.logsSub.Unsubscribe()
|
es.logsSub.Unsubscribe()
|
||||||
|
es.pendingLogsSub.Unsubscribe()
|
||||||
es.rmLogsSub.Unsubscribe()
|
es.rmLogsSub.Unsubscribe()
|
||||||
es.chainSub.Unsubscribe()
|
es.chainSub.Unsubscribe()
|
||||||
es.stateSyncSub.Unsubscribe()
|
es.stateSyncSub.Unsubscribe()
|
||||||
|
|
|
||||||
|
|
@ -46,6 +46,7 @@ var (
|
||||||
)
|
)
|
||||||
|
|
||||||
func TestOfflineBlockPrune(t *testing.T) {
|
func TestOfflineBlockPrune(t *testing.T) {
|
||||||
|
t.Skip("PBSS does not support ancient block pruning")
|
||||||
t.Parallel()
|
t.Parallel()
|
||||||
|
|
||||||
// Corner case for 0 remain in ancinetStore.
|
// Corner case for 0 remain in ancinetStore.
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue