| … | … | ||
|---|---|---|---|
| 130 | return mg ? (aio_req)mg->mg_ptr : 0; | 130 | return mg ? (aio_req)mg->mg_ptr : 0; |
| 131 | } | 131 | } |
| 132 | 132 | ||
| 133 | static void aio_grp_feed (aio_req grp) | 133 | static void aio_grp_feed (aio_req grp) |
| 134 | { | 134 | { |
| 135 | while (grp->length < grp->fd2) | 135 | while (grp->length < grp->fd2 && !grp->cancelled) |
| 136 | { | 136 | { |
| 137 | int old_len = grp->length; | 137 | int old_len = grp->length; |
| 138 | 138 | ||
| 139 | if (grp->fh2 && SvOK (grp->fh2)) | 139 | if (grp->fh2 && SvOK (grp->fh2)) |
| 140 | { | 140 | { |
| – | Removed lines |
| + | Added lines |
| < | Changed lines |
| > | Changed lines |