diff options
-rwxr-xr-x | stats.pl | 15 |
1 files changed, 7 insertions, 8 deletions
@@ -25,21 +25,20 @@ sub my_die { tcp_connect "unix/", $socket, sub { my ($fh) = @_ or my_die("Unable to connect to socket: $!");; + my $data; my $h; $h = new AnyEvent::Handle fh => $fh, on_eof => sub { - $h->destroy; - my_die('Connection closed.'); + # read stats data + my $stats = Storable::thaw($data); + + print "OK | ham=$stats->{ham};;;0 spam=$stats->{spam};;;0 block=$stats->{block};;;0\n"; + $cv->send; }, on_read => sub { $h->push_read(line => sub { my ($h, $line) = @_; - - # read stats data - my $stats = Storable::thaw($line); - - print "OK | ham=$stats->{ham};;;0 spam=$stats->{spam};;;0 block=$stats->{block};;;0\n"; - $cv->send; + $data .= "$line\n"; }); }; }; |