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
|
use strict;
use warnings;
use Test::More;
use Time::HiRes qw(time usleep);
use IO::Socket::INET;
use Test::TCP 'test_tcp';
use Net::EmptyPort 'empty_port';
BEGIN { use_ok 'Protocol::OSC' }
my $p = Protocol::OSC->new;
my @spec = (time,[qw(/echo isf 3 aaba 3.1)],[qw(/echo ii 3 1)]);
if (my $port = empty_port(undef, 'udp')) {
my $in = IO::Socket::INET->new( qw(LocalAddr localhost LocalPort), $port, qw(Proto udp Type), SOCK_DGRAM );
my $client = IO::Socket::INET->new( qw(PeerAddr localhost PeerPort), $port, qw(Proto udp Type), SOCK_DGRAM );
$client->send($p->bundle(@spec));
usleep 0.2e6;
$in->recv(my $packet, $in->sockopt(SO_RCVBUF));
ok($p->parse($packet)->[0] eq $spec[0], 'bundle in-out - udp') if $packet;
}
if (my $port = empty_port(undef, 'tcp')) {
test_tcp(
client => sub {
my ($port, $server_pid) = @_;
my $client = IO::Socket::INET->new( qw(PeerAddr localhost PeerPort), $port, qw(Proto tcp Type), SOCK_STREAM ) or die $!;
$client->syswrite($p->to_stream($p->bundle(@spec)));
usleep 0.2e6;
},
server => sub {
my $port = shift;
my $in = IO::Socket::INET->new( qw(LocalAddr localhost LocalPort), $port, qw(Proto tcp Type), SOCK_STREAM, qw(Listen 1),
$^O eq 'MSWin32' ? () : (ReuseAddr => 1) );
while (my $sock = $in->accept) {
print "accepted\n";
my $tail;
while ($sock->sysread(my $buf, $in->sockopt(SO_RCVBUF))) {
my @packets = $p->from_stream(length($tail) ? $tail.$buf : $buf);
$tail = pop @packets;
ok($p->parse($packets[0])->[0] eq $spec[0], 'bundle in-out - tcp') if @packets
}
}
}
);
}
done_testing;
|
