ViewVC Help
View File | Revision Log | Show Annotations | Download File
/cvs/AnyEvent/t/68_poe_07_io.t
(Generate patch)

Comparing AnyEvent/t/68_poe_07_io.t (file contents):
Revision 1.1 by root, Wed Jul 8 04:49:18 2009 UTC vs.
Revision 1.6 by root, Tue Aug 2 20:02:47 2011 UTC

1$|=1;
2$^W=0;
3BEGIN { print "1..18\n" }
4
5use AnyEvent; 1use AnyEvent;
6use AnyEvent::Util; 2use AnyEvent::Util;
7use AnyEvent::Impl::POE; 3BEGIN { eval q{use AnyEvent::Impl::POE;1} or ((print qq{1..0 # SKIP AnyEvent::Impl::POE not loadable
4}), exit 0) } $^W = 0;
5
6$| = 1; print "1..18\n";
8 7
9print "ok 1\n"; 8print "ok 1\n";
10 9
11my ($a, $b) = AnyEvent::Util::portable_socketpair; 10my ($a, $b) = AnyEvent::Util::portable_socketpair;
12 11
25 }); 24 });
26}); 25});
27 26
28print "ok 3\n"; 27print "ok 3\n";
29 28
30{ my $cv = AnyEvent->condvar; $t = AnyEvent->timer (after => 0.05, cb => sub { $cv->send }); $cv->wait } 29{ my $cv = AnyEvent->condvar; $t = AnyEvent->timer (after => 0.05, cb => sub { $cv->send }); $cv->recv }
31 30
32print "ok 4\n"; 31print "ok 4\n";
33 32
34$wa = AnyEvent->io (fh => $a, poll => "w", cb => sub { 33$wa = AnyEvent->io (fh => $a, poll => "w", cb => sub {
35 syswrite $a, "0"; 34 syswrite $a, "0";
41 sysread $a, my $buf, 1; 40 sysread $a, my $buf, 1;
42 print "ok 9\n"; 41 print "ok 9\n";
43 $cv->send; 42 $cv->send;
44}); 43});
45 44
46$cv = AnyEvent->condvar; $cv->wait; 45$cv = AnyEvent->condvar; $cv->recv;
47 46
48print "ok 10\n"; 47print "ok 10\n";
49 48
50$rb = AnyEvent->io (fh => fileno $b, poll => "r", cb => sub { 49$rb = AnyEvent->io (fh => fileno $b, poll => "r", cb => sub {
51 print "ok 14\n"; 50 print "ok 14\n";
58 }); 57 });
59}); 58});
60 59
61print "ok 11\n"; 60print "ok 11\n";
62 61
63{ my $cv = AnyEvent->condvar; $t = AnyEvent->timer (after => 0.05, cb => sub { $cv->send }); $cv->wait } 62{ my $cv = AnyEvent->condvar; $t = AnyEvent->timer (after => 0.05, cb => sub { $cv->send }); $cv->recv }
64 63
65print "ok 12\n"; 64print "ok 12\n";
66 65
67$wa = AnyEvent->io (fh => fileno $a, poll => "w", cb => sub { 66$wa = AnyEvent->io (fh => fileno $a, poll => "w", cb => sub {
68 syswrite $a, "0"; 67 syswrite $a, "0";
74 sysread $a, my $buf, 1; 73 sysread $a, my $buf, 1;
75 print "ok 17\n"; 74 print "ok 17\n";
76 $cv->send; 75 $cv->send;
77}); 76});
78 77
79$cv = AnyEvent->condvar; $cv->wait; 78$cv = AnyEvent->condvar; $cv->recv;
80 79
81print "ok 18\n"; 80print "ok 18\n";
82 81

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines