diff options
| author | Eric Wong <e@80x24.org> | 2021-10-01 09:54:41 +0000 |
|---|---|---|
| committer | Eric Wong <e@80x24.org> | 2021-10-01 12:06:31 +0000 |
| commit | 1c52f49354aa83e71fcceccae888da0c77f2391d (patch) | |
| tree | bd6eabaed8cc0376e4a56cb6ec34cf962fd7ffdb /xt | |
| parent | 5824d0d4ffac120a2840c980b4570868d6b3ea6b (diff) | |
| download | public-inbox-1c52f49354aa83e71fcceccae888da0c77f2391d.tar.gz | |
Since signalfd is often combined with our event loop, give it a convenient API and reduce the code duplication required to use it. EventLoop is replaced with ::event_loop to allow consistent parameter passing and avoid needlessly passing the package name on stack. We also avoid exporting SFD_NONBLOCK since it's the only flag we support. There's no sense in having the memory overhead of a constant function when it's in cold code.
Diffstat (limited to 'xt')
| -rw-r--r-- | xt/mem-imapd-tls.t | 6 | ||||
| -rw-r--r-- | xt/net_writer-imap.t | 2 |
2 files changed, 4 insertions, 4 deletions
diff --git a/xt/mem-imapd-tls.t b/xt/mem-imapd-tls.t index bd75ef45..8992a6fc 100644 --- a/xt/mem-imapd-tls.t +++ b/xt/mem-imapd-tls.t @@ -95,7 +95,7 @@ foreach my $n (1..$nfd) { # one step through the event loop # do a little work as we connect: - PublicInbox::DS->EventLoop; + PublicInbox::DS::event_loop(); # try not to overflow the listen() backlog: if (!($n % 128) && $DONE != $n) { @@ -104,7 +104,7 @@ foreach my $n (1..$nfd) { PublicInbox::DS->SetPostLoopCallback(sub { $DONE != $n }); # clear the backlog: - PublicInbox::DS->EventLoop; + PublicInbox::DS::event_loop(); # resume looping PublicInbox::DS->SetLoopTimeout(0); @@ -117,7 +117,7 @@ diag "done?: @".time." $DONE/$nfd"; if ($DONE != $nfd) { PublicInbox::DS->SetLoopTimeout(-1); PublicInbox::DS->SetPostLoopCallback(sub { $DONE != $nfd }); - PublicInbox::DS->EventLoop; + PublicInbox::DS::event_loop(); } is($nfd, $DONE, "$nfd/$DONE done"); if ($^O eq 'linux' && open(my $f, '<', "/proc/$pid/status")) { diff --git a/xt/net_writer-imap.t b/xt/net_writer-imap.t index 41438cf7..cb2ea61f 100644 --- a/xt/net_writer-imap.t +++ b/xt/net_writer-imap.t @@ -228,7 +228,7 @@ EOM $pub_cfg->each_inbox(sub { $_[0]->subscribe_unlock('ident', $obj) }); my $w = start_script(['-watch'], undef, { 2 => $err_wr }); diag 'waiting for initial fetch...'; - PublicInbox::DS->EventLoop; + PublicInbox::DS::event_loop(); my $ibx = $pub_cfg->lookup_name('wtest'); my $mm = $ibx->mm; ok(defined($mm->num_for('Seen@test.example.com')), |