lib/Sack/Client.pm

#!/usr/bin/perl

use warnings;
use strict;

use IO::Socket::INET;
use IO::Select;
use Storable qw();

use lib '/srv/Sack/lib';
use Data::Dump qw(dump);

my $port = shift @ARGV;

my $sock = IO::Socket::INET->new(
        PeerAddr => '127.0.0.1',
        PeerPort => $port,
        Proto => 'tcp',
) || die $!;

my $sel = IO::Select->new($sock);
$sel->add($sock);

while (1) {
        for my $sock ($sel->can_read(1)) {
                my $request = Storable::fd_retrieve($sock);
                warn "[$port] <<<< ", dump($request), $/;
                my $response = { port => $port };
                $response->{ping} = 'pong' if $request->{ping};
                Storable::store_fd( $response, $sock );
                warn "[$port] >>>> ", dump($response), $/;
        }
}
1	dpavlin	163	#!/usr/bin/perl
2
3			use warnings;
4			use strict;
5
6			use IO::Socket::INET;
7			use IO::Select;
8			use Storable qw();
9	dpavlin	168
10			use lib '/srv/Sack/lib';
11	dpavlin	163	use Data::Dump qw(dump);
12
13			my $port = shift @ARGV;
14
15			my $sock = IO::Socket::INET->new(
16			PeerAddr => '127.0.0.1',
17			PeerPort => $port,
18			Proto => 'tcp',
19			) \|\| die $!;
20
21			my $sel = IO::Select->new($sock);
22			$sel->add($sock);
23
24			while (1) {
25			for my $sock ($sel->can_read(1)) {
26			my $request = Storable::fd_retrieve($sock);
27			warn "[$port] <<<< ", dump($request), $/;
28			my $response = { port => $port };
29			$response->{ping} = 'pong' if $request->{ping};
30			Storable::store_fd( $response, $sock );
31			warn "[$port] >>>> ", dump($response), $/;
32			}
33			}