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

Comparing AnyEvent/t/09_multi.t (file contents):
Revision 1.2 by root, Tue Aug 2 22:07:16 2011 UTC vs.
Revision 1.5 by root, Fri Aug 12 18:41:26 2011 UTC

1BEGIN {
2 # check for broken perls
3 if ($^O =~ /mswin32/i) {
4 my $ok;
5 local $SIG{CHLD} = sub { $ok = 1 };
6 kill 'CHLD', 0;
7
8 unless ($ok) {
9 print <<EOF;
101..0 # SKIP Your perl interpreter is badly BROKEN. Child watchers will not work, ever. Try upgrading to a newer perl or a working perl (cygwin's perl is known to work). If that is not an option, you should be able to use the remaining functionality of AnyEvent, but child watchers WILL NOT WORK.
11EOF
12 exit 0;
13 }
14 }
15}
16
1use AnyEvent; 17use AnyEvent;
2use AnyEvent::Util; 18use AnyEvent::Util;
3BEGIN { require AnyEvent::Impl::Perl unless $ENV{PERL_ANYEVENT_MODEL} } 19BEGIN { require AnyEvent::Impl::Perl unless $ENV{PERL_ANYEVENT_MODEL} }
4 20
5$| = 1; print "1..14\n"; 21$| = 1; print "1..15\n";
6 22
7print "ok 1\n"; 23print "ok 1\n";
8 24
9my ($a, $b) = AnyEvent::Util::portable_socketpair; 25my ($a, $b) = AnyEvent::Util::portable_socketpair;
10 26
11# I/O write 27# I/O write
12{ 28{
13 my $cv = AE::cv; 29 my $cv = AE::cv;
14 my $wt = AE::timer 0.1, 0, $cv; 30 my $wt = AE::timer 1, 0, $cv;
15 my $s = 0; 31 my $s = 0;
16 32
17 $cv->begin; my $wa = AE::io $a, 1, sub { $cv->end; $s |= 1 }; 33 $cv->begin; my $wa = AE::io $a, 1, sub { $cv->end; $s |= 1 };
18 $cv->begin; my $wb = AE::io $a, 1, sub { $cv->end; $s |= 2 }; 34 $cv->begin; my $wb = AE::io $a, 1, sub { $cv->end; $s |= 2 };
19 35
… …
23} 39}
24 40
25# I/O read 41# I/O read
26{ 42{
27 my $cv = AE::cv; 43 my $cv = AE::cv;
28 my $wt = AE::timer 0.1, 0, $cv; 44 my $wt = AE::timer 0.01, 0, $cv;
29 my $s = 0; 45 my $s = 0;
30 46
31 my $wa = AE::io $a, 0, sub { $cv->end; $s |= 1 }; 47 my $wa = AE::io $a, 0, sub { $cv->end; $s |= 1 };
32 my $wb = AE::io $a, 0, sub { $cv->end; $s |= 2 }; 48 my $wb = AE::io $a, 0, sub { $cv->end; $s |= 2 };
33 49
… …
36 print $s == 0 ? "" : "not ", "ok 3 # $s\n"; 52 print $s == 0 ? "" : "not ", "ok 3 # $s\n";
37 53
38 syswrite $b, "x"; 54 syswrite $b, "x";
39 55
40 $cv = AE::cv; 56 $cv = AE::cv;
41 $wt = AE::timer 0.1, 0, $cv; 57 $wt = AE::timer 1, 0, $cv;
42 58
43 $s = 0; 59 $s = 0;
44 $cv->begin; 60 $cv->begin;
45 $cv->begin; 61 $cv->begin;
46 $cv->recv; 62 $cv->recv;
… …
48 print $s == 3 ? "" : "not ", "ok 4 # $s\n"; 64 print $s == 3 ? "" : "not ", "ok 4 # $s\n";
49 65
50 sysread $a, my $dummy, 1; 66 sysread $a, my $dummy, 1;
51 67
52 $cv = AE::cv; 68 $cv = AE::cv;
53 $wt = AE::timer 0.1, 0, $cv; 69 $wt = AE::timer 0.01, 0, $cv;
54 70
55 $s = 0; 71 $s = 0;
56 $cv->recv; 72 $cv->recv;
57 73
58 print $s == 0 ? "" : "not ", "ok 5 # $s\n"; 74 print $s == 0 ? "" : "not ", "ok 5 # $s\n";
59} 75}
60 76
61# signal 77# signal
62{ 78{
63 my $cv = AE::cv; 79 my $cv = AE::cv;
64 my $wt = AE::timer 0.1, 0, $cv; 80 my $wt = AE::timer 0.01, 0, $cv;
65 my $s = 0; 81 my $s = 0;
66 82
67 $cv->begin; my $wa = AE::signal INT => sub { $cv->end; $s |= 1 }; 83 $cv->begin; my $wa = AE::signal INT => sub { $cv->end; $s |= 1 };
68 $cv->begin; my $wb = AE::signal INT => sub { $cv->end; $s |= 2 }; 84 $cv->begin; my $wb = AE::signal INT => sub { $cv->end; $s |= 2 };
69 85
… …
72 print $s == 0 ? "" : "not ", "ok 6 # $s\n"; 88 print $s == 0 ? "" : "not ", "ok 6 # $s\n";
73 89
74 kill INT => $$; 90 kill INT => $$;
75 91
76 $cv = AE::cv; 92 $cv = AE::cv;
77 $wt = AE::timer 0.1, 0, $cv; 93 $wt = AE::timer 0.01, 0, $cv;
78 94
79 $s = 0; 95 $s = 0;
80 $cv->recv; 96 $cv->recv;
81 97
82 print $s == 3 ? "" : "not ", "ok 7 # $s\n"; 98 print $s == 3 ? "" : "not ", "ok 7 # $s\n";
83 99
84 $cv = AE::cv; 100 $cv = AE::cv;
85 $wt = AE::timer 0.1, 0, $cv; 101 $wt = AE::timer 0.01, 0, $cv;
86 102
87 $s = 0; 103 $s = 0;
88 $cv->recv; 104 $cv->recv;
89 105
90 print $s == 0 ? "" : "not ", "ok 8 # $s\n"; 106 print $s == 0 ? "" : "not ", "ok 8 # $s\n";
… …
93$AnyEvent::MAX_SIGNAL_LATENCY = 0.2; 109$AnyEvent::MAX_SIGNAL_LATENCY = 0.2;
94 110
95# child 111# child
96{ 112{
97 my $cv = AE::cv; 113 my $cv = AE::cv;
98 my $wt = AE::timer 0.1, 0, $cv; 114 my $wt = AE::timer 0.01, 0, $cv;
99 my $s = 0; 115 my $s = 0;
100 116
101 my $pid = fork; 117 my $pid = fork;
102 118
103 unless ($pid) { 119 unless ($pid) {
… …
115 print $s == 0 ? "" : "not ", "ok 9 # $s\n"; 131 print $s == 0 ? "" : "not ", "ok 9 # $s\n";
116 132
117 kill 9, $pid; 133 kill 9, $pid;
118 134
119 $cv = AE::cv; 135 $cv = AE::cv;
120 $wt = AE::timer 0.1, 0, $cv; 136 $wt = AE::timer 0.01, 0, $cv;
121 137
122 $s = 0; 138 $s = 0;
123 $cv->recv; 139 $cv->recv;
124 140
125 print $s == 3 ? "" : "not ", "ok 10 # $s\n"; 141 print $s == 3 ? "" : "not ", "ok 10 # $s\n";
126 print $apid == $pid && $bpid == $pid ? "" : "not ", "ok 11 # $apid == $bpid == $pid\n"; 142 print $apid == $pid && $bpid == $pid ? "" : "not ", "ok 11 # $apid == $bpid == $pid\n";
127 print $astatus == 9 && $bstatus == 9 ? "" : "not ", "ok 12 # $astatus == $bstatus == 9\n"; 143 print $astatus == 9 && $bstatus == 9 ? "" : "not ", "ok 12 # $astatus == $bstatus == 9\n";
128 144
129 $cv = AE::cv; 145 $cv = AE::cv;
130 $wt = AE::timer 0.1, 0, $cv; 146 $wt = AE::timer 0.01, 0, $cv;
131 147
132 $s = 0; 148 $s = 0;
133 $cv->recv; 149 $cv->recv;
134 150
135 print $s == 0 ? "" : "not ", "ok 13 # $s\n"; 151 print $s == 0 ? "" : "not ", "ok 13 # $s\n";
136} 152}
137 153
154# timers (don't laugh, some event loops are more broken...)
155{
156 my $cv = AE::cv;
157 my $wt = AE::timer 1, 0, $cv;
158 my $s = 0;
159
160 $cv->begin; my $wa = AE::timer 0 , 0, sub { $cv->end; $s |= 1 };
161 $cv->begin; my $wb = AE::timer 0 , 0, sub { $cv->end; $s |= 2 };
162 $cv->begin; my $wc = AE::timer 0.01, 0, sub { $cv->end; $s |= 4 };
163
164 $cv->recv;
165
166 print $s == 7 ? "" : "not ", "ok 14 # $s\n";
167}
168
138print "ok 14\n"; 169print "ok 15\n";
139 170
140exit 0; 171exit 0;
141 172

Diff Legend

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