-# Copyright (C) 2016 all contributors <meta@public-inbox.org>
+# Copyright (C) 2016-2019 all contributors <meta@public-inbox.org>
# License: AGPL-3.0+ <https://www.gnu.org/licenses/agpl-3.0.txt>
-# event cleanups (currently for Danga::Socket)
+# event cleanups (for PublicInbox::DS)
package PublicInbox::EvCleanup;
use strict;
use warnings;
-
-my $asapq = { queue => [], timer => undef };
-my $laterq = { queue => [], timer => undef };
-
-sub _run_all ($) {
- my ($q) = @_;
-
- my $run = $q->{queue};
- $q->{queue} = [];
- $q->{timer} = undef;
+require PublicInbox::DS;
+
+# this only runs under public-inbox-{httpd/nntpd}, not generic PSGI servers
+my $ENABLED;
+sub enabled { $ENABLED }
+sub enable { $ENABLED = 1 }
+my $laterq = [ [], undef ];
+
+sub _run_later () {
+ my $run = $laterq->[0];
+ $laterq->[0] = [];
+ $laterq->[1] = undef;
$_->() foreach @$run;
}
-sub _run_asap () { _run_all($asapq) }
-sub _run_later () { _run_all($laterq) }
-
-sub asap ($) {
- my ($cb) = @_;
- push @{$asapq->{queue}}, $cb;
- $asapq->{timer} ||= Danga::Socket->AddTimer(0, *_run_asap);
-}
-
sub later ($) {
my ($cb) = @_;
- push @{$laterq->{queue}}, $cb;
- $laterq->{timer} ||= Danga::Socket->AddTimer(60, *_run_later);
-}
-
-END {
- _run_asap();
- _run_later();
+ push @{$laterq->[0]}, $cb;
+ $laterq->[1] ||= PublicInbox::DS->AddTimer(60, *_run_later);
}
+END { _run_later() }
1;