| … | |
… | |
| 50 | } |
50 | } |
| 51 | |
51 | |
| 52 | our $connections = new Coro::Semaphore $MAX_CONNECTS || 250; |
52 | our $connections = new Coro::Semaphore $MAX_CONNECTS || 250; |
| 53 | our $httpevent = new Coro::Signal; |
53 | our $httpevent = new Coro::Signal; |
| 54 | |
54 | |
| 55 | our $queue_file = new transferqueue slots => $MAX_TRANSFERS, maxsize => 256*1024*1024; |
55 | our $queue_file = new transferqueue slots => $MAX_TRANSFERS, maxsize => 250_000_000; |
| 56 | our $queue_index = new transferqueue slots => 10; |
56 | our $queue_index = new transferqueue slots => 10; |
|
|
57 | |
|
|
58 | our $requests; |
| 57 | |
59 | |
| 58 | my @newcons; |
60 | my @newcons; |
| 59 | my @pool; |
61 | my @pool; |
| 60 | |
62 | |
| 61 | # one "execution thread" |
63 | # one "execution thread" |
| … | |
… | |
| 294 | |
296 | |
| 295 | $self->{h}{$h} = substr $v, 1 |
297 | $self->{h}{$h} = substr $v, 1 |
| 296 | while ($h, $v) = each %hdr; |
298 | while ($h, $v) = each %hdr; |
| 297 | } |
299 | } |
| 298 | |
300 | |
|
|
301 | $requests++; |
|
|
302 | |
| 299 | # remote id should be unique per user |
303 | # remote id should be unique per user |
| 300 | my $id = $self->{remote_addr}; |
304 | my $id = $self->{remote_addr}; |
| 301 | |
305 | |
| 302 | if (exists $self->{h}{"client-ip"}) { |
306 | if (exists $self->{h}{"client-ip"}) { |
| 303 | $id .= "[".$self->{h}{"client-ip"}."]"; |
307 | $id .= "[".$self->{h}{"client-ip"}."]"; |
