ViewVC Help
View File | Revision Log | Show Annotations | Download File
/cvs/cvsroot/Coro/Coro.pm
(Generate patch)

Comparing cvsroot/Coro/Coro.pm (file contents):
Revision 1.135 by root, Sat Sep 22 22:39:15 2007 UTC vs.
Revision 1.139 by root, Thu Sep 27 15:52:30 2007 UTC

50 50
51our $idle; # idle handler 51our $idle; # idle handler
52our $main; # main coroutine 52our $main; # main coroutine
53our $current; # current coroutine 53our $current; # current coroutine
54 54
55our $VERSION = '3.7'; 55our $VERSION = '3.8';
56 56
57our @EXPORT = qw(async async_pool cede schedule terminate current unblock_sub); 57our @EXPORT = qw(async async_pool cede schedule terminate current unblock_sub);
58our %EXPORT_TAGS = ( 58our %EXPORT_TAGS = (
59 prio => [qw(PRIO_MAX PRIO_HIGH PRIO_NORMAL PRIO_LOW PRIO_IDLE PRIO_MIN)], 59 prio => [qw(PRIO_MAX PRIO_HIGH PRIO_NORMAL PRIO_LOW PRIO_IDLE PRIO_MIN)],
60); 60);
155 # call all destruction callbacks 155 # call all destruction callbacks
156 $_->(@{$self->{status}}) 156 $_->(@{$self->{status}})
157 for @{(delete $self->{destroy_cb}) || []}; 157 for @{(delete $self->{destroy_cb}) || []};
158} 158}
159 159
160sub _do_trace_sub {
161 &{$current->{_trace_sub_cb}}
162}
163
164sub _do_trace_line {
165 &{$current->{_trace_line_cb}}
166}
167
160# this coroutine is necessary because a coroutine 168# this coroutine is necessary because a coroutine
161# cannot destroy itself. 169# cannot destroy itself.
162my @destroy; 170my @destroy;
163my $manager; 171my $manager;
164 172
241 my $cb; 249 my $cb;
242 250
243 while () { 251 while () {
244 eval { 252 eval {
245 while () { 253 while () {
246# &{&_pool_1 or &terminate}; # crashes, would be ~5% faster
247 $cb = &_pool_1 254 _pool_1 $cb;
248 or &terminate;
249 &$cb; 255 &$cb;
250 undef $cb; 256 _pool_2 $cb;
251 &terminate if &_pool_2;
252 &schedule; 257 &schedule;
253 } 258 }
254 }; 259 };
255 260
261 last if $@ eq "\3terminate\2\n";
256 warn $@ if $@; 262 warn $@ if $@;
257 } 263 }
258} 264}
259 265
260sub async_pool(&@) { 266sub async_pool(&@) {

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines