RepoMirrors/haproxy
1
0
Fork 0
mirror of http://git.haproxy.org/git/haproxy.git/ synced 2025-03-02 01:20:49 +00:00
Code Issues Packages Projects Releases Wiki Activity

[MINOR] move the listener reference from fd to session

Browse Source 
The listener referenced in the fd was only used to check the
listener state upon session termination. There was no guarantee
that the FD had not been reassigned by the moment it was processed,
so this was a bit racy. Having it in the session is more robust.
This commit is contained in:
Willy Tarreau 2008-12-07 16:45:10 +01:00
parent 7e5067d459
commit b5654f6ff4
5 changed files with 10 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
include/types/fd.h
View File

@ -3,7 +3,7 @@
File descriptors states.
Copyright (C) 2000-2008 Willy Tarreau - w@1wt.eu
This library is free software; you can redistribute it and/or
modify it under the terms of the GNU Lesser General Public
License as published by the Free Software Foundation, version 2.1
@ -70,7 +70,6 @@ struct fdtab {
unsigned char ev; /* event seen in return of poll() : FD_POLL_* */
struct sockaddr *peeraddr; /* pointer to peer's network address, or NULL if unset */
socklen_t peerlen; /* peer's address length, or 0 if unset */
struct listener *listener; /* the listener which created this fd, or NULL if unset */
};
/*

1
include/types/session.h
View File

@ -155,6 +155,7 @@ struct session {
struct list list; /* position in global sessions list */
struct task *task; /* the task associated with this session */
/* application specific below */
struct listener *listener; /* the listener by which the request arrived */
struct proxy *fe; /* the proxy this session depends on for the client side */
struct proxy *be; /* the proxy this session depends on for the server side */
int conn_retries; /* number of connect retries left */

2
src/client.c
View File

@ -157,6 +157,7 @@ int event_accept(int fd) {
t->context = s;
s->task = t;
s->listener = l;
s->be = s->fe = p;
/* in HTTP mode, content switching requires that the backend
@ -397,7 +398,6 @@ int event_accept(int fd) {
fd_insert(cfd);
fdtab[cfd].owner = &s->si[0];
fdtab[cfd].listener = l;
fdtab[cfd].state = FD_STREADY;
fdtab[cfd].cb[DIR_RD].f = l->proto->read;
fdtab[cfd].cb[DIR_RD].b = s->req;

1
src/proto_tcp.c
View File

@ -266,7 +266,6 @@ int tcp_bind_listener(struct listener *listener, char *errmsg, int errlen)
fdtab[fd].state = FD_STLISTEN;
fdtab[fd].peeraddr = NULL;
fdtab[fd].peerlen = 0;
fdtab[fd].listener = NULL;
tcp_return:
if (msg && errlen)
strlcpy2(errmsg, msg, errlen);

17
src/proto_uxst.c
View File

@ -270,7 +270,6 @@ static int uxst_bind_listener(struct listener *listener)
fdtab[fd].state = FD_STLISTEN;
fdtab[fd].peeraddr = NULL;
fdtab[fd].peerlen = 0;
fdtab[fd].listener = NULL;
return ERR_NONE;
}
@ -438,6 +437,7 @@ int uxst_event_accept(int fd) {
t->nice = -64; /* we want to boost priority for local stats */
s->task = t;
s->listener = l;
s->fe = NULL;
s->be = NULL;
@ -518,7 +518,6 @@ int uxst_event_accept(int fd) {
fd_insert(cfd);
fdtab[cfd].owner = &s->si[0];
fdtab[cfd].listener = l;
fdtab[cfd].state = FD_STREADY;
fdtab[cfd].cb[DIR_RD].f = l->proto->read;
fdtab[cfd].cb[DIR_RD].b = s->req;
@ -695,7 +694,6 @@ int uxst_req_analyser_stats(struct session *s, struct buffer *req)
void uxst_process_session(struct task *t, int *next)
{
struct session *s = t->context;
struct listener *listener;
int resync;
unsigned int rqf_last, rpf_last;
@ -937,14 +935,13 @@ void uxst_process_session(struct task *t, int *next)
}
actconn--;
listener = fdtab[s->si[0].fd].listener;
if (listener) {
listener->nbconn--;
if (listener->state == LI_FULL &&
listener->nbconn < listener->maxconn) {
if (s->listener) {
s->listener->nbconn--;
if (s->listener->state == LI_FULL &&
s->listener->nbconn < s->listener->maxconn) {
/* we should reactivate the listener */
EV_FD_SET(listener->fd, DIR_RD);
listener->state = LI_READY;
EV_FD_SET(s->listener->fd, DIR_RD);
s->listener->state = LI_READY;
}
}