| … | |
… | |
| 56 | |
56 | |
| 57 | our $queue_file = new transferqueue $MAX_TRANSFERS; |
57 | our $queue_file = new transferqueue $MAX_TRANSFERS; |
| 58 | our $queue_index = new transferqueue 10; |
58 | our $queue_index = new transferqueue 10; |
| 59 | |
59 | |
| 60 | our $tbf_top = new tbf rate => 200000; |
60 | our $tbf_top = new tbf rate => 200000; |
|
|
61 | |
|
|
62 | my $unused_bytes = 0; |
|
|
63 | my $unused_last = time; |
|
|
64 | |
|
|
65 | sub unused_bandwidth { |
|
|
66 | $unused_bytes += $_[0]; |
|
|
67 | if ($unused_last < $NOW - 30 && $unused_bytes / ($NOW - $unused_last) > 50000) { |
|
|
68 | $unused_last = $NOW; |
|
|
69 | $unused_bytes = 0; |
|
|
70 | $queue_file->force_wake_next; |
|
|
71 | slog 1, "forced filetransfer due to unused bandwidth"; |
|
|
72 | } |
|
|
73 | } |
| 61 | |
74 | |
| 62 | my @newcons; |
75 | my @newcons; |
| 63 | my @pool; |
76 | my @pool; |
| 64 | |
77 | |
| 65 | # one "execution thread" |
78 | # one "execution thread" |
