Revert "MEDIUM: proto_htx: Switch to infinite forwarding if there is no data filter"
This reverts commit f52170d2f47efbace729bc88349eb189968df568.
This commit was merged too early, some areas are not ready and
transfers from H1 to H2 often stall. Christopher suggested to wait
for the other parts to be ready before reintroducing it.
diff --git a/src/proto_htx.c b/src/proto_htx.c
index 80d7fa1..bdfd4ba 100644
--- a/src/proto_htx.c
+++ b/src/proto_htx.c
@@ -1212,18 +1212,9 @@
channel_auto_close(req);
if (req->to_forward) {
- if (req->to_forward == CHN_INFINITE_FORWARD) {
- if (req->flags & CF_SHUTR) {
- msg->msg_state = HTTP_MSG_DONE;
- req->to_forward = 0;
- goto done;
- }
- }
- else {
- /* We can't process the buffer's contents yet */
- req->flags |= CF_WAKE_WRITE;
- goto missing_data_or_waiting;
- }
+ /* We can't process the buffer's contents yet */
+ req->flags |= CF_WAKE_WRITE;
+ goto missing_data_or_waiting;
}
if (msg->msg_state >= HTTP_MSG_DONE)
@@ -1242,8 +1233,14 @@
}
else {
c_adv(req, htx->data - co_data(req));
- if (msg->flags & HTTP_MSGF_XFER_LEN)
- channel_htx_forward_forever(req, htx);
+
+ /* To let the function channel_forward work as expected we must update
+ * the channel's buffer to pretend there is no more input data. The
+ * right length is then restored. We must do that, because when an HTX
+ * message is stored into a buffer, it appears as full.
+ */
+ if ((msg->flags & HTTP_MSGF_XFER_LEN) && htx->extra)
+ htx->extra -= channel_htx_forward(req, htx, htx->extra);
}
/* Check if the end-of-message is reached and if so, switch the message
@@ -1253,7 +1250,6 @@
goto missing_data_or_waiting;
msg->msg_state = HTTP_MSG_DONE;
- req->to_forward = 0;
done:
/* other states, DONE...TUNNEL */
@@ -2134,18 +2130,9 @@
channel_auto_close(res);
if (res->to_forward) {
- if (res->to_forward == CHN_INFINITE_FORWARD) {
- if (res->flags & CF_SHUTR) {
- msg->msg_state = HTTP_MSG_DONE;
- res->to_forward = 0;
- goto done;
- }
- }
- else {
- /* We can't process the buffer's contents yet */
- res->flags |= CF_WAKE_WRITE;
- goto missing_data_or_waiting;
- }
+ /* We can't process the buffer's contents yet */
+ res->flags |= CF_WAKE_WRITE;
+ goto missing_data_or_waiting;
}
if (msg->msg_state >= HTTP_MSG_DONE)
@@ -2165,8 +2152,14 @@
}
else {
c_adv(res, htx->data - co_data(res));
- if (msg->flags & HTTP_MSGF_XFER_LEN)
- channel_htx_forward_forever(res, htx);
+
+ /* To let the function channel_forward work as expected we must update
+ * the channel's buffer to pretend there is no more input data. The
+ * right length is then restored. We must do that, because when an HTX
+ * message is stored into a buffer, it appears as full.
+ */
+ if ((msg->flags & HTTP_MSGF_XFER_LEN) && htx->extra)
+ htx->extra -= channel_htx_forward(res, htx, htx->extra);
}
if (!(msg->flags & HTTP_MSGF_XFER_LEN)) {
@@ -2184,7 +2177,6 @@
goto missing_data_or_waiting;
msg->msg_state = HTTP_MSG_DONE;
- res->to_forward = 0;
done:
/* other states, DONE...TUNNEL */