X-Git-Url: http://dxcluster.net/gitweb/gitweb.cgi?a=blobdiff_plain;f=perl%2FRoute%2FUser.pm;h=d9d5249c459d21c5ade0bd143134af3657b49efe;hb=689155304c3c1bf0787ecea54a4043145d7aa2fe;hp=51d14f21382951ed14b422dc43c2521678f6f16c;hpb=5835ca385fb719194163512276666aaf75e82484;p=spider.git diff --git a/perl/Route/User.pm b/perl/Route/User.pm index 51d14f21..d9d5249c 100644 --- a/perl/Route/User.pm +++ b/perl/Route/User.pm @@ -103,23 +103,46 @@ sub TO_JSON { return { %{ shift() } }; } sub write_cache { my $json = DXJSON->new; - $json->canonical(0)->allow_blessed(1)->convert_blessed(1); + $json->canonical(isdbg('routecache')); my $ta = [ gettimeofday ]; - $json->indent(1)->canonical(1) if isdbg('routecache'); - my $s = eval {$json->encode(\%list)}; - if ($s) { - my $fh = IO::File->new(">$cachefn") or confess("writing $cachefn $!"); - $fh->print($s); + my @s; + eval { + while (my ($k, $v) = each %list) { + push @s, "$k:" . $json->encode($v) . "\n"; + } + }; + if (!$@ && @s) { + my $fh = IO::File->new(">$cachefn") or carp("writing $cachefn $!"); + print $fh $_ for (sort @s); $fh->close; } else { - dbg("Route::User:Write_cache error '$@'"); + dbg("Route::User::write_cache error '$@'"); return; } - $json->indent(0)->canonical(0); my $diff = _diffms($ta); - my $size = sprintf('%.3fKB', (length($s) / 1000)); - dbg("Route::User:WRITE_CACHE size: $size time to write: $diff mS"); + dbg("Route::User::write_cache time to write: $diff mS"); +} + +sub read_cache +{ + my $json = DXJSON->new; + $json->canonical(isdbg('routecache')); + + my $ta = [ gettimeofday ]; + my $count; + + my $fh = IO::File->new("$cachefn") or carp("reading $cachefn $!"); + while (my $l = <$fh>) { + chomp $l; + my ($k, $v) = split /:/, $l, 2; + $list{$k} = bless $json->decode($v) or carp("json error decoding '$v'"); + ++$count; + } + $fh->close if $fh; + + my $diff = _diffms($ta); + dbg("Route::User::read_cache time to read $count records from $cachefn : $diff mS"); } #