| 408 | } |
| 409 | |
| 410 | static void push_buf( hb_work_private_t *r, hb_fifo_t *fifo, hb_buffer_t *buf ) |
| 411 | { |
| 412 | while ( !*r->die && !r->job->done ) |
| 413 | { |
| 414 | if ( hb_fifo_full_wait( fifo ) ) |
| 415 | { |
| 416 | hb_fifo_push( fifo, buf ); |
| 417 | buf = NULL; |
| 418 | break; |
| 419 | } |
| 420 | } |
| 421 | if ( buf ) |
| 422 | { |
| 423 | hb_buffer_close( &buf ); |
| 424 | } |
| 425 | } |
| 426 | |
| 427 | static void reader_send_eof( hb_work_private_t * r ) |
| 428 | { |
no test coverage detected