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.21 by root, Mon Dec 3 05:52:37 2001 UTC vs.
Revision 1.22 by root, Mon Dec 3 14:44:14 2001 UTC

12sub start_transfer { 12sub start_transfer {
13 my $self = shift; 13 my $self = shift;
14 my $size = $_[0]; 14 my $size = $_[0];
15 15
16 my $transfer = bless { 16 my $transfer = bless {
17 queue => $self, 17 queue => $self,
18 time => $::NOW, 18 time => $::NOW,
19 size => $size, 19 size => $size,
20 coro => $Coro::current, 20 coro => $Coro::current,
21 started => 0,
21 }, transfer::; 22 }, transfer::;
22 23
23 push @{$self->{wait}}, $transfer; 24 push @{$self->{wait}}, $transfer;
24 Scalar::Util::weaken($self->{wait}[-1]);
25 25
26 $self->wake_next; 26 $self->wake_next;
27 27
28 $trans; 28 $transfer;
29}
30
31sub sort {
32 my @queue = grep $_, @{$_[0]{wait}};
33
34 $_->{spb} = ($::NOW-$_->{time}) / ($_->{size} || 1) for @queue;
35
36 $_[0]{wait} = [sort { $b->{spb} <=> $a->{spb} } @queue];
37
38 Scalar::Util::weaken $_ for @{$_[0]{wait}};
29} 39}
30 40
31sub wake_next { 41sub wake_next {
32 my $self = shift; 42 my $self = shift;
33 43
37 my $transfer = shift @{$self->{wait}}; 47 my $transfer = shift @{$self->{wait}};
38 if ($transfer) { 48 if ($transfer) {
39 $self->{lastspb} = $transfer->{spb}; 49 $self->{lastspb} = $transfer->{spb};
40 $self->{avgspb} ||= $transfer->{spb}; 50 $self->{avgspb} ||= $transfer->{spb};
41 $self->{avgspb} = $self->{avgspb} * 0.95 + $transfer->{spb} * 0.05; 51 $self->{avgspb} = $self->{avgspb} * 0.95 + $transfer->{spb} * 0.05;
52 $self->{started}++;
42 $transfer->wake; 53 $transfer->wake;
43 last; 54 last;
44 } 55 }
45 } 56 }
46}
47
48sub sort {
49 my @queue = grep $_, @{$_[0]{wait}};
50
51 $_->{spb} = ($::NOW-$_->{time}) / ($_->{size} || 1) for @queue;
52
53 $_[0]{wait} = [sort { $b->{spb} <=> $a->{spb} } @queue];
54} 57}
55 58
56sub waiters { 59sub waiters {
57 $_[0]->sort; 60 $_[0]->sort;
58 @{$_[0]{wait}}; 61 @{$_[0]{wait}};

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines