| … | … | ||
|---|---|---|---|
| 75 | } | 75 | } |
| 76 | 76 | ||
| 77 | sub force_wake_next { | 77 | sub force_wake_next { |
| 78 | my $self = shift; | 78 | my $self = shift; |
| 79 | 79 | ||
| 80 | $self->{slots} += 1; | 80 | $self->{slots} += $::MAX_TRANSFERS; |
| 81 | $self->wake_next; | 81 | $self->wake_next; |
| 82 | $self->{slots} -= 1; | 82 | $self->{slots} -= $::MAX_TRANSFERS; |
| 83 | } | 83 | } |
| 84 | 84 | ||
| 85 | sub waiters { | 85 | sub waiters { |
| 86 | $_[0]->sort; | 86 | $_[0]->sort; |
| 87 | @{$_[0]{wait}}; | 87 | @{$_[0]{wait}}; |
| – | Removed lines |
| + | Added lines |
| < | Changed lines |
| > | Changed lines |