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

Comparing Coro/Coro.pm (file contents):
Revision 1.141 by root, Tue Oct 2 10:38:17 2007 UTC vs.
Revision 1.142 by root, Tue Oct 2 23:16:24 2007 UTC

… …
116=cut 116=cut
117 117
118$main->{desc} = "[main::]"; 118$main->{desc} = "[main::]";
119 119
120# maybe some other module used Coro::Specific before... 120# maybe some other module used Coro::Specific before...
121$main->{specific} = $current->{specific} 121$main->{_specific} = $current->{_specific}
122 if $current; 122 if $current;
123 123
124_set_current $main; 124_set_current $main;
125 125
126sub current() { $current } 126sub current() { $current }
… …
151 # free coroutine data and mark as destructed 151 # free coroutine data and mark as destructed
152 $self->_destroy 152 $self->_destroy
153 or return; 153 or return;
154 154
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->{_on_destroy}) || []};
158} 158}
159 159
160# this coroutine is necessary because a coroutine 160# this coroutine is necessary because a coroutine
161# cannot destroy itself. 161# cannot destroy itself.
162my @destroy; 162my @destroy;
… …
378 378
379=cut 379=cut
380 380
381sub cancel { 381sub cancel {
382 my $self = shift; 382 my $self = shift;
383 $self->{status} = [@_]; 383 $self->{_status} = [@_];
384 384
385 if ($current == $self) { 385 if ($current == $self) {
386 push @destroy, $self; 386 push @destroy, $self;
387 $manager->ready; 387 $manager->ready;
388 &schedule while 1; 388 &schedule while 1;
… …
400=cut 400=cut
401 401
402sub join { 402sub join {
403 my $self = shift; 403 my $self = shift;
404 404
405 unless ($self->{status}) { 405 unless ($self->{_status}) {
406 my $current = $current; 406 my $current = $current;
407 407
408 push @{$self->{destroy_cb}}, sub { 408 push @{$self->{_on_destroy}}, sub {
409 $current->ready; 409 $current->ready;
410 undef $current; 410 undef $current;
411 }; 411 };
412 412
413 &schedule while $current; 413 &schedule while $current;
414 } 414 }
415 415
416 wantarray ? @{$self->{status}} : $self->{status}[0]; 416 wantarray ? @{$self->{_status}} : $self->{_status}[0];
417} 417}
418 418
419=item $coroutine->on_destroy (\&cb) 419=item $coroutine->on_destroy (\&cb)
420 420
421Registers a callback that is called when this coroutine gets destroyed, 421Registers a callback that is called when this coroutine gets destroyed,
… …
425=cut 425=cut
426 426
427sub on_destroy { 427sub on_destroy {
428 my ($self, $cb) = @_; 428 my ($self, $cb) = @_;
429 429
430 push @{ $self->{destroy_cb} }, $cb; 430 push @{ $self->{_on_destroy} }, $cb;
431} 431}
432 432
433=item $oldprio = $coroutine->prio ($newprio) 433=item $oldprio = $coroutine->prio ($newprio)
434 434
435Sets (or gets, if the argument is missing) the priority of the 435Sets (or gets, if the argument is missing) the priority of the
… …
459 459
460=item $olddesc = $coroutine->desc ($newdesc) 460=item $olddesc = $coroutine->desc ($newdesc)
461 461
462Sets (or gets in case the argument is missing) the description for this 462Sets (or gets in case the argument is missing) the description for this
463coroutine. This is just a free-form string you can associate with a coroutine. 463coroutine. This is just a free-form string you can associate with a coroutine.
464
465This method simply sets the C<< $coroutine->{desc} >> member to the given string. You
466can modify this member directly if you wish.
464 467
465=cut 468=cut
466 469
467sub desc { 470sub desc {
468 my $old = $_[0]{desc}; 471 my $old = $_[0]{desc};

Diff Legend

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