[ViewVC] Diff of: cvs/cvsroot/Coro/myhttpd/access.pl

Comparing cvsroot/Coro/myhttpd/access.pl (file contents):
Revision 1.13 by root, Thu Nov 29 02:30:04 2001 UTC vs.
Revision 1.16 by root, Fri Nov 30 05:11:23 2001 UTC

 }
 sub start_transfer {
    my $self = shift;
-   my $trans = bless [ $self, $Coro::current ], transfer::;
+   my $trans = bless [ $self ], transfer::;
    Scalar::Util::weaken($trans->[0]);
    push @{$self->{wait}}, $trans;
    Scalar::Util::weaken($self->{wait}[-1]);
-   if (--$self->{conns} >= 0) {
+   --$self->{conns};
-      $self->wake_next;
+   $self->wake_next;
-   }
    $trans;
 }
 sub wake_next {
    my $self = shift;
-   return unless $self->{conns} >= 0;
+   if ($self->{conns} >= 0) {
-   if (@{$self->{wait}}) {
+      while(@{$self->{wait}}) {
-      while() {
          my $transfer = shift @{$self->{wait}};
          if ($transfer) {
             $transfer->wake;
             last;
          }
 package transfer;
 use Coro::Timer ();
-sub try {
-   my $self = shift;
-   my $timeout = Coro::Timer::timeout $_[0];
-   Coro::schedule;
-   return $self->[2];
-}
 sub wake {
    my $self = shift;
    $self->[2] = 1;
-   $self->[1]->ready;
+   ref $self->[1] and $self->[1]->ready;
+}
+sub try {
+   my $self = shift;
+   unless ($self->[2]) {
+      my $timeout = Coro::Timer::timeout $_[0];
+      $self->[1] = $Coro::current;
+      Coro::schedule;
+      undef $self->[1];
+   }
+   return $self->[2];
 }
 sub DESTROY {
    my $self = shift;
    $self->[0]{conns}++;

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