mirrors/haproxy
1
0
Fork 0
mirror of https://git.haproxy.org/git/haproxy.git/ synced 2025-08-07 15:47:01 +02:00
Code Issues Projects Releases Wiki Activity

Revert "added some comments to the places where we can send a pending connection"

Browse Source 
This reverts 704f32b78c commit.
This commit is contained in:
willy tarreau 2006-04-15 21:10:34 +02:00
parent 87ff241455
commit 8439e8c75c
1 changed files with 1 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
haproxy.c
View File

@ -4279,7 +4279,6 @@ int process_srv(struct session *t) {
t->flags |= conn_err; t->flags |= conn_err;
if (!(t->flags & SN_FINST_MASK)) if (!(t->flags & SN_FINST_MASK))
t->flags |= SN_FINST_C; t->flags |= SN_FINST_C;
/* TODO : check if there are pending connections on this server */
return 1; return 1;
} }
else { /* no error or write 0 */ else { /* no error or write 0 */
@ -4367,7 +4366,6 @@ int process_srv(struct session *t) {
Alert("Blocking cacheable cookie in response from instance %s, server %s.\n", t->proxy->id, t->srv->id); 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); 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; return 1;
} }
} }
@ -4385,7 +4383,6 @@ int process_srv(struct session *t) {
t->flags |= SN_ERR_PRXCOND; t->flags |= SN_ERR_PRXCOND;
if (!(t->flags & SN_FINST_MASK)) if (!(t->flags & SN_FINST_MASK))
t->flags |= SN_FINST_H; t->flags |= SN_FINST_H;
/* TODO : check if there are pending connections on this server */
return 1; return 1;
} }
@ -4818,7 +4815,6 @@ int process_srv(struct session *t) {
t->flags |= SN_ERR_SRVCL; t->flags |= SN_ERR_SRVCL;
if (!(t->flags & SN_FINST_MASK)) if (!(t->flags & SN_FINST_MASK))
t->flags |= SN_FINST_H; t->flags |= SN_FINST_H;
/* TODO : check if there are pending connections on this server */
return 1; return 1;
} }
/* end of client write or end of server read. /* end of client write or end of server read.
@ -4847,8 +4843,8 @@ int process_srv(struct session *t) {
t->flags |= SN_ERR_SRVTO; t->flags |= SN_ERR_SRVTO;
if (!(t->flags & SN_FINST_MASK)) if (!(t->flags & SN_FINST_MASK))
t->flags |= SN_FINST_H; t->flags |= SN_FINST_H;
/* TODO : check if there are pending connections on this server */
return 1; return 1;
} }
/* last client read and buffer empty */ /* last client read and buffer empty */
/* FIXME!!! here, we don't want to switch to SHUTW if the /* FIXME!!! here, we don't want to switch to SHUTW if the
@ -4940,7 +4936,6 @@ int process_srv(struct session *t) {
t->flags |= SN_ERR_SRVCL; t->flags |= SN_ERR_SRVCL;
if (!(t->flags & SN_FINST_MASK)) if (!(t->flags & SN_FINST_MASK))
t->flags |= SN_FINST_D; t->flags |= SN_FINST_D;
/* TODO : check if there are pending connections on this server */
return 1; return 1;
} }
/* last read, or end of client write */ /* last read, or end of client write */
@ -5047,7 +5042,6 @@ int process_srv(struct session *t) {
t->flags |= SN_ERR_SRVCL; t->flags |= SN_ERR_SRVCL;
if (!(t->flags & SN_FINST_MASK)) if (!(t->flags & SN_FINST_MASK))
t->flags |= SN_FINST_D; t->flags |= SN_FINST_D;
/* TODO : check if there are pending connections on this server */
return 1; return 1;
} }
else if ((c == CL_STSHUTR || c == CL_STCLOSE) && (req->l == 0)) { else if ((c == CL_STSHUTR || c == CL_STCLOSE) && (req->l == 0)) {
@ -5057,7 +5051,6 @@ int process_srv(struct session *t) {
t->srv->cur_sess--; t->srv->cur_sess--;
//close(t->srv_fd); //close(t->srv_fd);
t->srv_state = SV_STCLOSE; t->srv_state = SV_STCLOSE;
/* TODO : check if there are pending connections on this server */
return 1; return 1;
} }
else if (tv_cmp2_ms(&t->swexpire, &now) <= 0) { else if (tv_cmp2_ms(&t->swexpire, &now) <= 0) {
@ -5071,7 +5064,6 @@ int process_srv(struct session *t) {
t->flags |= SN_ERR_SRVTO; t->flags |= SN_ERR_SRVTO;
if (!(t->flags & SN_FINST_MASK)) if (!(t->flags & SN_FINST_MASK))
t->flags |= SN_FINST_D; t->flags |= SN_FINST_D;
/* TODO : check if there are pending connections on this server */
return 1; return 1;
} }
else if (req->l == 0) { else if (req->l == 0) {
@ -5106,7 +5098,6 @@ int process_srv(struct session *t) {
t->flags |= SN_ERR_SRVCL; t->flags |= SN_ERR_SRVCL;
if (!(t->flags & SN_FINST_MASK)) if (!(t->flags & SN_FINST_MASK))
t->flags |= SN_FINST_D; t->flags |= SN_FINST_D;
/* TODO : check if there are pending connections on this server */
return 1; return 1;
} }
else if (t->res_sr == RES_NULL || c == CL_STSHUTW || c == CL_STCLOSE) { else if (t->res_sr == RES_NULL || c == CL_STSHUTW || c == CL_STCLOSE) {
@ -5116,7 +5107,6 @@ int process_srv(struct session *t) {
t->srv->cur_sess--; t->srv->cur_sess--;
//close(t->srv_fd); //close(t->srv_fd);
t->srv_state = SV_STCLOSE; t->srv_state = SV_STCLOSE;
/* TODO : check if there are pending connections on this server */
return 1; return 1;
} }
else if (tv_cmp2_ms(&t->srexpire, &now) <= 0) { else if (tv_cmp2_ms(&t->srexpire, &now) <= 0) {
@ -5130,7 +5120,6 @@ int process_srv(struct session *t) {
t->flags |= SN_ERR_SRVTO; t->flags |= SN_ERR_SRVTO;
if (!(t->flags & SN_FINST_MASK)) if (!(t->flags & SN_FINST_MASK))
t->flags |= SN_FINST_D; t->flags |= SN_FINST_D;
/* TODO : check if there are pending connections on this server */
return 1; return 1;
} }
else if (rep->l == BUFSIZE) { /* no room to read more data */ else if (rep->l == BUFSIZE) { /* no room to read more data */