diff options
| author | Eric Wong <e@80x24.org> | 2023-03-26 09:35:43 +0000 |
|---|---|---|
| committer | Eric Wong <e@80x24.org> | 2023-03-26 09:35:43 +0000 |
| commit | 511b7ca599f1c151f6c50f5ba848be60d5857e22 (patch) | |
| tree | a7aa219b08af891c3d86d7be250c92ed597de261 /lib/PublicInbox/LEI.pm | |
| parent | 2dd3cec8783700f061a0c9b69e329918a4f5cccd (diff) | |
| parent | 2e28cc7edb58b04404a836dffc07d47b1a38ee17 (diff) | |
| download | public-inbox-511b7ca599f1c151f6c50f5ba848be60d5857e22.tar.gz | |
* cindex: (29 commits) cindex: --prune checkpoints to avoid OOM cindex: ignore SIGPIPE cindex: respect existing permissions cindex: squelch incompatible options cindex: implement reindex cindex: add support for --prune cindex: filter out non-existent git directories spawn: show failing directory for chdir failures cindex: improve granularity of quit checks cindex: attempt to give oldest commits lowest docids cindex: truncate or drop body for over-sized commits cindex: check for checkpoint before giant messages cindex: implement --max-size=SIZE sigfd: pass signal name rather than number to callback cindex: handle graceful shutdown by default cindex: drop `unchanged' progress message cindex: show shard number in progress message cindex: implement --exclude= like -clone ds: @post_loop_do replaces SetPostLoopCallback cindex: use DS and workqueues for parallelism ...
Diffstat (limited to 'lib/PublicInbox/LEI.pm')
| -rw-r--r-- | lib/PublicInbox/LEI.pm | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/lib/PublicInbox/LEI.pm b/lib/PublicInbox/LEI.pm index ff2db1ff..578686e2 100644 --- a/lib/PublicInbox/LEI.pm +++ b/lib/PublicInbox/LEI.pm @@ -1320,11 +1320,11 @@ sub lazy_start { }; require PublicInbox::DirIdle; local $dir_idle = PublicInbox::DirIdle->new(sub { - # just rely on wakeup to hit PostLoopCallback set below + # just rely on wakeup to hit post_loop_do dir_idle_handler($_[0]) if $_[0]->fullname ne $path; }); $dir_idle->add_watches([$sock_dir]); - PublicInbox::DS->SetPostLoopCallback(sub { + local @PublicInbox::DS::post_loop_do = (sub { my ($dmap, undef) = @_; if (@st = defined($path) ? stat($path) : ()) { if ($dev_ino_expect ne pack('dd', $st[0], $st[1])) { |