… | … | ||
---|---|---|---|
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 |