nntpd: move busy check to NNTP package

[public-inbox.git] / public-inbox-nntpd

diff --git a/public-inbox-nntpd b/public-inbox-nntpd
index 4c1560803e221c279be82a4de40637a6ee06393c..70bab46f304bc121ef1bf62b570665f79c0a669d 100644 (file)
--- a/public-inbox-nntpd
+++ b/public-inbox-nntpd
@@ -205,7 +205,7 @@ sub worker_quit {
 
                foreach my $s (values %$dmap) {
                        next unless ref($s) eq 'PublicInbox::NNTP';
-                       if ($s->{write_buf_size} || $s->{rbuf}) {
+                       if ($s->busy) {
                                ++$n;
                        } else {
                                $s->close;