infiniband.h File Reference

Infiniband protocol. More...

#include <stdint.h>
#include <ipxe/refcnt.h>
#include <ipxe/device.h>
#include <ipxe/tables.h>
#include <ipxe/ib_packet.h>
#include <ipxe/ib_mad.h>
#include <ipxe/if_ether.h>

Go to the source code of this file.

Data Structures
struct	ib_address_vector
	An Infiniband Address Vector. More...
struct	ib_work_queue
	An Infiniband Work Queue. More...
struct	ib_multicast_gid
	An Infiniband multicast GID. More...
struct	ib_queue_pair_operations
	Infiniband queue pair operations. More...
struct	ib_queue_pair
	An Infiniband Queue Pair. More...
struct	ib_completion_queue_operations
	Infiniband completion queue operations. More...
struct	ib_completion_queue
	An Infiniband Completion Queue. More...
struct	ib_device_operations
	Infiniband device operations. More...
struct	ib_device
	An Infiniband device. More...
struct	ib_driver
	An Infiniband upper-layer driver. More...

Macros
#define	IB_QPN_SMI   0
	Subnet management interface QPN.
#define	IB_QKEY_SMI   0
	Subnet management interface queue key.
#define	IB_QPN_GSI   1
	General service interface QPN.
#define	IB_QKEY_GSI   0x80010000UL
	General service interface queue key.
#define	IB_QPN_BROADCAST   0xffffffUL
	Broadcast QPN.
#define	IB_QPN_MASK   0xffffffUL
	QPN mask.
#define	IB_PKEY_DEFAULT   0xffff
	Default Infiniband partition key.
#define	IB_PKEY_FULL   0x8000
	Infiniband partition key full membership flag.
#define	IB_MAX_PAYLOAD_SIZE   2048
	Maximum payload size.
#define	IBDEV_NAME_LEN   8
	Maximum length of an Infiniband device name.
#define	IB_DRIVERS   __table ( struct ib_driver, "ib_drivers" )
	Infiniband driver table.
#define	__ib_driver   __table_entry ( IB_DRIVERS, 01 )
	Declare an Infiniband driver.
#define	for_each_ibdev(ibdev)
	Iterate over all network devices.

Enumerations
enum	ib_rate {   IB_RATE_2_5 = 2 , IB_RATE_10 = 3 , IB_RATE_30 = 4 , IB_RATE_5 = 5 ,   IB_RATE_20 = 6 , IB_RATE_40 = 7 , IB_RATE_60 = 8 , IB_RATE_80 = 9 ,   IB_RATE_120 = 10 }
	Infiniband transmission rates. More...
enum	ib_queue_pair_type {   IB_QPT_SMI , IB_QPT_GSI , IB_QPT_UD , IB_QPT_RC ,   IB_QPT_ETH }
	An Infiniband queue pair type. More...

Functions
	FILE_LICENCE (GPL2_OR_LATER_OR_UBDL)
	FILE_SECBOOT (PERMITTED)
int	ib_create_cq (struct ib_device *ibdev, unsigned int num_cqes, struct ib_completion_queue_operations *op, struct ib_completion_queue **new_cq)
	Create completion queue.
void	ib_destroy_cq (struct ib_device *ibdev, struct ib_completion_queue *cq)
	Destroy completion queue.
void	ib_poll_cq (struct ib_device *ibdev, struct ib_completion_queue *cq)
	Poll completion queue.
int	ib_create_qp (struct ib_device *ibdev, enum ib_queue_pair_type type, unsigned int num_send_wqes, struct ib_completion_queue *send_cq, unsigned int num_recv_wqes, struct ib_completion_queue *recv_cq, struct ib_queue_pair_operations *op, const char *name, struct ib_queue_pair **new_qp)
	Create queue pair.
int	ib_modify_qp (struct ib_device *ibdev, struct ib_queue_pair *qp)
	Modify queue pair.
void	ib_destroy_qp (struct ib_device *ibdev, struct ib_queue_pair *qp)
	Destroy queue pair.
struct ib_queue_pair *	ib_find_qp_qpn (struct ib_device *ibdev, unsigned long qpn)
	Find queue pair by QPN.
struct ib_queue_pair *	ib_find_qp_mgid (struct ib_device *ibdev, union ib_gid *gid)
	Find queue pair by multicast GID.
struct ib_work_queue *	ib_find_wq (struct ib_completion_queue *cq, unsigned long qpn, int is_send)
	Find work queue belonging to completion queue.
int	ib_post_send (struct ib_device *ibdev, struct ib_queue_pair *qp, struct ib_address_vector *dest, struct io_buffer *iobuf)
	Post send work queue entry.
int	ib_post_recv (struct ib_device *ibdev, struct ib_queue_pair *qp, struct io_buffer *iobuf)
	Post receive work queue entry.
void	ib_complete_send (struct ib_device *ibdev, struct ib_queue_pair *qp, struct io_buffer *iobuf, int rc)
	Complete send work queue entry.
void	ib_complete_recv (struct ib_device *ibdev, struct ib_queue_pair *qp, struct ib_address_vector *dest, struct ib_address_vector *source, struct io_buffer *iobuf, int rc)
	Complete receive work queue entry.
void	ib_refill_recv (struct ib_device *ibdev, struct ib_queue_pair *qp)
	Refill receive work queue.
int	ib_open (struct ib_device *ibdev)
	Open port.
void	ib_close (struct ib_device *ibdev)
	Close port.
int	ib_link_rc (struct ib_device *ibdev)
	Get link state.
int	ib_mcast_attach (struct ib_device *ibdev, struct ib_queue_pair *qp, union ib_gid *gid)
	Attach to multicast group.
void	ib_mcast_detach (struct ib_device *ibdev, struct ib_queue_pair *qp, union ib_gid *gid)
	Detach from multicast group.
int	ib_set_port_info (struct ib_device *ibdev, union ib_mad *mad)
	Set port information.
int	ib_set_pkey_table (struct ib_device *ibdev, union ib_mad *mad)
	Set partition key table.
struct ib_device *	alloc_ibdev (size_t priv_size)
	Allocate Infiniband device.
int	register_ibdev (struct ib_device *ibdev)
	Register Infiniband device.
void	unregister_ibdev (struct ib_device *ibdev)
	Unregister Infiniband device.
struct ib_device *	find_ibdev (union ib_gid *gid)
	Find Infiniband device by GID.
struct ib_device *	last_opened_ibdev (void)
	Get most recently opened Infiniband device.
void	ib_link_state_changed (struct ib_device *ibdev)
	Notify of Infiniband link state change.
void	ib_poll_eq (struct ib_device *ibdev)
	Poll event queue.
static __always_inline int	ib_link_ok (struct ib_device *ibdev)
	Check link state of Infiniband device.
static int	ib_is_open (struct ib_device *ibdev)
	Check whether or not Infiniband device is open.
static __always_inline struct ib_device *	ibdev_get (struct ib_device *ibdev)
	Get reference to Infiniband device.
static __always_inline void	ibdev_put (struct ib_device *ibdev)
	Drop reference to Infiniband device.
static __always_inline void	ib_wq_set_drvdata (struct ib_work_queue *wq, void *priv)
	Set Infiniband work queue driver-private data.
static __always_inline void *	ib_wq_get_drvdata (struct ib_work_queue *wq)
	Get Infiniband work queue driver-private data.
static __always_inline void	ib_qp_set_drvdata (struct ib_queue_pair *qp, void *priv)
	Set Infiniband queue pair driver-private data.
static __always_inline void *	ib_qp_get_drvdata (struct ib_queue_pair *qp)
	Get Infiniband queue pair driver-private data.
static __always_inline void	ib_qp_set_ownerdata (struct ib_queue_pair *qp, void *priv)
	Set Infiniband queue pair owner-private data.
static __always_inline void *	ib_qp_get_ownerdata (struct ib_queue_pair *qp)
	Get Infiniband queue pair owner-private data.
static __always_inline void	ib_cq_set_drvdata (struct ib_completion_queue *cq, void *priv)
	Set Infiniband completion queue driver-private data.
static __always_inline void *	ib_cq_get_drvdata (struct ib_completion_queue *cq)
	Get Infiniband completion queue driver-private data.
static __always_inline void	ib_set_drvdata (struct ib_device *ibdev, void *priv)
	Set Infiniband device driver-private data.
static __always_inline void *	ib_get_drvdata (struct ib_device *ibdev)
	Get Infiniband device driver-private data.

Variables
struct list_head	ib_devices
	List of Infiniband devices.

Detailed Description

Infiniband protocol.

Definition in file infiniband.h.

Macro Definition Documentation

IB_QPN_SMI

#define IB_QPN_SMI   0

Subnet management interface QPN.

Definition at line 22 of file infiniband.h.

Referenced by arbel_fill_mlx_send_wqe(), hermon_fill_mlx_send_wqe(), ib_create_qp(), and ib_push().

IB_QKEY_SMI

#define IB_QKEY_SMI   0

Subnet management interface queue key.

Definition at line 25 of file infiniband.h.

Referenced by ib_create_mi().

IB_QPN_GSI

#define IB_QPN_GSI   1

General service interface QPN.

Definition at line 28 of file infiniband.h.

Referenced by ib_cm_path_complete(), ib_create_madx(), ib_create_qp(), and xsigo_xds_complete().

IB_QKEY_GSI

#define IB_QKEY_GSI   0x80010000UL

General service interface queue key.

Definition at line 31 of file infiniband.h.

Referenced by ib_cm_path_complete(), ib_create_madx(), ib_create_mi(), and xsigo_xds_complete().

IB_QPN_BROADCAST

#define IB_QPN_BROADCAST   0xffffffUL

Broadcast QPN.

Definition at line 34 of file infiniband.h.

Referenced by ipoib_link_state_changed(), and xve_create().

IB_QPN_MASK

#define IB_QPN_MASK   0xffffffUL

QPN mask.

Definition at line 37 of file infiniband.h.

Referenced by ipoib_transmit().

IB_PKEY_DEFAULT

#define IB_PKEY_DEFAULT   0xffff

Default Infiniband partition key.

Definition at line 40 of file infiniband.h.

Referenced by alloc_ibdev(), and ib_srp_parse_pkey().

IB_PKEY_FULL

#define IB_PKEY_FULL   0x8000

Infiniband partition key full membership flag.

Definition at line 43 of file infiniband.h.

Referenced by eoib_link_state_changed(), ib_mcast_mad(), and ipoib_link_state_changed().

IB_MAX_PAYLOAD_SIZE

#define IB_MAX_PAYLOAD_SIZE   2048

Maximum payload size.

This is currently hard-coded in various places (drivers, subnet management agent, etc.) to 2048.

Definition at line 51 of file infiniband.h.

Referenced by alloc_ipoibdev(), ib_cmrc_xfer_window(), ib_post_recv(), ib_refill_recv(), and xve_update_mtu().

IBDEV_NAME_LEN

#define IBDEV_NAME_LEN   8

Maximum length of an Infiniband device name.

Definition at line 396 of file infiniband.h.

IB_DRIVERS

#define IB_DRIVERS   __table ( struct ib_driver, "ib_drivers" )

Infiniband driver table.

Definition at line 494 of file infiniband.h.

Referenced by ib_notify(), register_ibdev(), and unregister_ibdev().

__ib_driver

#define __ib_driver   __table_entry ( IB_DRIVERS, 01 )

Declare an Infiniband driver.

Definition at line 497 of file infiniband.h.

for_each_ibdev

#define for_each_ibdev

(

ibdev

)

Value:

        list_for_each_entry ( (ibdev), &ib_devices, list )

Iterate over all network devices.

Definition at line 556 of file infiniband.h.

#define for_each_ibdev( ibdev ) \
        list_for_each_entry ( (ibdev), &ib_devices, list )

Referenced by find_ibdev(), and ibstat_exec().

Enumeration Type Documentation

ib_rate

enum ib_rate

Infiniband transmission rates.

Enumerator
IB_RATE_2_5
IB_RATE_10
IB_RATE_30
IB_RATE_5
IB_RATE_20
IB_RATE_40
IB_RATE_60
IB_RATE_80
IB_RATE_120

Definition at line 60 of file infiniband.h.

             {
        IB_RATE_2_5 = 2,
        IB_RATE_10 = 3,
        IB_RATE_30 = 4,
        IB_RATE_5 = 5,
        IB_RATE_20 = 6,
        IB_RATE_40 = 7,
        IB_RATE_60 = 8,
        IB_RATE_80 = 9,
        IB_RATE_120 = 10,
};

ib_queue_pair_type

enum ib_queue_pair_type

An Infiniband queue pair type.

Enumerator
IB_QPT_SMI
IB_QPT_GSI
IB_QPT_UD
IB_QPT_RC
IB_QPT_ETH

Definition at line 139 of file infiniband.h.

                        {
        IB_QPT_SMI,
        IB_QPT_GSI,
        IB_QPT_UD,
        IB_QPT_RC,
        IB_QPT_ETH,
};

Function Documentation

FILE_LICENCE()

FILE_LICENCE

(

GPL2_OR_LATER_OR_UBDL

)

FILE_SECBOOT()

FILE_SECBOOT

(

PERMITTED

)

ib_create_cq()

int ib_create_cq ( struct ib_device * ibdev, unsigned int num_cqes, struct ib_completion_queue_operations * op, struct ib_completion_queue ** new_cq )

extern

Create completion queue.

Parameters

ibdev	Infiniband device
num_cqes	Number of completion queue entries
op	Completion queue operations
new_cq	New completion queue to fill in

Return values

rc	Return status code

Definition at line 98 of file infiniband.c.

                                                         {
        struct ib_completion_queue *cq;
        int rc;
 
        DBGC ( ibdev, "IBDEV %s creating completion queue\n", ibdev->name );
 
        /* Allocate and initialise data structure */
        cq = zalloc ( sizeof ( *cq ) );
        if ( ! cq ) {
                rc = -ENOMEM;
                goto err_alloc_cq;
        }
        cq->ibdev = ibdev;
        list_add_tail ( &cq->list, &ibdev->cqs );
        cq->num_cqes = num_cqes;
        INIT_LIST_HEAD ( &cq->work_queues );
        cq->op = op;
 
        /* Perform device-specific initialisation and get CQN */
        if ( ( rc = ibdev->op->create_cq ( ibdev, cq ) ) != 0 ) {
                DBGC ( ibdev, "IBDEV %s could not initialise completion "
                       "queue: %s\n", ibdev->name, strerror ( rc ) );
                goto err_dev_create_cq;
        }
 
        DBGC ( ibdev, "IBDEV %s created %d-entry completion queue %p (%p) "
               "with CQN %#lx\n", ibdev->name, num_cqes, cq,
               ib_cq_get_drvdata ( cq ), cq->cqn );
        *new_cq = cq;
        return 0;
 
        ibdev->op->destroy_cq ( ibdev, cq );
 err_dev_create_cq:
        list_del ( &cq->list );
        free ( cq );
 err_alloc_cq:
        return rc;
}

References ib_completion_queue::cqn, ib_device::cqs, ib_device_operations::create_cq, DBGC, ib_device_operations::destroy_cq, ENOMEM, free, ib_cq_get_drvdata(), ib_completion_queue::ibdev, INIT_LIST_HEAD, ib_completion_queue::list, list_add_tail, list_del, ib_device::name, ib_completion_queue::num_cqes, ib_completion_queue::op, ib_device::op, op, rc, strerror(), ib_completion_queue::work_queues, and zalloc().

Referenced by eoib_open(), flexboot_nodnic_eth_open(), hermon_eth_open(), ib_cmrc_open(), ib_create_mi(), and ipoib_open().

ib_destroy_cq()

void ib_destroy_cq ( struct ib_device * ibdev, struct ib_completion_queue * cq )

extern

Destroy completion queue.

Parameters

ibdev	Infiniband device
cq	Completion queue

Definition at line 145 of file infiniband.c.

                                                      {
        DBGC ( ibdev, "IBDEV %s destroying completion queue %#lx\n",
               ibdev->name, cq->cqn );
        assert ( list_empty ( &cq->work_queues ) );
        ibdev->op->destroy_cq ( ibdev, cq );
        list_del ( &cq->list );
        free ( cq );
}

References assert, ib_completion_queue::cqn, DBGC, ib_device_operations::destroy_cq, free, ib_completion_queue::ibdev, ib_completion_queue::list, list_del, list_empty, ib_device::name, ib_device::op, and ib_completion_queue::work_queues.

Referenced by eoib_close(), eoib_open(), flexboot_nodnic_eth_close(), hermon_eth_close(), hermon_eth_open(), ib_cmrc_open(), ib_cmrc_shutdown(), ib_create_mi(), ib_destroy_mi(), ipoib_close(), and ipoib_open().

ib_poll_cq()

void ib_poll_cq ( struct ib_device * ibdev, struct ib_completion_queue * cq )

extern

Poll completion queue.

Parameters

ibdev	Infiniband device
cq	Completion queue

Definition at line 161 of file infiniband.c.

                                                   {
        struct ib_work_queue *wq;
 
        /* Poll completion queue */
        ibdev->op->poll_cq ( ibdev, cq );
 
        /* Refill receive work queues */
        list_for_each_entry ( wq, &cq->work_queues, list ) {
                if ( ! wq->is_send )
                        ib_refill_recv ( ibdev, wq->qp );
        }
}

References ib_work_queue::cq, ib_refill_recv(), ib_work_queue::is_send, ib_work_queue::list, list_for_each_entry, ib_device::op, ib_device_operations::poll_cq, ib_work_queue::qp, and ib_completion_queue::work_queues.

Referenced by flexboot_nodnic_complete_all_tx(), golan_cq_clean(), and ib_poll_eq().

ib_create_qp()

int ib_create_qp ( struct ib_device * ibdev, enum ib_queue_pair_type type, unsigned int num_send_wqes, struct ib_completion_queue * send_cq, unsigned int num_recv_wqes, struct ib_completion_queue * recv_cq, struct ib_queue_pair_operations * op, const char * name, struct ib_queue_pair ** new_qp )

extern

Create queue pair.

Parameters

ibdev	Infiniband device
type	Queue pair type
num_send_wqes	Number of send work queue entries
send_cq	Send completion queue
num_recv_wqes	Number of receive work queue entries
recv_cq	Receive completion queue
op	Queue pair operations
name	Queue pair name
new_qp	New queue pair to fill in

Return values

rc	Return status code

The queue pair will be left in the INIT state; you must call ib_modify_qp() before it is ready to use for sending and receiving.

Definition at line 199 of file infiniband.c.

                                                   {
        struct ib_queue_pair *qp;
        size_t total_size;
        int rc;
 
        DBGC ( ibdev, "IBDEV %s creating queue pair\n", ibdev->name );
 
        /* Allocate and initialise data structure */
        total_size = ( sizeof ( *qp ) +
                       ( num_send_wqes * sizeof ( qp->send.iobufs[0] ) ) +
                       ( num_recv_wqes * sizeof ( qp->recv.iobufs[0] ) ) );
        qp = zalloc ( total_size );
        if ( ! qp ) {
                rc = -ENOMEM;
                goto err_alloc_qp;
        }
        qp->ibdev = ibdev;
        list_add_tail ( &qp->list, &ibdev->qps );
        qp->type = type;
        qp->send.qp = qp;
        qp->send.is_send = 1;
        qp->send.cq = send_cq;
        list_add_tail ( &qp->send.list, &send_cq->work_queues );
        qp->send.psn = ( random() & 0xffffffUL );
        qp->send.num_wqes = num_send_wqes;
        qp->send.iobufs = ( ( ( void * ) qp ) + sizeof ( *qp ) );
        qp->recv.qp = qp;
        qp->recv.cq = recv_cq;
        list_add_tail ( &qp->recv.list, &recv_cq->work_queues );
        qp->recv.psn = ( random() & 0xffffffUL );
        qp->recv.num_wqes = num_recv_wqes;
        qp->recv.iobufs = ( ( ( void * ) qp ) + sizeof ( *qp ) +
                            ( num_send_wqes * sizeof ( qp->send.iobufs[0] ) ));
        INIT_LIST_HEAD ( &qp->mgids );
        qp->op = op;
        qp->name = name;
 
        /* Perform device-specific initialisation and get QPN */
        if ( ( rc = ibdev->op->create_qp ( ibdev, qp ) ) != 0 ) {
                DBGC ( ibdev, "IBDEV %s could not initialise queue pair: "
                       "%s\n", ibdev->name, strerror ( rc ) );
                goto err_dev_create_qp;
        }
        DBGC ( ibdev, "IBDEV %s created queue pair %p (%p) with QPN %#lx\n",
               ibdev->name, qp, ib_qp_get_drvdata ( qp ), qp->qpn );
        DBGC ( ibdev, "IBDEV %s QPN %#lx has %d send entries at [%p,%p)\n",
               ibdev->name, qp->qpn, num_send_wqes, qp->send.iobufs,
               qp->recv.iobufs );
        DBGC ( ibdev, "IBDEV %s QPN %#lx has %d receive entries at [%p,%p)\n",
               ibdev->name, qp->qpn, num_recv_wqes, qp->recv.iobufs,
               ( ( ( void * ) qp ) + total_size ) );
 
        /* Calculate externally-visible QPN */
        switch ( type ) {
        case IB_QPT_SMI:
                qp->ext_qpn = IB_QPN_SMI;
                break;
        case IB_QPT_GSI:
                qp->ext_qpn = IB_QPN_GSI;
                break;
        default:
                qp->ext_qpn = qp->qpn;
                break;
        }
        if ( qp->ext_qpn != qp->qpn ) {
                DBGC ( ibdev, "IBDEV %s QPN %#lx has external QPN %#lx\n",
                       ibdev->name, qp->qpn, qp->ext_qpn );
        }
 
        *new_qp = qp;
        return 0;
 
        ibdev->op->destroy_qp ( ibdev, qp );
 err_dev_create_qp:
        list_del ( &qp->send.list );
        list_del ( &qp->recv.list );
        list_del ( &qp->list );
        free ( qp );
 err_alloc_qp:
        return rc;
}

References ib_device_operations::create_qp, DBGC, ib_device_operations::destroy_qp, ENOMEM, free, ib_qp_get_drvdata(), IB_QPN_GSI, IB_QPN_SMI, IB_QPT_GSI, IB_QPT_SMI, ib_queue_pair::ibdev, INIT_LIST_HEAD, list_add_tail, list_del, ib_device::name, name, ib_device::op, op, qp, ib_device::qps, random(), rc, strerror(), type, ib_completion_queue::work_queues, and zalloc().

Referenced by eoib_open(), flexboot_nodnic_eth_open(), hermon_eth_open(), ib_cmrc_open(), ib_create_mi(), and ipoib_open().

ib_modify_qp()

int ib_modify_qp ( struct ib_device * ibdev, struct ib_queue_pair * qp )

extern

Modify queue pair.

Parameters

ibdev	Infiniband device
qp	Queue pair

Return values

rc	Return status code

Definition at line 294 of file infiniband.c.

                                                                       {
        int rc;
 
        DBGC ( ibdev, "IBDEV %s modifying QPN %#lx\n", ibdev->name, qp->qpn );
 
        if ( ( rc = ibdev->op->modify_qp ( ibdev, qp ) ) != 0 ) {
                DBGC ( ibdev, "IBDEV %s could not modify QPN %#lx: %s\n",
                       ibdev->name, qp->qpn, strerror ( rc ) );
                return rc;
        }
 
        return 0;
}

References DBGC, ib_queue_pair::ibdev, ib_device_operations::modify_qp, ib_device::name, ib_device::op, qp, rc, and strerror().

Referenced by hermon_eth_open(), ib_cm_req_complete(), ib_create_mi(), and ib_mcast_complete().

ib_destroy_qp()

void ib_destroy_qp ( struct ib_device * ibdev, struct ib_queue_pair * qp )

extern

Destroy queue pair.

Parameters

ibdev	Infiniband device
qp	Queue pair

Definition at line 314 of file infiniband.c.

                                                                         {
        struct io_buffer *iobuf;
        unsigned int i;
 
        DBGC ( ibdev, "IBDEV %s destroying QPN %#lx\n",
               ibdev->name, qp->qpn );
 
        assert ( list_empty ( &qp->mgids ) );
 
        /* Perform device-specific destruction */
        ibdev->op->destroy_qp ( ibdev, qp );
 
        /* Complete any remaining I/O buffers with errors */
        for ( i = 0 ; i < qp->send.num_wqes ; i++ ) {
                if ( ( iobuf = qp->send.iobufs[i] ) != NULL )
                        ib_complete_send ( ibdev, qp, iobuf, -ECANCELED );
        }
        for ( i = 0 ; i < qp->recv.num_wqes ; i++ ) {
                if ( ( iobuf = qp->recv.iobufs[i] ) != NULL ) {
                        ib_complete_recv ( ibdev, qp, NULL, NULL, iobuf,
                                           -ECANCELED );
                }
        }
 
        /* Remove work queues from completion queue */
        list_del ( &qp->send.list );
        list_del ( &qp->recv.list );
 
        /* Free QP */
        list_del ( &qp->list );
        free ( qp );
}

References assert, DBGC, ib_device_operations::destroy_qp, ECANCELED, free, ib_complete_recv(), ib_complete_send(), list_del, list_empty, ib_device::name, NULL, ib_device::op, and qp.

Referenced by eoib_close(), eoib_open(), flexboot_nodnic_eth_close(), flexboot_nodnic_eth_open(), hermon_eth_close(), hermon_eth_open(), ib_cmrc_open(), ib_cmrc_shutdown(), ib_create_mi(), ib_destroy_mi(), ipoib_close(), and ipoib_open().

ib_find_qp_qpn()

struct ib_queue_pair * ib_find_qp_qpn ( struct ib_device * ibdev, unsigned long qpn )

extern

Find queue pair by QPN.

Parameters

ibdev	Infiniband device
qpn	Queue pair number

Return values

qp	Queue pair, or NULL

Definition at line 354 of file infiniband.c.

                                                            {
        struct ib_queue_pair *qp;
 
        list_for_each_entry ( qp, &ibdev->qps, list ) {
                if ( ( qpn == qp->qpn ) || ( qpn == qp->ext_qpn ) )
                        return qp;
        }
        return NULL;
}

References ib_queue_pair::ibdev, ib_queue_pair::list, list_for_each_entry, NULL, qp, qpn, and ib_device::qps.

Referenced by ib_pull().

ib_find_qp_mgid()

struct ib_queue_pair * ib_find_qp_mgid ( struct ib_device * ibdev, union ib_gid * gid )

extern

Find queue pair by multicast GID.

Parameters

ibdev	Infiniband device
gid	Multicast GID

Return values

qp	Queue pair, or NULL

Definition at line 372 of file infiniband.c.

                                                             {
        struct ib_queue_pair *qp;
        struct ib_multicast_gid *mgid;
 
        list_for_each_entry ( qp, &ibdev->qps, list ) {
                list_for_each_entry ( mgid, &qp->mgids, list ) {
                        if ( memcmp ( &mgid->gid, gid,
                                      sizeof ( mgid->gid ) ) == 0 ) {
                                return qp;
                        }
                }
        }
        return NULL;
}

References gid, ib_multicast_gid::list, list_for_each_entry, memcmp(), mgid, NULL, qp, and ib_device::qps.

Referenced by ib_pull().

ib_find_wq()

struct ib_work_queue * ib_find_wq ( struct ib_completion_queue * cq, unsigned long qpn, int is_send )

extern

Find work queue belonging to completion queue.

Parameters

cq	Completion queue
qpn	Queue pair number
is_send	Find send work queue (rather than receive)

Return values

wq	Work queue, or NULL if not found

Definition at line 396 of file infiniband.c.

                                                                     {
        struct ib_work_queue *wq;
 
        list_for_each_entry ( wq, &cq->work_queues, list ) {
                if ( ( wq->qp->qpn == qpn ) && ( wq->is_send == is_send ) )
                        return wq;
        }
        return NULL;
}

References ib_work_queue::cq, ib_work_queue::is_send, ib_work_queue::list, list_for_each_entry, NULL, ib_work_queue::qp, ib_queue_pair::qpn, qpn, and ib_completion_queue::work_queues.

Referenced by arbel_complete(), golan_complete(), and hermon_complete().

ib_post_send()

int ib_post_send ( struct ib_device * ibdev, struct ib_queue_pair * qp, struct ib_address_vector * dest, struct io_buffer * iobuf )

extern

Post send work queue entry.

Parameters

ibdev	Infiniband device
qp	Queue pair
dest	Destination address vector
iobuf	I/O buffer

Return values

rc	Return status code

Definition at line 416 of file infiniband.c.

                                             {
        struct ib_address_vector dest_copy;
        int rc;
 
        /* Start profiling */
        profile_start ( &ib_post_send_profiler );
 
        /* Check queue fill level */
        if ( qp->send.fill >= qp->send.num_wqes ) {
                DBGC ( ibdev, "IBDEV %s QPN %#lx send queue full\n",
                       ibdev->name, qp->qpn );
                return -ENOBUFS;
        }
 
        /* Use default address vector if none specified */
        if ( ! dest )
                dest = &qp->av;
 
        /* Make modifiable copy of address vector */
        memcpy ( &dest_copy, dest, sizeof ( dest_copy ) );
        dest = &dest_copy;
 
        /* Fill in optional parameters in address vector */
        if ( ! dest->qkey )
                dest->qkey = qp->qkey;
        if ( ! dest->rate )
                dest->rate = IB_RATE_2_5;
 
        /* Post to hardware */
        if ( ( rc = ibdev->op->post_send ( ibdev, qp, dest, iobuf ) ) != 0 ) {
                DBGC ( ibdev, "IBDEV %s QPN %#lx could not post send WQE: "
                       "%s\n", ibdev->name, qp->qpn, strerror ( rc ) );
                return rc;
        }
 
        /* Increase fill level */
        qp->send.fill++;
 
        /* Stop profiling */
        profile_stop ( &ib_post_send_profiler );
 
        return 0;
}

References DBGC, dest, ENOBUFS, IB_RATE_2_5, memcpy(), ib_device::name, ib_device::op, ib_device_operations::post_send, profile_start(), profile_stop(), qp, rc, and strerror().

Referenced by eoib_duplicate(), eoib_transmit(), flexboot_nodnic_eth_transmit(), hermon_eth_transmit(), ib_cmrc_xfer_deliver(), ib_mi_send(), and ipoib_transmit().

ib_post_recv()

int ib_post_recv ( struct ib_device * ibdev, struct ib_queue_pair * qp, struct io_buffer * iobuf )

extern

Post receive work queue entry.

Parameters

ibdev	Infiniband device
qp	Queue pair
iobuf	I/O buffer

Return values

rc	Return status code

Definition at line 470 of file infiniband.c.

                                             {
        int rc;
 
        /* Start profiling */
        profile_start ( &ib_post_recv_profiler );
 
        /* Check packet length */
        if ( iob_tailroom ( iobuf ) < IB_MAX_PAYLOAD_SIZE ) {
                DBGC ( ibdev, "IBDEV %s QPN %#lx wrong RX buffer size (%zd)\n",
                       ibdev->name, qp->qpn, iob_tailroom ( iobuf ) );
                return -EINVAL;
        }
 
        /* Check queue fill level */
        if ( qp->recv.fill >= qp->recv.num_wqes ) {
                DBGC ( ibdev, "IBDEV %s QPN %#lx receive queue full\n",
                       ibdev->name, qp->qpn );
                return -ENOBUFS;
        }
 
        /* Post to hardware */
        if ( ( rc = ibdev->op->post_recv ( ibdev, qp, iobuf ) ) != 0 ) {
                DBGC ( ibdev, "IBDEV %s QPN %#lx could not post receive WQE: "
                       "%s\n", ibdev->name, qp->qpn, strerror ( rc ) );
                return rc;
        }
 
        /* Increase fill level */
        qp->recv.fill++;
 
        /* Stop profiling */
        profile_stop ( &ib_post_recv_profiler );
 
        return 0;
}

References DBGC, EINVAL, ENOBUFS, IB_MAX_PAYLOAD_SIZE, iob_tailroom(), ib_device::name, ib_device::op, ib_device_operations::post_recv, profile_start(), profile_stop(), qp, rc, and strerror().

Referenced by ib_refill_recv().

ib_complete_send()

void ib_complete_send ( struct ib_device * ibdev, struct ib_queue_pair * qp, struct io_buffer * iobuf, int rc )

extern

Complete send work queue entry.

Parameters

ibdev	Infiniband device
qp	Queue pair
iobuf	I/O buffer
rc	Completion status code

Definition at line 515 of file infiniband.c.

                                                          {
 
        if ( qp->send.cq->op->complete_send ) {
                qp->send.cq->op->complete_send ( ibdev, qp, iobuf, rc );
        } else {
                free_iob ( iobuf );
        }
        qp->send.fill--;
}

References free_iob(), qp, and rc.

Referenced by arbel_complete(), flexboot_nodnic_complete(), golan_complete(), hermon_complete(), ib_destroy_qp(), linda_complete_send(), and qib7322_complete_send().

ib_complete_recv()

void ib_complete_recv ( struct ib_device * ibdev, struct ib_queue_pair * qp, struct ib_address_vector * dest, struct ib_address_vector * source, struct io_buffer * iobuf, int rc )

extern

Complete receive work queue entry.

Parameters

ibdev	Infiniband device
qp	Queue pair
dest	Destination address vector, or NULL
source	Source address vector, or NULL
iobuf	I/O buffer
rc	Completion status code

Definition at line 536 of file infiniband.c.

                                                          {
 
        if ( qp->recv.cq->op->complete_recv ) {
                qp->recv.cq->op->complete_recv ( ibdev, qp, dest, source,
                                                 iobuf, rc );
        } else {
                free_iob ( iobuf );
        }
        qp->recv.fill--;
}

References dest, free_iob(), qp, and rc.

Referenced by arbel_complete(), flexboot_nodnic_complete(), golan_complete(), hermon_complete(), ib_destroy_qp(), linda_complete_recv(), and qib7322_complete_recv().

ib_refill_recv()

void ib_refill_recv ( struct ib_device * ibdev, struct ib_queue_pair * qp )

extern

Refill receive work queue.

Parameters

ibdev	Infiniband device
qp	Queue pair

Definition at line 556 of file infiniband.c.

                                                                          {
        struct io_buffer *iobuf;
        int rc;
 
        /* Keep filling while unfilled entries remain */
        while ( qp->recv.fill < qp->recv.num_wqes ) {
 
                /* Allocate I/O buffer */
                iobuf = qp->op->alloc_iob ( IB_MAX_PAYLOAD_SIZE );
                if ( ! iobuf ) {
                        /* Non-fatal; we will refill on next attempt */
                        return;
                }
 
                /* Post I/O buffer */
                if ( ( rc = ib_post_recv ( ibdev, qp, iobuf ) ) != 0 ) {
                        DBGC ( ibdev, "IBDEV %s could not refill: %s\n",
                               ibdev->name, strerror ( rc ) );
                        free_iob ( iobuf );
                        /* Give up */
                        return;
                }
        }
}

References DBGC, free_iob(), IB_MAX_PAYLOAD_SIZE, ib_post_recv(), ib_device::name, qp, rc, and strerror().

Referenced by eoib_open(), flexboot_nodnic_eth_open(), hermon_eth_open(), ib_create_mi(), ib_poll_cq(), and ipoib_open().

ib_open()

int ib_open ( struct ib_device * ibdev )

extern

Open port.

Parameters

ibdev

Infiniband device

Return values

rc	Return status code

Definition at line 652 of file infiniband.c.

                                        {
        int rc;
 
        /* Increment device open request counter */
        if ( ibdev->open_count++ > 0 ) {
                /* Device was already open; do nothing */
                return 0;
        }
 
        /* Open device */
        if ( ( rc = ibdev->op->open ( ibdev ) ) != 0 ) {
                DBGC ( ibdev, "IBDEV %s could not open: %s\n",
                       ibdev->name, strerror ( rc ) );
                goto err_open;
        }
 
        /* Create subnet management interface */
        if ( ( rc = ib_create_mi ( ibdev, IB_QPT_SMI, &ibdev->smi ) ) != 0 ) {
                DBGC ( ibdev, "IBDEV %s could not create SMI: %s\n",
                       ibdev->name, strerror ( rc ) );
                goto err_create_smi;
        }
 
        /* Create subnet management agent */
        if ( ( rc = ib_create_sma ( ibdev, ibdev->smi ) ) != 0 ) {
                DBGC ( ibdev, "IBDEV %s could not create SMA: %s\n",
                       ibdev->name, strerror ( rc ) );
                goto err_create_sma;
        }
 
        /* Create general services interface */
        if ( ( rc = ib_create_mi ( ibdev, IB_QPT_GSI, &ibdev->gsi ) ) != 0 ) {
                DBGC ( ibdev, "IBDEV %s could not create GSI: %s\n",
                       ibdev->name, strerror ( rc ) );
                goto err_create_gsi;
        }
 
        /* Add to head of open devices list */
        list_add ( &ibdev->open_list, &open_ib_devices );
 
        /* Notify drivers of device state change */
        ib_notify ( ibdev );
 
        assert ( ibdev->open_count == 1 );
        return 0;
 
        ib_destroy_mi ( ibdev, ibdev->gsi );
 err_create_gsi:
        ib_destroy_sma ( ibdev, ibdev->smi );
 err_create_sma:
        ib_destroy_mi ( ibdev, ibdev->smi );
 err_create_smi:
        ibdev->op->close ( ibdev );
 err_open:
        assert ( ibdev->open_count == 1 );
        ibdev->open_count = 0;
        return rc;
}

References assert, ib_device_operations::close, DBGC, ib_device::gsi, ib_create_mi(), ib_create_sma(), ib_destroy_mi(), ib_destroy_sma(), ib_notify(), IB_QPT_GSI, IB_QPT_SMI, list_add, ib_device::name, ib_device::op, ib_device_operations::open, ib_device::open_count, open_ib_devices, ib_device::open_list, rc, ib_device::smi, and strerror().

Referenced by eoib_open(), ib_cmrc_open(), ipoib_open(), and xsigo_ib_open().

ib_close()

void ib_close ( struct ib_device * ibdev )

extern

Close port.

Parameters

ibdev

Infiniband device

Definition at line 716 of file infiniband.c.

                                          {
 
        /* Decrement device open request counter */
        ibdev->open_count--;
 
        /* Close device if this was the last remaining requested opening */
        if ( ibdev->open_count == 0 ) {
                ib_notify ( ibdev );
                list_del ( &ibdev->open_list );
                ib_destroy_mi ( ibdev, ibdev->gsi );
                ib_destroy_sma ( ibdev, ibdev->smi );
                ib_destroy_mi ( ibdev, ibdev->smi );
                ibdev->op->close ( ibdev );
                ibdev->port_state = IB_PORT_STATE_DOWN;
        }
}

References ib_device_operations::close, ib_device::gsi, ib_destroy_mi(), ib_destroy_sma(), ib_notify(), IB_PORT_STATE_DOWN, list_del, ib_device::op, ib_device::open_count, ib_device::open_list, ib_device::port_state, and ib_device::smi.

Referenced by eoib_close(), eoib_open(), ib_cmrc_open(), ib_cmrc_shutdown(), ipoib_close(), ipoib_open(), and xsigo_ib_remove().

ib_link_rc()

int ib_link_rc ( struct ib_device * ibdev )

extern

Get link state.

Parameters

ibdev

Infiniband device

Return values

rc	Link status code

Definition at line 594 of file infiniband.c.

                                           {
        switch ( ibdev->port_state ) {
        case IB_PORT_STATE_DOWN:      return -ENOTCONN;
        case IB_PORT_STATE_INIT:      return -EINPROGRESS_INIT;
        case IB_PORT_STATE_ARMED:    return -EINPROGRESS_ARMED;
        case IB_PORT_STATE_ACTIVE:  return 0;
        default:                        return -EINVAL;
        }
}

References EINPROGRESS_ARMED, EINPROGRESS_INIT, EINVAL, ENOTCONN, IB_PORT_STATE_ACTIVE, IB_PORT_STATE_ARMED, IB_PORT_STATE_DOWN, IB_PORT_STATE_INIT, and ib_device::port_state.

Referenced by eoib_link_state_changed(), and ipoib_link_state_changed().

ib_mcast_attach()

int ib_mcast_attach ( struct ib_device * ibdev, struct ib_queue_pair * qp, union ib_gid * gid )

extern

Attach to multicast group.

Parameters

ibdev	Infiniband device
qp	Queue pair
gid	Multicast GID

Return values

rc	Return status code

Note that this function handles only the local device's attachment to the multicast GID; it does not issue the relevant MADs to join the multicast group on the subnet.

Definition at line 752 of file infiniband.c.

                                          {
        struct ib_multicast_gid *mgid;
        int rc;
 
        /* Sanity check */
        assert ( qp != NULL );
 
        /* Add to software multicast GID list */
        mgid = zalloc ( sizeof ( *mgid ) );
        if ( ! mgid ) {
                rc = -ENOMEM;
                goto err_alloc_mgid;
        }
        memcpy ( &mgid->gid, gid, sizeof ( mgid->gid ) );
        list_add_tail ( &mgid->list, &qp->mgids );
 
        /* Add to hardware multicast GID list */
        if ( ( rc = ibdev->op->mcast_attach ( ibdev, qp, gid ) ) != 0 )
                goto err_dev_mcast_attach;
 
        return 0;
 
 err_dev_mcast_attach:
        list_del ( &mgid->list );
        free ( mgid );
 err_alloc_mgid:
        return rc;
}

References assert, ENOMEM, free, gid, list_add_tail, list_del, ib_device_operations::mcast_attach, memcpy(), mgid, NULL, ib_device::op, qp, rc, and zalloc().

Referenced by ib_mcast_join().

ib_mcast_detach()

void ib_mcast_detach ( struct ib_device * ibdev, struct ib_queue_pair * qp, union ib_gid * gid )

extern

Detach from multicast group.

Parameters

ibdev	Infiniband device
qp	Queue pair
gid	Multicast GID

Definition at line 789 of file infiniband.c.

                                           {
        struct ib_multicast_gid *mgid;
 
        /* Sanity check */
        assert ( qp != NULL );
 
        /* Remove from hardware multicast GID list */
        ibdev->op->mcast_detach ( ibdev, qp, gid );
 
        /* Remove from software multicast GID list */
        list_for_each_entry ( mgid, &qp->mgids, list ) {
                if ( memcmp ( &mgid->gid, gid, sizeof ( mgid->gid ) ) == 0 ) {
                        list_del ( &mgid->list );
                        free ( mgid );
                        break;
                }
        }
}

References assert, free, gid, ib_multicast_gid::list, list_del, list_for_each_entry, ib_device_operations::mcast_detach, memcmp(), mgid, NULL, ib_device::op, and qp.

Referenced by ib_mcast_join(), and ib_mcast_leave().

ib_set_port_info()

int ib_set_port_info ( struct ib_device * ibdev, union ib_mad * mad )

extern

Set port information.

Parameters

ibdev	Infiniband device
mad	Set port information MAD

Definition at line 822 of file infiniband.c.

                                                                    {
        int rc;
 
        /* Adapters with embedded SMAs do not need to support this method */
        if ( ! ibdev->op->set_port_info ) {
                DBGC ( ibdev, "IBDEV %s does not support setting port "
                       "information\n", ibdev->name );
                return -ENOTSUP;
        }
 
        if ( ( rc = ibdev->op->set_port_info ( ibdev, mad ) ) != 0 ) {
                DBGC ( ibdev, "IBDEV %s could not set port information: %s\n",
                       ibdev->name, strerror ( rc ) );
                return rc;
        }
 
        return 0;
};

References DBGC, ENOTSUP, mad, ib_device::name, ib_device::op, rc, ib_device_operations::set_port_info, and strerror().

Referenced by ib_sma_set_port_info().

ib_set_pkey_table()

int ib_set_pkey_table ( struct ib_device * ibdev, union ib_mad * mad )

extern

Set partition key table.

Parameters

ibdev	Infiniband device
mad	Set partition key table MAD

Definition at line 847 of file infiniband.c.

                                                                     {
        int rc;
 
        /* Adapters with embedded SMAs do not need to support this method */
        if ( ! ibdev->op->set_pkey_table ) {
                DBGC ( ibdev, "IBDEV %s does not support setting partition "
                       "key table\n", ibdev->name );
                return -ENOTSUP;
        }
 
        if ( ( rc = ibdev->op->set_pkey_table ( ibdev, mad ) ) != 0 ) {
                DBGC ( ibdev, "IBDEV %s could not set partition key table: "
                       "%s\n", ibdev->name, strerror ( rc ) );
                return rc;
        }
 
        return 0;
};

References DBGC, ENOTSUP, mad, ib_device::name, ib_device::op, rc, ib_device_operations::set_pkey_table, and strerror().

Referenced by ib_sma_set_pkey_table().

alloc_ibdev()

struct ib_device * alloc_ibdev ( size_t priv_size )

extern

Allocate Infiniband device.

Parameters

priv_size

Size of driver private data area

Return values

ibdev

Infiniband device, or NULL

Definition at line 917 of file infiniband.c.

                                                    {
        struct ib_device *ibdev;
        void *drv_priv;
        size_t total_len;
 
        total_len = ( sizeof ( *ibdev ) + priv_size );
        ibdev = zalloc ( total_len );
        if ( ibdev ) {
                drv_priv = ( ( ( void * ) ibdev ) + sizeof ( *ibdev ) );
                ib_set_drvdata ( ibdev, drv_priv );
                INIT_LIST_HEAD ( &ibdev->list );
                INIT_LIST_HEAD ( &ibdev->open_list );
                INIT_LIST_HEAD ( &ibdev->cqs );
                INIT_LIST_HEAD ( &ibdev->qps );
                ibdev->port_state = IB_PORT_STATE_DOWN;
                ibdev->lid = IB_LID_NONE;
                ibdev->pkey = IB_PKEY_DEFAULT;
        }
        return ibdev;
}

References ib_device::cqs, ib_device::drv_priv, IB_LID_NONE, IB_PKEY_DEFAULT, IB_PORT_STATE_DOWN, ib_set_drvdata(), INIT_LIST_HEAD, ib_device::lid, ib_device::list, ib_device::open_list, ib_device::pkey, ib_device::port_state, ib_device::qps, and zalloc().

Referenced by arbel_probe(), flexboot_nodnic_allocate_infiniband_devices(), golan_probe_normal(), hermon_probe(), linda_probe(), and qib7322_probe().

register_ibdev()

int register_ibdev ( struct ib_device * ibdev )

extern

Register Infiniband device.

Parameters

ibdev

Infiniband device

Return values

rc	Return status code

Definition at line 944 of file infiniband.c.

                                               {
        struct ib_driver *driver;
        int rc;
 
        /* Record device index and create device name */
        if ( ibdev->name[0] == '\0' ) {
                snprintf ( ibdev->name, sizeof ( ibdev->name ), "inf%d",
                           ibdev_index );
        }
        ibdev->index = ++ibdev_index;
 
        /* Add to device list */
        ibdev_get ( ibdev );
        list_add_tail ( &ibdev->list, &ib_devices );
        DBGC ( ibdev, "IBDEV %s registered (phys %s)\n", ibdev->name,
               ibdev->dev->name );
 
        /* Probe device */
        for_each_table_entry ( driver, IB_DRIVERS ) {
                if ( ( rc = driver->probe ( ibdev ) ) != 0 ) {
                        DBGC ( ibdev, "IBDEV %s could not add %s device: %s\n",
                               ibdev->name, driver->name, strerror ( rc ) );
                        goto err_probe;
                }
        }
 
        return 0;
 
 err_probe:
        for_each_table_entry_continue_reverse ( driver, IB_DRIVERS )
                driver->remove ( ibdev );
        list_del ( &ibdev->list );
        ibdev_put ( ibdev );
        return rc;
}

References DBGC, ib_device::dev, for_each_table_entry, for_each_table_entry_continue_reverse, ib_devices, IB_DRIVERS, ibdev_get(), ibdev_index, ibdev_put(), ib_device::index, ib_device::list, list_add_tail, list_del, device::name, ib_device::name, ib_driver::name, ib_driver::probe, rc, ib_driver::remove, snprintf(), and strerror().

Referenced by arbel_probe(), golan_register_ibdev(), hermon_register_ibdev(), linda_probe(), qib7322_probe(), and REQUIRING_SYMBOL().

unregister_ibdev()

void unregister_ibdev ( struct ib_device * ibdev )

extern

Unregister Infiniband device.

Parameters

ibdev

Infiniband device

Definition at line 985 of file infiniband.c.

                                                  {
        struct ib_driver *driver;
 
        /* Remove device */
        for_each_table_entry_reverse ( driver, IB_DRIVERS )
                driver->remove ( ibdev );
 
        /* Remove from device list */
        list_del ( &ibdev->list );
        ibdev_put ( ibdev );
        DBGC ( ibdev, "IBDEV %s unregistered\n", ibdev->name );
 
        /* Reset device index if no devices remain */
        if ( list_empty ( &ib_devices ) )
                ibdev_index = 0;
}

References DBGC, for_each_table_entry_reverse, ib_devices, IB_DRIVERS, ibdev_index, ibdev_put(), ib_device::list, list_del, list_empty, ib_device::name, and ib_driver::remove.

Referenced by arbel_probe(), arbel_remove(), golan_probe_normal(), golan_remove_normal(), hermon_unregister_ibdev(), linda_probe(), linda_remove(), qib7322_probe(), and qib7322_remove().

find_ibdev()

struct ib_device * find_ibdev ( union ib_gid * gid )

extern

Find Infiniband device by GID.

Parameters

gid

GID

Return values

ibdev

Infiniband device, or NULL

Definition at line 1008 of file infiniband.c.

                                                    {
        struct ib_device *ibdev;
 
        for_each_ibdev ( ibdev ) {
                if ( memcmp ( gid, &ibdev->gid, sizeof ( *gid ) ) == 0 )
                        return ibdev;
        }
        return NULL;
}

References for_each_ibdev, gid, ib_device::gid, memcmp(), and NULL.

Referenced by ib_srp_open_uri().

last_opened_ibdev()

struct ib_device * last_opened_ibdev ( void )

extern

Get most recently opened Infiniband device.

Return values

ibdev

Most recently opened Infiniband device, or NULL

Definition at line 1023 of file infiniband.c.

                                              {
        struct ib_device *ibdev;
 
        ibdev = list_first_entry ( &open_ib_devices, struct ib_device,
                                   open_list );
        if ( ! ibdev )
                return NULL;
 
        assert ( ibdev->open_count != 0 );
        return ibdev;
}

References assert, list_first_entry, NULL, ib_device::open_count, open_ib_devices, and ib_device::open_list.

Referenced by ib_srp_parse_sgid().

ib_link_state_changed()

void ib_link_state_changed ( struct ib_device * ibdev )

extern

Notify of Infiniband link state change.

Parameters

ibdev

Infiniband device

Definition at line 637 of file infiniband.c.

                                                       {
 
        DBGC ( ibdev, "IBDEV %s link state is %s\n",
               ibdev->name, ib_link_state_text ( ibdev ) );
 
        /* Notify drivers of link state change */
        ib_notify ( ibdev );
}

References DBGC, ib_link_state_text(), ib_notify(), and ib_device::name.

Referenced by golan_ib_update(), ib_smc_update(), linda_link_state_changed(), and qib7322_link_state_changed().

ib_poll_eq()

void ib_poll_eq ( struct ib_device * ibdev )

extern

Poll event queue.

Parameters

ibdev

Infiniband device

Definition at line 878 of file infiniband.c.

                                            {
        struct ib_completion_queue *cq;
 
        /* Poll device's event queue */
        ibdev->op->poll_eq ( ibdev );
 
        /* Poll all completion queues */
        list_for_each_entry ( cq, &ibdev->cqs, list )
                ib_poll_cq ( ibdev, cq );
}

References ib_device::cqs, ib_poll_cq(), ib_completion_queue::ibdev, ib_completion_queue::list, list_for_each_entry, ib_device::op, and ib_device_operations::poll_eq.

Referenced by eoib_poll(), flexboot_nodnic_eth_poll(), hermon_eth_poll(), ib_step(), and ipoib_poll().

ib_link_ok()

__always_inline int ib_link_ok ( struct ib_device * ibdev )

inlinestatic

Check link state of Infiniband device.

Parameters

ibdev

Infiniband device

Return values

link_up

Link is up

Definition at line 566 of file infiniband.h.

                                       {
        return ( ibdev->port_state == IB_PORT_STATE_ACTIVE );
}

References IB_PORT_STATE_ACTIVE, and ib_device::port_state.

Referenced by eoib_link_state_changed(), ibstat(), ipoib_link_state_changed(), ipoib_transmit(), xsigo_ib_notify(), and xsigo_ib_open().

ib_is_open()

int ib_is_open ( struct ib_device * ibdev )

inlinestatic

Check whether or not Infiniband device is open.

Parameters

ibdev	Infiniband device
is_open	Infiniband device is open

Definition at line 577 of file infiniband.h.

                                       {
        return ( ibdev->open_count > 0 );
}

References ib_device::open_count.

Referenced by arbel_poll_eq(), eoib_link_state_changed(), golan_handle_port_event(), hermon_poll_eq(), ibstat(), and ipoib_link_state_changed().

ibdev_get()

__always_inline struct ib_device * ibdev_get ( struct ib_device * ibdev )

inlinestatic

Get reference to Infiniband device.

Parameters

ibdev

Infiniband device

Return values

ibdev

Infiniband device

Definition at line 588 of file infiniband.h.

                                      {
        ref_get ( &ibdev->refcnt );
        return ibdev;
}

References ref_get, and ib_device::refcnt.

Referenced by eoib_create(), ib_srp_open(), register_ibdev(), and xsigo_ib_probe().

ibdev_put()

__always_inline void ibdev_put ( struct ib_device * ibdev )

inlinestatic

Drop reference to Infiniband device.

Parameters

ibdev

Infiniband device

Definition at line 599 of file infiniband.h.

                                      {
        ref_put ( &ibdev->refcnt );
}

References ref_put, and ib_device::refcnt.

Referenced by arbel_probe(), arbel_remove(), eoib_create(), eoib_destroy(), flexboot_nodnic_allocate_infiniband_devices(), flexboot_nodnic_ports_unregister_dev(), golan_probe_normal(), golan_remove_normal(), hermon_probe(), hermon_remove(), ib_srp_free(), linda_probe(), linda_remove(), qib7322_probe(), qib7322_remove(), register_ibdev(), unregister_ibdev(), and xsigo_free().

ib_wq_set_drvdata()

__always_inline void ib_wq_set_drvdata ( struct ib_work_queue * wq, void * priv )

inlinestatic

Set Infiniband work queue driver-private data.

Parameters

wq	Work queue
priv	Private data

Definition at line 610 of file infiniband.h.

                                                           {
        wq->drv_priv = priv;
}

References ib_work_queue::drv_priv, and priv.

Referenced by linda_create_qp(), and qib7322_create_qp().

ib_wq_get_drvdata()

__always_inline void * ib_wq_get_drvdata ( struct ib_work_queue * wq )

inlinestatic

Get Infiniband work queue driver-private data.

Parameters

wq	Work queue

Return values

priv	Private data

Definition at line 621 of file infiniband.h.

                                               {
        return wq->drv_priv;
}

References ib_work_queue::drv_priv.

Referenced by linda_complete_recv(), linda_complete_send(), linda_create_recv_wq(), linda_create_send_wq(), linda_destroy_recv_wq(), linda_destroy_send_wq(), linda_poll_recv_wq(), linda_poll_send_wq(), linda_post_recv(), linda_post_send(), qib7322_complete_recv(), qib7322_complete_send(), qib7322_create_recv_wq(), qib7322_create_send_wq(), qib7322_destroy_recv_wq(), qib7322_destroy_send_wq(), qib7322_poll_recv_wq(), qib7322_poll_send_wq(), qib7322_post_recv(), and qib7322_post_send().

ib_qp_set_drvdata()

__always_inline void ib_qp_set_drvdata ( struct ib_queue_pair * qp, void * priv )

inlinestatic

Set Infiniband queue pair driver-private data.

Parameters

qp	Queue pair
priv	Private data

Definition at line 632 of file infiniband.h.

                                                           {
        qp->drv_priv = priv;
}

References priv, and qp.

Referenced by arbel_create_qp(), arbel_destroy_qp(), flexboot_nodnic_create_qp(), golan_create_qp_aux(), golan_destroy_qp(), hermon_create_qp(), and hermon_destroy_qp().

ib_qp_get_drvdata()

__always_inline void * ib_qp_get_drvdata ( struct ib_queue_pair * qp )

inlinestatic

Get Infiniband queue pair driver-private data.

Parameters

qp	Queue pair

Return values

priv	Private data

Definition at line 643 of file infiniband.h.

                                               {
        return qp->drv_priv;
}

References qp.

Referenced by arbel_complete(), arbel_destroy_qp(), arbel_modify_qp(), arbel_post_recv(), arbel_post_send(), flexboot_nodnic_destroy_qp(), flexboot_nodnic_eth_open(), flexboot_nodnic_find_wq(), flexboot_nodnic_post_recv(), flexboot_nodnic_post_send(), golan_complete(), golan_destroy_qp(), golan_modify_qp(), golan_modify_qp_to_rst(), golan_post_recv(), golan_post_send(), hermon_complete(), hermon_destroy_qp(), hermon_dump_qpctx(), hermon_modify_qp(), hermon_post_recv(), hermon_post_send(), ib_create_qp(), and shomron_fill_eth_send_wqe().

ib_qp_set_ownerdata()

__always_inline void ib_qp_set_ownerdata ( struct ib_queue_pair * qp, void * priv )

inlinestatic

Set Infiniband queue pair owner-private data.

Parameters

qp	Queue pair
priv	Private data

Definition at line 654 of file infiniband.h.

                                                             {
        qp->owner_priv = priv;
}

References priv, and qp.

Referenced by eoib_open(), flexboot_nodnic_eth_open(), hermon_eth_open(), ib_cmrc_open(), ib_create_mi(), and ipoib_open().

ib_qp_get_ownerdata()

__always_inline void * ib_qp_get_ownerdata ( struct ib_queue_pair * qp )

inlinestatic

Get Infiniband queue pair owner-private data.

Parameters

qp	Queue pair

Return values

priv	Private data

Definition at line 665 of file infiniband.h.

                                                 {
        return qp->owner_priv;
}

References qp.

Referenced by eoib_complete_recv(), eoib_complete_send(), flexboot_nodnic_eth_complete_recv(), flexboot_nodnic_eth_complete_send(), hermon_eth_complete_recv(), hermon_eth_complete_send(), ib_cmrc_changed(), ib_cmrc_complete_recv(), ib_cmrc_complete_send(), ib_mi_complete_recv(), ipoib_complete_recv(), and ipoib_complete_send().

ib_cq_set_drvdata()

__always_inline void ib_cq_set_drvdata ( struct ib_completion_queue * cq, void * priv )

inlinestatic

Set Infiniband completion queue driver-private data.

Parameters

cq	Completion queue
priv	Private data

Definition at line 676 of file infiniband.h.

                                                                 {
        cq->drv_priv = priv;
}

References ib_completion_queue::drv_priv, and priv.

Referenced by arbel_create_cq(), arbel_destroy_cq(), flexboot_nodnic_create_cq(), golan_create_cq(), golan_destroy_cq(), hermon_create_cq(), and hermon_destroy_cq().

ib_cq_get_drvdata()

__always_inline void * ib_cq_get_drvdata ( struct ib_completion_queue * cq )

inlinestatic

Get Infiniband completion queue driver-private data.

Parameters

cq	Completion queue

Return values

priv	Private data

Definition at line 687 of file infiniband.h.

                                                     {
        return cq->drv_priv;
}

References ib_completion_queue::drv_priv.

Referenced by arbel_destroy_cq(), arbel_poll_cq(), flexboot_nodnic_destroy_cq(), flexboot_nodnic_poll_cq(), golan_destroy_cq(), golan_poll_cq(), hermon_destroy_cq(), hermon_poll_cq(), and ib_create_cq().

ib_set_drvdata()

__always_inline void ib_set_drvdata ( struct ib_device * ibdev, void * priv )

inlinestatic

Set Infiniband device driver-private data.

Parameters

ibdev	Infiniband device
priv	Private data

Definition at line 698 of file infiniband.h.

                                                       {
        ibdev->drv_priv = priv;
}

References ib_device::drv_priv, and priv.

Referenced by alloc_ibdev(), arbel_probe(), flexboot_nodnic_allocate_infiniband_devices(), golan_probe_normal(), hermon_probe(), and qib7322_probe().

ib_get_drvdata()

__always_inline void * ib_get_drvdata ( struct ib_device * ibdev )

inlinestatic

Get Infiniband device driver-private data.

Parameters

ibdev

Infiniband device

Return values

priv	Private data

Definition at line 709 of file infiniband.h.

                                           {
        return ibdev->drv_priv;
}

References ib_device::drv_priv.

Referenced by arbel_alloc_qpn(), arbel_complete(), arbel_create_cq(), arbel_create_qp(), arbel_destroy_cq(), arbel_destroy_qp(), arbel_fill_mlx_send_wqe(), arbel_fill_rc_send_wqe(), arbel_fill_ud_send_wqe(), arbel_free_qpn(), arbel_ib_close(), arbel_ib_open(), arbel_mad(), arbel_mcast_attach(), arbel_mcast_detach(), arbel_modify_qp(), arbel_poll_cq(), arbel_poll_eq(), arbel_post_recv(), arbel_post_send(), flexboot_nodnic_complete(), flexboot_nodnic_create_cq(), flexboot_nodnic_create_qp(), flexboot_nodnic_destroy_cq(), flexboot_nodnic_destroy_qp(), flexboot_nodnic_eth_close(), flexboot_nodnic_eth_open(), flexboot_nodnic_eth_transmit(), flexboot_nodnic_find_wq(), flexboot_nodnic_mcast_attach(), flexboot_nodnic_mcast_detach(), flexboot_nodnic_poll_cq(), flexboot_nodnic_poll_eq(), flexboot_nodnic_post_recv(), flexboot_nodnic_post_send(), golan_complete(), golan_create_cq(), golan_create_qp_aux(), golan_destroy_cq(), golan_destroy_qp(), golan_ib_close(), golan_ib_open(), golan_mcast_attach(), golan_mcast_detach(), golan_modify_qp(), golan_modify_qp_to_rst(), golan_poll_cq(), golan_poll_eq(), golan_post_recv(), golan_post_send(), golan_query_vport_context(), golan_query_vport_gid(), golan_query_vport_pkey(), hermon_alloc_qpn(), hermon_complete(), hermon_create_cq(), hermon_create_qp(), hermon_destroy_cq(), hermon_destroy_qp(), hermon_eth_close(), hermon_eth_open(), hermon_eth_transmit(), hermon_fill_eth_send_wqe(), hermon_fill_mlx_send_wqe(), hermon_fill_rc_send_wqe(), hermon_fill_ud_send_wqe(), hermon_free_qpn(), hermon_ib_close(), hermon_ib_open(), hermon_mad(), hermon_mcast_attach(), hermon_mcast_detach(), hermon_modify_qp(), hermon_poll_cq(), hermon_poll_eq(), hermon_post_recv(), hermon_post_send(), linda_close(), linda_complete_recv(), linda_complete_send(), linda_create_cq(), linda_create_qp(), linda_destroy_cq(), linda_destroy_qp(), linda_link_state_changed(), linda_mcast_attach(), linda_mcast_detach(), linda_modify_qp(), linda_open(), linda_poll_eq(), linda_poll_recv_wq(), linda_poll_send_wq(), linda_post_recv(), linda_post_send(), linda_probe(), linda_remove(), linda_set_port_info(), qib7322_alloc_ctx(), qib7322_close(), qib7322_complete_recv(), qib7322_complete_send(), qib7322_create_cq(), qib7322_create_qp(), qib7322_create_recv_wq(), qib7322_create_send_wq(), qib7322_destroy_cq(), qib7322_destroy_recv_wq(), qib7322_free_ctx(), qib7322_link_state_changed(), qib7322_link_state_check(), qib7322_mcast_attach(), qib7322_mcast_detach(), qib7322_modify_qp(), qib7322_open(), qib7322_poll_eq(), qib7322_poll_recv_wq(), qib7322_poll_send_wq(), qib7322_post_recv(), qib7322_post_send(), qib7322_set_port_info(), shomron_fill_eth_send_wqe(), and shomron_tx_uar_send_db().

Variable Documentation

ib_devices

struct list_head ib_devices

extern

List of Infiniband devices.

Definition at line 52 of file infiniband.c.

Referenced by register_ibdev(), and unregister_ibdev().