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

Comparing cvsroot/Coro/myhttpd/access.pl (file contents):
Revision 1.25 by root, Tue Dec 4 03:43:54 2001 UTC vs.
Revision 1.28 by root, Thu Jan 3 01:20:17 2002 UTC

 package transferqueue;
 my @reserve = (
-      [  1_200_000, 1],
+      [  1_200_000, 2],
-      [  3_000_000, 1],
+      [  8_000_000, 1],
       [ 75_000_000, 1],
 );
 sub new {
    my $class = shift;
-   bless {
+   my $self = bless {
-      slots   => $_[0],
+      slots   => 1,
+      maxsize => 0,
       lastspb => 0,
       avgspb  => 0,
+      @_,
    }, $class;
+   $self->{reschedule} = Event->timer(
+         after => 10,
+         interval => 3,
+         cb => sub { $self->wake_next },
+   );
+   $self;
 }
 sub start_transfer {
    my $self = shift;
    my $size = $_[0];
+   if ($self->{maxsize} && $self->{maxsize} < $size) {
+      $size = $self->{maxsize};
+   }
    my $transfer = bless {
       queue   => $self,
       time    => $::NOW,
       size    => $size,
          $min += $_->[1];
       }
       last unless $self->{slots} > $min;
       my $transfer = shift @{$self->{wait}};
       $self->{lastspb} = $transfer->{spb};
-      $self->{avgspb} ||= $transfer->{spb};
-      $self->{avgspb} = $self->{avgspb} * 0.95 + $transfer->{spb} * 0.05;
+      $self->{avgspb} = $self->{avgspb} * 0.99 + $transfer->{spb} * 0.01;
       $self->{started}++;
       $transfer->wake;
       last;
    }
 }
 sub waiters {
    $_[0]->sort;
    @{$_[0]{wait}};
+}
+sub DESTROY {
+   my $self = shift;
+   $self->{reschedule}->cancel;
 }
 package transfer;
 use Coro::Timer ();

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