stats: Serialized data could be more than one lineHEADmaster

We need to buffer the incomming data and process is at whole if we receive
an EOF. Storabel::freeze can produce multiple lines.

1 files changed, 7 insertions, 8 deletions

diff --git a/stats.pl b/stats.pl
index 4d54e35..19a1b5f 100755
--- a/stats.pl
+++ b/stats.pl
@@ -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";
             });
         };
 };