diff --git a/haproxy.c b/haproxy.c index 0f0e1813b..c5af86a36 100644 --- a/haproxy.c +++ b/haproxy.c @@ -4297,6 +4297,7 @@ int process_srv(struct session *t) { t->flags |= conn_err; if (!(t->flags & SN_FINST_MASK)) t->flags |= SN_FINST_C; + /* TODO : check if there are pending connections on this server */ return 1; } else { /* no error or write 0 */ @@ -4384,6 +4385,7 @@ int process_srv(struct session *t) { Alert("Blocking cacheable cookie in response from instance %s, server %s.\n", t->proxy->id, t->srv->id); send_log(t->proxy, LOG_ALERT, "Blocking cacheable cookie in response from instance %s, server %s.\n", t->proxy->id, t->srv->id); + /* TODO : check if there are pending connections on this server */ return 1; } } @@ -4401,6 +4403,7 @@ int process_srv(struct session *t) { t->flags |= SN_ERR_PRXCOND; if (!(t->flags & SN_FINST_MASK)) t->flags |= SN_FINST_H; + /* TODO : check if there are pending connections on this server */ return 1; } @@ -4833,6 +4836,7 @@ int process_srv(struct session *t) { t->flags |= SN_ERR_SRVCL; if (!(t->flags & SN_FINST_MASK)) t->flags |= SN_FINST_H; + /* TODO : check if there are pending connections on this server */ return 1; } /* end of client write or end of server read. @@ -4861,8 +4865,8 @@ int process_srv(struct session *t) { t->flags |= SN_ERR_SRVTO; if (!(t->flags & SN_FINST_MASK)) t->flags |= SN_FINST_H; + /* TODO : check if there are pending connections on this server */ return 1; - } /* last client read and buffer empty */ /* FIXME!!! here, we don't want to switch to SHUTW if the @@ -4954,6 +4958,7 @@ int process_srv(struct session *t) { t->flags |= SN_ERR_SRVCL; if (!(t->flags & SN_FINST_MASK)) t->flags |= SN_FINST_D; + /* TODO : check if there are pending connections on this server */ return 1; } /* last read, or end of client write */ @@ -5060,6 +5065,7 @@ int process_srv(struct session *t) { t->flags |= SN_ERR_SRVCL; if (!(t->flags & SN_FINST_MASK)) t->flags |= SN_FINST_D; + /* TODO : check if there are pending connections on this server */ return 1; } else if ((c == CL_STSHUTR || c == CL_STCLOSE) && (req->l == 0)) { @@ -5069,6 +5075,7 @@ int process_srv(struct session *t) { t->srv->cur_sess--; //close(t->srv_fd); t->srv_state = SV_STCLOSE; + /* TODO : check if there are pending connections on this server */ return 1; } else if (tv_cmp2_ms(&t->swexpire, &now) <= 0) { @@ -5082,6 +5089,7 @@ int process_srv(struct session *t) { t->flags |= SN_ERR_SRVTO; if (!(t->flags & SN_FINST_MASK)) t->flags |= SN_FINST_D; + /* TODO : check if there are pending connections on this server */ return 1; } else if (req->l == 0) { @@ -5116,6 +5124,7 @@ int process_srv(struct session *t) { t->flags |= SN_ERR_SRVCL; if (!(t->flags & SN_FINST_MASK)) t->flags |= SN_FINST_D; + /* TODO : check if there are pending connections on this server */ return 1; } else if (t->res_sr == RES_NULL || c == CL_STSHUTW || c == CL_STCLOSE) { @@ -5125,6 +5134,7 @@ int process_srv(struct session *t) { t->srv->cur_sess--; //close(t->srv_fd); t->srv_state = SV_STCLOSE; + /* TODO : check if there are pending connections on this server */ return 1; } else if (tv_cmp2_ms(&t->srexpire, &now) <= 0) { @@ -5138,6 +5148,7 @@ int process_srv(struct session *t) { t->flags |= SN_ERR_SRVTO; if (!(t->flags & SN_FINST_MASK)) t->flags |= SN_FINST_D; + /* TODO : check if there are pending connections on this server */ return 1; } else if (rep->l == BUFSIZE) { /* no room to read more data */