Lines Matching defs:my_qp
401 static inline int post_one_send(struct ehca_qp *my_qp,
408 u64 start_offset = my_qp->ipz_squeue.current_q_offset;
411 wqe_p = ipz_qeit_get_inc(&my_qp->ipz_squeue);
414 ehca_err(my_qp->ib_qp.device, "Too many posted WQEs "
415 "qp_num=%x", my_qp->ib_qp.qp_num);
423 sq_map_idx = start_offset / my_qp->ipz_squeue.qe_size;
426 ret = ehca_write_swqe(my_qp, wqe_p, cur_send_wr, sq_map_idx, hidden);
432 my_qp->ipz_squeue.current_q_offset = start_offset;
433 ehca_err(my_qp->ib_qp.device, "Could not write WQE "
434 "qp_num=%x", my_qp->ib_qp.qp_num);
445 struct ehca_qp *my_qp = container_of(qp, struct ehca_qp, ib_qp);
451 if (unlikely(my_qp->state < IB_QPS_RTS)) {
453 my_qp->state, qp->qp_num);
459 spin_lock_irqsave(&my_qp->spinlock_s, flags);
467 if (unlikely(my_qp->unsol_ack_circ &&
468 my_qp->packet_count > ACK_CIRC_THRESHOLD &&
469 my_qp->message_count > my_qp->init_attr.cap.max_send_wr)) {
474 post_one_send(my_qp, &circ_wr, 1); /* ignore retcode */
477 my_qp->message_count = my_qp->packet_count = 0;
482 ret = post_one_send(my_qp, send_wr, 0);
492 hipz_update_sqa(my_qp, wqe_cnt);
495 my_qp, qp->qp_num, wqe_cnt, ret);
496 my_qp->message_count += wqe_cnt;
497 spin_unlock_irqrestore(&my_qp->spinlock_s, flags);
505 static int internal_post_recv(struct ehca_qp *my_qp,
517 if (unlikely(!HAS_RQ(my_qp))) {
519 my_qp, my_qp->real_qp_num, my_qp->ext_type);
525 spin_lock_irqsave(&my_qp->spinlock_r, flags);
529 u64 start_offset = my_qp->ipz_rqueue.current_q_offset;
531 wqe_p = ipz_qeit_get_inc(&my_qp->ipz_rqueue);
536 "qp_num=%x", my_qp->real_qp_num);
543 rq_map_idx = start_offset / my_qp->ipz_rqueue.qe_size;
546 ret = ehca_write_rwqe(&my_qp->ipz_rqueue, wqe_p, recv_wr,
553 my_qp->ipz_rqueue.current_q_offset = start_offset;
556 "qp_num=%x", my_qp->real_qp_num);
560 qmap_entry = &my_qp->rq_map.map[rq_map_idx];
571 hipz_update_rqa(my_qp, wqe_cnt);
574 my_qp, my_qp->real_qp_num, wqe_cnt, ret);
575 spin_unlock_irqrestore(&my_qp->spinlock_r, flags);
588 struct ehca_qp *my_qp = container_of(qp, struct ehca_qp, ib_qp);
591 if (unlikely(my_qp->state == IB_QPS_RESET)) {
593 my_qp->state, qp->qp_num);
598 return internal_post_recv(my_qp, qp->device, recv_wr, bad_recv_wr);
631 struct ehca_qp *my_qp;
702 my_qp = idr_find(&ehca_qp_idr, cqe->qp_token);
704 if (!my_qp)
706 wc->qp = &my_qp->ib_qp;
711 qmap = &my_qp->sq_map;
714 qmap = &my_qp->rq_map;
724 my_qp->sq_map.next_wqe_idx = next_index(my_qp->sq_map.tail,
725 my_qp->sq_map.entries);
726 my_qp->sq_map.left_to_poll = 0;
727 ehca_add_to_err_list(my_qp, 1);
729 my_qp->rq_map.next_wqe_idx = next_index(my_qp->rq_map.tail,
730 my_qp->rq_map.entries);
731 my_qp->rq_map.left_to_poll = 0;
732 if (HAS_RQ(my_qp))
733 ehca_add_to_err_list(my_qp, 0);
739 my_qp->real_qp_num);
750 if ((my_qp->sq_map.left_to_poll == 0) &&
751 (my_qp->rq_map.left_to_poll == 0)) {
752 ehca_add_to_err_list(my_qp, 1);
753 if (HAS_RQ(my_qp))
754 ehca_add_to_err_list(my_qp, 0);
799 static int generate_flush_cqes(struct ehca_qp *my_qp, struct ib_cq *cq,
810 qmap = &my_qp->sq_map;
812 qmap = &my_qp->rq_map;
825 "qp_num=%#x", offset, my_qp->real_qp_num);
858 wc->qp = &my_qp->ib_qp;