| … | |
… | |
| 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); |
| … | |
… | |
| 1446 | length = svlen - dataoffset; |
1446 | length = svlen - dataoffset; |
| 1447 | } |
1447 | } |
| 1448 | else |
1448 | else |
| 1449 | { |
1449 | { |
| 1450 | /* read: grow scalar as necessary */ |
1450 | /* read: grow scalar as necessary */ |
| 1451 | svptr = SvGROW (data, length + dataoffset); |
1451 | svptr = SvGROW (data, length + dataoffset + 1); |
| 1452 | } |
1452 | } |
| 1453 | |
1453 | |
| 1454 | if (length < 0) |
1454 | if (length < 0) |
| 1455 | croak ("length must not be negative"); |
1455 | croak ("length must not be negative"); |
| 1456 | |
1456 | |
