X-Git-Url: http://dxcluster.org/gitweb/gitweb.cgi?a=blobdiff_plain;f=perl%2FRoute%2FUser.pm;h=6c91d3e2225ab283946fed48aaf70f7e761303c2;hb=42e13afbe924d02919cef432ab0cee537ed1e20d;hp=bbd289d292755a0bf89cf3041b0d152d68f21bcf;hpb=b55a5be0062fb96613a2f42c25de550d69283b7a;p=spider.git diff --git a/perl/Route/User.pm b/perl/Route/User.pm index bbd289d2..6c91d3e2 100644 --- a/perl/Route/User.pm +++ b/perl/Route/User.pm @@ -103,7 +103,7 @@ sub TO_JSON { return { %{ shift() } }; } sub write_cache { my $json = DXJSON->new; - $json->canonical(isdbg('routecache')); + $json->canonical(isdbg('routecache')||0); my $ta = [ gettimeofday ]; my @s; @@ -113,20 +113,36 @@ sub write_cache } }; if (!$@ && @s) { - my $fh = IO::File->new(">$cachefn") or confess("writing $cachefn $!"); - if (isdbg("routecache")) { - $fh->print(sort @s); - } - else { - $fh->print(@s); - } + my $fh = IO::File->new(">$cachefn") or dbg("Route::User: ERROR writing $cachefn $!"), return; + print $fh $_ for (sort @s); $fh->close; } else { - dbg("Route::User:Write_cache error '$@'"); + dbg("Route::User::write_cache error '$@'"); return; } my $diff = _diffms($ta); - dbg("Route::User:WRITE_CACHE 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 dbg("Route::User: ERROR reading $cachefn $!"), return; + while (my $l = <$fh>) { + chomp $l; + my ($k, $v) = split /:/, $l, 2; + $list{$k} = bless $json->decode($v) or dbg("Route::User: Error json error $! decoding '$v'"), next; + ++$count; + } + $fh->close if $fh; + + my $diff = _diffms($ta); + dbg("Route::User::read_cache time to read $count records from $cachefn : $diff mS"); } #