Lines Matching refs:tcp

54     lm_tcp_state_t *tcp,  in lm_tcp_tx_write_db()  argument
57 lm_tcp_con_t *tx_con = tcp->tx_con; in lm_tcp_tx_write_db()
66 _lm_tcp_tx_write_db(pdev, tx_con, tcp->cid, tx_con->db_more_bytes, tx_con->db_more_bds, 0); in lm_tcp_tx_write_db()
76 "skipped doorbell ringing for cid=%d\n", tcp->cid); in lm_tcp_tx_write_db()
90 lm_tcp_state_t *tcp, in lm_tcp_tx_post_buf() argument
103 DbgBreakIf(!(pdev && tcp && tcp_buf && frag_list)); in lm_tcp_tx_post_buf()
104 DbgBreakIf(tcp->cid && (tcp != lm_cid_cookie(pdev, TOE_CONNECTION_TYPE, tcp->cid))); in lm_tcp_tx_post_buf()
106 tx_con = tcp->tx_con; in lm_tcp_tx_post_buf()
115 tcp->cid, tx_con->flags); in lm_tcp_tx_post_buf()
122 tcp->cid, lm_bd_chain_avail_bds(tx_chain), frag_list->cnt); in lm_tcp_tx_post_buf()
130 lm_tcp_tx_write_db(pdev, tcp, 1); in lm_tcp_tx_post_buf()
207 lm_tcp_tx_write_db(pdev, tcp, tcp_buf->flags & TCP_BUF_FLAG_L4_POST_END); in lm_tcp_tx_post_buf()
215 tcp->cid, tcp_buf->size, tcp_buf->bd_used, tcp_buf->flags, tcp_buf->app_buf_size); in lm_tcp_tx_post_buf()
227 …atic __inline void lm_tcp_tx_graceful_disconnect_complete(lm_device_t * pdev, lm_tcp_state_t * tcp) in lm_tcp_tx_graceful_disconnect_complete() argument
230 DbgBreakIf(!s_list_is_empty(&tcp->tx_con->active_tb_list)); in lm_tcp_tx_graceful_disconnect_complete()
231 DbgBreakIf(tcp->tx_con->flags & TCP_FIN_REQ_COMPLETED); in lm_tcp_tx_graceful_disconnect_complete()
232 tcp->tx_con->flags |= TCP_FIN_REQ_COMPLETED; in lm_tcp_tx_graceful_disconnect_complete()
233 DbgMessage(pdev, INFORMl4tx, "fin request completed (cid=%d)\n", tcp->cid); in lm_tcp_tx_graceful_disconnect_complete()
234 tcp->tcp_state_calc.fin_completed_time = mm_get_current_time(pdev); in lm_tcp_tx_graceful_disconnect_complete()
235 if (!(tcp->tx_con->u.tx.flags & TCP_CON_FIN_REQ_LM_INTERNAL)) { in lm_tcp_tx_graceful_disconnect_complete()
236 …ip_version = (tcp->path->path_const.ip_version == IP_VERSION_IPV4)? STATS_IP_4_IDX : STATS_IP_6_ID… in lm_tcp_tx_graceful_disconnect_complete()
238 mm_tcp_graceful_disconnect_done(pdev,tcp, LM_STATUS_SUCCESS); in lm_tcp_tx_graceful_disconnect_complete()
244 lm_tcp_state_t *tcp, in lm_tcp_tx_cmp_process() argument
248 lm_tcp_con_t *tx_con = tcp->tx_con; in lm_tcp_tx_cmp_process()
253 tcp->cid, completed_bytes); in lm_tcp_tx_cmp_process()
265 actual_completed = lm_tcp_complete_nbytes(pdev, tcp, tcp->tx_con, completed_bytes, FALSE); in lm_tcp_tx_cmp_process()
307 lm_tcp_state_t *tcp, in lm_tcp_tx_inc_trm_aborted_bytes() argument
311 lm_tcp_con_t *tx_con = tcp->tx_con; in lm_tcp_tx_inc_trm_aborted_bytes()
315 tcp->cid, aborted_bytes); in lm_tcp_tx_inc_trm_aborted_bytes()
334 void lm_tcp_tx_complete_tcp_fp(lm_device_t * pdev, lm_tcp_state_t * tcp, lm_tcp_con_t * con) in lm_tcp_tx_complete_tcp_fp() argument
358 lm_tcp_complete_bufs(pdev, tcp, con); in lm_tcp_tx_complete_tcp_fp()
372 lm_tcp_state_t * tcp in lm_tcp_tx_process_cqe() argument
380 DbgMessage(pdev, INFORMl4tx, "###lm_tcp_tx_process_cqe cid=%d cmd=%d\n", tcp->cid, cmd); in lm_tcp_tx_process_cqe()
381 DbgBreakIf( ! (pdev && tcp) ); in lm_tcp_tx_process_cqe()
390 …((tcp->tx_con->dpc_info.dpc_flags & LM_TCP_DPC_RESET_RECV /* RST recv on this DPC on a previous CQ… in lm_tcp_tx_process_cqe()
391 (tcp->tx_con->flags & TCP_REMOTE_RST_RECEIVED /* RST recv on previous DPC */ ))) in lm_tcp_tx_process_cqe()
400 lm_tcp_tx_inc_trm_aborted_bytes(pdev, tcp, cqe->len); in lm_tcp_tx_process_cqe()
404 DbgBreakIf(tcp->tx_con->dpc_info.dpc_comp_blocked); in lm_tcp_tx_process_cqe()
405 lm_tcp_tx_cmp_process(pdev, tcp, cqe->len); in lm_tcp_tx_process_cqe()
412 tcp->tx_con->dpc_info.dpc_flags |= LM_TCP_DPC_RESET_RECV; in lm_tcp_tx_process_cqe()
413 tcp->tx_con->dpc_info.dpc_comp_blocked = TRUE; /* TCP_REMOTE_RST_RECEIVED */ in lm_tcp_tx_process_cqe()
416 DbgBreakIf(! tcp->sp_request); in lm_tcp_tx_process_cqe()
417 DbgBreakIf(tcp->sp_request->type != SP_REQUEST_ABORTIVE_DISCONNECT); in lm_tcp_tx_process_cqe()
418 tcp->tx_con->dpc_info.dpc_flags |= LM_TCP_DPC_RAMROD_CMP; in lm_tcp_tx_process_cqe()
419 tcp->tx_con->dpc_info.dpc_comp_blocked = TRUE; /* TCP_RST_REQ_COMPLETED */ in lm_tcp_tx_process_cqe()
422 DbgBreakIf(! tcp->sp_request); in lm_tcp_tx_process_cqe()
423 DbgBreakIf(tcp->sp_request->type != SP_REQUEST_INVALIDATE); in lm_tcp_tx_process_cqe()
424 tcp->tx_con->dpc_info.dpc_flags |= LM_TCP_DPC_RAMROD_CMP; in lm_tcp_tx_process_cqe()
425 tcp->tx_con->dpc_info.dpc_comp_blocked = TRUE; /* TCP_INV_REQ_COMPLETED */ in lm_tcp_tx_process_cqe()
428 DbgBreakIf(! tcp->sp_request); in lm_tcp_tx_process_cqe()
429 DbgBreakIf(tcp->sp_request->type != SP_REQUEST_TERMINATE1_OFFLOAD); in lm_tcp_tx_process_cqe()
430 tcp->tx_con->dpc_info.dpc_flags |= LM_TCP_DPC_RAMROD_CMP; in lm_tcp_tx_process_cqe()
431 tcp->tx_con->dpc_info.dpc_comp_blocked = TRUE; /* TCP_TRM_REQ_COMPLETED */ in lm_tcp_tx_process_cqe()
435 DbgBreakIf(! tcp->sp_request ); in lm_tcp_tx_process_cqe()
436 DbgBreakIf((tcp->sp_request->type != SP_REQUEST_PENDING_LOCAL_FIN_DISCONNECT) && in lm_tcp_tx_process_cqe()
437 (tcp->sp_request->type != SP_REQUEST_PENDING_REMOTE_DISCONNECT) && in lm_tcp_tx_process_cqe()
438 (tcp->sp_request->type != SP_REQUEST_PENDING_TX_RST)); in lm_tcp_tx_process_cqe()
439 tcp->tx_con->dpc_info.dpc_flags |= LM_TCP_DPC_RAMROD_CMP; in lm_tcp_tx_process_cqe()
456 lm_tcp_state_t *tcp; in lm_tcp_tx_process_cqes() local
503 tcp = lm_cid_cookie(pdev, TOE_CONNECTION_TYPE, cid); in lm_tcp_tx_process_cqes()
504 DbgBreakIf(!tcp); in lm_tcp_tx_process_cqes()
506 … hist_cqe = (struct toe_tx_cqe *)lm_tcp_qe_buffer_next_cqe_override(&tcp->tx_con->history_cqes); in lm_tcp_tx_process_cqes()
509 defer_cqe = ((tcp->tx_con->flags & TCP_TX_COMP_DEFERRED) == TCP_TX_COMP_DEFERRED); in lm_tcp_tx_process_cqes()
513 mm_acquire_tcp_lock(pdev, tcp->tx_con); in lm_tcp_tx_process_cqes()
515 defer_cqe = ((tcp->tx_con->flags & TCP_TX_COMP_DEFERRED) == TCP_TX_COMP_DEFERRED); in lm_tcp_tx_process_cqes()
517 tcp->tx_con->flags |= TCP_DEFERRED_PROCESSING; in lm_tcp_tx_process_cqes()
518 lm_tcp_tx_process_cqe(pdev, cqe, tcp); in lm_tcp_tx_process_cqes()
520 mm_release_tcp_lock(pdev, tcp->tx_con); in lm_tcp_tx_process_cqes()
525 if (s_list_next_entry(&tcp->tx_con->dpc_info.link) == NULL) { in lm_tcp_tx_process_cqes()
526 s_list_push_head(connections, &tcp->tx_con->dpc_info.link); in lm_tcp_tx_process_cqes()
528 lm_tcp_tx_process_cqe(pdev, cqe, tcp); in lm_tcp_tx_process_cqes()
553 lm_tcp_state_t * tcp; in lm_toe_service_tx_intr() local
568 tcp = con->tcp_state; in lm_toe_service_tx_intr()
574 tcp = con->tcp_state; in lm_toe_service_tx_intr()
580 tcp = con->tcp_state; in lm_toe_service_tx_intr()
585 lm_tcp_tx_complete_tcp_sp(pdev, tcp, con); in lm_toe_service_tx_intr()
589 tcp = con->tcp_state; in lm_toe_service_tx_intr()