1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
|
use warnings;
use strict;
use FindBin;
use lib "$FindBin::Bin/../";
BEGIN {
if ($^O =~ m/^(?:qnx|nto|vos|MSWin32)$/ ) {
print "1..0 # Skip: UNIX domain sockets not implemented on $^O\n";
exit 0;
}
};
use Test::More;
use Test::UNIXSock;
use IO::Socket::UNIX;
use t::ServerUNIX;
my $server = Test::UNIXSock->new(
code => sub {
my $path = shift;
ok $path, "test case for sharedfork" for 1..10;
t::ServerUNIX->new($path)->run(sub {
note "new request";
my ($remote, $line, $sock) = @_;
print {$remote} $line;
});
}
);
ok $server->path, "test case for sharedfork" for 1..10;
my $sock = IO::Socket::UNIX->new(
Peer => $server->path,
Type => SOCK_STREAM(),
) or die "Cannot open client socket: $!";
note "send 1";
print {$sock} "foo\n";
my $res = <$sock>;
is $res, "foo\n";
note "send 2";
print {$sock} "bar\n";
my $res2 = <$sock>;
is $res2, "bar\n";
note "finalize";
print {$sock} "quit\n";
$server->stop;
done_testing;
|
