Home | History | Annotate | Download | only in infiniband

Lines Matching refs:qp

467  * @v qp		Queue pair
470 struct ib_queue_pair *qp ) {
471 struct ib_work_queue *wq = &qp->send;
476 if ( ( linda->reserved_send_bufs + qp->send.num_wqes ) >
480 linda->reserved_send_bufs, qp->send.num_wqes );
484 linda->reserved_send_bufs += qp->send.num_wqes;
491 linda_wq->send_buf = zalloc ( qp->send.num_wqes *
502 linda->reserved_send_bufs -= qp->send.num_wqes;
511 * @v qp Queue pair
514 struct ib_queue_pair *qp ) {
515 struct ib_work_queue *wq = &qp->send;
519 linda->reserved_send_bufs -= qp->send.num_wqes;
606 * @v qp Queue pair
610 struct ib_queue_pair *qp ) {
611 struct ib_work_queue *wq = &qp->recv;
618 unsigned int ctx = linda_qpn_to_ctx ( qp->qpn );
661 linda, qp->qpn, ctx, virt_to_bus ( linda_wq->header ),
675 * @v qp Queue pair
678 struct ib_queue_pair *qp ) {
679 struct ib_work_queue *wq = &qp->recv;
682 unsigned int ctx = linda_qpn_to_ctx ( qp->qpn );
776 /* Set the BTH QP for Infinipath packets to an unused value */
852 * @v qp Queue pair
856 struct ib_queue_pair *qp ) {
869 qp->qpn = linda_ctx_to_qpn ( ctx );
872 ib_wq_set_drvdata ( &qp->send, &linda->send_wq[ctx] );
873 ib_wq_set_drvdata ( &qp->recv, &linda->recv_wq[ctx] );
876 if ( ( rc = linda_create_recv_wq ( linda, qp ) ) != 0 )
880 if ( ( rc = linda_create_send_wq ( linda, qp ) ) != 0 )
885 linda_destroy_send_wq ( linda, qp );
887 linda_destroy_recv_wq ( linda, qp );
898 * @v qp Queue pair
902 struct ib_queue_pair *qp ) {
908 DBGC ( linda, "Linda %p QPN %ld modified\n", linda, qp->qpn );
916 * @v qp Queue pair
919 struct ib_queue_pair *qp ) {
922 linda_destroy_send_wq ( linda, qp );
923 linda_destroy_recv_wq ( linda, qp );
937 * @v qp Queue pair
943 struct ib_queue_pair *qp,
947 struct ib_work_queue *wq = &qp->send;
971 ib_push ( ibdev, &headers, qp, iob_len ( iobuf ), av );
1003 linda, qp->qpn, send_buf, linda_wq->prod,
1016 * @v qp Queue pair
1020 struct ib_queue_pair *qp,
1023 struct ib_work_queue *wq = &qp->send;
1031 linda, qp->qpn, send_buf, wqe_idx );
1036 ib_complete_send ( ibdev, qp, iobuf, 0 );
1047 * @v qp Queue pair
1050 struct ib_queue_pair *qp ) {
1052 struct ib_work_queue *wq = &qp->send;
1065 linda_complete_send ( ibdev, qp, linda_wq->cons );
1077 * @v qp Queue pair
1082 struct ib_queue_pair *qp,
1085 struct ib_work_queue *wq = &qp->recv;
1089 unsigned int ctx = linda_qpn_to_ctx ( qp->qpn );
1100 "(%08lx)\n", linda, qp->qpn, addr );
1105 linda, qp->qpn, len );
1136 linda, qp->qpn, linda_wq->eager_prod, wqe_idx,
1158 * @v qp Queue pair
1162 struct ib_queue_pair *qp,
1165 struct ib_work_queue *wq = &qp->recv;
1218 qp->qpn, egrindex, ( useegrbfr ? "" : "(unused)" ),
1229 "len %d(%d+%d+4)\n", linda, qp->qpn, egrindex,
1237 qp0 = ( qp->qpn == 0 );
1246 intended_qp = qp;
1288 /* Redirect to target QP if necessary */
1289 if ( qp != intended_qp ) {
1292 linda, qp->qpn, intended_qp->qpn );
1294 qp->recv.fill--;
1300 ib_complete_recv ( ibdev, qp, &av, iobuf, -ECANCELED );
1318 * @v qp Queue pair
1321 struct ib_queue_pair *qp ) {
1323 struct ib_work_queue *wq = &qp->recv;
1326 unsigned int ctx = linda_qpn_to_ctx ( qp->qpn );
1338 linda_complete_recv ( ibdev, qp, linda_wq->header_cons );
1367 linda_poll_send_wq ( ibdev, wq->qp );
1369 linda_poll_recv_wq ( ibdev, wq->qp );
1453 * @v qp Queue pair
1458 struct ib_queue_pair *qp,
1463 ( void ) qp;
1472 * @v qp Queue pair
1476 struct ib_queue_pair *qp,
1481 ( void ) qp;