MEDIUM: proxy: make soft_stop() stop most listeners using protocol_stop_now()

One difficulty in soft-stopping is to make sure not to forget unlisted
listeners. By first doing a pass using protocol_stop_now() we catch the
vast majority of them. The few remaining ones are the ones belonging to
a proxy having a grace period. For these ones, the proxy will arm its
stop_time timer and emit a log message.

Since neither UDP listeners nor peers use the grace period, we can already
get rid of the special cases there since we know they will have been stopped
by the protocols.

diff --git a/src/proxy.c b/src/proxy.c
index a77ad0a8f995ae6cc6d4fc3e1a98083ed32d98b1..79ba5a679b172f44065490f715711e47b14eff18 100644 (file)
--- a/src/proxy.c
+++ b/src/proxy.c
@@ -35,6 +35,7 @@
 #include <haproxy/obj_type-t.h>
 #include <haproxy/peers.h>
 #include <haproxy/pool.h>
+#include <haproxy/protocol.h>
 #include <haproxy/proto_tcp.h>
 #include <haproxy/proxy.h>
 #include <haproxy/server-t.h>
@@ -1231,7 +1232,6 @@ struct task *hard_stop(struct task *t, void *context, unsigned short state)
 void soft_stop(void)
 {
        struct proxy *p;
-       struct peers *prs;
        struct task *task;
 
        stopping = 1;
@@ -1247,6 +1247,12 @@ void soft_stop(void)
                        ha_alert("out of memory trying to allocate the hard-stop task.\n");
                }
        }
+
+       /* stop all stoppable listeners, resulting in disabling all proxies
+        * that don't use a grace period.
+        */
+       protocol_stop_now();
+
        p = proxies_list;
        tv_update_date(0,1); /* else, the old time before select will be used */
        while (p) {
@@ -1267,34 +1273,6 @@ void soft_stop(void)
                p = p->next;
        }
 
-       prs = cfg_peers;
-       while (prs) {
-               if (prs->peers_fe)
-                       stop_proxy(prs->peers_fe);
-               prs = prs->next;
-       }
-
-       p = cfg_log_forward;
-       while (p) {
-               /* Zombie proxy, let's close the file descriptors */
-               if (p->disabled &&
-                   !LIST_ISEMPTY(&p->conf.listeners) &&
-                   LIST_ELEM(p->conf.listeners.n,
-                   struct listener *, by_fe)->state > LI_ASSIGNED) {
-                       struct listener *l;
-                       list_for_each_entry(l, &p->conf.listeners, by_fe) {
-                               if (l->state > LI_ASSIGNED)
-                                       close(l->rx.fd);
-                               l->state = LI_INIT;
-                       }
-               }
-
-               if (!p->disabled) {
-                       stop_proxy(p);
-               }
-               p = p->next;
-       }
-
        /* signal zero is used to broadcast the "stopping" event */
        signal_handler(0);
 }