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.6 by root, Sat May 24 23:10:18 2008 UTC vs.
Revision 1.14 by root, Fri Aug 26 03:34:01 2011 UTC

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

Diff Legend

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