goto fail;
data = htx->data - co_data(res);
- res->total += data;
- res->flags |= CF_READ_PARTIAL;
+ channel_add_input(res, data);
appctx->appctx->ctx.hlua_apphttp.flags &= ~APPLET_100C;
return;
/* Copy data. */
if (!htx_add_data(htx, ist2(data + l, max)))
goto snd_yield;
- res->total += max;
- res->flags |= CF_READ_PARTIAL;
htx_to_buf(htx, &res->buf);
+ channel_add_input(res, max);
/* update counters. */
l += max;
}
htx_to_buf(htx, &res->buf);
- res->total += htx->data;
- res->flags |= CF_READ_PARTIAL;
+ channel_add_input(res, htx->data);
/* Headers sent, set the flag. */
appctx->appctx->ctx.hlua_apphttp.flags |= APPLET_HDR_SENT;
si_rx_room_blk(si);
goto out;
}
- res->total++;
- res->flags |= CF_READ_PARTIAL;
+ channel_add_input(res, 1);
}
done:
res->buf.data = b_data(err);
memcpy(res->buf.area, b_head(err), b_data(err));
res_htx = htx_from_buf(&res->buf);
-
- res->total += res_htx->data;
- res->flags |= CF_READ_PARTIAL;
+ channel_add_input(res, res_htx->data);
}
if (!(strm->flags & SF_ERR_MASK))
strm->flags |= SF_ERR_RESOURCE;