about summary refs log tree commit homepage
path: root/lib/PublicInbox/Inbox.pm
diff options
context:
space:
mode:
authorEric Wong <e@yhbt.net>2020-06-10 07:04:01 +0000
committerEric Wong <e@yhbt.net>2020-06-13 07:55:45 +0000
commit34c1a6c16733adee3acfe5861096692f3ea55378 (patch)
treef22f3a47a81d5023ce4152d6f6abc129b95a35e7 /lib/PublicInbox/Inbox.pm
parent90f11ce471c53365a77896c847d0a39b0995b5b5 (diff)
downloadpublic-inbox-34c1a6c16733adee3acfe5861096692f3ea55378.tar.gz
This will be used to implement IMAP IDLE, first.

Eventually, it may be used to trigger other things:

* incremental internal updates for manifest.js.gz
* restart `git cat-file' processes on pack index unlink
* IMAP IDLE-like long-polling HTTP endpoint

And maybe more things we haven't thought of, yet.

It uses Linux::Inotify2 or IO::KQueue depending on what packages
are installed and what the kernel supports.  It falls back to
nanosecond-aware Time::HiRes::stat() (available with Perl 5.10.0+)
on systems lacking Linux::Inotify2 and IO::KQueue.

In the future, a pure Perl alternative to Linux::Inotify2 may be
supplied for users of architectures we already support signalfd
and epoll on.

v2 changes:
- avoid O_TRUNC on lock file
- change ctime on Linux systems w/o inotify
- fix naming of comments and fields
Diffstat (limited to 'lib/PublicInbox/Inbox.pm')
-rw-r--r--lib/PublicInbox/Inbox.pm20
1 files changed, 20 insertions, 0 deletions
diff --git a/lib/PublicInbox/Inbox.pm b/lib/PublicInbox/Inbox.pm
index af034358..b250bef3 100644
--- a/lib/PublicInbox/Inbox.pm
+++ b/lib/PublicInbox/Inbox.pm
@@ -391,4 +391,24 @@ sub altid_map ($) {
         } // {};
 }
 
+# $obj must respond to ->on_inbox_unlock, which takes Inbox ($self) as an arg
+sub subscribe_unlock {
+        my ($self, $ident, $obj) = @_;
+        $self->{unlock_subs}->{$ident} = $obj;
+}
+
+sub unsubscribe_unlock {
+        my ($self, $ident) = @_;
+        delete $self->{unlock_subs}->{$ident};
+}
+
+# called by inotify
+sub on_unlock {
+        my ($self) = @_;
+        my $subs = $self->{unlock_subs} or return;
+        for (values %$subs) {
+                eval { $_->on_inbox_unlock($self) };
+        }
+}
+
 1;