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

Comparing AnyEvent/t/handle/01_readline.t (file contents):
Revision 1.4 by root, Sat May 3 12:17:35 2008 UTC vs.
Revision 1.11 by root, Fri Jun 6 11:05:16 2008 UTC

1#!perl 1#!perl
2 2
3# actually tests a few other read/write types as well
4
3use strict; 5use strict;
6
4use AnyEvent::Impl::Perl; 7use AnyEvent::Impl::Perl;
5use AnyEvent::Handle; 8use AnyEvent::Handle;
6use Test::More tests => 3; 9use Test::More tests => 8;
7use Socket; 10use Socket;
11use Errno;
8 12
9{ 13{
10 my $cv = AnyEvent->condvar; 14 my $cv = AnyEvent->condvar;
11 15
12 socketpair my $rd, my $wr, AF_UNIX, SOCK_STREAM, PF_UNSPEC; 16 socketpair my $rd, my $wr, AF_UNIX, SOCK_STREAM, PF_UNSPEC;
13 17
14 my $rd_ae = AnyEvent::Handle->new ( 18 my $rd_ae = AnyEvent::Handle->new (
15 fh => $rd, 19 fh => $rd,
20 on_error => sub {
21 ok ($! == &Errno::EPIPE);
22 },
16 on_eof => sub { $cv->broadcast }, 23 on_eof => sub { $cv->broadcast },
17 ); 24 );
18 25
19 my $concat; 26 my $concat;
20 27
21 $rd_ae->push_read_line (sub { 28 $rd_ae->push_read (line => sub {
22 is ($_[1], "A", 'A line was read correctly'); 29 is ($_[1], "A", 'A line was read correctly');
23 my $cb; $cb = sub { 30 my $cb; $cb = sub {
24 $concat .= $_[1]; 31 $concat .= $_[1];
25 $_[0]->push_read_line ($cb); 32 $_[0]->push_read (line => $cb);
26 }; 33 };
27 $_[0]->push_read_line ($cb); 34 $_[0]->push_read (line => $cb);
28 }); 35 });
29 36
30 syswrite $wr, "A\nBC\nDEF\nG\n" . ("X" x 113) . "\n"; 37 syswrite $wr, "A\012BC\012DEF\012G\012" . ("X" x 113) . "\012";
31 close $wr; 38 close $wr;
32 39
33 $cv->wait; 40 $cv->wait;
34 is ($concat, "BCDEFG" . ("X" x 113), 'first lines were read correctly'); 41 is ($concat, "BCDEFG" . ("X" x 113), 'initial lines were read correctly');
35} 42}
36 43
37{ 44{
38 my $cv = AnyEvent->condvar; 45 my $cv = AnyEvent->condvar;
39 46
… …
44 my $rd_ae = 51 my $rd_ae =
45 AnyEvent::Handle->new ( 52 AnyEvent::Handle->new (
46 fh => $rd, 53 fh => $rd,
47 on_eof => sub { $cv->broadcast }, 54 on_eof => sub { $cv->broadcast },
48 on_read => sub { 55 on_read => sub {
49 $_[0]->push_read_line (sub { 56 $_[0]->push_read (line => sub {
50 $concat .= "$_[1]:"; 57 $concat .= "$_[1]:";
51 }); 58 });
52 } 59 }
53 ); 60 );
54 61
55 my $wr_ae = new AnyEvent::Handle fh => $wr, on_eof => sub { die }; 62 my $wr_ae = new AnyEvent::Handle fh => $wr, on_eof => sub { die };
56 63
57 $wr_ae->push_write ("A\nBC\nDEF\nG\n" . ("X" x 113) . "\n");
58 undef $wr; 64 undef $wr;
65 undef $rd;
66
67 $wr_ae->push_write (netstring => "0:xx,,");
68 $wr_ae->push_write (netstring => "");
69 $wr_ae->push_write (storable => [4,3,2]);
70 $wr_ae->push_write (packstring => "w", "hallole" x 99999); # try to exhaust socket buffer here
71 $wr_ae->push_write ("A\012BC\012DEF\nG\012" . ("X" x 113) . "\012");
59 undef $wr_ae; 72 undef $wr_ae;
73
74 $rd_ae->push_read (netstring => sub { is ($_[1], "0:xx,,") });
75 $rd_ae->push_read (netstring => sub { is ($_[1], "") });
76 $rd_ae->push_read (storable => "w", sub { is ("@{$_[1]}", "4 3 2") });
77 $rd_ae->push_read (packstring => "w", sub { is ($_[1], "hallole" x 99999) });
60 78
61 $cv->wait; 79 $cv->wait;
62 80
63 is ($concat, "A:BC:DEF:G:" . ("X" x 113) . ":", 'second lines were read correctly'); 81 is ($concat, "A:BC:DEF:G:" . ("X" x 113) . ":", 'second set of lines were read correctly');
64} 82}
83

Diff Legend

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