| 1511 | return child_is_working(pp_child) && pp_child->process.in > 0; |
| 1512 | } |
| 1513 | static int child_is_sending_output(const struct parallel_child *pp_child) |
| 1514 | { |
| 1515 | /* |
| 1516 | * all pp children which buffer output through run_command via ungroup=0 |
| 1517 | * redirect stdout to stderr, so we just need to check process.err. |
| 1518 | */ |
| 1519 | return child_is_working(pp_child) && pp_child->process.err > 0; |
| 1520 | } |
| 1521 | |
| 1522 | struct parallel_processes { |
| 1523 | size_t nr_processes; |
no test coverage detected