t/handle/02_write.t

#!perl

use strict;

use AnyEvent::Impl::Perl;
use AnyEvent::Handle;
use Socket;

print "1..7\n";

my $cv = AnyEvent->condvar;

socketpair my $rd, my $wr, AF_UNIX, SOCK_STREAM, PF_UNSPEC;

my $rd_ae =
   AnyEvent::Handle->new (
      fh => $rd,
      on_eof => sub {
         warn "reader got EOF";
         $cv->broadcast
      }
   );

my $wr_ae =
   AnyEvent::Handle->new (
      fh => $wr,
      on_eof => sub {
         warn "writer got EOF\n";
         $cv->broadcast
      }
   );

my $dat = '';

$rd_ae->push_read (chunk => 5132, sub {
   my ($rd_ae, $data) = @_;
   $dat = substr $data, 0, 2;
   $dat .= substr $data, -5;

   print "ok 4 - first read chunk\n";
   my $n = 5;
   $wr_ae->push_write ("A" x 5000);
   $wr_ae->on_drain (sub {
      my ($wr_ae) = @_;
      $wr_ae->on_drain;
      print "ok " . $n++ . " - fourth write\n";

   });

   $rd_ae->push_read (chunk => 1, sub {
      print "ok " . $n++ . " - second read chunk\n";
      $cv->broadcast
   });
});

$wr_ae->push_write ("A" x 5000);
$wr_ae->push_write ("X" x 130);

# and now some extreme CPS action:
$wr_ae->on_drain (sub {
   my ($wr_ae) = @_;
   $wr_ae->on_drain;
   print "ok 1 - first write\n";

   $wr_ae->push_write ("Y");
   $wr_ae->on_drain (sub {
      my ($wr_ae) = @_;
      $wr_ae->on_drain;
      print "ok 2 - second write\n";

      $wr_ae->push_write ("Z");
      $wr_ae->on_drain (sub {
         my ($wr_ae) = @_;
         $wr_ae->on_drain;
         print "ok 3 - third write\n";
      });
   });
});

$cv->wait;

if ($dat eq "AAXXXYZ") {
   print "ok 7 - received data\n";
} else {
   warn "dat was '$dat'\n";
   print "not ok 7 - received data\n";
}
Revision:	1.7
Committed:	Fri Jul 4 12:19:00 2008 UTC (18 years, 4 months ago) by elmex
Content type:	application/x-troff
Branch:	MAIN
Changes since 1.6:	+7 -5 lines
Log Message:	fixed a broken test
#	User	Rev	Content
1	elmex	1.1	#!perl
2	root	1.5
3	elmex	1.1	use strict;
4	root	1.5
5	root	1.2	use AnyEvent::Impl::Perl;
6	elmex	1.1	use AnyEvent::Handle;
7			use Socket;
8
9	elmex	1.3	print "1..7\n";
10
11	elmex	1.1	my $cv = AnyEvent->condvar;
12
13			socketpair my $rd, my $wr, AF_UNIX, SOCK_STREAM, PF_UNSPEC;
14
15	elmex	1.3	my $rd_ae =
16			AnyEvent::Handle->new (
17			fh => $rd,
18			on_eof => sub {
19			warn "reader got EOF";
20			$cv->broadcast
21			}
22			);
23
24			my $wr_ae =
25			AnyEvent::Handle->new (
26			fh => $wr,
27			on_eof => sub {
28			warn "writer got EOF\n";
29			$cv->broadcast
30			}
31			);
32	elmex	1.1
33			my $dat = '';
34
35	root	1.6	$rd_ae->push_read (chunk => 5132, sub {
36	elmex	1.1	my ($rd_ae, $data) = @_;
37			$dat = substr $data, 0, 2;
38			$dat .= substr $data, -5;
39	elmex	1.3
40			print "ok 4 - first read chunk\n";
41	elmex	1.7	my $n = 5;
42	elmex	1.3	$wr_ae->push_write ("A" x 5000);
43			$wr_ae->on_drain (sub {
44			my ($wr_ae) = @_;
45			$wr_ae->on_drain;
46	elmex	1.7	print "ok " . $n++ . " - fourth write\n";
47	elmex	1.3
48	elmex	1.7	});
49
50			$rd_ae->push_read (chunk => 1, sub {
51			print "ok " . $n++ . " - second read chunk\n";
52			$cv->broadcast
53	elmex	1.3	});
54	elmex	1.1	});
55
56	elmex	1.3	$wr_ae->push_write ("A" x 5000);
57			$wr_ae->push_write ("X" x 130);
58	elmex	1.1
59	elmex	1.3	# and now some extreme CPS action:
60			$wr_ae->on_drain (sub {
61			my ($wr_ae) = @_;
62			$wr_ae->on_drain;
63			print "ok 1 - first write\n";
64
65			$wr_ae->push_write ("Y");
66			$wr_ae->on_drain (sub {
67			my ($wr_ae) = @_;
68			$wr_ae->on_drain;
69			print "ok 2 - second write\n";
70
71			$wr_ae->push_write ("Z");
72			$wr_ae->on_drain (sub {
73			my ($wr_ae) = @_;
74			$wr_ae->on_drain;
75			print "ok 3 - third write\n";
76			});
77			});
78			});
79	elmex	1.1
80			$cv->wait;
81
82	elmex	1.3	if ($dat eq "AAXXXYZ") {
83			print "ok 7 - received data\n";
84			} else {
85			warn "dat was '$dat'\n";
86			print "not ok 7 - received data\n";
87			}