Please sign in to comment.
Re-prime data avail condvar before waiting
If @data_queue has data before the collector is first called, then ->recv would not be called and the condvar not recreated. This meant on the next call @data_queue was empty but the condvar was ready resulting in undef being returned. So we re-prime the condvar before we wait so that the condvar will only be ready when the next chunk is placed into @data_queue
- Loading branch information...
Showing with 4 additions and 3 deletions.