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