|
|
|
|
@ -162,7 +162,7 @@ static void read_queue_drain_cb(struct ll_queue* q, void* arg) {
|
|
|
|
|
struct ll_entry* e = queue_data_get(q); |
|
|
|
|
if (!e) { queue_resume_callback(q); return; } |
|
|
|
|
int ret = send_msg(inst, rc->peer_node_id, TCP_PROXY_SUBCMD_DATA, rc->stream_id, e->dgram, e->len, 0); |
|
|
|
|
DEBUG_INFO(DEBUG_CATEGORY_SOCKET, "SOCK:RECV fd=%d sid=%08x len=%u total=%d", |
|
|
|
|
DEBUG_TRACE(DEBUG_CATEGORY_SOCKET, "SOCK:RECV fd=%d sid=%08x len=%u total=%d", |
|
|
|
|
(int)rc->tc->sock, rc->stream_id, e->len, rc->ctx ? rc->ctx->conn_count : 0); |
|
|
|
|
memory_pool_free(rc->tc->data_pool, e->dgram); |
|
|
|
|
queue_entry_free(e); |
|
|
|
|
|