| … | … | ||
|---|---|---|---|
| 777 | --npending; | 777 | --npending; |
| 778 | 778 | ||
| 779 | if (!res_queue.size) | 779 | if (!res_queue.size) |
| 780 | { | 780 | { |
| 781 | /* read any signals sent by the worker threads */ | 781 | /* read any signals sent by the worker threads */ |
| 782 | char buf [32]; | 782 | char buf [4]; |
| 783 | while (read (respipe [0], buf, 32) == 32) | 783 | while (read (respipe [0], buf, 4) == 4) |
| 784 | ; | 784 | ; |
| 785 | } | 785 | } |
| 786 | } | 786 | } |
| 787 | 787 | ||
| 788 | UNLOCK (reslock); | 788 | UNLOCK (reslock); |
| – | Removed lines |
| + | Added lines |
| < | Changed lines |
| > | Changed lines |