| … | |
… | |
| 25 | use CFPlus; |
25 | use CFPlus; |
| 26 | |
26 | |
| 27 | our $DB_HOME = "$Crossfire::VARDIR/cfplus-$BerkeleyDB::db_version-$Config{archname}"; |
27 | our $DB_HOME = "$Crossfire::VARDIR/cfplus-$BerkeleyDB::db_version-$Config{archname}"; |
| 28 | |
28 | |
| 29 | sub path_of_res($) { |
29 | sub path_of_res($) { |
|
|
30 | utf8::downgrade $_[0]; # bug in unpack "H*" |
| 30 | "$DB_HOME/res-data-$_[0]" |
31 | "$DB_HOME/res-data-" . unpack "H*", $_[0] |
| 31 | } |
32 | } |
| 32 | |
33 | |
| 33 | sub sync { |
34 | sub sync { |
| 34 | # for debugging |
35 | # for debugging |
| 35 | #CFPlus::DB::Server::req (sync => sub { }); |
36 | #CFPlus::DB::Server::req (sync => sub { }); |
| … | |
… | |
| 347 | close $fh; |
348 | close $fh; |
| 348 | CFPlus::fh_nonblocking $FH, 1; |
349 | CFPlus::fh_nonblocking $FH, 1; |
| 349 | |
350 | |
| 350 | $CB{die} = sub { die shift }; |
351 | $CB{die} = sub { die shift }; |
| 351 | |
352 | |
| 352 | $fh_r_watcher = AnyEvent->io (fh => $FH, poll => 'r', cb => \&fh_read); |
353 | $fh_r_watcher = AnyEvent->io (fh => $FH, poll => 'r', nice => 1, cb => \&fh_read); |
| 353 | |
354 | |
| 354 | sync_tick; |
355 | sync_tick; |
| 355 | } |
356 | } |
| 356 | |
357 | |
| 357 | sub stop { |
358 | sub stop { |
