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