monitor/analyze: Use conn_pkt_tx on acl_pkt
authorLuiz Augusto von Dentz <luiz.von.dentz@intel.com>
Mon, 31 Jul 2023 21:01:09 +0000 (14:01 -0700)
committerAyush Garg <ayush.garg@samsung.com>
Fri, 5 Jan 2024 13:34:03 +0000 (19:04 +0530)
This makes use of conn_pkt_tx also on acl_pkt like other connections.

monitor/analyze.c

index 6a81854..b9f7ede 100755 (executable)
@@ -602,6 +602,24 @@ static void event_pkt(struct timeval *tv, uint16_t index,
        }
 }
 
+static void conn_pkt_tx(struct hci_conn *conn, struct timeval *tv,
+                                       uint16_t size)
+{
+       struct timeval *last_tx;
+
+       conn->tx_num++;
+
+       last_tx = new0(struct timeval, 1);
+       memcpy(last_tx, tv, sizeof(*tv));
+       queue_push_tail(conn->tx_queue, last_tx);
+       conn->tx_bytes += size;
+
+       if (!conn->tx_pkt_min || size < conn->tx_pkt_min)
+               conn->tx_pkt_min = size;
+       if (!conn->tx_pkt_max || size > conn->tx_pkt_max)
+               conn->tx_pkt_max = size;
+}
+
 static void acl_pkt(struct timeval *tv, uint16_t index, bool out,
                                        const void *data, uint16_t size)
 {
@@ -639,39 +657,12 @@ static void acl_pkt(struct timeval *tv, uint16_t index, bool out,
        }
 
        if (out) {
-               struct timeval *last_tx;
-
-               conn->tx_num++;
-               last_tx = new0(struct timeval, 1);
-               memcpy(last_tx, tv, sizeof(*tv));
-               queue_push_tail(conn->tx_queue, last_tx);
-               conn->tx_bytes += size;
-
-               if (!conn->tx_pkt_min || size < conn->tx_pkt_min)
-                       conn->tx_pkt_min = size;
-               if (!conn->tx_pkt_max || size > conn->tx_pkt_max)
-                       conn->tx_pkt_max = size;
+               conn_pkt_tx(conn, tv, size);
        } else {
                conn->rx_num++;
        }
 }
 
-static void conn_pkt_tx(struct hci_conn *conn, struct timeval *tv,
-                                       uint16_t size)
-{
-       struct timeval *last_tx;
-
-       last_tx = new0(struct timeval, 1);
-       memcpy(last_tx, tv, sizeof(*tv));
-       queue_push_tail(conn->tx_queue, last_tx);
-       conn->tx_bytes += size;
-
-       if (!conn->tx_pkt_min || size < conn->tx_pkt_min)
-               conn->tx_pkt_min = size;
-       if (!conn->tx_pkt_max || size > conn->tx_pkt_max)
-               conn->tx_pkt_max = size;
-}
-
 static void sco_pkt(struct timeval *tv, uint16_t index, bool out,
                                        const void *data, uint16_t size)
 {
@@ -692,7 +683,6 @@ static void sco_pkt(struct timeval *tv, uint16_t index, bool out,
                return;
 
        if (out) {
-               conn->tx_num++;
                conn_pkt_tx(conn, tv, size - sizeof(*hdr));
        } else {
                conn->rx_num++;
@@ -780,7 +770,6 @@ static void iso_pkt(struct timeval *tv, uint16_t index, bool out,
                return;
 
        if (out) {
-               conn->tx_num++;
                conn_pkt_tx(conn, tv, size - sizeof(*hdr));
        } else {
                conn->rx_num++;