iPXE
ib_mi.c
Go to the documentation of this file.
1 /*
2  * Copyright (C) 2009 Michael Brown <mbrown@fensystems.co.uk>.
3  *
4  * This program is free software; you can redistribute it and/or
5  * modify it under the terms of the GNU General Public License as
6  * published by the Free Software Foundation; either version 2 of the
7  * License, or any later version.
8  *
9  * This program is distributed in the hope that it will be useful, but
10  * WITHOUT ANY WARRANTY; without even the implied warranty of
11  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
12  * General Public License for more details.
13  *
14  * You should have received a copy of the GNU General Public License
15  * along with this program; if not, write to the Free Software
16  * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA
17  * 02110-1301, USA.
18  *
19  * You can also choose to distribute this program under the terms of
20  * the Unmodified Binary Distribution Licence (as given in the file
21  * COPYING.UBDL), provided that you have satisfied its requirements.
22  */
23 
24 FILE_LICENCE ( GPL2_OR_LATER_OR_UBDL );
25 
26 #include <stdint.h>
27 #include <stdlib.h>
28 #include <string.h>
29 #include <errno.h>
30 #include <stdio.h>
31 #include <unistd.h>
32 #include <byteswap.h>
33 #include <ipxe/infiniband.h>
34 #include <ipxe/iobuf.h>
35 #include <ipxe/ib_mi.h>
36 
37 /**
38  * @file
39  *
40  * Infiniband management interfaces
41  *
42  */
43 
44 /** Management interface number of send WQEs
45  *
46  * This is a policy decision.
47  */
48 #define IB_MI_NUM_SEND_WQES 4
49 
50 /** Management interface number of receive WQEs
51  *
52  * This is a policy decision.
53  */
54 #define IB_MI_NUM_RECV_WQES 2
55 
56 /** Management interface number of completion queue entries
57  *
58  * This is a policy decision
59  */
60 #define IB_MI_NUM_CQES 8
61 
62 /** TID magic signature */
63 #define IB_MI_TID_MAGIC ( ( 'i' << 24 ) | ( 'P' << 16 ) | ( 'X' << 8 ) | 'E' )
64 
65 /** TID to use for next MAD */
66 static unsigned int next_tid;
67 
68 /**
69  * Handle received MAD
70  *
71  * @v ibdev Infiniband device
72  * @v mi Management interface
73  * @v mad Received MAD
74  * @v av Source address vector
75  * @ret rc Return status code
76  */
77 static int ib_mi_handle ( struct ib_device *ibdev,
78  struct ib_mad_interface *mi,
79  union ib_mad *mad,
80  struct ib_address_vector *av ) {
81  struct ib_mad_hdr *hdr = &mad->hdr;
82  struct ib_mad_transaction *madx;
83  struct ib_mad_agent *agent;
84 
85  /* Look for a matching transaction by TID */
86  list_for_each_entry ( madx, &mi->madx, list ) {
87  if ( memcmp ( &hdr->tid, &madx->mad.hdr.tid,
88  sizeof ( hdr->tid ) ) != 0 )
89  continue;
90  /* Found a matching transaction */
91  madx->op->complete ( ibdev, mi, madx, 0, mad, av );
92  return 0;
93  }
94 
95  /* If there is no matching transaction, look for a listening agent */
97  if ( ( ( agent->mgmt_class & IB_MGMT_CLASS_MASK ) !=
98  ( hdr->mgmt_class & IB_MGMT_CLASS_MASK ) ) ||
99  ( agent->class_version != hdr->class_version ) ||
100  ( agent->attr_id != hdr->attr_id ) )
101  continue;
102  /* Found a matching agent */
103  agent->handle ( ibdev, mi, mad, av );
104  return 0;
105  }
106 
107  /* Otherwise, ignore it */
108  DBGC ( mi, "MI %p RX TID %08x%08x ignored\n",
109  mi, ntohl ( hdr->tid.high ), ntohl ( hdr->tid.low ) );
110  return -ENOTSUP;
111 }
112 
113 /**
114  * Complete receive via management interface
115  *
116  *
117  * @v ibdev Infiniband device
118  * @v qp Queue pair
119  * @v dest Destination address vector
120  * @v source Source address vector
121  * @v iobuf I/O buffer
122  * @v rc Completion status code
123  */
124 static void ib_mi_complete_recv ( struct ib_device *ibdev,
125  struct ib_queue_pair *qp,
127  struct ib_address_vector *source,
128  struct io_buffer *iobuf, int rc ) {
129  struct ib_mad_interface *mi = ib_qp_get_ownerdata ( qp );
130  union ib_mad *mad;
131  struct ib_mad_hdr *hdr;
132 
133  /* Ignore errors */
134  if ( rc != 0 ) {
135  DBGC ( mi, "MI %p RX error: %s\n", mi, strerror ( rc ) );
136  goto out;
137  }
138 
139  /* Sanity checks */
140  if ( iob_len ( iobuf ) != sizeof ( *mad ) ) {
141  DBGC ( mi, "MI %p RX bad size (%zd bytes)\n",
142  mi, iob_len ( iobuf ) );
143  DBGC_HDA ( mi, 0, iobuf->data, iob_len ( iobuf ) );
144  goto out;
145  }
146  mad = iobuf->data;
147  hdr = &mad->hdr;
148  if ( hdr->base_version != IB_MGMT_BASE_VERSION ) {
149  DBGC ( mi, "MI %p RX unsupported base version %x\n",
150  mi, hdr->base_version );
151  DBGC_HDA ( mi, 0, mad, sizeof ( *mad ) );
152  goto out;
153  }
154  DBGC ( mi, "MI %p RX TID %08x%08x (%02x,%02x,%02x,%04x) status "
155  "%04x\n", mi, ntohl ( hdr->tid.high ), ntohl ( hdr->tid.low ),
156  hdr->mgmt_class, hdr->class_version, hdr->method,
157  ntohs ( hdr->attr_id ), ntohs ( hdr->status ) );
158  DBGC2_HDA ( mi, 0, mad, sizeof ( *mad ) );
159 
160  /* Handle MAD */
161  if ( ( rc = ib_mi_handle ( ibdev, mi, mad, source ) ) != 0 )
162  goto out;
163 
164  out:
165  free_iob ( iobuf );
166 }
167 
168 /** Management interface completion operations */
171 };
172 
173 /** Management interface queue pair operations */
175  .alloc_iob = alloc_iob,
176 };
177 
178 /**
179  * Transmit MAD
180  *
181  * @v ibdev Infiniband device
182  * @v mi Management interface
183  * @v mad MAD
184  * @v av Destination address vector
185  * @ret rc Return status code
186  */
187 int ib_mi_send ( struct ib_device *ibdev, struct ib_mad_interface *mi,
188  union ib_mad *mad, struct ib_address_vector *av ) {
189  struct ib_mad_hdr *hdr = &mad->hdr;
190  struct io_buffer *iobuf;
191  int rc;
192 
193  /* Set common fields */
194  hdr->base_version = IB_MGMT_BASE_VERSION;
195  if ( ( hdr->tid.high == 0 ) && ( hdr->tid.low == 0 ) ) {
196  hdr->tid.high = htonl ( IB_MI_TID_MAGIC );
197  hdr->tid.low = htonl ( ++next_tid );
198  }
199  DBGC ( mi, "MI %p TX TID %08x%08x (%02x,%02x,%02x,%04x) status "
200  "%04x\n", mi, ntohl ( hdr->tid.high ), ntohl ( hdr->tid.low ),
201  hdr->mgmt_class, hdr->class_version, hdr->method,
202  ntohs ( hdr->attr_id ), ntohs ( hdr->status ) );
203  DBGC2_HDA ( mi, 0, mad, sizeof ( *mad ) );
204 
205  /* Construct directed route portion of response, if necessary */
206  if ( hdr->mgmt_class == IB_MGMT_CLASS_SUBN_DIRECTED_ROUTE ) {
207  struct ib_mad_smp *smp = &mad->smp;
208  unsigned int hop_pointer;
209  unsigned int hop_count;
210 
211  smp->mad_hdr.status |= htons ( IB_SMP_STATUS_D_INBOUND );
212  hop_pointer = smp->mad_hdr.class_specific.smp.hop_pointer;
213  hop_count = smp->mad_hdr.class_specific.smp.hop_count;
215  if ( hop_pointer < ( sizeof ( smp->return_path.hops ) /
216  sizeof ( smp->return_path.hops[0] ) ) ) {
217  smp->return_path.hops[hop_pointer] = ibdev->port;
218  } else {
219  DBGC ( mi, "MI %p TX TID %08x%08x invalid hop pointer "
220  "%d\n", mi, ntohl ( hdr->tid.high ),
221  ntohl ( hdr->tid.low ), hop_pointer );
222  return -EINVAL;
223  }
224  }
225 
226  /* Construct I/O buffer */
227  iobuf = alloc_iob ( sizeof ( *mad ) );
228  if ( ! iobuf ) {
229  DBGC ( mi, "MI %p could not allocate buffer for TID "
230  "%08x%08x\n",
231  mi, ntohl ( hdr->tid.high ), ntohl ( hdr->tid.low ) );
232  return -ENOMEM;
233  }
234  memcpy ( iob_put ( iobuf, sizeof ( *mad ) ), mad, sizeof ( *mad ) );
235 
236  /* Send I/O buffer */
237  if ( ( rc = ib_post_send ( ibdev, mi->qp, av, iobuf ) ) != 0 ) {
238  DBGC ( mi, "MI %p TX TID %08x%08x failed: %s\n",
239  mi, ntohl ( hdr->tid.high ), ntohl ( hdr->tid.low ),
240  strerror ( rc ) );
241  free_iob ( iobuf );
242  return rc;
243  }
244 
245  return 0;
246 }
247 
248 /**
249  * Handle management transaction timer expiry
250  *
251  * @v timer Retry timer
252  * @v expired Failure indicator
253  */
254 static void ib_mi_timer_expired ( struct retry_timer *timer, int expired ) {
255  struct ib_mad_transaction *madx =
257  struct ib_mad_interface *mi = madx->mi;
258  struct ib_device *ibdev = mi->ibdev;
259  struct ib_mad_hdr *hdr = &madx->mad.hdr;
260 
261  /* Abandon transaction if we have tried too many times */
262  if ( expired ) {
263  DBGC ( mi, "MI %p abandoning TID %08x%08x\n",
264  mi, ntohl ( hdr->tid.high ), ntohl ( hdr->tid.low ) );
265  madx->op->complete ( ibdev, mi, madx, -ETIMEDOUT, NULL, NULL );
266  return;
267  }
268 
269  /* Restart retransmission timer */
270  start_timer ( timer );
271 
272  /* Resend MAD */
273  ib_mi_send ( ibdev, mi, &madx->mad, &madx->av );
274 }
275 
276 /**
277  * Create management transaction
278  *
279  * @v ibdev Infiniband device
280  * @v mi Management interface
281  * @v mad MAD to send
282  * @v av Destination address, or NULL to use SM's GSI
283  * @v op Management transaction operations
284  * @ret madx Management transaction, or NULL
285  */
286 struct ib_mad_transaction *
287 ib_create_madx ( struct ib_device *ibdev, struct ib_mad_interface *mi,
288  union ib_mad *mad, struct ib_address_vector *av,
290  struct ib_mad_transaction *madx;
291 
292  /* Allocate and initialise structure */
293  madx = zalloc ( sizeof ( *madx ) );
294  if ( ! madx )
295  return NULL;
296  timer_init ( &madx->timer, ib_mi_timer_expired, NULL );
297  madx->mi = mi;
298  madx->op = op;
299 
300  /* Determine address vector */
301  if ( av ) {
302  memcpy ( &madx->av, av, sizeof ( madx->av ) );
303  } else {
304  madx->av.lid = ibdev->sm_lid;
305  madx->av.sl = ibdev->sm_sl;
306  madx->av.qpn = IB_QPN_GSI;
307  madx->av.qkey = IB_QKEY_GSI;
308  }
309 
310  /* Copy MAD */
311  memcpy ( &madx->mad, mad, sizeof ( madx->mad ) );
312 
313  /* Add to list and start timer to send initial MAD */
314  list_add ( &madx->list, &mi->madx );
315  start_timer_nodelay ( &madx->timer );
316 
317  return madx;
318 }
319 
320 /**
321  * Destroy management transaction
322  *
323  * @v ibdev Infiniband device
324  * @v mi Management interface
325  * @v madx Management transaction
326  */
327 void ib_destroy_madx ( struct ib_device *ibdev __unused,
328  struct ib_mad_interface *mi __unused,
329  struct ib_mad_transaction *madx ) {
330 
331  /* Stop timer and remove from list */
332  stop_timer ( &madx->timer );
333  list_del ( &madx->list );
334 
335  /* Free transaction */
336  free ( madx );
337 }
338 
339 /**
340  * Create management interface
341  *
342  * @v ibdev Infiniband device
343  * @v type Queue pair type
344  * @v new_mi New management interface to fill in
345  * @ret rc Return status code
346  */
347 int ib_create_mi ( struct ib_device *ibdev, enum ib_queue_pair_type type,
348  struct ib_mad_interface **new_mi ) {
349  struct ib_mad_interface *mi;
350  const char *name;
351  int rc;
352 
353  /* Allocate and initialise fields */
354  mi = zalloc ( sizeof ( *mi ) );
355  if ( ! mi ) {
356  rc = -ENOMEM;
357  goto err_alloc;
358  }
359  mi->ibdev = ibdev;
360  INIT_LIST_HEAD ( &mi->madx );
361 
362  /* Create completion queue */
364  &mi->cq ) ) != 0 ) {
365  DBGC ( mi, "MI %p could not create completion queue: %s\n",
366  mi, strerror ( rc ) );
367  goto err_create_cq;
368  }
369 
370  /* Create queue pair */
371  name = ( ( type == IB_QPT_SMI ) ? "SMI" : "GSI" );
372  if ( ( rc = ib_create_qp ( ibdev, type, IB_MI_NUM_SEND_WQES, mi->cq,
373  IB_MI_NUM_RECV_WQES, mi->cq,
374  &ib_mi_queue_pair_ops, name, &mi->qp ) )!=0){
375  DBGC ( mi, "MI %p could not create queue pair: %s\n",
376  mi, strerror ( rc ) );
377  goto err_create_qp;
378  }
379  ib_qp_set_ownerdata ( mi->qp, mi );
380  DBGC ( mi, "MI %p (%s) running on QPN %#lx\n",
381  mi, mi->qp->name, mi->qp->qpn );
382 
383  /* Set queue key */
384  mi->qp->qkey = ( ( type == IB_QPT_SMI ) ? IB_QKEY_SMI : IB_QKEY_GSI );
385  if ( ( rc = ib_modify_qp ( ibdev, mi->qp ) ) != 0 ) {
386  DBGC ( mi, "MI %p could not set queue key: %s\n",
387  mi, strerror ( rc ) );
388  goto err_modify_qp;
389  }
390 
391  /* Fill receive ring */
392  ib_refill_recv ( ibdev, mi->qp );
393  *new_mi = mi;
394  return 0;
395 
396  err_modify_qp:
397  ib_destroy_qp ( ibdev, mi->qp );
398  err_create_qp:
399  ib_destroy_cq ( ibdev, mi->cq );
400  err_create_cq:
401  free ( mi );
402  err_alloc:
403  return rc;
404 }
405 
406 /**
407  * Destroy management interface
408  *
409  * @v mi Management interface
410  */
411 void ib_destroy_mi ( struct ib_device *ibdev, struct ib_mad_interface *mi ) {
412  struct ib_mad_transaction *madx;
413  struct ib_mad_transaction *tmp;
414 
415  /* Flush any outstanding requests */
416  list_for_each_entry_safe ( madx, tmp, &mi->madx, list ) {
417  DBGC ( mi, "MI %p destroyed while TID %08x%08x in progress\n",
418  mi, ntohl ( madx->mad.hdr.tid.high ),
419  ntohl ( madx->mad.hdr.tid.low ) );
420  madx->op->complete ( ibdev, mi, madx, -ECANCELED, NULL, NULL );
421  }
422 
423  ib_destroy_qp ( ibdev, mi->qp );
424  ib_destroy_cq ( ibdev, mi->cq );
425  free ( mi );
426 }
struct ib_device * ibdev
Infiniband device.
Definition: ib_mi.h:90
#define EINVAL
Invalid argument.
Definition: errno.h:428
struct arbelprm_rc_send_wqe rc
Definition: arbel.h:14
Infiniband management interfaces.
#define IB_MI_NUM_RECV_WQES
Management interface number of receive WQEs.
Definition: ib_mi.c:54
const char * name
Definition: ath9k_hw.c:1984
void ib_destroy_mi(struct ib_device *ibdev, struct ib_mad_interface *mi)
Destroy management interface.
Definition: ib_mi.c:411
Infiniband protocol.
struct ib_address_vector av
Destination address vector.
Definition: ib_mi.h:78
void(* 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 WQE.
Definition: infiniband.h:216
#define iob_put(iobuf, len)
Definition: iobuf.h:116
struct ib_smp_class_specific smp
Definition: ib_mad.h:12
static void(* expired)(struct pooled_connection *pool)
Definition: pool.h:61
static void start_timer_nodelay(struct retry_timer *timer)
Start timer with no delay.
Definition: retry.h:99
#define IB_MAD_AGENTS
Infiniband management agents.
Definition: ib_mi.h:43
#define list_add(new, head)
Add a new entry to the head of a list.
Definition: list.h:69
Error codes.
I/O buffers.
void free_iob(struct io_buffer *iobuf)
Free I/O buffer.
Definition: iobuf.c:145
uint8_t type
Type.
Definition: ena.h:16
#define IB_QKEY_SMI
Subnet management interface queue key.
Definition: infiniband.h:24
void(* handle)(struct ib_device *ibdev, struct ib_mad_interface *mi, union ib_mad *mad, struct ib_address_vector *av)
Handle MAD.
Definition: ib_mi.h:36
int ib_modify_qp(struct ib_device *ibdev, struct ib_queue_pair *qp)
Modify queue pair.
Definition: infiniband.c:294
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.
Definition: infiniband.c:98
void ib_refill_recv(struct ib_device *ibdev, struct ib_queue_pair *qp)
Refill receive work queue.
Definition: infiniband.c:556
#define DBGC(...)
Definition: compiler.h:505
struct list_head list
List of transactions.
Definition: ib_mi.h:74
A subnet management MAD.
Definition: ib_mad.h:587
A retry timer.
Definition: retry.h:21
struct io_buffer *(* alloc_iob)(size_t len)
Allocate receive I/O buffer.
Definition: infiniband.h:153
#define ntohl(value)
Definition: byteswap.h:134
uint16_t attr_id
Attribute (in network byte order)
Definition: ib_mi.h:27
#define ntohs(value)
Definition: byteswap.h:136
uint8_t hop_pointer
Definition: ib_mad.h:196
An Infiniband management interface.
Definition: ib_mi.h:88
struct io_buffer * alloc_iob(size_t len)
Allocate I/O buffer.
Definition: iobuf.c:128
#define htonl(value)
Definition: byteswap.h:133
#define IB_QKEY_GSI
General service interface queue key.
Definition: infiniband.h:30
unsigned long qkey
Queue key.
Definition: infiniband.h:176
#define ECANCELED
Operation canceled.
Definition: errno.h:343
#define ENOTSUP
Operation not supported.
Definition: errno.h:589
void ib_destroy_cq(struct ib_device *ibdev, struct ib_completion_queue *cq)
Destroy completion queue.
Definition: infiniband.c:145
struct ib_queue_pair * qp
Queue pair.
Definition: ib_mi.h:94
A timer.
Definition: timer.h:28
An Infiniband device.
Definition: infiniband.h:398
#define IB_SMP_STATUS_D_INBOUND
Subnet management direction bit.
Definition: ib_mad.h:40
uint32_t low
Definition: ib_mad.h:531
#define list_del(list)
Delete an entry from a list.
Definition: list.h:119
#define ENOMEM
Not enough space.
Definition: errno.h:534
Infiniband completion queue operations.
Definition: infiniband.h:194
void * memcpy(void *dest, const void *src, size_t len) __nonnull
Infiniband queue pair operations.
Definition: infiniband.h:147
static struct ib_completion_queue_operations ib_mi_completion_ops
Management interface completion operations.
Definition: ib_mi.c:169
struct ib_completion_queue * cq
Completion queue.
Definition: ib_mi.h:92
unsigned long qkey
Queue key.
Definition: infiniband.h:79
assert((readw(&hdr->flags) &(GTF_reading|GTF_writing))==0)
#define container_of(ptr, type, field)
Get containing structure.
Definition: stddef.h:35
An Infiniband management transaction.
Definition: ib_mi.h:70
#define list_for_each_entry(pos, head, member)
Iterate over entries in a list.
Definition: list.h:420
#define DBGC_HDA(...)
Definition: compiler.h:506
#define IB_MI_NUM_SEND_WQES
Management interface number of send WQEs.
Definition: ib_mi.c:48
const char * name
Queue pair name.
Definition: infiniband.h:163
unsigned long qpn
Queue pair number.
Definition: infiniband.h:165
struct ib_mad_transaction * ib_create_madx(struct ib_device *ibdev, struct ib_mad_interface *mi, union ib_mad *mad, struct ib_address_vector *av, struct ib_mad_transaction_operations *op)
Create management transaction.
Definition: ib_mi.c:287
uint16_t sm_lid
Subnet manager LID.
Definition: infiniband.h:443
An Infiniband management agent.
Definition: ib_mi.h:21
__be32 out[4]
Definition: CIB_PRM.h:36
uint8_t class_version
Class version.
Definition: ib_mi.h:25
static void ib_mi_complete_recv(struct ib_device *ibdev, struct ib_queue_pair *qp, struct ib_address_vector *dest __unused, struct ib_address_vector *source, struct io_buffer *iobuf, int rc)
Complete receive via management interface.
Definition: ib_mi.c:124
static void * dest
Definition: strings.h:176
#define list_for_each_entry_safe(pos, tmp, head, member)
Iterate over entries in a list, safe against deletion of the current entry.
Definition: list.h:447
uint8_t sm_sl
Subnet manager SL.
Definition: infiniband.h:445
#define DBGC2_HDA(...)
Definition: compiler.h:523
#define IB_QPN_GSI
General service interface QPN.
Definition: infiniband.h:27
unsigned int port
Port number.
Definition: infiniband.h:418
char * strerror(int errno)
Retrieve string representation of error number.
Definition: strerror.c:78
static void(* free)(struct refcnt *refcnt))
Definition: refcnt.h:54
struct ib_mad_smp smp
Definition: ib_mad.h:612
ib_queue_pair_type
An Infiniband queue pair type.
Definition: infiniband.h:138
static __always_inline void * ib_qp_get_ownerdata(struct ib_queue_pair *qp)
Get Infiniband queue pair owner-private data.
Definition: infiniband.h:663
void * zalloc(size_t size)
Allocate cleared memory.
Definition: malloc.c:624
static size_t iob_len(struct io_buffer *iobuf)
Calculate length of data in an I/O buffer.
Definition: iobuf.h:151
uint8_t hop_pointer
Definition: ib_mad.h:11
A management datagram common header.
Definition: ib_mad.h:538
uint8_t * tmp
Definition: entropy.h:156
#define for_each_table_entry(pointer, table)
Iterate through all entries within a linker table.
Definition: tables.h:358
void ib_destroy_qp(struct ib_device *ibdev, struct ib_queue_pair *qp)
Destroy queue pair.
Definition: infiniband.c:314
struct ib_mad_transaction_operations * op
Transaction operations.
Definition: ib_mi.h:82
unsigned long qpn
Queue Pair Number.
Definition: infiniband.h:74
struct ib_mad_tid tid
Definition: ib_mad.h:545
An Infiniband Queue Pair.
Definition: infiniband.h:157
void start_timer(struct retry_timer *timer)
Start timer.
Definition: retry.c:93
uint32_t hdr
Message header.
Definition: intelvf.h:12
static struct ib_queue_pair_operations ib_mi_queue_pair_ops
Management interface queue pair operations.
Definition: ib_mi.c:174
unsigned int sl
Service level.
Definition: infiniband.h:88
#define IB_MI_NUM_CQES
Management interface number of completion queue entries.
Definition: ib_mi.c:60
#define __unused
Declare a variable or data structure as unused.
Definition: compiler.h:573
struct arbelprm_qp_db_record qp
Definition: arbel.h:13
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.
Definition: infiniband.c:416
static uint16_t struct vmbus_xfer_pages_operations * op
Definition: netvsc.h:327
#define INIT_LIST_HEAD(list)
Initialise a list head.
Definition: list.h:45
void stop_timer(struct retry_timer *timer)
Stop timer.
Definition: retry.c:117
struct ib_mad_hdr hdr
Definition: ib_mad.h:611
#define IB_MGMT_CLASS_SUBN_DIRECTED_ROUTE
Definition: ib_mad.h:556
struct ib_mad_interface * mi
Associated management interface.
Definition: ib_mi.h:72
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.
Definition: infiniband.c:199
uint8_t mgmt_class
Management class.
Definition: ib_mi.h:23
void * data
Start of data.
Definition: iobuf.h:44
#define IB_MGMT_CLASS_MASK
Definition: ib_mad.h:566
#define IB_MI_TID_MAGIC
TID magic signature.
Definition: ib_mi.c:63
A management datagram.
Definition: ib_mad.h:610
#define IB_MGMT_BASE_VERSION
Definition: ib_mad.h:552
uint32_t high
Definition: ib_mad.h:530
static void ib_mi_timer_expired(struct retry_timer *timer, int expired)
Handle management transaction timer expiry.
Definition: ib_mi.c:254
uint8_t hop_count
Definition: ib_mad.h:12
An Infiniband Address Vector.
Definition: infiniband.h:72
union ib_mad mad
MAD being sent.
Definition: ib_mi.h:80
unsigned int lid
Local ID.
Definition: infiniband.h:81
static unsigned int next_tid
TID to use for next MAD.
Definition: ib_mi.c:66
void(* complete)(struct ib_device *ibdev, struct ib_mad_interface *mi, struct ib_mad_transaction *madx, int rc, union ib_mad *mad, struct ib_address_vector *av)
Handle transaction completion.
Definition: ib_mi.h:62
Infiniband management transaction operations.
Definition: ib_mi.h:49
static int ib_mi_handle(struct ib_device *ibdev, struct ib_mad_interface *mi, union ib_mad *mad, struct ib_address_vector *av)
Handle received MAD.
Definition: ib_mi.c:77
struct list_head madx
List of management transactions.
Definition: ib_mi.h:96
int memcmp(const void *first, const void *second, size_t len)
Compare memory regions.
Definition: string.c:98
#define NULL
NULL pointer (VOID *)
Definition: Base.h:362
#define ETIMEDOUT
Connection timed out.
Definition: errno.h:669
static __always_inline void ib_qp_set_ownerdata(struct ib_queue_pair *qp, void *priv)
Set Infiniband queue pair owner-private data.
Definition: infiniband.h:652
String functions.
#define htons(value)
Definition: byteswap.h:135
FILE_LICENCE(GPL2_OR_LATER_OR_UBDL)
int ib_mi_send(struct ib_device *ibdev, struct ib_mad_interface *mi, union ib_mad *mad, struct ib_address_vector *av)
Transmit MAD.
Definition: ib_mi.c:187
union ib_mad mad
Definition: arbel.h:12
int ib_create_mi(struct ib_device *ibdev, enum ib_queue_pair_type type, struct ib_mad_interface **new_mi)
Create management interface.
Definition: ib_mi.c:347
struct retry_timer timer
Retry timer.
Definition: ib_mi.h:76
void ib_destroy_madx(struct ib_device *ibdev __unused, struct ib_mad_interface *mi __unused, struct ib_mad_transaction *madx)
Destroy management transaction.
Definition: ib_mi.c:327
A persistent I/O buffer.
Definition: iobuf.h:32