Lines Matching refs:conn
48 static int mlx5_fpga_conn_map_buf(struct mlx5_fpga_conn *conn, in mlx5_fpga_conn_map_buf() argument
57 dma_device = &conn->fdev->mdev->pdev->dev; in mlx5_fpga_conn_map_buf()
62 mlx5_fpga_warn(conn->fdev, "DMA error on sg 0: %d\n", err); in mlx5_fpga_conn_map_buf()
74 mlx5_fpga_warn(conn->fdev, "DMA error on sg 1: %d\n", err); in mlx5_fpga_conn_map_buf()
84 static void mlx5_fpga_conn_unmap_buf(struct mlx5_fpga_conn *conn, in mlx5_fpga_conn_unmap_buf() argument
89 dma_device = &conn->fdev->mdev->pdev->dev; in mlx5_fpga_conn_unmap_buf()
99 static int mlx5_fpga_conn_post_recv(struct mlx5_fpga_conn *conn, in mlx5_fpga_conn_post_recv() argument
106 err = mlx5_fpga_conn_map_buf(conn, buf); in mlx5_fpga_conn_post_recv()
110 if (unlikely(conn->qp.rq.pc - conn->qp.rq.cc >= conn->qp.rq.size)) { in mlx5_fpga_conn_post_recv()
111 mlx5_fpga_conn_unmap_buf(conn, buf); in mlx5_fpga_conn_post_recv()
115 ix = conn->qp.rq.pc & (conn->qp.rq.size - 1); in mlx5_fpga_conn_post_recv()
116 data = mlx5_wq_cyc_get_wqe(&conn->qp.wq.rq, ix); in mlx5_fpga_conn_post_recv()
118 data->lkey = cpu_to_be32(conn->fdev->conn_res.mkey.key); in mlx5_fpga_conn_post_recv()
121 conn->qp.rq.pc++; in mlx5_fpga_conn_post_recv()
122 conn->qp.rq.bufs[ix] = buf; in mlx5_fpga_conn_post_recv()
126 *conn->qp.wq.rq.db = cpu_to_be32(conn->qp.rq.pc & 0xffff); in mlx5_fpga_conn_post_recv()
131 static void mlx5_fpga_conn_notify_hw(struct mlx5_fpga_conn *conn, void *wqe) in mlx5_fpga_conn_notify_hw() argument
135 *conn->qp.wq.sq.db = cpu_to_be32(conn->qp.sq.pc); in mlx5_fpga_conn_notify_hw()
138 mlx5_write64(wqe, conn->fdev->conn_res.uar->map + MLX5_BF_OFFSET, NULL); in mlx5_fpga_conn_notify_hw()
141 static void mlx5_fpga_conn_post_send(struct mlx5_fpga_conn *conn, in mlx5_fpga_conn_post_send() argument
149 ix = conn->qp.sq.pc & (conn->qp.sq.size - 1); in mlx5_fpga_conn_post_send()
151 ctrl = mlx5_wq_cyc_get_wqe(&conn->qp.wq.sq, ix); in mlx5_fpga_conn_post_send()
158 data->lkey = cpu_to_be32(conn->fdev->conn_res.mkey.key); in mlx5_fpga_conn_post_send()
166 ctrl->opmod_idx_opcode = cpu_to_be32(((conn->qp.sq.pc & 0xffff) << 8) | in mlx5_fpga_conn_post_send()
168 ctrl->qpn_ds = cpu_to_be32(size | (conn->qp.mqp.qpn << 8)); in mlx5_fpga_conn_post_send()
170 conn->qp.sq.pc++; in mlx5_fpga_conn_post_send()
171 conn->qp.sq.bufs[ix] = buf; in mlx5_fpga_conn_post_send()
172 mlx5_fpga_conn_notify_hw(conn, ctrl); in mlx5_fpga_conn_post_send()
175 int mlx5_fpga_conn_send(struct mlx5_fpga_conn *conn, in mlx5_fpga_conn_send() argument
181 if (!conn->qp.active) in mlx5_fpga_conn_send()
184 err = mlx5_fpga_conn_map_buf(conn, buf); in mlx5_fpga_conn_send()
188 spin_lock_irqsave(&conn->qp.sq.lock, flags); in mlx5_fpga_conn_send()
190 if (conn->qp.sq.pc - conn->qp.sq.cc >= conn->qp.sq.size) { in mlx5_fpga_conn_send()
191 list_add_tail(&buf->list, &conn->qp.sq.backlog); in mlx5_fpga_conn_send()
195 mlx5_fpga_conn_post_send(conn, buf); in mlx5_fpga_conn_send()
198 spin_unlock_irqrestore(&conn->qp.sq.lock, flags); in mlx5_fpga_conn_send()
202 static int mlx5_fpga_conn_post_recv_buf(struct mlx5_fpga_conn *conn) in mlx5_fpga_conn_post_recv_buf() argument
215 err = mlx5_fpga_conn_post_recv(conn, buf); in mlx5_fpga_conn_post_recv_buf()
249 static void mlx5_fpga_conn_rq_cqe(struct mlx5_fpga_conn *conn, in mlx5_fpga_conn_rq_cqe() argument
255 ix = be16_to_cpu(cqe->wqe_counter) & (conn->qp.rq.size - 1); in mlx5_fpga_conn_rq_cqe()
256 buf = conn->qp.rq.bufs[ix]; in mlx5_fpga_conn_rq_cqe()
257 conn->qp.rq.bufs[ix] = NULL; in mlx5_fpga_conn_rq_cqe()
260 conn->qp.rq.cc++; in mlx5_fpga_conn_rq_cqe()
263 mlx5_fpga_warn(conn->fdev, "RQ buf %p on FPGA QP %u completion status %d\n", in mlx5_fpga_conn_rq_cqe()
264 buf, conn->fpga_qpn, status); in mlx5_fpga_conn_rq_cqe()
266 mlx5_fpga_dbg(conn->fdev, "RQ buf %p on FPGA QP %u completion status %d\n", in mlx5_fpga_conn_rq_cqe()
267 buf, conn->fpga_qpn, status); in mlx5_fpga_conn_rq_cqe()
269 mlx5_fpga_conn_unmap_buf(conn, buf); in mlx5_fpga_conn_rq_cqe()
271 if (unlikely(status || !conn->qp.active)) { in mlx5_fpga_conn_rq_cqe()
272 conn->qp.active = false; in mlx5_fpga_conn_rq_cqe()
277 mlx5_fpga_dbg(conn->fdev, "Message with %u bytes received successfully\n", in mlx5_fpga_conn_rq_cqe()
279 conn->recv_cb(conn->cb_arg, buf); in mlx5_fpga_conn_rq_cqe()
282 err = mlx5_fpga_conn_post_recv(conn, buf); in mlx5_fpga_conn_rq_cqe()
284 mlx5_fpga_warn(conn->fdev, in mlx5_fpga_conn_rq_cqe()
290 static void mlx5_fpga_conn_sq_cqe(struct mlx5_fpga_conn *conn, in mlx5_fpga_conn_sq_cqe() argument
297 spin_lock_irqsave(&conn->qp.sq.lock, flags); in mlx5_fpga_conn_sq_cqe()
299 ix = be16_to_cpu(cqe->wqe_counter) & (conn->qp.sq.size - 1); in mlx5_fpga_conn_sq_cqe()
300 buf = conn->qp.sq.bufs[ix]; in mlx5_fpga_conn_sq_cqe()
301 conn->qp.sq.bufs[ix] = NULL; in mlx5_fpga_conn_sq_cqe()
302 conn->qp.sq.cc++; in mlx5_fpga_conn_sq_cqe()
305 if (unlikely(!list_empty(&conn->qp.sq.backlog))) { in mlx5_fpga_conn_sq_cqe()
306 if (likely(conn->qp.active)) { in mlx5_fpga_conn_sq_cqe()
307 nextbuf = list_first_entry(&conn->qp.sq.backlog, in mlx5_fpga_conn_sq_cqe()
310 mlx5_fpga_conn_post_send(conn, nextbuf); in mlx5_fpga_conn_sq_cqe()
314 spin_unlock_irqrestore(&conn->qp.sq.lock, flags); in mlx5_fpga_conn_sq_cqe()
317 mlx5_fpga_warn(conn->fdev, "SQ buf %p on FPGA QP %u completion status %d\n", in mlx5_fpga_conn_sq_cqe()
318 buf, conn->fpga_qpn, status); in mlx5_fpga_conn_sq_cqe()
320 mlx5_fpga_dbg(conn->fdev, "SQ buf %p on FPGA QP %u completion status %d\n", in mlx5_fpga_conn_sq_cqe()
321 buf, conn->fpga_qpn, status); in mlx5_fpga_conn_sq_cqe()
323 mlx5_fpga_conn_unmap_buf(conn, buf); in mlx5_fpga_conn_sq_cqe()
326 buf->complete(conn, conn->fdev, buf, status); in mlx5_fpga_conn_sq_cqe()
329 conn->qp.active = false; in mlx5_fpga_conn_sq_cqe()
332 static void mlx5_fpga_conn_handle_cqe(struct mlx5_fpga_conn *conn, in mlx5_fpga_conn_handle_cqe() argument
344 mlx5_fpga_conn_sq_cqe(conn, cqe, status); in mlx5_fpga_conn_handle_cqe()
351 mlx5_fpga_conn_rq_cqe(conn, cqe, status); in mlx5_fpga_conn_handle_cqe()
354 mlx5_fpga_warn(conn->fdev, "Unexpected cqe opcode %u\n", in mlx5_fpga_conn_handle_cqe()
359 static void mlx5_fpga_conn_arm_cq(struct mlx5_fpga_conn *conn) in mlx5_fpga_conn_arm_cq() argument
361 mlx5_cq_arm(&conn->cq.mcq, MLX5_CQ_DB_REQ_NOT, in mlx5_fpga_conn_arm_cq()
362 conn->fdev->conn_res.uar->map, conn->cq.wq.cc); in mlx5_fpga_conn_arm_cq()
368 struct mlx5_fpga_conn *conn; in mlx5_fpga_conn_cq_event() local
370 conn = container_of(mcq, struct mlx5_fpga_conn, cq.mcq); in mlx5_fpga_conn_cq_event()
371 mlx5_fpga_warn(conn->fdev, "CQ event %u on CQ #%u\n", event, mcq->cqn); in mlx5_fpga_conn_cq_event()
376 struct mlx5_fpga_conn *conn; in mlx5_fpga_conn_event() local
378 conn = container_of(mqp, struct mlx5_fpga_conn, qp.mqp); in mlx5_fpga_conn_event()
379 mlx5_fpga_warn(conn->fdev, "QP event %u on QP #%u\n", event, mqp->qpn); in mlx5_fpga_conn_event()
382 static inline void mlx5_fpga_conn_cqes(struct mlx5_fpga_conn *conn, in mlx5_fpga_conn_cqes() argument
388 cqe = mlx5_cqwq_get_cqe(&conn->cq.wq); in mlx5_fpga_conn_cqes()
393 mlx5_cqwq_pop(&conn->cq.wq); in mlx5_fpga_conn_cqes()
394 mlx5_fpga_conn_handle_cqe(conn, cqe); in mlx5_fpga_conn_cqes()
395 mlx5_cqwq_update_db_record(&conn->cq.wq); in mlx5_fpga_conn_cqes()
398 tasklet_schedule(&conn->cq.tasklet); in mlx5_fpga_conn_cqes()
402 mlx5_fpga_dbg(conn->fdev, "Re-arming CQ with cc# %u\n", conn->cq.wq.cc); in mlx5_fpga_conn_cqes()
405 mlx5_fpga_conn_arm_cq(conn); in mlx5_fpga_conn_cqes()
410 struct mlx5_fpga_conn *conn = (void *)data; in mlx5_fpga_conn_cq_tasklet() local
412 if (unlikely(!conn->qp.active)) in mlx5_fpga_conn_cq_tasklet()
414 mlx5_fpga_conn_cqes(conn, MLX5_FPGA_CQ_BUDGET); in mlx5_fpga_conn_cq_tasklet()
419 struct mlx5_fpga_conn *conn; in mlx5_fpga_conn_cq_complete() local
421 conn = container_of(mcq, struct mlx5_fpga_conn, cq.mcq); in mlx5_fpga_conn_cq_complete()
422 if (unlikely(!conn->qp.active)) in mlx5_fpga_conn_cq_complete()
424 mlx5_fpga_conn_cqes(conn, MLX5_FPGA_CQ_BUDGET); in mlx5_fpga_conn_cq_complete()
427 static int mlx5_fpga_conn_create_cq(struct mlx5_fpga_conn *conn, int cq_size) in mlx5_fpga_conn_create_cq() argument
429 struct mlx5_fpga_device *fdev = conn->fdev; in mlx5_fpga_conn_create_cq()
446 err = mlx5_cqwq_create(mdev, &wqp, temp_cqc, &conn->cq.wq, in mlx5_fpga_conn_create_cq()
447 &conn->cq.wq_ctrl); in mlx5_fpga_conn_create_cq()
451 for (i = 0; i < mlx5_cqwq_get_size(&conn->cq.wq); i++) { in mlx5_fpga_conn_create_cq()
452 cqe = mlx5_cqwq_get_wqe(&conn->cq.wq, i); in mlx5_fpga_conn_create_cq()
457 sizeof(u64) * conn->cq.wq_ctrl.frag_buf.npages; in mlx5_fpga_conn_create_cq()
472 MLX5_SET(cqc, cqc, log_page_size, conn->cq.wq_ctrl.frag_buf.page_shift - in mlx5_fpga_conn_create_cq()
474 MLX5_SET64(cqc, cqc, dbr_addr, conn->cq.wq_ctrl.db.dma); in mlx5_fpga_conn_create_cq()
477 mlx5_fill_page_frag_array(&conn->cq.wq_ctrl.frag_buf, pas); in mlx5_fpga_conn_create_cq()
479 err = mlx5_core_create_cq(mdev, &conn->cq.mcq, in, inlen); in mlx5_fpga_conn_create_cq()
485 conn->cq.mcq.cqe_sz = 64; in mlx5_fpga_conn_create_cq()
486 conn->cq.mcq.set_ci_db = conn->cq.wq_ctrl.db.db; in mlx5_fpga_conn_create_cq()
487 conn->cq.mcq.arm_db = conn->cq.wq_ctrl.db.db + 1; in mlx5_fpga_conn_create_cq()
488 *conn->cq.mcq.set_ci_db = 0; in mlx5_fpga_conn_create_cq()
489 *conn->cq.mcq.arm_db = 0; in mlx5_fpga_conn_create_cq()
490 conn->cq.mcq.vector = 0; in mlx5_fpga_conn_create_cq()
491 conn->cq.mcq.comp = mlx5_fpga_conn_cq_complete; in mlx5_fpga_conn_create_cq()
492 conn->cq.mcq.event = mlx5_fpga_conn_cq_event; in mlx5_fpga_conn_create_cq()
493 conn->cq.mcq.irqn = irqn; in mlx5_fpga_conn_create_cq()
494 conn->cq.mcq.uar = fdev->conn_res.uar; in mlx5_fpga_conn_create_cq()
495 tasklet_init(&conn->cq.tasklet, mlx5_fpga_conn_cq_tasklet, in mlx5_fpga_conn_create_cq()
496 (unsigned long)conn); in mlx5_fpga_conn_create_cq()
498 mlx5_fpga_dbg(fdev, "Created CQ #0x%x\n", conn->cq.mcq.cqn); in mlx5_fpga_conn_create_cq()
503 mlx5_cqwq_destroy(&conn->cq.wq_ctrl); in mlx5_fpga_conn_create_cq()
508 static void mlx5_fpga_conn_destroy_cq(struct mlx5_fpga_conn *conn) in mlx5_fpga_conn_destroy_cq() argument
510 tasklet_disable(&conn->cq.tasklet); in mlx5_fpga_conn_destroy_cq()
511 tasklet_kill(&conn->cq.tasklet); in mlx5_fpga_conn_destroy_cq()
512 mlx5_core_destroy_cq(conn->fdev->mdev, &conn->cq.mcq); in mlx5_fpga_conn_destroy_cq()
513 mlx5_cqwq_destroy(&conn->cq.wq_ctrl); in mlx5_fpga_conn_destroy_cq()
516 static int mlx5_fpga_conn_create_wq(struct mlx5_fpga_conn *conn, void *qpc) in mlx5_fpga_conn_create_wq() argument
518 struct mlx5_fpga_device *fdev = conn->fdev; in mlx5_fpga_conn_create_wq()
525 return mlx5_wq_qp_create(mdev, &wqp, qpc, &conn->qp.wq, in mlx5_fpga_conn_create_wq()
526 &conn->qp.wq_ctrl); in mlx5_fpga_conn_create_wq()
529 static int mlx5_fpga_conn_create_qp(struct mlx5_fpga_conn *conn, in mlx5_fpga_conn_create_qp() argument
532 struct mlx5_fpga_device *fdev = conn->fdev; in mlx5_fpga_conn_create_qp()
538 conn->qp.rq.pc = 0; in mlx5_fpga_conn_create_qp()
539 conn->qp.rq.cc = 0; in mlx5_fpga_conn_create_qp()
540 conn->qp.rq.size = roundup_pow_of_two(rx_size); in mlx5_fpga_conn_create_qp()
541 conn->qp.sq.pc = 0; in mlx5_fpga_conn_create_qp()
542 conn->qp.sq.cc = 0; in mlx5_fpga_conn_create_qp()
543 conn->qp.sq.size = roundup_pow_of_two(tx_size); in mlx5_fpga_conn_create_qp()
546 MLX5_SET(qpc, temp_qpc, log_rq_size, ilog2(conn->qp.rq.size)); in mlx5_fpga_conn_create_qp()
547 MLX5_SET(qpc, temp_qpc, log_sq_size, ilog2(conn->qp.sq.size)); in mlx5_fpga_conn_create_qp()
548 err = mlx5_fpga_conn_create_wq(conn, temp_qpc); in mlx5_fpga_conn_create_qp()
552 conn->qp.rq.bufs = kvzalloc(sizeof(conn->qp.rq.bufs[0]) * in mlx5_fpga_conn_create_qp()
553 conn->qp.rq.size, GFP_KERNEL); in mlx5_fpga_conn_create_qp()
554 if (!conn->qp.rq.bufs) { in mlx5_fpga_conn_create_qp()
559 conn->qp.sq.bufs = kvzalloc(sizeof(conn->qp.sq.bufs[0]) * in mlx5_fpga_conn_create_qp()
560 conn->qp.sq.size, GFP_KERNEL); in mlx5_fpga_conn_create_qp()
561 if (!conn->qp.sq.bufs) { in mlx5_fpga_conn_create_qp()
568 conn->qp.wq_ctrl.buf.npages; in mlx5_fpga_conn_create_qp()
578 conn->qp.wq_ctrl.buf.page_shift - MLX5_ADAPTER_PAGE_SHIFT); in mlx5_fpga_conn_create_qp()
585 MLX5_SET(qpc, qpc, log_rq_size, ilog2(conn->qp.rq.size)); in mlx5_fpga_conn_create_qp()
587 MLX5_SET(qpc, qpc, log_sq_size, ilog2(conn->qp.sq.size)); in mlx5_fpga_conn_create_qp()
588 MLX5_SET(qpc, qpc, cqn_snd, conn->cq.mcq.cqn); in mlx5_fpga_conn_create_qp()
589 MLX5_SET(qpc, qpc, cqn_rcv, conn->cq.mcq.cqn); in mlx5_fpga_conn_create_qp()
590 MLX5_SET64(qpc, qpc, dbr_addr, conn->qp.wq_ctrl.db.dma); in mlx5_fpga_conn_create_qp()
594 mlx5_fill_page_array(&conn->qp.wq_ctrl.buf, in mlx5_fpga_conn_create_qp()
597 err = mlx5_core_create_qp(mdev, &conn->qp.mqp, in, inlen); in mlx5_fpga_conn_create_qp()
601 conn->qp.mqp.event = mlx5_fpga_conn_event; in mlx5_fpga_conn_create_qp()
602 mlx5_fpga_dbg(fdev, "Created QP #0x%x\n", conn->qp.mqp.qpn); in mlx5_fpga_conn_create_qp()
607 kvfree(conn->qp.sq.bufs); in mlx5_fpga_conn_create_qp()
609 kvfree(conn->qp.rq.bufs); in mlx5_fpga_conn_create_qp()
611 mlx5_wq_destroy(&conn->qp.wq_ctrl); in mlx5_fpga_conn_create_qp()
617 static void mlx5_fpga_conn_free_recv_bufs(struct mlx5_fpga_conn *conn) in mlx5_fpga_conn_free_recv_bufs() argument
621 for (ix = 0; ix < conn->qp.rq.size; ix++) { in mlx5_fpga_conn_free_recv_bufs()
622 if (!conn->qp.rq.bufs[ix]) in mlx5_fpga_conn_free_recv_bufs()
624 mlx5_fpga_conn_unmap_buf(conn, conn->qp.rq.bufs[ix]); in mlx5_fpga_conn_free_recv_bufs()
625 kfree(conn->qp.rq.bufs[ix]); in mlx5_fpga_conn_free_recv_bufs()
626 conn->qp.rq.bufs[ix] = NULL; in mlx5_fpga_conn_free_recv_bufs()
630 static void mlx5_fpga_conn_flush_send_bufs(struct mlx5_fpga_conn *conn) in mlx5_fpga_conn_flush_send_bufs() argument
635 for (ix = 0; ix < conn->qp.sq.size; ix++) { in mlx5_fpga_conn_flush_send_bufs()
636 buf = conn->qp.sq.bufs[ix]; in mlx5_fpga_conn_flush_send_bufs()
639 conn->qp.sq.bufs[ix] = NULL; in mlx5_fpga_conn_flush_send_bufs()
640 mlx5_fpga_conn_unmap_buf(conn, buf); in mlx5_fpga_conn_flush_send_bufs()
643 buf->complete(conn, conn->fdev, buf, MLX5_CQE_SYNDROME_WR_FLUSH_ERR); in mlx5_fpga_conn_flush_send_bufs()
645 list_for_each_entry_safe(buf, temp, &conn->qp.sq.backlog, list) { in mlx5_fpga_conn_flush_send_bufs()
646 mlx5_fpga_conn_unmap_buf(conn, buf); in mlx5_fpga_conn_flush_send_bufs()
649 buf->complete(conn, conn->fdev, buf, MLX5_CQE_SYNDROME_WR_FLUSH_ERR); in mlx5_fpga_conn_flush_send_bufs()
653 static void mlx5_fpga_conn_destroy_qp(struct mlx5_fpga_conn *conn) in mlx5_fpga_conn_destroy_qp() argument
655 mlx5_core_destroy_qp(conn->fdev->mdev, &conn->qp.mqp); in mlx5_fpga_conn_destroy_qp()
656 mlx5_fpga_conn_free_recv_bufs(conn); in mlx5_fpga_conn_destroy_qp()
657 mlx5_fpga_conn_flush_send_bufs(conn); in mlx5_fpga_conn_destroy_qp()
658 kvfree(conn->qp.sq.bufs); in mlx5_fpga_conn_destroy_qp()
659 kvfree(conn->qp.rq.bufs); in mlx5_fpga_conn_destroy_qp()
660 mlx5_wq_destroy(&conn->qp.wq_ctrl); in mlx5_fpga_conn_destroy_qp()
663 static inline int mlx5_fpga_conn_reset_qp(struct mlx5_fpga_conn *conn) in mlx5_fpga_conn_reset_qp() argument
665 struct mlx5_core_dev *mdev = conn->fdev->mdev; in mlx5_fpga_conn_reset_qp()
667 mlx5_fpga_dbg(conn->fdev, "Modifying QP %u to RST\n", conn->qp.mqp.qpn); in mlx5_fpga_conn_reset_qp()
670 &conn->qp.mqp); in mlx5_fpga_conn_reset_qp()
673 static inline int mlx5_fpga_conn_init_qp(struct mlx5_fpga_conn *conn) in mlx5_fpga_conn_init_qp() argument
675 struct mlx5_fpga_device *fdev = conn->fdev; in mlx5_fpga_conn_init_qp()
680 mlx5_fpga_dbg(conn->fdev, "Modifying QP %u to INIT\n", conn->qp.mqp.qpn); in mlx5_fpga_conn_init_qp()
692 MLX5_SET(qpc, qpc, pd, conn->fdev->conn_res.pdn); in mlx5_fpga_conn_init_qp()
693 MLX5_SET(qpc, qpc, cqn_snd, conn->cq.mcq.cqn); in mlx5_fpga_conn_init_qp()
694 MLX5_SET(qpc, qpc, cqn_rcv, conn->cq.mcq.cqn); in mlx5_fpga_conn_init_qp()
695 MLX5_SET64(qpc, qpc, dbr_addr, conn->qp.wq_ctrl.db.dma); in mlx5_fpga_conn_init_qp()
698 &conn->qp.mqp); in mlx5_fpga_conn_init_qp()
709 static inline int mlx5_fpga_conn_rtr_qp(struct mlx5_fpga_conn *conn) in mlx5_fpga_conn_rtr_qp() argument
711 struct mlx5_fpga_device *fdev = conn->fdev; in mlx5_fpga_conn_rtr_qp()
716 mlx5_fpga_dbg(conn->fdev, "QP RTR\n"); in mlx5_fpga_conn_rtr_qp()
726 MLX5_SET(qpc, qpc, remote_qpn, conn->fpga_qpn); in mlx5_fpga_conn_rtr_qp()
728 MLX5_GET(fpga_qpc, conn->fpga_qpc, next_send_psn)); in mlx5_fpga_conn_rtr_qp()
732 MLX5_ADDR_OF(fpga_qpc, conn->fpga_qpc, fpga_mac_47_32)); in mlx5_fpga_conn_rtr_qp()
736 conn->qp.sgid_index); in mlx5_fpga_conn_rtr_qp()
739 MLX5_ADDR_OF(fpga_qpc, conn->fpga_qpc, fpga_ip), in mlx5_fpga_conn_rtr_qp()
743 &conn->qp.mqp); in mlx5_fpga_conn_rtr_qp()
754 static inline int mlx5_fpga_conn_rts_qp(struct mlx5_fpga_conn *conn) in mlx5_fpga_conn_rts_qp() argument
756 struct mlx5_fpga_device *fdev = conn->fdev; in mlx5_fpga_conn_rts_qp()
762 mlx5_fpga_dbg(conn->fdev, "QP RTS\n"); in mlx5_fpga_conn_rts_qp()
774 MLX5_GET(fpga_qpc, conn->fpga_qpc, next_rcv_psn)); in mlx5_fpga_conn_rts_qp()
780 &conn->qp.mqp); in mlx5_fpga_conn_rts_qp()
791 static int mlx5_fpga_conn_connect(struct mlx5_fpga_conn *conn) in mlx5_fpga_conn_connect() argument
793 struct mlx5_fpga_device *fdev = conn->fdev; in mlx5_fpga_conn_connect()
796 MLX5_SET(fpga_qpc, conn->fpga_qpc, state, MLX5_FPGA_QPC_STATE_ACTIVE); in mlx5_fpga_conn_connect()
797 err = mlx5_fpga_modify_qp(conn->fdev->mdev, conn->fpga_qpn, in mlx5_fpga_conn_connect()
798 MLX5_FPGA_QPC_STATE, &conn->fpga_qpc); in mlx5_fpga_conn_connect()
804 err = mlx5_fpga_conn_reset_qp(conn); in mlx5_fpga_conn_connect()
810 err = mlx5_fpga_conn_init_qp(conn); in mlx5_fpga_conn_connect()
815 conn->qp.active = true; in mlx5_fpga_conn_connect()
817 while (!mlx5_fpga_conn_post_recv_buf(conn)) in mlx5_fpga_conn_connect()
820 err = mlx5_fpga_conn_rtr_qp(conn); in mlx5_fpga_conn_connect()
826 err = mlx5_fpga_conn_rts_qp(conn); in mlx5_fpga_conn_connect()
834 mlx5_fpga_conn_free_recv_bufs(conn); in mlx5_fpga_conn_connect()
836 MLX5_SET(fpga_qpc, conn->fpga_qpc, state, MLX5_FPGA_QPC_STATE_INIT); in mlx5_fpga_conn_connect()
837 if (mlx5_fpga_modify_qp(conn->fdev->mdev, conn->fpga_qpn, in mlx5_fpga_conn_connect()
838 MLX5_FPGA_QPC_STATE, &conn->fpga_qpc)) in mlx5_fpga_conn_connect()
848 struct mlx5_fpga_conn *ret, *conn; in mlx5_fpga_conn_create() local
855 conn = kzalloc(sizeof(*conn), GFP_KERNEL); in mlx5_fpga_conn_create()
856 if (!conn) in mlx5_fpga_conn_create()
859 conn->fdev = fdev; in mlx5_fpga_conn_create()
860 INIT_LIST_HEAD(&conn->qp.sq.backlog); in mlx5_fpga_conn_create()
862 spin_lock_init(&conn->qp.sq.lock); in mlx5_fpga_conn_create()
864 conn->recv_cb = attr->recv_cb; in mlx5_fpga_conn_create()
865 conn->cb_arg = attr->cb_arg; in mlx5_fpga_conn_create()
867 remote_mac = MLX5_ADDR_OF(fpga_qpc, conn->fpga_qpc, remote_mac_47_32); in mlx5_fpga_conn_create()
876 remote_ip = MLX5_ADDR_OF(fpga_qpc, conn->fpga_qpc, remote_ip); in mlx5_fpga_conn_create()
881 err = mlx5_core_reserved_gid_alloc(fdev->mdev, &conn->qp.sgid_index); in mlx5_fpga_conn_create()
888 err = mlx5_core_roce_gid_set(fdev->mdev, conn->qp.sgid_index, in mlx5_fpga_conn_create()
897 mlx5_fpga_dbg(fdev, "Reserved SGID index %u\n", conn->qp.sgid_index); in mlx5_fpga_conn_create()
902 err = mlx5_fpga_conn_create_cq(conn, in mlx5_fpga_conn_create()
910 mlx5_fpga_conn_arm_cq(conn); in mlx5_fpga_conn_create()
912 err = mlx5_fpga_conn_create_qp(conn, attr->tx_size, attr->rx_size); in mlx5_fpga_conn_create()
919 MLX5_SET(fpga_qpc, conn->fpga_qpc, state, MLX5_FPGA_QPC_STATE_INIT); in mlx5_fpga_conn_create()
920 MLX5_SET(fpga_qpc, conn->fpga_qpc, qp_type, qp_type); in mlx5_fpga_conn_create()
921 MLX5_SET(fpga_qpc, conn->fpga_qpc, st, MLX5_FPGA_QPC_ST_RC); in mlx5_fpga_conn_create()
922 MLX5_SET(fpga_qpc, conn->fpga_qpc, ether_type, ETH_P_8021Q); in mlx5_fpga_conn_create()
923 MLX5_SET(fpga_qpc, conn->fpga_qpc, vid, 0); in mlx5_fpga_conn_create()
924 MLX5_SET(fpga_qpc, conn->fpga_qpc, next_rcv_psn, 1); in mlx5_fpga_conn_create()
925 MLX5_SET(fpga_qpc, conn->fpga_qpc, next_send_psn, 0); in mlx5_fpga_conn_create()
926 MLX5_SET(fpga_qpc, conn->fpga_qpc, pkey, MLX5_FPGA_PKEY); in mlx5_fpga_conn_create()
927 MLX5_SET(fpga_qpc, conn->fpga_qpc, remote_qpn, conn->qp.mqp.qpn); in mlx5_fpga_conn_create()
928 MLX5_SET(fpga_qpc, conn->fpga_qpc, rnr_retry, 7); in mlx5_fpga_conn_create()
929 MLX5_SET(fpga_qpc, conn->fpga_qpc, retry_count, 7); in mlx5_fpga_conn_create()
931 err = mlx5_fpga_create_qp(fdev->mdev, &conn->fpga_qpc, in mlx5_fpga_conn_create()
932 &conn->fpga_qpn); in mlx5_fpga_conn_create()
939 err = mlx5_fpga_conn_connect(conn); in mlx5_fpga_conn_create()
945 mlx5_fpga_dbg(fdev, "FPGA QPN is %u\n", conn->fpga_qpn); in mlx5_fpga_conn_create()
946 ret = conn; in mlx5_fpga_conn_create()
950 mlx5_fpga_destroy_qp(conn->fdev->mdev, conn->fpga_qpn); in mlx5_fpga_conn_create()
952 mlx5_fpga_conn_destroy_qp(conn); in mlx5_fpga_conn_create()
954 mlx5_fpga_conn_destroy_cq(conn); in mlx5_fpga_conn_create()
956 mlx5_core_roce_gid_set(fdev->mdev, conn->qp.sgid_index, 0, 0, NULL, in mlx5_fpga_conn_create()
959 mlx5_core_reserved_gid_free(fdev->mdev, conn->qp.sgid_index); in mlx5_fpga_conn_create()
961 kfree(conn); in mlx5_fpga_conn_create()
966 void mlx5_fpga_conn_destroy(struct mlx5_fpga_conn *conn) in mlx5_fpga_conn_destroy() argument
968 struct mlx5_fpga_device *fdev = conn->fdev; in mlx5_fpga_conn_destroy()
972 conn->qp.active = false; in mlx5_fpga_conn_destroy()
973 tasklet_disable(&conn->cq.tasklet); in mlx5_fpga_conn_destroy()
974 synchronize_irq(conn->cq.mcq.irqn); in mlx5_fpga_conn_destroy()
976 mlx5_fpga_destroy_qp(conn->fdev->mdev, conn->fpga_qpn); in mlx5_fpga_conn_destroy()
978 &conn->qp.mqp); in mlx5_fpga_conn_destroy()
981 mlx5_fpga_conn_destroy_qp(conn); in mlx5_fpga_conn_destroy()
982 mlx5_fpga_conn_destroy_cq(conn); in mlx5_fpga_conn_destroy()
984 mlx5_core_roce_gid_set(conn->fdev->mdev, conn->qp.sgid_index, 0, 0, in mlx5_fpga_conn_destroy()
986 mlx5_core_reserved_gid_free(conn->fdev->mdev, conn->qp.sgid_index); in mlx5_fpga_conn_destroy()
987 kfree(conn); in mlx5_fpga_conn_destroy()