diff --git a/src/adaptors/tcp/tcp_adaptor.c b/src/adaptors/tcp/tcp_adaptor.c index 416670b35..4f5d51479 100644 --- a/src/adaptors/tcp/tcp_adaptor.c +++ b/src/adaptors/tcp/tcp_adaptor.c @@ -753,6 +753,16 @@ static void grant_read_buffers_XSIDE_IO(qd_tcp_connection_t *conn, const size_t raw_buffers[i].capacity = qd_buffer_capacity(buf); raw_buffers[i].offset = 0; raw_buffers[i].size = 0; + + // + qd_log(LOG_TCP_ADAPTOR, QD_LOG_DEBUG, + "[C%" PRIu64 "] PX (%zu) C=%p B=%p T=%"PRIu32" S=%"PRIu32" O=%"PRIu32, conn->conn_id, i, + (void *)raw_buffers[i].context, + (void *)raw_buffers[i].bytes, + raw_buffers[i].capacity, + raw_buffers[i].size, + raw_buffers[i].offset); + // } size_t actual = pn_raw_connection_give_read_buffers(conn->raw_conn, raw_buffers, granted); diff --git a/src/tls/tls_raw.c b/src/tls/tls_raw.c index 2b9a1333c..2553378ad 100644 --- a/src/tls/tls_raw.c +++ b/src/tls/tls_raw.c @@ -312,7 +312,8 @@ int qd_tls_session_do_io(qd_tls_session_t *session, ++pushed; } else { qd_log(log_module, QD_LOG_DEBUG, - "[C%" PRIu64 "] Empty buffer read from raw conn: %p", conn_id, (void *)pn_buf_desc.context); + "[C%" PRIu64 "] Empty buffer read from raw conn: %p R/C=%s", conn_id, (void *)pn_buf_desc.context, + pn_raw_connection_is_read_closed(raw_conn) ? "CLOSED" : "OPEN" ); qd_buffer_free((qd_buffer_t *) pn_buf_desc.context); } }