#!/usr/bin/perl
use strict;
use warnings;
use threads:                                                               ## Added
use threads::shared;                                                       ## Added
use Data::Dumper;
use Net::WebSocket::Server;
use JSON;

my %data;
my $json :shared;                                                          ## Modded

async {                                                                    ## Added
    Net::WebSocket::Server->new(
        listen => 8080,
        on_connect => sub {
            my ($serv, $conn) = @_;
            $conn->on(
                handshake => sub {
                    my ($conn, $handshake) = @_;
                },
                utf8 => sub {
                    my ($conn) = @_;
                    lock $json;                                           ## Added
                    $_->send_utf8($json) for $conn->server->connections;
                },
            );
        },
    )->start;
}->detach;                                                                ## Added

open my $fh, '<', 'toto1' or die "can't open fifo toto1: $?";

while ( my $line = <$fh> ) {

    my @list = ( split /\s+/, $line );

    # skip empty lines
    next if $#list <= 1;
    shift @list if $list[0] eq '';

    # test for iostat header
    next if $list[0] eq 'avg-cpu:';
    next if $list[0] eq 'Device:';
    # test for vmstat header
    next if $list[0] eq 'procs';

    if ( $#list == 11 ) {
        (
        undef,
        $data{io}{ $list[0] }{rrqms},
        $data{io}{ $list[0] }{wrqms},
        $data{io}{ $list[0] }{reads},
        $data{io}{ $list[0] }{writes},
        $data{io}{ $list[0] }{rsecs},
        $data{io}{ $list[0] }{wsecs},
        $data{io}{ $list[0] }{avgrqsz},
        $data{io}{ $list[0] }{avgqusz},
        $data{io}{ $list[0] }{await},
        $data{io}{ $list[0] }{svctm},
        $data{io}{ $list[0] }{util}
        ) = @list;
    } elsif ( $#list == 15 ) {
        (
        $data{vm}{r},      $data{vm}{b},       $data{vm}{swpd},
        $data{vm}{free},   $data{vm}{buff},    $data{vm}{cache},
        $data{vm}{swapin}, $data{vm}{swapout}, $data{vm}{ioin},
        $data{vm}{ioout},  $data{vm}{sysin},   $data{vm}{syscs},
        $data{vm}{user},   $data{vm}{sys},     $data{vm}{idle},
        $data{vm}{wait}
        ) = @list;
    } elsif ( $#list == 5 ) {
        $data{vm}{nice} = $list[1];
    }
    {                                                               ## Added
        lock $json;                                                 ## Added
        $json = encode_json( \%data);
    }                                                               ## Added
    sleep 1;
}