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

Comparing cvsroot/Coro/myhttpd/access.pl (file contents):
Revision 1.25 by root, Tue Dec 4 03:43:54 2001 UTC vs.
Revision 1.29 by root, Wed Jan 23 03:07:05 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 bless { 11 my $self = bless {
12 slots => $_[0], 12 slots => $_[0],
13 lastspb => 0, 13 lastspb => 0,
14 avgspb => 0, 14 avgspb => 0,
15 }, $class; 15 }, $class;
16 $self->{reschedule} = Event->timer(
17 after => 10,
18 interval => 3,
19 cb => sub { $self->wake_next },
20 );
21 $self;
16} 22}
17 23
18sub start_transfer { 24sub start_transfer {
19 my $self = shift; 25 my $self = shift;
20 my $size = $_[0]; 26 my $size = $_[0];
57 $min += $_->[1]; 63 $min += $_->[1];
58 } 64 }
59 last unless $self->{slots} > $min; 65 last unless $self->{slots} > $min;
60 my $transfer = shift @{$self->{wait}}; 66 my $transfer = shift @{$self->{wait}};
61 $self->{lastspb} = $transfer->{spb}; 67 $self->{lastspb} = $transfer->{spb};
62 $self->{avgspb} ||= $transfer->{spb};
63 $self->{avgspb} = $self->{avgspb} * 0.95 + $transfer->{spb} * 0.05; 68 $self->{avgspb} = $self->{avgspb} * 0.99 + $transfer->{spb} * 0.01;
64 $self->{started}++; 69 $self->{started}++;
65 $transfer->wake; 70 $transfer->wake;
66 last; 71 last;
67 } 72 }
68} 73}
69 74
70sub waiters { 75sub waiters {
71 $_[0]->sort; 76 $_[0]->sort;
72 @{$_[0]{wait}}; 77 @{$_[0]{wait}};
78}
79
80sub DESTROY {
81 my $self = shift;
82
83 $self->{reschedule}->cancel;
73} 84}
74 85
75package transfer; 86package transfer;
76 87
77use Coro::Timer (); 88use Coro::Timer ();

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines