remove duplicated routes in tcp section

Author: tifayuki

haproxy/helper/backend_helper.py

@@ -23,14 +23,14 @@ def get_backend_routes(route_health_check, is_sticky, routes, routes_added, serv
     backend_routes = []
     for _service_alias, routes in routes.iteritems():
         if not service_alias or _service_alias == service_alias:
-            address_add = []
+            addresses_added = []
             for route in routes:
                 # avoid adding those tcp routes adding http backends
                 if route in routes_added:
                     continue
                 address = "%s:%s" % (route["addr"], route["port"])
-                if address not in address_add:
-                    address_add.append(address)
+                if address not in addresses_added:
+                    addresses_added.append(address)
                     backend_route = ["server %s %s" % (route["container_name"], address)]
                     if is_sticky:
                         backend_route.append("cookie %s" % route["container_name"])

haproxy/helper/tcp_helper.py

@@ -27,6 +27,7 @@ def parse_port_string(port, ssl_bind_string):
 def get_tcp_routes(details, routes, port, port_num):
     tcp_routes = []
     routes_added = []
+    addresses_added = []
     if port != port_num and port != port_num + "/ssl":
         return tcp_routes, routes_added
 
@@ -35,11 +36,15 @@ def get_tcp_routes(details, routes, port, port_num):
         if tcp_ports and port in tcp_ports:
             for route in routes:
                 if route["port"] == port_num:
-                    tcp_route = ["server %s %s:%s" % (route["container_name"], route["addr"], route["port"])]
-                    health_check = get_healthcheck_string(details, _service_alias)
-                    tcp_route.append(health_check)
-                    tcp_routes.append(" ".join(tcp_route))
+                    address = "%s:%s" % (route["addr"], route["port"])
+                    if address not in addresses_added:
+                        addresses_added.append(address)
+                        tcp_route = ["server %s %s" % (route["container_name"], address)]
+                        health_check = get_healthcheck_string(details, _service_alias)
+                        tcp_route.append(health_check)
+                        tcp_routes.append(" ".join(tcp_route))
                     routes_added.append(route)
+
     return tcp_routes, routes_added