1

src/control_server.c

@@ -760,6 +760,11 @@ static void send_metrics(struct control_server* server, struct control_client* c
     rsp->etcp.last_delivered_id = conn->last_delivered_id;
     rsp->etcp.rx_ack_till = conn->rx_ack_till;
     
+    /* input_wait_ack queue state */
+    rsp->etcp.wait_ack_cb_suspended = (uint8_t)conn->input_wait_ack->callback_suspended;
+    rsp->etcp.wait_ack_cb_set = (conn->input_wait_ack->callback != NULL) ? 1 : 0;
+    rsp->etcp.wait_ack_resume_timeout = (conn->input_wait_ack->resume_timeout_id != NULL) ? 1 : 0;
+    
     /* Fill TUN metrics */
     if (instance->tun) {
         rsp->tun.bytes_read = instance->tun->bytes_read;

src/etcp.h

@@ -90,7 +90,7 @@ struct ETCP_CONN {
     struct ll_queue*        input_wait_ack;    // очередь ожидающих подтверждение (inflight_pool -> struct INFLIGHT_PACKET)
     struct ll_queue*        ack_q;             // неотправленные подтверждения приема пакетов (instance.ack_pool -> struct ACK_PACKET)
 
-    struct ll_queue*        recv_q;            // очередь на сборку (rx_pool -> struct ETCP_FRAGMENT)
+    struct ll_queue*        recv_q;            // очередь на сборку фрагментированных пакетов(rx_pool -> struct ETCP_FRAGMENT)
 
     void (*link_ready_for_send_fn)(struct ETCP_CONN*);// функцию которую должен вызвать драйвер линка при готовности линка принимать данные
 

src/etcp_connections.c

@@ -1011,6 +1011,9 @@ process_decrypted:
                    link->etcp->log_name, link, link->local_link_id);
     }
     
+    // Count decrypted bytes
+    link->total_decrypted += pkt->data_len;
+    
     // Count received keepalive packets (empty packets with no payload)
     if (pkt->data_len == 0) {
         link->keepalive_recv_count++;