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