ViewVC Help
View File | Revision Log | Show Annotations | Download File
/cvs/AnyEvent/t/handle/04_listen.t
(Generate patch)

Comparing AnyEvent/t/handle/04_listen.t (file contents):
Revision 1.3 by root, Fri May 2 09:04:57 2008 UTC vs.
Revision 1.6 by elmex, Fri May 2 09:15:34 2008 UTC

… …
12my $cv = AnyEvent->condvar; 12my $cv = AnyEvent->condvar;
13 13
14my $lsock = 14my $lsock =
15 AnyEvent::Socket->new ( 15 AnyEvent::Socket->new (
16 Listen => 1, 16 Listen => 1,
17 LocalPort => 32391,
18 ReuseAddr => 1, 17 ReuseAddr => 1,
19 ); 18 );
19
20$lsock->on_accept (sub {
21 my ($lsock, $cl, $paddr) = @_;
22
23 unless (defined $cl) {
24 diag "accept failed: $!";
25 return;
26 }
27
28 $cl->read (6, sub {
29 my ($cl, $data) = @_;
30 $lbytes = $data;
31 $cl->write ("BLABLABLA\015\012");
32 });
33});
34
20my $ae_sock = 35my $ae_sock =
21 AnyEvent::Socket->new ( 36 AnyEvent::Socket->new (
22 PeerAddr => "127.0.0.1:32391", 37 PeerAddr => "127.0.0.1:" . $lsock->fh->sockport,
23 on_connect => sub { 38 on_connect => sub {
24 my ($ae_sock, $error) = @_; 39 my ($ae_sock, $error) = @_;
25 if ($error) { diag "connection failed: $!"; $cv->broadcast; return } 40 if ($error) { diag "connection failed: $!"; $cv->broadcast; return }
26 41
27 print "connected to ".$ae_sock->fh->peerhost.":".$ae_sock->fh->peerport."\n"; 42 print "connected to ".$ae_sock->fh->peerhost.":".$ae_sock->fh->peerport."\n";
… …
35 } 50 }
36 ); 51 );
37 52
38$ae_sock->on_eof (sub { $cv->broadcast }); 53$ae_sock->on_eof (sub { $cv->broadcast });
39 54
40$lsock->on_accept (sub {
41 my ($lsock, $cl, $paddr) = @_;
42
43 unless (defined $cl) {
44 diag "accept failed: $!";
45 return;
46 }
47
48 $cl->read (6, sub {
49 my ($cl, $data) = @_;
50 $lbytes = $data;
51 $cl->write ("BLABLABLA\015\012");
52 });
53});
54
55$cv->wait; 55$cv->wait;
56 56
57is ($lbytes, "TEST\015\012", 'listening end received data'); 57is ($lbytes, "TEST\015\012", 'listening end received data');
58is ($rbytes, "BLABLABLA\015\012", 'connecting received response'); 58is ($rbytes, "BLABLABLA\015\012", 'connecting received response');
59

Diff Legend

– Removed lines
+ Added lines
< Changed lines
> Changed lines