]> git.ipfire.org Git - thirdparty/haproxy.git/commitdiff
MINOR: stream/cli: use conn_get_{src,dst} in "show sess" and "show peers" output
authorWilly Tarreau <w@1wt.eu>
Wed, 17 Jul 2019 09:44:11 +0000 (11:44 +0200)
committerWilly Tarreau <w@1wt.eu>
Fri, 19 Jul 2019 11:50:09 +0000 (13:50 +0200)
The stream outputs requires to retrieve connections sources and
destinations. The previous call involving conn_get_{to,from}_addr()
was missing a status check which has now been integrated with the
new call since these places already handle connection errors there.

The same code parts were reused for "show peers" and were modified
similarly.

src/peers.c
src/stream.c

index 69fed6dd269f81d28798184897843e63aa2ecac3..bdaf498dc44fada6c2d96cf3b32cf5629a324686 100644 (file)
@@ -3128,7 +3128,7 @@ static int peers_dump_peer(struct buffer *msg, struct stream_interface *si, stru
        if (conn)
                chunk_appendf(&trash, "\n        xprt=%s", conn_get_xprt_name(conn));
 
-       switch (conn ? addr_to_str(&conn->addr.from, pn, sizeof(pn)) : AF_UNSPEC) {
+       switch (conn && conn_get_src(conn) ? addr_to_str(&conn->addr.from, pn, sizeof(pn)) : AF_UNSPEC) {
        case AF_INET:
        case AF_INET6:
                chunk_appendf(&trash, " src=%s:%d", pn, get_host_port(&conn->addr.from));
@@ -3138,10 +3138,7 @@ static int peers_dump_peer(struct buffer *msg, struct stream_interface *si, stru
                break;
        }
 
-       if (conn)
-               conn_get_to_addr(conn);
-
-       switch (conn ? addr_to_str(&conn->addr.to, pn, sizeof(pn)) : AF_UNSPEC) {
+       switch (conn && conn_get_dst(conn) ? addr_to_str(&conn->addr.to, pn, sizeof(pn)) : AF_UNSPEC) {
        case AF_INET:
        case AF_INET6:
                chunk_appendf(&trash, " addr=%s:%d", pn, get_host_port(&conn->addr.to));
index e2405511893a5986a689c1fc191cd1ac52edc887..fb5555cc3b2d26dc8f4dc1ab8faa7cffdb00ebf2 100644 (file)
@@ -3083,10 +3083,7 @@ static int stats_dump_full_strm_to_buffer(struct stream_interface *si, struct st
                             strm_li(strm) ? strm_li(strm)->name ? strm_li(strm)->name : "?" : "?",
                             strm_li(strm) ? strm_li(strm)->luid : 0);
 
-               if (conn)
-                       conn_get_to_addr(conn);
-
-               switch (conn ? addr_to_str(&conn->addr.to, pn, sizeof(pn)) : AF_UNSPEC) {
+               switch (conn && conn_get_dst(conn) ? addr_to_str(&conn->addr.to, pn, sizeof(pn)) : AF_UNSPEC) {
                case AF_INET:
                case AF_INET6:
                        chunk_appendf(&trash, " addr=%s:%d\n",
@@ -3112,10 +3109,7 @@ static int stats_dump_full_strm_to_buffer(struct stream_interface *si, struct st
                cs = objt_cs(strm->si[1].end);
                conn = cs_conn(cs);
 
-               if (conn)
-                       conn_get_from_addr(conn);
-
-               switch (conn ? addr_to_str(&conn->addr.from, pn, sizeof(pn)) : AF_UNSPEC) {
+               switch (conn && conn_get_src(conn) ? addr_to_str(&conn->addr.from, pn, sizeof(pn)) : AF_UNSPEC) {
                case AF_INET:
                case AF_INET6:
                        chunk_appendf(&trash, " addr=%s:%d\n",
@@ -3138,10 +3132,7 @@ static int stats_dump_full_strm_to_buffer(struct stream_interface *si, struct st
                else
                        chunk_appendf(&trash, "  server=<NONE> (id=-1)");
 
-               if (conn)
-                       conn_get_to_addr(conn);
-
-               switch (conn ? addr_to_str(&conn->addr.to, pn, sizeof(pn)) : AF_UNSPEC) {
+               switch (conn && conn_get_dst(conn) ? addr_to_str(&conn->addr.to, pn, sizeof(pn)) : AF_UNSPEC) {
                case AF_INET:
                case AF_INET6:
                        chunk_appendf(&trash, " addr=%s:%d\n",