MINOR: tree-wide: Replace several chn_cons() by the corresponding SC
At many places, call to chn_cons() can be easily replaced by the
corresponding SC. It is a bit easier to understand which side is
manipulated.
diff --git a/src/backend.c b/src/backend.c
index 7044ae1..7bc321b 100644
--- a/src/backend.c
+++ b/src/backend.c
@@ -1956,7 +1956,7 @@
static int back_may_abort_req(struct channel *req, struct stream *s)
{
return (sc_ep_test(s->scf, SE_FL_ERROR) ||
- ((chn_cons(req)->flags & (SC_FL_SHUT_WANTED|SC_FL_SHUT_DONE)) && /* empty and client aborted */
+ ((s->scb->flags & (SC_FL_SHUT_WANTED|SC_FL_SHUT_DONE)) && /* empty and client aborted */
(channel_is_empty(req) || (s->be->options & PR_O_ABRT_CLOSE))));
}
@@ -2241,13 +2241,12 @@
{
struct stconn *sc = s->scb;
struct channel *req = &s->req;
- struct channel *rep = &s->res;
DBG_TRACE_ENTER(STRM_EV_STRM_PROC|STRM_EV_CS_ST, s);
/* the client might want to abort */
- if ((chn_cons(rep)->flags & SC_FL_SHUT_DONE) ||
- ((chn_cons(req)->flags & SC_FL_SHUT_WANTED) &&
+ if ((s->scf->flags & SC_FL_SHUT_DONE) ||
+ ((s->scb->flags & SC_FL_SHUT_WANTED) &&
(channel_is_empty(req) || (s->be->options & PR_O_ABRT_CLOSE)))) {
sc->flags |= SC_FL_NOLINGER;
sc_shutdown(sc);
@@ -2434,7 +2433,6 @@
{
struct stconn *sc = s->scb;
struct channel *req = &s->req;
- struct channel *rep = &s->res;
DBG_TRACE_ENTER(STRM_EV_STRM_PROC|STRM_EV_CS_ST, s);
@@ -2470,8 +2468,8 @@
*/
if (!(req->flags & CF_WROTE_DATA)) {
/* client abort ? */
- if ((chn_cons(rep)->flags & SC_FL_SHUT_DONE) ||
- ((chn_cons(req)->flags & SC_FL_SHUT_WANTED) &&
+ if ((s->scf->flags & SC_FL_SHUT_DONE) ||
+ ((s->scb->flags & SC_FL_SHUT_WANTED) &&
(channel_is_empty(req) || (s->be->options & PR_O_ABRT_CLOSE)))) {
/* give up */
sc->flags |= SC_FL_NOLINGER;
diff --git a/src/cli.c b/src/cli.c
index bcb4ce7..5ac4935 100644
--- a/src/cli.c
+++ b/src/cli.c
@@ -2716,7 +2716,7 @@
struct proxy *be = s->be;
if (sc_ep_test(s->scb, SE_FL_ERR_PENDING|SE_FL_ERROR) || (rep->flags & (CF_READ_TIMEOUT|CF_WRITE_TIMEOUT)) ||
- ((chn_cons(rep)->flags & SC_FL_SHUT_DONE) && (rep->to_forward || co_data(rep)))) {
+ ((s->scf->flags & SC_FL_SHUT_DONE) && (rep->to_forward || co_data(rep)))) {
pcli_reply_and_close(s, "Can't connect to the target CLI!\n");
s->req.analysers &= ~AN_REQ_WAIT_CLI;
s->res.analysers &= ~AN_RES_WAIT_CLI;
diff --git a/src/http_ana.c b/src/http_ana.c
index 61b5443..3c46f2a 100644
--- a/src/http_ana.c
+++ b/src/http_ana.c
@@ -983,7 +983,7 @@
if (!(txn->flags & TX_CON_WANT_TUN))
channel_dont_close(req);
- if ((chn_cons(req)->flags & SC_FL_SHUT_DONE) && co_data(req)) {
+ if ((s->scb->flags & SC_FL_SHUT_DONE) && co_data(req)) {
/* request errors are most likely due to the server aborting the
* transfer. */
goto return_srv_abort;
@@ -1023,7 +1023,7 @@
waiting:
/* waiting for the last bits to leave the buffer */
- if (chn_cons(req)->flags & SC_FL_SHUT_DONE)
+ if (s->scb->flags & SC_FL_SHUT_DONE)
goto return_srv_abort;
/* When TE: chunked is used, we need to get there again to parse remaining
@@ -1296,7 +1296,7 @@
/* 3: client abort with an abortonclose */
else if ((chn_prod(rep)->flags & SC_FL_ABRT_DONE) &&
(chn_prod(&s->req)->flags & SC_FL_ABRT_DONE) &&
- (chn_cons(&s->req)->flags & SC_FL_SHUT_DONE)) {
+ (s->scb->flags & SC_FL_SHUT_DONE)) {
_HA_ATOMIC_INC(&sess->fe->fe_counters.cli_aborts);
_HA_ATOMIC_INC(&s->be->be_counters.cli_aborts);
if (sess->listener && sess->listener->counters)
@@ -2104,7 +2104,7 @@
channel_dont_close(res);
- if ((chn_cons(res)->flags & SC_FL_SHUT_DONE) && co_data(res)) {
+ if ((s->scf->flags & SC_FL_SHUT_DONE) && co_data(res)) {
/* response errors are most likely due to the client aborting
* the transfer. */
goto return_cli_abort;
@@ -2120,7 +2120,7 @@
return 0;
missing_data_or_waiting:
- if (chn_cons(res)->flags & SC_FL_SHUT_DONE)
+ if (s->scf->flags & SC_FL_SHUT_DONE)
goto return_cli_abort;
/* stop waiting for data if the input is closed before the end. If the
@@ -2130,7 +2130,7 @@
*/
if (msg->msg_state < HTTP_MSG_ENDING && (chn_prod(res)->flags & SC_FL_ABRT_DONE)) {
if ((chn_prod(&s->req)->flags & SC_FL_ABRT_DONE) &&
- (chn_cons(&s->req)->flags & SC_FL_SHUT_DONE))
+ (s->scb->flags & SC_FL_SHUT_DONE))
goto return_cli_abort;
/* If we have some pending data, we continue the processing */
if (htx_is_empty(htx))
@@ -4272,7 +4272,7 @@
txn->rsp.msg_state != HTTP_MSG_CLOSED)
goto check_channel_flags;
- if (!(chn_cons(chn)->flags & (SC_FL_SHUT_DONE|SC_FL_SHUT_WANTED))) {
+ if (!(s->scb->flags & (SC_FL_SHUT_DONE|SC_FL_SHUT_WANTED))) {
sc_schedule_abort(s->scf);
sc_schedule_shutdown(s->scb);
}
@@ -4306,7 +4306,7 @@
check_channel_flags:
/* Here, we are in HTTP_MSG_DONE or HTTP_MSG_TUNNEL */
- if (chn_cons(chn)->flags & (SC_FL_SHUT_DONE|SC_FL_SHUT_WANTED)) {
+ if (s->scb->flags & (SC_FL_SHUT_DONE|SC_FL_SHUT_WANTED)) {
/* if we've just closed an output, let's switch */
txn->req.msg_state = HTTP_MSG_CLOSING;
goto http_msg_closing;
@@ -4371,7 +4371,7 @@
/* we're not expecting any new data to come for this
* transaction, so we can close it.
*/
- if (!(chn_cons(chn)->flags & (SC_FL_SHUT_DONE|SC_FL_SHUT_WANTED))) {
+ if (!(s->scf->flags & (SC_FL_SHUT_DONE|SC_FL_SHUT_WANTED))) {
sc_schedule_abort(s->scb);
sc_schedule_shutdown(s->scf);
}
@@ -4402,7 +4402,7 @@
check_channel_flags:
/* Here, we are in HTTP_MSG_DONE or HTTP_MSG_TUNNEL */
- if (chn_cons(chn)->flags & (SC_FL_SHUT_DONE|SC_FL_SHUT_WANTED)) {
+ if (s->scf->flags & (SC_FL_SHUT_DONE|SC_FL_SHUT_WANTED)) {
/* if we've just closed an output, let's switch */
txn->rsp.msg_state = HTTP_MSG_CLOSING;
goto http_msg_closing;
diff --git a/src/stconn.c b/src/stconn.c
index d320173..eca1e45 100644
--- a/src/stconn.c
+++ b/src/stconn.c
@@ -1369,7 +1369,7 @@
cur_read += ret;
/* if we're allowed to directly forward data, we must update ->o */
- if (ic->to_forward && !(chn_cons(ic)->flags & (SC_FL_SHUT_DONE|SC_FL_SHUT_WANTED))) {
+ if (ic->to_forward && !(sc_opposite(sc)->flags & (SC_FL_SHUT_DONE|SC_FL_SHUT_WANTED))) {
unsigned long fwd = ret;
if (ic->to_forward != CHN_INFINITE_FORWARD) {
if (fwd > ic->to_forward)
diff --git a/src/stream.c b/src/stream.c
index 83e3b72..9c3361f 100644
--- a/src/stream.c
+++ b/src/stream.c
@@ -1956,7 +1956,7 @@
if (((req->flags & ~rqf_last) & CF_MASK_ANALYSER) ||
((scf->flags ^ scf_flags) & (SC_FL_ABRT_DONE|SC_FL_ABRT_WANTED)) ||
((scb->flags ^ scb_flags) & (SC_FL_SHUT_DONE|SC_FL_SHUT_WANTED)) ||
- (req->analysers && (chn_cons(req)->flags & SC_FL_SHUT_DONE)) ||
+ (req->analysers && (scb->flags & SC_FL_SHUT_DONE)) ||
scf->state != rq_prod_last ||
scb->state != rq_cons_last ||
s->pending_events & TASK_WOKEN_MSG) {
@@ -2061,7 +2061,7 @@
if (((res->flags & ~rpf_last) & CF_MASK_ANALYSER) ||
((scb->flags ^ scb_flags) & (SC_FL_ABRT_DONE|SC_FL_ABRT_WANTED)) ||
((scf->flags ^ scf_flags) & (SC_FL_SHUT_DONE|SC_FL_SHUT_WANTED)) ||
- (res->analysers && (chn_cons(res)->flags & SC_FL_SHUT_DONE)) ||
+ (res->analysers && (scf->flags & SC_FL_SHUT_DONE)) ||
scf->state != rp_cons_last ||
scb->state != rp_prod_last ||
s->pending_events & TASK_WOKEN_MSG) {