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

Comparing Coro/myhttpd/httpd.pl (file contents):
Revision 1.67 by root, Sun May 19 21:00:47 2002 UTC vs.
Revision 1.71 by root, Mon Jul 29 21:41:54 2002 UTC

 our $httpevent   = new Coro::Signal;
 our $queue_file  = new transferqueue $MAX_TRANSFERS;
 our $queue_index = new transferqueue 10;
-our $tbf_top     = new tbf rate => 200000;
+our $tbf_top     = new tbf rate => 100000;
+my $unused_bytes = 0;
+my $unused_last  = time;
+sub unused_bandwidth {
+   $unused_bytes += $_[0];
+   if ($unused_last < $NOW - 30 && $unused_bytes / ($NOW - $unused_last) > 50000) {
+      $unused_last = $NOW;
+      $unused_bytes = 0;
+      $queue_file->force_wake_next;
+      slog 1, "forced filetransfer due to unused bandwidth";
+   }
+}
 my @newcons;
 my @pool;
 # one "execution thread"
       $hdr->{"Content-Length"} = length $content;
       $GZ = sprintf "GZ%02d", 100 - 100*((length $content) / $orig);
    }
    $res .= "Date: $HTTP_NOW\015\012";
+   $res .= "Server: $::NAME\015\012";
    while (my ($h, $v) = each %$hdr) {
       $res .= "$h: $v\015\012"
    }
    $res .= "\015\012";
    $self->response(@code, $hdr, "");
    if ($self->{method} eq "GET") {
       $self->{time} = $::NOW;
+      $self->{written} = 0;
       my $current = $Coro::current;
       my ($fh, $buf, $r);
       while ($h > 0) {
          unless ($locked) {
             if ($locked ||= $transfer->try($::WAIT_INTERVAL)) {
                $bufsize = $::BUFSIZE;
                $self->{time} = $::NOW;
+               $self->{written} = 0;
             }
          }
          if ($blocked{$self->{remote_id}}) {
             $self->{h}{connection} = "close";

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