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

Comparing Coro/myhttpd/access.pl (file contents):
Revision 1.26 by root, Tue Dec 4 15:57:59 2001 UTC vs.
Revision 1.28 by root, Thu Jan 3 01:20:17 2002 UTC

1package transferqueue; 1package transferqueue;
2 2
3my @reserve = ( 3my @reserve = (
4 [ 1_200_000, 1], 4 [ 1_200_000, 2],
5 [ 3_000_000, 1], 5 [ 8_000_000, 1],
6 [ 75_000_000, 1], 6 [ 75_000_000, 1],
7); 7);
8 8
9sub new { 9sub new {
10 my $class = shift; 10 my $class = shift;
11 my $self = bless { 11 my $self = bless {
12 slots => $_[0], 12 slots => 1,
13 maxsize => 0,
13 lastspb => 0, 14 lastspb => 0,
14 avgspb => 0, 15 avgspb => 0,
16 @_,
15 }, $class; 17 }, $class;
16 $self->{reschedule} = Event->timer( 18 $self->{reschedule} = Event->timer(
17 after => 10, 19 after => 10,
18 interval => 3, 20 interval => 3,
19 cb => sub { $self->wake_next }, 21 cb => sub { $self->wake_next },
23 25
24sub start_transfer { 26sub start_transfer {
25 my $self = shift; 27 my $self = shift;
26 my $size = $_[0]; 28 my $size = $_[0];
27 29
30 if ($self->{maxsize} && $self->{maxsize} < $size) {
31 $size = $self->{maxsize};
32 }
33
28 my $transfer = bless { 34 my $transfer = bless {
29 queue => $self, 35 queue => $self,
30 time => $::NOW, 36 time => $::NOW,
31 size => $size, 37 size => $size,
32 coro => $Coro::current, 38 coro => $Coro::current,
63 $min += $_->[1]; 69 $min += $_->[1];
64 } 70 }
65 last unless $self->{slots} > $min; 71 last unless $self->{slots} > $min;
66 my $transfer = shift @{$self->{wait}}; 72 my $transfer = shift @{$self->{wait}};
67 $self->{lastspb} = $transfer->{spb}; 73 $self->{lastspb} = $transfer->{spb};
68 $self->{avgspb} ||= $transfer->{spb};
69 $self->{avgspb} = $self->{avgspb} * 0.95 + $transfer->{spb} * 0.05; 74 $self->{avgspb} = $self->{avgspb} * 0.99 + $transfer->{spb} * 0.01;
70 $self->{started}++; 75 $self->{started}++;
71 $transfer->wake; 76 $transfer->wake;
72 last; 77 last;
73 } 78 }
74} 79}

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines