ib_cmrc.h File Reference

Infiniband Communication-managed Reliable Connections. More...

#include <gpxe/infiniband.h>
#include <gpxe/xfer.h>

Go to the source code of this file.

Functions
	FILE_LICENCE (BSD2)
int	ib_cmrc_open (struct xfer_interface *xfer, struct ib_device *ibdev, struct ib_gid *dgid, struct ib_gid_half *service_id)
	Open CMRC connection.

---

Detailed Description

Infiniband Communication-managed Reliable Connections.

Definition in file ib_cmrc.h.

---

Function Documentation

FILE_LICENCE

(

BSD2

)

int ib_cmrc_open	(	struct xfer_interface *	xfer,
		struct ib_device *	ibdev,
		struct ib_gid *	dgid,
		struct ib_gid_half *	service_id
	)

Open CMRC connection.

Parameters:

	xfer	Data transfer interface
	ibdev	Infiniband device
	dgid	Destination GID
	service_id	Service ID

Return values:

rc

Returns status code

Definition at line 375 of file ib_cmrc.c.

References ib_cmrc_connection::cq, DBGC, ib_cmrc_connection::dgid, ENOMEM, ib_close(), IB_CMRC_NUM_CQES, IB_CMRC_NUM_RECV_WQES, IB_CMRC_NUM_SEND_WQES, ib_cmrc_shutdown(), ib_create_cq(), ib_create_qp(), ib_destroy_cq(), ib_destroy_qp(), ib_open(), ib_qp_set_ownerdata(), IB_QPT_RC, ib_cmrc_connection::ibdev, memcpy, process_init_stopped(), ib_cmrc_connection::qp, ib_queue_pair::qpn, ref_put(), ib_cmrc_connection::refcnt, ib_cmrc_connection::service_id, ib_cmrc_connection::shutdown, strerror(), ib_cmrc_connection::xfer, xfer_init(), and zalloc().

Referenced by ib_srp_connect().

                                                                         {
        struct ib_cmrc_connection *cmrc;
        int rc;

        /* Allocate and initialise structure */
        cmrc = zalloc ( sizeof ( *cmrc ) );
        if ( ! cmrc ) {
                rc = -ENOMEM;
                goto err_alloc;
        }
        xfer_init ( &cmrc->xfer, &ib_cmrc_xfer_operations, &cmrc->refcnt );
        cmrc->ibdev = ibdev;
        memcpy ( &cmrc->dgid, dgid, sizeof ( cmrc->dgid ) );
        memcpy ( &cmrc->service_id, service_id, sizeof ( cmrc->service_id ) );
        process_init_stopped ( &cmrc->shutdown, ib_cmrc_shutdown,
                               &cmrc->refcnt );

        /* Open Infiniband device */
        if ( ( rc = ib_open ( ibdev ) ) != 0 ) {
                DBGC ( cmrc, "CMRC %p could not open device: %s\n",
                       cmrc, strerror ( rc ) );
                goto err_open;
        }

        /* Create completion queue */
        cmrc->cq = ib_create_cq ( ibdev, IB_CMRC_NUM_CQES,
                                  &ib_cmrc_completion_ops );
        if ( ! cmrc->cq ) {
                DBGC ( cmrc, "CMRC %p could not create completion queue\n",
                       cmrc );
                rc = -ENOMEM;
                goto err_create_cq;
        }

        /* Create queue pair */
        cmrc->qp = ib_create_qp ( ibdev, IB_QPT_RC, IB_CMRC_NUM_SEND_WQES,
                                  cmrc->cq, IB_CMRC_NUM_RECV_WQES, cmrc->cq );
        if ( ! cmrc->qp ) {
                DBGC ( cmrc, "CMRC %p could not create queue pair\n", cmrc );
                rc = -ENOMEM;
                goto err_create_qp;
        }
        ib_qp_set_ownerdata ( cmrc->qp, cmrc );
        DBGC ( cmrc, "CMRC %p using QPN %lx\n", cmrc, cmrc->qp->qpn );

        /* Attach to parent interface, transfer reference (implicitly)
         * to our shutdown process, and return.
         */
        xfer_plug_plug ( &cmrc->xfer, xfer );
        return 0;

        ib_destroy_qp ( ibdev, cmrc->qp );
 err_create_qp:
        ib_destroy_cq ( ibdev, cmrc->cq );
 err_create_cq:
        ib_close ( ibdev );
 err_open:
        ref_put ( &cmrc->refcnt );
 err_alloc:
        return rc;
}