|
|
|
|
@ -547,7 +547,7 @@ static void input_queue_cb(struct ll_queue* q, void* arg) {
|
|
|
|
|
// memory_pool_free(etcp->io_pool, in_pkt);// перемещаем из io_pool в inflight_pool
|
|
|
|
|
queue_entry_free(&in_pkt->ll); |
|
|
|
|
|
|
|
|
|
DEBUG_DEBUG(DEBUG_CATEGORY_ETCP, "[%s] input -> inflight (seq=%u, len=%u); Qlen: in=%d snd=%d wait=%d", etcp->log_name, p->seq, p->ll.len, etcp->input_queue->count, etcp->input_send_q->count, etcp->input_wait_ack->count); |
|
|
|
|
DEBUG_TRACE(DEBUG_CATEGORY_ETCP, "[%s] TX input -> inflight (seq=%u, len=%u); Qlen: in=%d snd=%d wait=%d", etcp->log_name, p->seq, p->ll.len, etcp->input_queue->count, etcp->input_send_q->count, etcp->input_wait_ack->count); |
|
|
|
|
int len=p->ll.len;// сохраним len
|
|
|
|
|
|
|
|
|
|
// Add to send queue
|
|
|
|
|
|