~ubuntu-branches/ubuntu/utopic/haproxy/utopic-proposed

Index: haproxy/include/proto/queue.h

===================================================================

--- haproxy.orig/include/proto/queue.h  2008-12-30 18:27:39.000000000 +0100

+++ haproxy/include/proto/queue.h       2008-12-30 18:29:16.000000000 +0100

@@ -64,10 +64,10 @@

 }

 

 /* returns 0 if nothing has to be done for server <s> regarding queued connections,

- * and non-zero otherwise. Suited for and if/else usage.

+ * and non-zero otherwise. If the server is down, we only check its own queue. Suited for and if/else usage.

  */

 static inline int may_dequeue_tasks(const struct server *s, const struct proxy *p) {

-       return (s && (s->nbpend || p->nbpend) &&

+       return (s && (s->nbpend || (p->nbpend && (s->state & SRV_RUNNING))) &&

                (!s->maxconn || s->cur_sess < srv_dynamic_maxconn(s)));

 }

 

Index: haproxy/src/queue.c

===================================================================

--- haproxy.orig/src/queue.c    2008-12-30 18:29:24.000000000 +0100

+++ haproxy/src/queue.c 2008-12-30 18:30:33.000000000 +0100

@@ -89,6 +89,10 @@

  * returned. Note that neither <srv> nor <px> may be NULL.

  * Priority is given to the oldest request in the queue if both <srv> and <px>

  * have pending requests. This ensures that no request will be left unserved.

+ * The <px> queue is not considered if the server is not RUNNING. The <srv>

+ * queue is still considered in this case, because if some connections remain

+ * there, it means that some requests have been forced there after it was seen

+ * down (eg: due to option persist).

  * The session is immediately marked as "assigned", and both its <srv> and

  * <srv_conn> are set to <srv>,

  */

@@ -100,7 +104,7 @@

        ps = pendconn_from_srv(srv);

        pp = pendconn_from_px(px);

        /* we want to get the definitive pendconn in <ps> */

-       if (!pp) {

+       if (!pp || !(srv->state & SRV_RUNNING)) {

                if (!ps)

                        return NULL;

        } else {

Index: haproxy/src/session.c

===================================================================

--- haproxy.orig/src/session.c  2008-12-30 18:30:52.000000000 +0100

+++ haproxy/src/session.c       2008-12-30 18:35:40.000000000 +0100

@@ -41,8 +41,10 @@

 

        if (s->pend_pos)

                pendconn_free(s->pend_pos);

-       if (s->srv)  /* there may be requests left pending in queue */

-               process_srv_queue(s->srv);

+       if (s->srv) {  /* there may be requests left pending in queue */

+               if (may_dequeue_tasks(s->srv, s->be))

+                       process_srv_queue(s->srv);

+       }

        if (unlikely(s->srv_conn)) {

                /* the session still has a reserved slot on a server, but

                 * it should normally be only the same as the one above,