Lines Matching refs:cpl

1196 	const struct cpl_peer_close *cpl = (const void *)(rss + 1);  in do_peer_close()  local
1197 unsigned int tid = GET_TID(cpl); in do_peer_close()
1204 unsigned int opcode = G_CPL_OPCODE(be32toh(OPCODE_TID(cpl))); in do_peer_close()
1246 handle_ddp_close(toep, tp, cpl->rcv_nxt); in do_peer_close()
1251 KASSERT(tp->rcv_nxt == be32toh(cpl->rcv_nxt), in do_peer_close()
1253 be32toh(cpl->rcv_nxt))); in do_peer_close()
1298 const struct cpl_close_con_rpl *cpl = (const void *)(rss + 1); in do_close_con_rpl() local
1299 unsigned int tid = GET_TID(cpl); in do_close_con_rpl()
1306 unsigned int opcode = G_CPL_OPCODE(be32toh(OPCODE_TID(cpl))); in do_close_con_rpl()
1326 tp->snd_una = be32toh(cpl->snd_nxt) - 1; /* exclude FIN */ in do_close_con_rpl()
1368 struct cpl_abort_rpl *cpl; in send_abort_rpl() local
1370 wr = alloc_wrqe(sizeof(*cpl), ofld_txq); in send_abort_rpl()
1375 cpl = wrtod(wr); in send_abort_rpl()
1377 INIT_TP_WR_MIT_CPL(cpl, CPL_ABORT_RPL, tid); in send_abort_rpl()
1378 cpl->cmd = rst_status; in send_abort_rpl()
1407 const struct cpl_abort_req_rss *cpl = (const void *)(rss + 1); in do_abort_req() local
1408 unsigned int tid = GET_TID(cpl); in do_abort_req()
1415 unsigned int opcode = G_CPL_OPCODE(be32toh(OPCODE_TID(cpl))); in do_abort_req()
1427 if (negative_advice(cpl->status)) { in do_abort_req()
1429 __func__, cpl->status, tid, toep->flags); in do_abort_req()
1443 inp->inp_flags, cpl->status); in do_abort_req()
1461 cpl->status)); in do_abort_req()
1482 const struct cpl_abort_rpl_rss *cpl = (const void *)(rss + 1); in do_abort_rpl() local
1483 unsigned int tid = GET_TID(cpl); in do_abort_rpl()
1487 unsigned int opcode = G_CPL_OPCODE(be32toh(OPCODE_TID(cpl))); in do_abort_rpl()
1500 __func__, tid, toep, inp, cpl->status); in do_abort_rpl()
1515 const struct cpl_rx_data *cpl = mtod(m, const void *); in do_rx_data() local
1516 unsigned int tid = GET_TID(cpl); in do_rx_data()
1542 m_adj(m, sizeof(*cpl)); in do_rx_data()
1561 do_rx_data_tls(cpl, toep, m); in do_rx_data()
1565 if (__predict_false(tp->rcv_nxt != be32toh(cpl->seq))) in do_rx_data()
1566 ddp_placed = be32toh(cpl->seq) - tp->rcv_nxt; in do_rx_data()
1620 int changed = !(toep->ddp.flags & DDP_ON) ^ cpl->ddp_off; in do_rx_data()
1630 KASSERT(cpl->ddp_off == 1, in do_rx_data()
1682 const struct cpl_fw4_ack *cpl = (const void *)(rss + 1); in do_fw4_ack() local
1683 unsigned int tid = G_CPL_FW4_ACK_FLOWID(be32toh(OPCODE_TID(cpl))); in do_fw4_ack()
1688 uint8_t credits = cpl->credits; in do_fw4_ack()
1692 unsigned int opcode = G_CPL_FW4_ACK_OPCODE(be32toh(OPCODE_TID(cpl))); in do_fw4_ack()
1724 if (cpl->flags & CPL_FW4_ACK_FLAGS_SEQVAL) { in do_fw4_ack()
1725 tcp_seq snd_una = be32toh(cpl->snd_una); in do_fw4_ack()