… | |
… | |
58 | use BDB (); |
58 | use BDB (); |
59 | use Data::Dumper; |
59 | use Data::Dumper; |
60 | use Fcntl; |
60 | use Fcntl; |
61 | use YAML::XS (); |
61 | use YAML::XS (); |
62 | use IO::AIO (); |
62 | use IO::AIO (); |
63 | use Time::HiRes; |
|
|
64 | use Compress::LZF; |
63 | use Compress::LZF; |
65 | use Digest::MD5 (); |
64 | use Digest::MD5 (); |
66 | |
65 | |
67 | AnyEvent::detect; |
66 | AnyEvent::detect; |
68 | |
67 | |
… | |
… | |
901 | |
900 | |
902 | return db_get cache => "$id/data"; |
901 | return db_get cache => "$id/data"; |
903 | } |
902 | } |
904 | } |
903 | } |
905 | |
904 | |
906 | my $t1 = Time::HiRes::time; |
905 | my $t1 = EV::time; |
907 | my $data = $process->(\@data); |
906 | my $data = $process->(\@data); |
908 | my $t2 = Time::HiRes::time; |
907 | my $t2 = EV::time; |
909 | |
908 | |
910 | info "cache: '$id' processed in ", $t2 - $t1, "s\n"; |
909 | info "cache: '$id' processed in ", $t2 - $t1, "s\n"; |
911 | |
910 | |
912 | db_put cache => "$id/data", $data; |
911 | db_put cache => "$id/data", $data; |
913 | db_put cache => "$id/md5" , $md5; |
912 | db_put cache => "$id/md5" , $md5; |