1 files changed, 6 insertions, 2 deletions
diff --git a/lib/PublicInbox/EvCleanup.pm b/lib/PublicInbox/EvCleanup.pm
index 559730e9..1a3a3d5e 100644
--- a/lib/PublicInbox/EvCleanup.pm
+++ b/lib/PublicInbox/EvCleanup.pm
@@ -7,6 +7,10 @@ use strict;
  use warnings;
  use base qw(Danga::Socket);
  use fields qw(rd);
+
+my $ENABLED;
+sub enabled { $ENABLED }
+sub enable { $ENABLED = 1 }
  my $singleton;
  my $asapq = [ [], undef ];
  my $nextq = [ [], undef ];
@@ -77,8 +81,8 @@ sub later ($) {
  
  END {
          _run_asap();
-        _run_next();
-        _run_later();
+        _run_all($nextq);
+        _run_all($laterq);
  }
  
  1;