Lines Matching refs:cpl

920 	struct cpl_tx_data_iso *cpl;  in write_tx_data_iso()  local
940 cpl = (struct cpl_tx_data_iso *)dst; in write_tx_data_iso()
941 cpl->op_to_scsi = htonl(V_CPL_TX_DATA_ISO_OP(CPL_TX_DATA_ISO) | in write_tx_data_iso()
949 cpl->ahs_len = 0; in write_tx_data_iso()
950 cpl->mpdu = htons(DIV_ROUND_UP(mss, 4)); in write_tx_data_iso()
951 cpl->burst_size = htonl(DIV_ROUND_UP(burst_size, 4)); in write_tx_data_iso()
952 cpl->len = htonl(len); in write_tx_data_iso()
953 cpl->reserved2_seglen_offset = htonl(0); in write_tx_data_iso()
954 cpl->datasn_offset = htonl(0); in write_tx_data_iso()
955 cpl->buffer_offset = htonl(0); in write_tx_data_iso()
956 cpl->reserved3 = 0; in write_tx_data_iso()
1313 const struct cpl_peer_close *cpl = (const void *)(rss + 1); in do_peer_close() local
1314 unsigned int tid = GET_TID(cpl); in do_peer_close()
1321 unsigned int opcode = G_CPL_OPCODE(be32toh(OPCODE_TID(cpl))); in do_peer_close()
1359 handle_ddp_close(toep, tp, cpl->rcv_nxt); in do_peer_close()
1374 KASSERT(tp->rcv_nxt + 1 == be32toh(cpl->rcv_nxt), in do_peer_close()
1376 be32toh(cpl->rcv_nxt))); in do_peer_close()
1379 tp->rcv_nxt = be32toh(cpl->rcv_nxt); in do_peer_close()
1425 const struct cpl_close_con_rpl *cpl = (const void *)(rss + 1); in do_close_con_rpl() local
1426 unsigned int tid = GET_TID(cpl); in do_close_con_rpl()
1433 unsigned int opcode = G_CPL_OPCODE(be32toh(OPCODE_TID(cpl))); in do_close_con_rpl()
1453 tp->snd_una = be32toh(cpl->snd_nxt) - 1; /* exclude FIN */ in do_close_con_rpl()
1497 struct cpl_abort_rpl *cpl; in send_abort_rpl() local
1499 wr = alloc_wrqe(sizeof(*cpl), &ofld_txq->wrq); in send_abort_rpl()
1504 cpl = wrtod(wr); in send_abort_rpl()
1506 INIT_TP_WR_MIT_CPL(cpl, CPL_ABORT_RPL, tid); in send_abort_rpl()
1507 cpl->cmd = rst_status; in send_abort_rpl()
1536 const struct cpl_abort_req_rss *cpl = (const void *)(rss + 1); in do_abort_req() local
1537 unsigned int tid = GET_TID(cpl); in do_abort_req()
1544 unsigned int opcode = G_CPL_OPCODE(be32toh(OPCODE_TID(cpl))); in do_abort_req()
1556 if (negative_advice(cpl->status)) { in do_abort_req()
1558 __func__, cpl->status, tid, toep->flags); in do_abort_req()
1572 inp->inp_flags, cpl->status); in do_abort_req()
1590 cpl->status)); in do_abort_req()
1611 const struct cpl_abort_rpl_rss *cpl = (const void *)(rss + 1); in do_abort_rpl() local
1612 unsigned int tid = GET_TID(cpl); in do_abort_rpl()
1616 unsigned int opcode = G_CPL_OPCODE(be32toh(OPCODE_TID(cpl))); in do_abort_rpl()
1629 __func__, tid, toep, inp, cpl->status); in do_abort_rpl()
1644 const struct cpl_rx_data *cpl = mtod(m, const void *); in do_rx_data() local
1645 unsigned int tid = GET_TID(cpl); in do_rx_data()
1671 m_adj(m, sizeof(*cpl)); in do_rx_data()
1690 do_rx_data_tls(cpl, toep, m); in do_rx_data()
1694 if (__predict_false(tp->rcv_nxt != be32toh(cpl->seq))) in do_rx_data()
1695 ddp_placed = be32toh(cpl->seq) - tp->rcv_nxt; in do_rx_data()
1749 int changed = !(toep->ddp.flags & DDP_ON) ^ cpl->ddp_off; in do_rx_data()
1758 else if (cpl->ddp_off == 1) { in do_rx_data()
1810 const struct cpl_fw4_ack *cpl = (const void *)(rss + 1); in do_fw4_ack() local
1811 unsigned int tid = G_CPL_FW4_ACK_FLOWID(be32toh(OPCODE_TID(cpl))); in do_fw4_ack()
1816 uint8_t credits = cpl->credits; in do_fw4_ack()
1820 unsigned int opcode = G_CPL_FW4_ACK_OPCODE(be32toh(OPCODE_TID(cpl))); in do_fw4_ack()
1852 if (cpl->flags & CPL_FW4_ACK_FLAGS_SEQVAL) { in do_fw4_ack()
1853 tcp_seq snd_una = be32toh(cpl->snd_una); in do_fw4_ack()