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.24 by root, Tue Dec 4 02:46:29 2001 UTC vs.
Revision 1.27 by root, Wed Dec 5 02:02:23 2001 UTC

1package transferqueue; 1package transferqueue;
2 2
3my @reserve = ( 3my @reserve = (
4 [ 1_200_000, 2],
4 [ 1_000_000, 1], 5 [ 8_000_000, 1],
5 [ 10_000_000, 1], 6 [ 75_000_000, 1],
6); 7);
7 8
8sub new { 9sub new {
9 my $class = shift; 10 my $class = shift;
10 bless { 11 my $self = bless {
11 slots => $_[0], 12 slots => $_[0],
12 lastspb => 0, 13 lastspb => 0,
13 avgspb => 0, 14 avgspb => 0,
14 }, $class; 15 }, $class;
16 $self->{reschedule} = Event->timer(
17 after => 10,
18 interval => 3,
19 cb => sub { $self->wake_next },
20 );
21 $self;
15} 22}
16 23
17sub start_transfer { 24sub start_transfer {
18 my $self = shift; 25 my $self = shift;
19 my $size = $_[0]; 26 my $size = $_[0];
… …
56 $min += $_->[1]; 63 $min += $_->[1];
57 } 64 }
58 last unless $self->{slots} > $min; 65 last unless $self->{slots} > $min;
59 my $transfer = shift @{$self->{wait}}; 66 my $transfer = shift @{$self->{wait}};
60 $self->{lastspb} = $transfer->{spb}; 67 $self->{lastspb} = $transfer->{spb};
61 $self->{avgspb} ||= $transfer->{spb};
62 $self->{avgspb} = $self->{avgspb} * 0.95 + $transfer->{spb} * 0.05; 68 $self->{avgspb} = $self->{avgspb} * 0.99 + $transfer->{spb} * 0.01;
63 $self->{started}++; 69 $self->{started}++;
64 $transfer->wake; 70 $transfer->wake;
65 last; 71 last;
66 } 72 }
67} 73}
68 74
69sub waiters { 75sub waiters {
70 $_[0]->sort; 76 $_[0]->sort;
71 @{$_[0]{wait}}; 77 @{$_[0]{wait}};
78}
79
80sub DESTROY {
81 my $self = shift;
82
83 $self->{reschedule}->cancel;
72} 84}
73 85
74package transfer; 86package transfer;
75 87
76use Coro::Timer (); 88use Coro::Timer ();

Diff Legend

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