… | |
… | |
18 | use utf8; |
18 | use utf8; |
19 | |
19 | |
20 | use File::Path (); |
20 | use File::Path (); |
21 | use Carp (); |
21 | use Carp (); |
22 | use Storable (); |
22 | use Storable (); |
|
|
23 | use AnyEvent::Util (); |
23 | use Config; |
24 | use Config; |
24 | use BDB; |
25 | use BDB; |
25 | |
26 | |
26 | use DC; |
27 | use DC; |
27 | |
28 | |
… | |
… | |
355 | |
356 | |
356 | print { $LOG_FH{$path} } "$ts $line\n" |
357 | print { $LOG_FH{$path} } "$ts $line\n" |
357 | } |
358 | } |
358 | |
359 | |
359 | sub run { |
360 | sub run { |
360 | ($FH, my $fh) = DC::socketpipe; |
361 | ($FH, my $fh) = AnyEvent::Util::portable_socketpair |
|
|
362 | or die "unable to create database socketpair: $!"; |
361 | |
363 | |
362 | my $oldfh = select $FH; $| = 1; select $oldfh; |
364 | my $oldfh = select $FH; $| = 1; select $oldfh; |
363 | my $oldfh = select $fh; $| = 1; select $oldfh; |
365 | my $oldfh = select $fh; $| = 1; select $oldfh; |
364 | |
366 | |
365 | my $pid = fork; |
367 | my $pid = fork; |