Skip to content

Commit

Permalink
debug
Browse files Browse the repository at this point in the history
  • Loading branch information
kgiusti committed Sep 6, 2024
1 parent 52ac485 commit 05c6089
Show file tree
Hide file tree
Showing 2 changed files with 12 additions and 1 deletion.
10 changes: 10 additions & 0 deletions src/adaptors/tcp/tcp_adaptor.c
Original file line number Diff line number Diff line change
Expand Up @@ -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);
Expand Down
3 changes: 2 additions & 1 deletion src/tls/tls_raw.c
Original file line number Diff line number Diff line change
Expand Up @@ -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);
}
}
Expand Down

0 comments on commit 05c6089

Please sign in to comment.