… | |
… | |
18 | use utf8; |
18 | use utf8; |
19 | |
19 | |
20 | use Carp (); |
20 | use Carp (); |
21 | use AnyEvent (); |
21 | use AnyEvent (); |
22 | use Storable (); # finally |
22 | use Storable (); # finally |
|
|
23 | |
|
|
24 | use CFPlus; |
23 | |
25 | |
24 | sub sync { |
26 | sub sync { |
25 | # for debugging |
27 | # for debugging |
26 | #CFPlus::DB::Server::req (sync => sub { }); |
28 | #CFPlus::DB::Server::req (sync => sub { }); |
27 | CFPlus::DB::Server::sync (); |
29 | CFPlus::DB::Server::sync (); |
… | |
… | |
278 | |
280 | |
279 | CFPlus::_exit 0; |
281 | CFPlus::_exit 0; |
280 | } |
282 | } |
281 | |
283 | |
282 | close $fh; |
284 | close $fh; |
283 | fcntl $FH, F_SETFL, O_NONBLOCK; |
285 | CFPlus::fh_nonblocking $FH, 1; |
284 | |
286 | |
285 | $CB{die} = sub { die shift }; |
287 | $CB{die} = sub { die shift }; |
286 | |
288 | |
287 | $fh_r_watcher = AnyEvent->io (fh => $FH, poll => 'r', cb => \&fh_read); |
289 | $fh_r_watcher = AnyEvent->io (fh => $FH, poll => 'r', cb => \&fh_read); |
288 | |
290 | |