ib_mcast.h File Reference

Infiniband multicast groups. More...

#include <ipxe/infiniband.h>

Go to the source code of this file.

Data Structures
struct	ib_mc_membership
	An Infiniband multicast group membership. More...

Functions
	FILE_LICENCE (GPL2_OR_LATER_OR_UBDL)
int	ib_mcast_join (struct ib_device *ibdev, struct ib_queue_pair *qp, struct ib_mc_membership *membership, struct ib_address_vector *av, unsigned int mask, void(*joined)(struct ib_mc_membership *memb, int rc))
	Join multicast group.
void	ib_mcast_leave (struct ib_device *ibdev, struct ib_queue_pair *qp, struct ib_mc_membership *membership)
	Leave multicast group.

Detailed Description

Infiniband multicast groups.

Definition in file ib_mcast.h.

Function Documentation

FILE_LICENCE()

FILE_LICENCE

(

GPL2_OR_LATER_OR_UBDL

)

ib_mcast_join()

int ib_mcast_join ( struct ib_device * ibdev, struct ib_queue_pair * qp, struct ib_mc_membership * membership, struct ib_address_vector * av, unsigned int mask, void(* complete )(struct ib_mc_membership *membership, int rc) )

extern

Join multicast group.

Parameters

ibdev	Infiniband device
qp	Queue pair
membership	Multicast group membership
av	Address vector to fill in
joined	Join completion handler

Return values

rc	Return status code

Definition at line 152 of file ib_mcast.c.

                                                     {
        union ib_mad mad;
        int rc;
 
        DBGC ( ibdev, "IBDEV %s QPN %#lx joining " IB_GID_FMT "\n",
               ibdev->name, qp->qpn, IB_GID_ARGS ( &av->gid ) );
 
        /* Sanity checks */
        assert ( qp != NULL );
        assert ( ! membership->attached );
 
        /* Initialise structure */
        membership->qp = qp;
        membership->av = av;
        membership->complete = complete;
 
        /* Attach queue pair to multicast GID */
        if ( ( rc = ib_mcast_attach ( ibdev, qp, &av->gid ) ) != 0 ) {
                DBGC ( ibdev, "IBDEV %s QPN %#lx could not attach: %s\n",
                       ibdev->name, qp->qpn, strerror ( rc ) );
                goto err_mcast_attach;
        }
        membership->attached = 1;
 
        /* Initiate multicast membership join */
        ib_mcast_mad ( ibdev, av, IB_MGMT_METHOD_SET, mask, &mad );
        membership->madx = ib_create_madx ( ibdev, ibdev->gsi, &mad, NULL,
                                            &ib_mcast_op );
        if ( ! membership->madx ) {
                DBGC ( ibdev, "IBDEV %s QPN %#lx could not create join "
                       "transaction\n", ibdev->name, qp->qpn );
                rc = -ENOMEM;
                goto err_create_madx;
        }
        ib_madx_set_ownerdata ( membership->madx, membership );
 
        return 0;
 
        ib_destroy_madx ( ibdev, ibdev->gsi, membership->madx );
 err_create_madx:
        ib_mcast_detach ( ibdev, qp, &av->gid );
        membership->attached = 0;
 err_mcast_attach:
        return rc;
}

References assert, ib_mc_membership::attached, ib_mc_membership::av, ib_mc_membership::complete, DBGC, ENOMEM, ib_address_vector::gid, ib_device::gsi, ib_create_madx(), ib_destroy_madx(), IB_GID_ARGS, IB_GID_FMT, ib_madx_set_ownerdata(), ib_mcast_attach(), ib_mcast_detach(), ib_mcast_mad(), ib_mcast_op, IB_MGMT_METHOD_SET, mad, ib_mc_membership::madx, ib_device::name, NULL, ib_mc_membership::qp, qp, rc, and strerror().

Referenced by eoib_join_broadcast_group(), and ipoib_join_broadcast_group().

ib_mcast_leave()

void ib_mcast_leave ( struct ib_device * ibdev, struct ib_queue_pair * qp, struct ib_mc_membership * membership )

extern

Leave multicast group.

Parameters

ibdev	Infiniband device
qp	Queue pair
membership	Multicast group membership

Definition at line 209 of file ib_mcast.c.

                                                            {
        struct ib_address_vector *av = membership->av;
        union ib_mad mad;
        int rc;
 
        /* Do nothing if we are already detached from the multicast GID */
        if ( ! membership->attached )
                return;
 
        DBGC ( ibdev, "IBDEV %s QPN %#lx leaving " IB_GID_FMT "\n",
               ibdev->name, qp->qpn, IB_GID_ARGS ( &av->gid ) );
 
        /* Sanity check */
        assert ( qp != NULL );
 
        /* Detach from multicast GID */
        ib_mcast_detach ( ibdev, qp, &av->gid );
        membership->attached = 0;
 
        /* Cancel multicast membership join, if applicable */
        if ( membership->madx ) {
                ib_destroy_madx ( ibdev, ibdev->gsi, membership->madx );
                membership->madx = NULL;
        }
 
        /* Send a single group leave MAD */
        ib_mcast_mad ( ibdev, av, IB_MGMT_METHOD_DELETE, 0, &mad );
        if ( ( rc = ib_mi_send ( ibdev, ibdev->gsi, &mad, NULL ) ) != 0 ) {
                DBGC ( ibdev, "IBDEV %s QPN %#lx could not send leave request: "
                       "%s\n", ibdev->name, qp->qpn, strerror ( rc ) );
        }
}

References assert, ib_mc_membership::attached, ib_mc_membership::av, DBGC, ib_address_vector::gid, ib_device::gsi, ib_destroy_madx(), IB_GID_ARGS, IB_GID_FMT, ib_mcast_detach(), ib_mcast_mad(), IB_MGMT_METHOD_DELETE, ib_mi_send(), mad, ib_mc_membership::madx, ib_device::name, NULL, qp, rc, and strerror().

Referenced by eoib_leave_broadcast_group(), and ipoib_leave_broadcast_group().