| … | |
… | |
| 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 $MAX_TRANSFERS; |
55 | our $queue_file = new transferqueue slots => $MAX_TRANSFERS, maxsize => 256*1024*1024; |
| 56 | our $queue_index = new transferqueue 10; |
56 | our $queue_index = new transferqueue slots => 10; |
| 57 | |
57 | |
| 58 | my @newcons; |
58 | my @newcons; |
| 59 | my @pool; |
59 | my @pool; |
| 60 | |
60 | |
| 61 | # one "execution thread" |
61 | # one "execution thread" |
