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.5 by root, Fri May 2 09:07:02 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 );
20 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
21my $ae_sock = 35my $ae_sock =
22 AnyEvent::Socket->new ( 36 AnyEvent::Socket->new (
23 PeerAddr => "127.0.0.1:32391", 37 PeerAddr => "127.0.0.1:" . $lsock->fh->sockport,
24 on_connect => sub { 38 on_connect => sub {
25 my ($ae_sock, $error) = @_; 39 my ($ae_sock, $error) = @_;
26 if ($error) { diag "connection failed: $!"; $cv->broadcast; return } 40 if ($error) { diag "connection failed: $!"; $cv->broadcast; return }
27 41
28 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";
36 } 50 }
37 ); 51 );
38 52
39$ae_sock->on_eof (sub { $cv->broadcast }); 53$ae_sock->on_eof (sub { $cv->broadcast });
40 54
41$lsock->on_accept (sub {
42 my ($lsock, $cl, $paddr) = @_;
43
44 unless (defined $cl) {
45 diag "accept failed: $!";
46 return;
47 }
48
49 $cl->read (6, sub {
50 my ($cl, $data) = @_;
51 $lbytes = $data;
52 $cl->write ("BLABLABLA\015\012");
53 });
54});
55
56$cv->wait; 55$cv->wait;
57 56
58is ($lbytes, "TEST\015\012", 'listening end received data'); 57is ($lbytes, "TEST\015\012", 'listening end received data');
59is ($rbytes, "BLABLABLA\015\012", 'connecting received response'); 58is ($rbytes, "BLABLABLA\015\012", 'connecting received response');
60 59

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines