]> git.kernelconcepts.de Git - karo-tx-linux.git/blob - drivers/net/ethernet/mellanox/mlxsw/pci.c
mlxsw: pci: Limit number of entries being sent in single MAP_FA cmd
[karo-tx-linux.git] / drivers / net / ethernet / mellanox / mlxsw / pci.c
1 /*
2  * drivers/net/ethernet/mellanox/mlxsw/pci.c
3  * Copyright (c) 2015 Mellanox Technologies. All rights reserved.
4  * Copyright (c) 2015 Jiri Pirko <jiri@mellanox.com>
5  *
6  * Redistribution and use in source and binary forms, with or without
7  * modification, are permitted provided that the following conditions are met:
8  *
9  * 1. Redistributions of source code must retain the above copyright
10  *    notice, this list of conditions and the following disclaimer.
11  * 2. Redistributions in binary form must reproduce the above copyright
12  *    notice, this list of conditions and the following disclaimer in the
13  *    documentation and/or other materials provided with the distribution.
14  * 3. Neither the names of the copyright holders nor the names of its
15  *    contributors may be used to endorse or promote products derived from
16  *    this software without specific prior written permission.
17  *
18  * Alternatively, this software may be distributed under the terms of the
19  * GNU General Public License ("GPL") version 2 as published by the Free
20  * Software Foundation.
21  *
22  * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
23  * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
24  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
25  * ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE
26  * LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
27  * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
28  * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
29  * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
30  * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
31  * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
32  * POSSIBILITY OF SUCH DAMAGE.
33  */
34
35 #include <linux/kernel.h>
36 #include <linux/module.h>
37 #include <linux/export.h>
38 #include <linux/err.h>
39 #include <linux/device.h>
40 #include <linux/pci.h>
41 #include <linux/interrupt.h>
42 #include <linux/wait.h>
43 #include <linux/types.h>
44 #include <linux/skbuff.h>
45 #include <linux/if_vlan.h>
46 #include <linux/log2.h>
47 #include <linux/debugfs.h>
48 #include <linux/seq_file.h>
49 #include <linux/string.h>
50
51 #include "pci.h"
52 #include "core.h"
53 #include "cmd.h"
54 #include "port.h"
55
56 static const char mlxsw_pci_driver_name[] = "mlxsw_pci";
57
58 static const struct pci_device_id mlxsw_pci_id_table[] = {
59         {PCI_VDEVICE(MELLANOX, PCI_DEVICE_ID_MELLANOX_SWITCHX2), 0},
60         {0, }
61 };
62
63 static struct dentry *mlxsw_pci_dbg_root;
64
65 static const char *mlxsw_pci_device_kind_get(const struct pci_device_id *id)
66 {
67         switch (id->device) {
68         case PCI_DEVICE_ID_MELLANOX_SWITCHX2:
69                 return MLXSW_DEVICE_KIND_SWITCHX2;
70         default:
71                 BUG();
72         }
73 }
74
75 #define mlxsw_pci_write32(mlxsw_pci, reg, val) \
76         iowrite32be(val, (mlxsw_pci)->hw_addr + (MLXSW_PCI_ ## reg))
77 #define mlxsw_pci_read32(mlxsw_pci, reg) \
78         ioread32be((mlxsw_pci)->hw_addr + (MLXSW_PCI_ ## reg))
79
80 enum mlxsw_pci_queue_type {
81         MLXSW_PCI_QUEUE_TYPE_SDQ,
82         MLXSW_PCI_QUEUE_TYPE_RDQ,
83         MLXSW_PCI_QUEUE_TYPE_CQ,
84         MLXSW_PCI_QUEUE_TYPE_EQ,
85 };
86
87 static const char *mlxsw_pci_queue_type_str(enum mlxsw_pci_queue_type q_type)
88 {
89         switch (q_type) {
90         case MLXSW_PCI_QUEUE_TYPE_SDQ:
91                 return "sdq";
92         case MLXSW_PCI_QUEUE_TYPE_RDQ:
93                 return "rdq";
94         case MLXSW_PCI_QUEUE_TYPE_CQ:
95                 return "cq";
96         case MLXSW_PCI_QUEUE_TYPE_EQ:
97                 return "eq";
98         }
99         BUG();
100 }
101
102 #define MLXSW_PCI_QUEUE_TYPE_COUNT      4
103
104 static const u16 mlxsw_pci_doorbell_type_offset[] = {
105         MLXSW_PCI_DOORBELL_SDQ_OFFSET,  /* for type MLXSW_PCI_QUEUE_TYPE_SDQ */
106         MLXSW_PCI_DOORBELL_RDQ_OFFSET,  /* for type MLXSW_PCI_QUEUE_TYPE_RDQ */
107         MLXSW_PCI_DOORBELL_CQ_OFFSET,   /* for type MLXSW_PCI_QUEUE_TYPE_CQ */
108         MLXSW_PCI_DOORBELL_EQ_OFFSET,   /* for type MLXSW_PCI_QUEUE_TYPE_EQ */
109 };
110
111 static const u16 mlxsw_pci_doorbell_arm_type_offset[] = {
112         0, /* unused */
113         0, /* unused */
114         MLXSW_PCI_DOORBELL_ARM_CQ_OFFSET, /* for type MLXSW_PCI_QUEUE_TYPE_CQ */
115         MLXSW_PCI_DOORBELL_ARM_EQ_OFFSET, /* for type MLXSW_PCI_QUEUE_TYPE_EQ */
116 };
117
118 struct mlxsw_pci_mem_item {
119         char *buf;
120         dma_addr_t mapaddr;
121         size_t size;
122 };
123
124 struct mlxsw_pci_queue_elem_info {
125         char *elem; /* pointer to actual dma mapped element mem chunk */
126         union {
127                 struct {
128                         struct sk_buff *skb;
129                 } sdq;
130                 struct {
131                         struct sk_buff *skb;
132                 } rdq;
133         } u;
134 };
135
136 struct mlxsw_pci_queue {
137         spinlock_t lock; /* for queue accesses */
138         struct mlxsw_pci_mem_item mem_item;
139         struct mlxsw_pci_queue_elem_info *elem_info;
140         u16 producer_counter;
141         u16 consumer_counter;
142         u16 count; /* number of elements in queue */
143         u8 num; /* queue number */
144         u8 elem_size; /* size of one element */
145         enum mlxsw_pci_queue_type type;
146         struct tasklet_struct tasklet; /* queue processing tasklet */
147         struct mlxsw_pci *pci;
148         union {
149                 struct {
150                         u32 comp_sdq_count;
151                         u32 comp_rdq_count;
152                 } cq;
153                 struct {
154                         u32 ev_cmd_count;
155                         u32 ev_comp_count;
156                         u32 ev_other_count;
157                 } eq;
158         } u;
159 };
160
161 struct mlxsw_pci_queue_type_group {
162         struct mlxsw_pci_queue *q;
163         u8 count; /* number of queues in group */
164 };
165
166 struct mlxsw_pci {
167         struct pci_dev *pdev;
168         u8 __iomem *hw_addr;
169         struct mlxsw_pci_queue_type_group queues[MLXSW_PCI_QUEUE_TYPE_COUNT];
170         u32 doorbell_offset;
171         struct msix_entry msix_entry;
172         struct mlxsw_core *core;
173         struct {
174                 struct mlxsw_pci_mem_item *items;
175                 unsigned int count;
176         } fw_area;
177         struct {
178                 struct mlxsw_pci_mem_item out_mbox;
179                 struct mlxsw_pci_mem_item in_mbox;
180                 struct mutex lock; /* Lock access to command registers */
181                 bool nopoll;
182                 wait_queue_head_t wait;
183                 bool wait_done;
184                 struct {
185                         u8 status;
186                         u64 out_param;
187                 } comp;
188         } cmd;
189         struct mlxsw_bus_info bus_info;
190         struct dentry *dbg_dir;
191 };
192
193 static void mlxsw_pci_queue_tasklet_schedule(struct mlxsw_pci_queue *q)
194 {
195         tasklet_schedule(&q->tasklet);
196 }
197
198 static char *__mlxsw_pci_queue_elem_get(struct mlxsw_pci_queue *q,
199                                         size_t elem_size, int elem_index)
200 {
201         return q->mem_item.buf + (elem_size * elem_index);
202 }
203
204 static struct mlxsw_pci_queue_elem_info *
205 mlxsw_pci_queue_elem_info_get(struct mlxsw_pci_queue *q, int elem_index)
206 {
207         return &q->elem_info[elem_index];
208 }
209
210 static struct mlxsw_pci_queue_elem_info *
211 mlxsw_pci_queue_elem_info_producer_get(struct mlxsw_pci_queue *q)
212 {
213         int index = q->producer_counter & (q->count - 1);
214
215         if ((q->producer_counter - q->consumer_counter) == q->count)
216                 return NULL;
217         return mlxsw_pci_queue_elem_info_get(q, index);
218 }
219
220 static struct mlxsw_pci_queue_elem_info *
221 mlxsw_pci_queue_elem_info_consumer_get(struct mlxsw_pci_queue *q)
222 {
223         int index = q->consumer_counter & (q->count - 1);
224
225         return mlxsw_pci_queue_elem_info_get(q, index);
226 }
227
228 static char *mlxsw_pci_queue_elem_get(struct mlxsw_pci_queue *q, int elem_index)
229 {
230         return mlxsw_pci_queue_elem_info_get(q, elem_index)->elem;
231 }
232
233 static bool mlxsw_pci_elem_hw_owned(struct mlxsw_pci_queue *q, bool owner_bit)
234 {
235         return owner_bit != !!(q->consumer_counter & q->count);
236 }
237
238 static char *mlxsw_pci_queue_sw_elem_get(struct mlxsw_pci_queue *q,
239                                          u32 (*get_elem_owner_func)(char *))
240 {
241         struct mlxsw_pci_queue_elem_info *elem_info;
242         char *elem;
243         bool owner_bit;
244
245         elem_info = mlxsw_pci_queue_elem_info_consumer_get(q);
246         elem = elem_info->elem;
247         owner_bit = get_elem_owner_func(elem);
248         if (mlxsw_pci_elem_hw_owned(q, owner_bit))
249                 return NULL;
250         q->consumer_counter++;
251         rmb(); /* make sure we read owned bit before the rest of elem */
252         return elem;
253 }
254
255 static struct mlxsw_pci_queue_type_group *
256 mlxsw_pci_queue_type_group_get(struct mlxsw_pci *mlxsw_pci,
257                                enum mlxsw_pci_queue_type q_type)
258 {
259         return &mlxsw_pci->queues[q_type];
260 }
261
262 static u8 __mlxsw_pci_queue_count(struct mlxsw_pci *mlxsw_pci,
263                                   enum mlxsw_pci_queue_type q_type)
264 {
265         struct mlxsw_pci_queue_type_group *queue_group;
266
267         queue_group = mlxsw_pci_queue_type_group_get(mlxsw_pci, q_type);
268         return queue_group->count;
269 }
270
271 static u8 mlxsw_pci_sdq_count(struct mlxsw_pci *mlxsw_pci)
272 {
273         return __mlxsw_pci_queue_count(mlxsw_pci, MLXSW_PCI_QUEUE_TYPE_SDQ);
274 }
275
276 static u8 mlxsw_pci_rdq_count(struct mlxsw_pci *mlxsw_pci)
277 {
278         return __mlxsw_pci_queue_count(mlxsw_pci, MLXSW_PCI_QUEUE_TYPE_RDQ);
279 }
280
281 static u8 mlxsw_pci_cq_count(struct mlxsw_pci *mlxsw_pci)
282 {
283         return __mlxsw_pci_queue_count(mlxsw_pci, MLXSW_PCI_QUEUE_TYPE_CQ);
284 }
285
286 static u8 mlxsw_pci_eq_count(struct mlxsw_pci *mlxsw_pci)
287 {
288         return __mlxsw_pci_queue_count(mlxsw_pci, MLXSW_PCI_QUEUE_TYPE_EQ);
289 }
290
291 static struct mlxsw_pci_queue *
292 __mlxsw_pci_queue_get(struct mlxsw_pci *mlxsw_pci,
293                       enum mlxsw_pci_queue_type q_type, u8 q_num)
294 {
295         return &mlxsw_pci->queues[q_type].q[q_num];
296 }
297
298 static struct mlxsw_pci_queue *mlxsw_pci_sdq_get(struct mlxsw_pci *mlxsw_pci,
299                                                  u8 q_num)
300 {
301         return __mlxsw_pci_queue_get(mlxsw_pci,
302                                      MLXSW_PCI_QUEUE_TYPE_SDQ, q_num);
303 }
304
305 static struct mlxsw_pci_queue *mlxsw_pci_rdq_get(struct mlxsw_pci *mlxsw_pci,
306                                                  u8 q_num)
307 {
308         return __mlxsw_pci_queue_get(mlxsw_pci,
309                                      MLXSW_PCI_QUEUE_TYPE_RDQ, q_num);
310 }
311
312 static struct mlxsw_pci_queue *mlxsw_pci_cq_get(struct mlxsw_pci *mlxsw_pci,
313                                                 u8 q_num)
314 {
315         return __mlxsw_pci_queue_get(mlxsw_pci, MLXSW_PCI_QUEUE_TYPE_CQ, q_num);
316 }
317
318 static struct mlxsw_pci_queue *mlxsw_pci_eq_get(struct mlxsw_pci *mlxsw_pci,
319                                                 u8 q_num)
320 {
321         return __mlxsw_pci_queue_get(mlxsw_pci, MLXSW_PCI_QUEUE_TYPE_EQ, q_num);
322 }
323
324 static void __mlxsw_pci_queue_doorbell_set(struct mlxsw_pci *mlxsw_pci,
325                                            struct mlxsw_pci_queue *q,
326                                            u16 val)
327 {
328         mlxsw_pci_write32(mlxsw_pci,
329                           DOORBELL(mlxsw_pci->doorbell_offset,
330                                    mlxsw_pci_doorbell_type_offset[q->type],
331                                    q->num), val);
332 }
333
334 static void __mlxsw_pci_queue_doorbell_arm_set(struct mlxsw_pci *mlxsw_pci,
335                                                struct mlxsw_pci_queue *q,
336                                                u16 val)
337 {
338         mlxsw_pci_write32(mlxsw_pci,
339                           DOORBELL(mlxsw_pci->doorbell_offset,
340                                    mlxsw_pci_doorbell_arm_type_offset[q->type],
341                                    q->num), val);
342 }
343
344 static void mlxsw_pci_queue_doorbell_producer_ring(struct mlxsw_pci *mlxsw_pci,
345                                                    struct mlxsw_pci_queue *q)
346 {
347         wmb(); /* ensure all writes are done before we ring a bell */
348         __mlxsw_pci_queue_doorbell_set(mlxsw_pci, q, q->producer_counter);
349 }
350
351 static void mlxsw_pci_queue_doorbell_consumer_ring(struct mlxsw_pci *mlxsw_pci,
352                                                    struct mlxsw_pci_queue *q)
353 {
354         wmb(); /* ensure all writes are done before we ring a bell */
355         __mlxsw_pci_queue_doorbell_set(mlxsw_pci, q,
356                                        q->consumer_counter + q->count);
357 }
358
359 static void
360 mlxsw_pci_queue_doorbell_arm_consumer_ring(struct mlxsw_pci *mlxsw_pci,
361                                            struct mlxsw_pci_queue *q)
362 {
363         wmb(); /* ensure all writes are done before we ring a bell */
364         __mlxsw_pci_queue_doorbell_arm_set(mlxsw_pci, q, q->consumer_counter);
365 }
366
367 static dma_addr_t __mlxsw_pci_queue_page_get(struct mlxsw_pci_queue *q,
368                                              int page_index)
369 {
370         return q->mem_item.mapaddr + MLXSW_PCI_PAGE_SIZE * page_index;
371 }
372
373 static int mlxsw_pci_sdq_init(struct mlxsw_pci *mlxsw_pci, char *mbox,
374                               struct mlxsw_pci_queue *q)
375 {
376         int i;
377         int err;
378
379         q->producer_counter = 0;
380         q->consumer_counter = 0;
381
382         /* Set CQ of same number of this SDQ. */
383         mlxsw_cmd_mbox_sw2hw_dq_cq_set(mbox, q->num);
384         mlxsw_cmd_mbox_sw2hw_dq_sdq_tclass_set(mbox, 7);
385         mlxsw_cmd_mbox_sw2hw_dq_log2_dq_sz_set(mbox, 3); /* 8 pages */
386         for (i = 0; i < MLXSW_PCI_AQ_PAGES; i++) {
387                 dma_addr_t mapaddr = __mlxsw_pci_queue_page_get(q, i);
388
389                 mlxsw_cmd_mbox_sw2hw_dq_pa_set(mbox, i, mapaddr);
390         }
391
392         err = mlxsw_cmd_sw2hw_sdq(mlxsw_pci->core, mbox, q->num);
393         if (err)
394                 return err;
395         mlxsw_pci_queue_doorbell_producer_ring(mlxsw_pci, q);
396         return 0;
397 }
398
399 static void mlxsw_pci_sdq_fini(struct mlxsw_pci *mlxsw_pci,
400                                struct mlxsw_pci_queue *q)
401 {
402         mlxsw_cmd_hw2sw_sdq(mlxsw_pci->core, q->num);
403 }
404
405 static int mlxsw_pci_sdq_dbg_read(struct seq_file *file, void *data)
406 {
407         struct mlxsw_pci *mlxsw_pci = dev_get_drvdata(file->private);
408         struct mlxsw_pci_queue *q;
409         int i;
410         static const char hdr[] =
411                 "NUM PROD_COUNT CONS_COUNT COUNT\n";
412
413         seq_printf(file, hdr);
414         for (i = 0; i < mlxsw_pci_sdq_count(mlxsw_pci); i++) {
415                 q = mlxsw_pci_sdq_get(mlxsw_pci, i);
416                 spin_lock_bh(&q->lock);
417                 seq_printf(file, "%3d %10d %10d %5d\n",
418                            i, q->producer_counter, q->consumer_counter,
419                            q->count);
420                 spin_unlock_bh(&q->lock);
421         }
422         return 0;
423 }
424
425 static int mlxsw_pci_wqe_frag_map(struct mlxsw_pci *mlxsw_pci, char *wqe,
426                                   int index, char *frag_data, size_t frag_len,
427                                   int direction)
428 {
429         struct pci_dev *pdev = mlxsw_pci->pdev;
430         dma_addr_t mapaddr;
431
432         mapaddr = pci_map_single(pdev, frag_data, frag_len, direction);
433         if (unlikely(pci_dma_mapping_error(pdev, mapaddr))) {
434                 if (net_ratelimit())
435                         dev_err(&pdev->dev, "failed to dma map tx frag\n");
436                 return -EIO;
437         }
438         mlxsw_pci_wqe_address_set(wqe, index, mapaddr);
439         mlxsw_pci_wqe_byte_count_set(wqe, index, frag_len);
440         return 0;
441 }
442
443 static void mlxsw_pci_wqe_frag_unmap(struct mlxsw_pci *mlxsw_pci, char *wqe,
444                                      int index, int direction)
445 {
446         struct pci_dev *pdev = mlxsw_pci->pdev;
447         size_t frag_len = mlxsw_pci_wqe_byte_count_get(wqe, index);
448         dma_addr_t mapaddr = mlxsw_pci_wqe_address_get(wqe, index);
449
450         if (!frag_len)
451                 return;
452         pci_unmap_single(pdev, mapaddr, frag_len, direction);
453 }
454
455 static int mlxsw_pci_rdq_skb_alloc(struct mlxsw_pci *mlxsw_pci,
456                                    struct mlxsw_pci_queue_elem_info *elem_info)
457 {
458         size_t buf_len = MLXSW_PORT_MAX_MTU;
459         char *wqe = elem_info->elem;
460         struct sk_buff *skb;
461         int err;
462
463         elem_info->u.rdq.skb = NULL;
464         skb = netdev_alloc_skb_ip_align(NULL, buf_len);
465         if (!skb)
466                 return -ENOMEM;
467
468         /* Assume that wqe was previously zeroed. */
469
470         err = mlxsw_pci_wqe_frag_map(mlxsw_pci, wqe, 0, skb->data,
471                                      buf_len, DMA_FROM_DEVICE);
472         if (err)
473                 goto err_frag_map;
474
475         elem_info->u.rdq.skb = skb;
476         return 0;
477
478 err_frag_map:
479         dev_kfree_skb_any(skb);
480         return err;
481 }
482
483 static void mlxsw_pci_rdq_skb_free(struct mlxsw_pci *mlxsw_pci,
484                                    struct mlxsw_pci_queue_elem_info *elem_info)
485 {
486         struct sk_buff *skb;
487         char *wqe;
488
489         skb = elem_info->u.rdq.skb;
490         wqe = elem_info->elem;
491
492         mlxsw_pci_wqe_frag_unmap(mlxsw_pci, wqe, 0, DMA_FROM_DEVICE);
493         dev_kfree_skb_any(skb);
494 }
495
496 static int mlxsw_pci_rdq_init(struct mlxsw_pci *mlxsw_pci, char *mbox,
497                               struct mlxsw_pci_queue *q)
498 {
499         struct mlxsw_pci_queue_elem_info *elem_info;
500         u8 sdq_count = mlxsw_pci_sdq_count(mlxsw_pci);
501         int i;
502         int err;
503
504         q->producer_counter = 0;
505         q->consumer_counter = 0;
506
507         /* Set CQ of same number of this RDQ with base
508          * above SDQ count as the lower ones are assigned to SDQs.
509          */
510         mlxsw_cmd_mbox_sw2hw_dq_cq_set(mbox, sdq_count + q->num);
511         mlxsw_cmd_mbox_sw2hw_dq_log2_dq_sz_set(mbox, 3); /* 8 pages */
512         for (i = 0; i < MLXSW_PCI_AQ_PAGES; i++) {
513                 dma_addr_t mapaddr = __mlxsw_pci_queue_page_get(q, i);
514
515                 mlxsw_cmd_mbox_sw2hw_dq_pa_set(mbox, i, mapaddr);
516         }
517
518         err = mlxsw_cmd_sw2hw_rdq(mlxsw_pci->core, mbox, q->num);
519         if (err)
520                 return err;
521
522         mlxsw_pci_queue_doorbell_producer_ring(mlxsw_pci, q);
523
524         for (i = 0; i < q->count; i++) {
525                 elem_info = mlxsw_pci_queue_elem_info_producer_get(q);
526                 BUG_ON(!elem_info);
527                 err = mlxsw_pci_rdq_skb_alloc(mlxsw_pci, elem_info);
528                 if (err)
529                         goto rollback;
530                 /* Everything is set up, ring doorbell to pass elem to HW */
531                 q->producer_counter++;
532                 mlxsw_pci_queue_doorbell_producer_ring(mlxsw_pci, q);
533         }
534
535         return 0;
536
537 rollback:
538         for (i--; i >= 0; i--) {
539                 elem_info = mlxsw_pci_queue_elem_info_get(q, i);
540                 mlxsw_pci_rdq_skb_free(mlxsw_pci, elem_info);
541         }
542         mlxsw_cmd_hw2sw_rdq(mlxsw_pci->core, q->num);
543
544         return err;
545 }
546
547 static void mlxsw_pci_rdq_fini(struct mlxsw_pci *mlxsw_pci,
548                                struct mlxsw_pci_queue *q)
549 {
550         struct mlxsw_pci_queue_elem_info *elem_info;
551         int i;
552
553         mlxsw_cmd_hw2sw_rdq(mlxsw_pci->core, q->num);
554         for (i = 0; i < q->count; i++) {
555                 elem_info = mlxsw_pci_queue_elem_info_get(q, i);
556                 mlxsw_pci_rdq_skb_free(mlxsw_pci, elem_info);
557         }
558 }
559
560 static int mlxsw_pci_rdq_dbg_read(struct seq_file *file, void *data)
561 {
562         struct mlxsw_pci *mlxsw_pci = dev_get_drvdata(file->private);
563         struct mlxsw_pci_queue *q;
564         int i;
565         static const char hdr[] =
566                 "NUM PROD_COUNT CONS_COUNT COUNT\n";
567
568         seq_printf(file, hdr);
569         for (i = 0; i < mlxsw_pci_rdq_count(mlxsw_pci); i++) {
570                 q = mlxsw_pci_rdq_get(mlxsw_pci, i);
571                 spin_lock_bh(&q->lock);
572                 seq_printf(file, "%3d %10d %10d %5d\n",
573                            i, q->producer_counter, q->consumer_counter,
574                            q->count);
575                 spin_unlock_bh(&q->lock);
576         }
577         return 0;
578 }
579
580 static int mlxsw_pci_cq_init(struct mlxsw_pci *mlxsw_pci, char *mbox,
581                              struct mlxsw_pci_queue *q)
582 {
583         int i;
584         int err;
585
586         q->consumer_counter = 0;
587
588         for (i = 0; i < q->count; i++) {
589                 char *elem = mlxsw_pci_queue_elem_get(q, i);
590
591                 mlxsw_pci_cqe_owner_set(elem, 1);
592         }
593
594         mlxsw_cmd_mbox_sw2hw_cq_cv_set(mbox, 0); /* CQE ver 0 */
595         mlxsw_cmd_mbox_sw2hw_cq_c_eqn_set(mbox, MLXSW_PCI_EQ_COMP_NUM);
596         mlxsw_cmd_mbox_sw2hw_cq_oi_set(mbox, 0);
597         mlxsw_cmd_mbox_sw2hw_cq_st_set(mbox, 0);
598         mlxsw_cmd_mbox_sw2hw_cq_log_cq_size_set(mbox, ilog2(q->count));
599         for (i = 0; i < MLXSW_PCI_AQ_PAGES; i++) {
600                 dma_addr_t mapaddr = __mlxsw_pci_queue_page_get(q, i);
601
602                 mlxsw_cmd_mbox_sw2hw_cq_pa_set(mbox, i, mapaddr);
603         }
604         err = mlxsw_cmd_sw2hw_cq(mlxsw_pci->core, mbox, q->num);
605         if (err)
606                 return err;
607         mlxsw_pci_queue_doorbell_consumer_ring(mlxsw_pci, q);
608         mlxsw_pci_queue_doorbell_arm_consumer_ring(mlxsw_pci, q);
609         return 0;
610 }
611
612 static void mlxsw_pci_cq_fini(struct mlxsw_pci *mlxsw_pci,
613                               struct mlxsw_pci_queue *q)
614 {
615         mlxsw_cmd_hw2sw_cq(mlxsw_pci->core, q->num);
616 }
617
618 static int mlxsw_pci_cq_dbg_read(struct seq_file *file, void *data)
619 {
620         struct mlxsw_pci *mlxsw_pci = dev_get_drvdata(file->private);
621
622         struct mlxsw_pci_queue *q;
623         int i;
624         static const char hdr[] =
625                 "NUM CONS_INDEX  SDQ_COUNT  RDQ_COUNT COUNT\n";
626
627         seq_printf(file, hdr);
628         for (i = 0; i < mlxsw_pci_cq_count(mlxsw_pci); i++) {
629                 q = mlxsw_pci_cq_get(mlxsw_pci, i);
630                 spin_lock_bh(&q->lock);
631                 seq_printf(file, "%3d %10d %10d %10d %5d\n",
632                            i, q->consumer_counter, q->u.cq.comp_sdq_count,
633                            q->u.cq.comp_rdq_count, q->count);
634                 spin_unlock_bh(&q->lock);
635         }
636         return 0;
637 }
638
639 static void mlxsw_pci_cqe_sdq_handle(struct mlxsw_pci *mlxsw_pci,
640                                      struct mlxsw_pci_queue *q,
641                                      u16 consumer_counter_limit,
642                                      char *cqe)
643 {
644         struct pci_dev *pdev = mlxsw_pci->pdev;
645         struct mlxsw_pci_queue_elem_info *elem_info;
646         char *wqe;
647         struct sk_buff *skb;
648         int i;
649
650         spin_lock(&q->lock);
651         elem_info = mlxsw_pci_queue_elem_info_consumer_get(q);
652         skb = elem_info->u.sdq.skb;
653         wqe = elem_info->elem;
654         for (i = 0; i < MLXSW_PCI_WQE_SG_ENTRIES; i++)
655                 mlxsw_pci_wqe_frag_unmap(mlxsw_pci, wqe, i, DMA_TO_DEVICE);
656         dev_kfree_skb_any(skb);
657         elem_info->u.sdq.skb = NULL;
658
659         if (q->consumer_counter++ != consumer_counter_limit)
660                 dev_dbg_ratelimited(&pdev->dev, "Consumer counter does not match limit in SDQ\n");
661         spin_unlock(&q->lock);
662 }
663
664 static void mlxsw_pci_cqe_rdq_handle(struct mlxsw_pci *mlxsw_pci,
665                                      struct mlxsw_pci_queue *q,
666                                      u16 consumer_counter_limit,
667                                      char *cqe)
668 {
669         struct pci_dev *pdev = mlxsw_pci->pdev;
670         struct mlxsw_pci_queue_elem_info *elem_info;
671         char *wqe;
672         struct sk_buff *skb;
673         struct mlxsw_rx_info rx_info;
674         u16 byte_count;
675         int err;
676
677         elem_info = mlxsw_pci_queue_elem_info_consumer_get(q);
678         skb = elem_info->u.sdq.skb;
679         if (!skb)
680                 return;
681         wqe = elem_info->elem;
682         mlxsw_pci_wqe_frag_unmap(mlxsw_pci, wqe, 0, DMA_FROM_DEVICE);
683
684         if (q->consumer_counter++ != consumer_counter_limit)
685                 dev_dbg_ratelimited(&pdev->dev, "Consumer counter does not match limit in RDQ\n");
686
687         /* We do not support lag now */
688         if (mlxsw_pci_cqe_lag_get(cqe))
689                 goto drop;
690
691         rx_info.sys_port = mlxsw_pci_cqe_system_port_get(cqe);
692         rx_info.trap_id = mlxsw_pci_cqe_trap_id_get(cqe);
693
694         byte_count = mlxsw_pci_cqe_byte_count_get(cqe);
695         if (mlxsw_pci_cqe_crc_get(cqe))
696                 byte_count -= ETH_FCS_LEN;
697         skb_put(skb, byte_count);
698         mlxsw_core_skb_receive(mlxsw_pci->core, skb, &rx_info);
699
700 put_new_skb:
701         memset(wqe, 0, q->elem_size);
702         err = mlxsw_pci_rdq_skb_alloc(mlxsw_pci, elem_info);
703         if (err && net_ratelimit())
704                 dev_dbg(&pdev->dev, "Failed to alloc skb for RDQ\n");
705         /* Everything is set up, ring doorbell to pass elem to HW */
706         q->producer_counter++;
707         mlxsw_pci_queue_doorbell_producer_ring(mlxsw_pci, q);
708         return;
709
710 drop:
711         dev_kfree_skb_any(skb);
712         goto put_new_skb;
713 }
714
715 static char *mlxsw_pci_cq_sw_cqe_get(struct mlxsw_pci_queue *q)
716 {
717         return mlxsw_pci_queue_sw_elem_get(q, mlxsw_pci_cqe_owner_get);
718 }
719
720 static void mlxsw_pci_cq_tasklet(unsigned long data)
721 {
722         struct mlxsw_pci_queue *q = (struct mlxsw_pci_queue *) data;
723         struct mlxsw_pci *mlxsw_pci = q->pci;
724         char *cqe;
725         int items = 0;
726         int credits = q->count >> 1;
727
728         while ((cqe = mlxsw_pci_cq_sw_cqe_get(q))) {
729                 u16 wqe_counter = mlxsw_pci_cqe_wqe_counter_get(cqe);
730                 u8 sendq = mlxsw_pci_cqe_sr_get(cqe);
731                 u8 dqn = mlxsw_pci_cqe_dqn_get(cqe);
732
733                 if (sendq) {
734                         struct mlxsw_pci_queue *sdq;
735
736                         sdq = mlxsw_pci_sdq_get(mlxsw_pci, dqn);
737                         mlxsw_pci_cqe_sdq_handle(mlxsw_pci, sdq,
738                                                  wqe_counter, cqe);
739                         q->u.cq.comp_sdq_count++;
740                 } else {
741                         struct mlxsw_pci_queue *rdq;
742
743                         rdq = mlxsw_pci_rdq_get(mlxsw_pci, dqn);
744                         mlxsw_pci_cqe_rdq_handle(mlxsw_pci, rdq,
745                                                  wqe_counter, cqe);
746                         q->u.cq.comp_rdq_count++;
747                 }
748                 if (++items == credits)
749                         break;
750         }
751         if (items) {
752                 mlxsw_pci_queue_doorbell_consumer_ring(mlxsw_pci, q);
753                 mlxsw_pci_queue_doorbell_arm_consumer_ring(mlxsw_pci, q);
754         }
755 }
756
757 static int mlxsw_pci_eq_init(struct mlxsw_pci *mlxsw_pci, char *mbox,
758                              struct mlxsw_pci_queue *q)
759 {
760         int i;
761         int err;
762
763         q->consumer_counter = 0;
764
765         for (i = 0; i < q->count; i++) {
766                 char *elem = mlxsw_pci_queue_elem_get(q, i);
767
768                 mlxsw_pci_eqe_owner_set(elem, 1);
769         }
770
771         mlxsw_cmd_mbox_sw2hw_eq_int_msix_set(mbox, 1); /* MSI-X used */
772         mlxsw_cmd_mbox_sw2hw_eq_oi_set(mbox, 0);
773         mlxsw_cmd_mbox_sw2hw_eq_st_set(mbox, 1); /* armed */
774         mlxsw_cmd_mbox_sw2hw_eq_log_eq_size_set(mbox, ilog2(q->count));
775         for (i = 0; i < MLXSW_PCI_AQ_PAGES; i++) {
776                 dma_addr_t mapaddr = __mlxsw_pci_queue_page_get(q, i);
777
778                 mlxsw_cmd_mbox_sw2hw_eq_pa_set(mbox, i, mapaddr);
779         }
780         err = mlxsw_cmd_sw2hw_eq(mlxsw_pci->core, mbox, q->num);
781         if (err)
782                 return err;
783         mlxsw_pci_queue_doorbell_consumer_ring(mlxsw_pci, q);
784         mlxsw_pci_queue_doorbell_arm_consumer_ring(mlxsw_pci, q);
785         return 0;
786 }
787
788 static void mlxsw_pci_eq_fini(struct mlxsw_pci *mlxsw_pci,
789                               struct mlxsw_pci_queue *q)
790 {
791         mlxsw_cmd_hw2sw_eq(mlxsw_pci->core, q->num);
792 }
793
794 static int mlxsw_pci_eq_dbg_read(struct seq_file *file, void *data)
795 {
796         struct mlxsw_pci *mlxsw_pci = dev_get_drvdata(file->private);
797         struct mlxsw_pci_queue *q;
798         int i;
799         static const char hdr[] =
800                 "NUM CONS_COUNT     EV_CMD    EV_COMP   EV_OTHER COUNT\n";
801
802         seq_printf(file, hdr);
803         for (i = 0; i < mlxsw_pci_eq_count(mlxsw_pci); i++) {
804                 q = mlxsw_pci_eq_get(mlxsw_pci, i);
805                 spin_lock_bh(&q->lock);
806                 seq_printf(file, "%3d %10d %10d %10d %10d %5d\n",
807                            i, q->consumer_counter, q->u.eq.ev_cmd_count,
808                            q->u.eq.ev_comp_count, q->u.eq.ev_other_count,
809                            q->count);
810                 spin_unlock_bh(&q->lock);
811         }
812         return 0;
813 }
814
815 static void mlxsw_pci_eq_cmd_event(struct mlxsw_pci *mlxsw_pci, char *eqe)
816 {
817         mlxsw_pci->cmd.comp.status = mlxsw_pci_eqe_cmd_status_get(eqe);
818         mlxsw_pci->cmd.comp.out_param =
819                 ((u64) mlxsw_pci_eqe_cmd_out_param_h_get(eqe)) << 32 |
820                 mlxsw_pci_eqe_cmd_out_param_l_get(eqe);
821         mlxsw_pci->cmd.wait_done = true;
822         wake_up(&mlxsw_pci->cmd.wait);
823 }
824
825 static char *mlxsw_pci_eq_sw_eqe_get(struct mlxsw_pci_queue *q)
826 {
827         return mlxsw_pci_queue_sw_elem_get(q, mlxsw_pci_eqe_owner_get);
828 }
829
830 static void mlxsw_pci_eq_tasklet(unsigned long data)
831 {
832         struct mlxsw_pci_queue *q = (struct mlxsw_pci_queue *) data;
833         struct mlxsw_pci *mlxsw_pci = q->pci;
834         u8 cq_count = mlxsw_pci_cq_count(mlxsw_pci);
835         unsigned long active_cqns[BITS_TO_LONGS(MLXSW_PCI_CQS_MAX)];
836         char *eqe;
837         u8 cqn;
838         bool cq_handle = false;
839         int items = 0;
840         int credits = q->count >> 1;
841
842         memset(&active_cqns, 0, sizeof(active_cqns));
843
844         while ((eqe = mlxsw_pci_eq_sw_eqe_get(q))) {
845                 u8 event_type = mlxsw_pci_eqe_event_type_get(eqe);
846
847                 switch (event_type) {
848                 case MLXSW_PCI_EQE_EVENT_TYPE_CMD:
849                         mlxsw_pci_eq_cmd_event(mlxsw_pci, eqe);
850                         q->u.eq.ev_cmd_count++;
851                         break;
852                 case MLXSW_PCI_EQE_EVENT_TYPE_COMP:
853                         cqn = mlxsw_pci_eqe_cqn_get(eqe);
854                         set_bit(cqn, active_cqns);
855                         cq_handle = true;
856                         q->u.eq.ev_comp_count++;
857                         break;
858                 default:
859                         q->u.eq.ev_other_count++;
860                 }
861                 if (++items == credits)
862                         break;
863         }
864         if (items) {
865                 mlxsw_pci_queue_doorbell_consumer_ring(mlxsw_pci, q);
866                 mlxsw_pci_queue_doorbell_arm_consumer_ring(mlxsw_pci, q);
867         }
868
869         if (!cq_handle)
870                 return;
871         for_each_set_bit(cqn, active_cqns, cq_count) {
872                 q = mlxsw_pci_cq_get(mlxsw_pci, cqn);
873                 mlxsw_pci_queue_tasklet_schedule(q);
874         }
875 }
876
877 struct mlxsw_pci_queue_ops {
878         const char *name;
879         enum mlxsw_pci_queue_type type;
880         int (*init)(struct mlxsw_pci *mlxsw_pci, char *mbox,
881                     struct mlxsw_pci_queue *q);
882         void (*fini)(struct mlxsw_pci *mlxsw_pci,
883                      struct mlxsw_pci_queue *q);
884         void (*tasklet)(unsigned long data);
885         int (*dbg_read)(struct seq_file *s, void *data);
886         u16 elem_count;
887         u8 elem_size;
888 };
889
890 static const struct mlxsw_pci_queue_ops mlxsw_pci_sdq_ops = {
891         .type           = MLXSW_PCI_QUEUE_TYPE_SDQ,
892         .init           = mlxsw_pci_sdq_init,
893         .fini           = mlxsw_pci_sdq_fini,
894         .dbg_read       = mlxsw_pci_sdq_dbg_read,
895         .elem_count     = MLXSW_PCI_WQE_COUNT,
896         .elem_size      = MLXSW_PCI_WQE_SIZE,
897 };
898
899 static const struct mlxsw_pci_queue_ops mlxsw_pci_rdq_ops = {
900         .type           = MLXSW_PCI_QUEUE_TYPE_RDQ,
901         .init           = mlxsw_pci_rdq_init,
902         .fini           = mlxsw_pci_rdq_fini,
903         .dbg_read       = mlxsw_pci_rdq_dbg_read,
904         .elem_count     = MLXSW_PCI_WQE_COUNT,
905         .elem_size      = MLXSW_PCI_WQE_SIZE
906 };
907
908 static const struct mlxsw_pci_queue_ops mlxsw_pci_cq_ops = {
909         .type           = MLXSW_PCI_QUEUE_TYPE_CQ,
910         .init           = mlxsw_pci_cq_init,
911         .fini           = mlxsw_pci_cq_fini,
912         .tasklet        = mlxsw_pci_cq_tasklet,
913         .dbg_read       = mlxsw_pci_cq_dbg_read,
914         .elem_count     = MLXSW_PCI_CQE_COUNT,
915         .elem_size      = MLXSW_PCI_CQE_SIZE
916 };
917
918 static const struct mlxsw_pci_queue_ops mlxsw_pci_eq_ops = {
919         .type           = MLXSW_PCI_QUEUE_TYPE_EQ,
920         .init           = mlxsw_pci_eq_init,
921         .fini           = mlxsw_pci_eq_fini,
922         .tasklet        = mlxsw_pci_eq_tasklet,
923         .dbg_read       = mlxsw_pci_eq_dbg_read,
924         .elem_count     = MLXSW_PCI_EQE_COUNT,
925         .elem_size      = MLXSW_PCI_EQE_SIZE
926 };
927
928 static int mlxsw_pci_queue_init(struct mlxsw_pci *mlxsw_pci, char *mbox,
929                                 const struct mlxsw_pci_queue_ops *q_ops,
930                                 struct mlxsw_pci_queue *q, u8 q_num)
931 {
932         struct mlxsw_pci_mem_item *mem_item = &q->mem_item;
933         int i;
934         int err;
935
936         spin_lock_init(&q->lock);
937         q->num = q_num;
938         q->count = q_ops->elem_count;
939         q->elem_size = q_ops->elem_size;
940         q->type = q_ops->type;
941         q->pci = mlxsw_pci;
942
943         if (q_ops->tasklet)
944                 tasklet_init(&q->tasklet, q_ops->tasklet, (unsigned long) q);
945
946         mem_item->size = MLXSW_PCI_AQ_SIZE;
947         mem_item->buf = pci_alloc_consistent(mlxsw_pci->pdev,
948                                              mem_item->size,
949                                              &mem_item->mapaddr);
950         if (!mem_item->buf)
951                 return -ENOMEM;
952         memset(mem_item->buf, 0, mem_item->size);
953
954         q->elem_info = kcalloc(q->count, sizeof(*q->elem_info), GFP_KERNEL);
955         if (!q->elem_info) {
956                 err = -ENOMEM;
957                 goto err_elem_info_alloc;
958         }
959
960         /* Initialize dma mapped elements info elem_info for
961          * future easy access.
962          */
963         for (i = 0; i < q->count; i++) {
964                 struct mlxsw_pci_queue_elem_info *elem_info;
965
966                 elem_info = mlxsw_pci_queue_elem_info_get(q, i);
967                 elem_info->elem =
968                         __mlxsw_pci_queue_elem_get(q, q_ops->elem_size, i);
969         }
970
971         mlxsw_cmd_mbox_zero(mbox);
972         err = q_ops->init(mlxsw_pci, mbox, q);
973         if (err)
974                 goto err_q_ops_init;
975         return 0;
976
977 err_q_ops_init:
978         kfree(q->elem_info);
979 err_elem_info_alloc:
980         pci_free_consistent(mlxsw_pci->pdev, mem_item->size,
981                             mem_item->buf, mem_item->mapaddr);
982         return err;
983 }
984
985 static void mlxsw_pci_queue_fini(struct mlxsw_pci *mlxsw_pci,
986                                  const struct mlxsw_pci_queue_ops *q_ops,
987                                  struct mlxsw_pci_queue *q)
988 {
989         struct mlxsw_pci_mem_item *mem_item = &q->mem_item;
990
991         q_ops->fini(mlxsw_pci, q);
992         kfree(q->elem_info);
993         pci_free_consistent(mlxsw_pci->pdev, mem_item->size,
994                             mem_item->buf, mem_item->mapaddr);
995 }
996
997 static int mlxsw_pci_queue_group_init(struct mlxsw_pci *mlxsw_pci, char *mbox,
998                                       const struct mlxsw_pci_queue_ops *q_ops,
999                                       u8 num_qs)
1000 {
1001         struct pci_dev *pdev = mlxsw_pci->pdev;
1002         struct mlxsw_pci_queue_type_group *queue_group;
1003         char tmp[16];
1004         int i;
1005         int err;
1006
1007         queue_group = mlxsw_pci_queue_type_group_get(mlxsw_pci, q_ops->type);
1008         queue_group->q = kcalloc(num_qs, sizeof(*queue_group->q), GFP_KERNEL);
1009         if (!queue_group->q)
1010                 return -ENOMEM;
1011
1012         for (i = 0; i < num_qs; i++) {
1013                 err = mlxsw_pci_queue_init(mlxsw_pci, mbox, q_ops,
1014                                            &queue_group->q[i], i);
1015                 if (err)
1016                         goto err_queue_init;
1017         }
1018         queue_group->count = num_qs;
1019
1020         sprintf(tmp, "%s_stats", mlxsw_pci_queue_type_str(q_ops->type));
1021         debugfs_create_devm_seqfile(&pdev->dev, tmp, mlxsw_pci->dbg_dir,
1022                                     q_ops->dbg_read);
1023
1024         return 0;
1025
1026 err_queue_init:
1027         for (i--; i >= 0; i--)
1028                 mlxsw_pci_queue_fini(mlxsw_pci, q_ops, &queue_group->q[i]);
1029         kfree(queue_group->q);
1030         return err;
1031 }
1032
1033 static void mlxsw_pci_queue_group_fini(struct mlxsw_pci *mlxsw_pci,
1034                                        const struct mlxsw_pci_queue_ops *q_ops)
1035 {
1036         struct mlxsw_pci_queue_type_group *queue_group;
1037         int i;
1038
1039         queue_group = mlxsw_pci_queue_type_group_get(mlxsw_pci, q_ops->type);
1040         for (i = 0; i < queue_group->count; i++)
1041                 mlxsw_pci_queue_fini(mlxsw_pci, q_ops, &queue_group->q[i]);
1042         kfree(queue_group->q);
1043 }
1044
1045 static int mlxsw_pci_aqs_init(struct mlxsw_pci *mlxsw_pci, char *mbox)
1046 {
1047         struct pci_dev *pdev = mlxsw_pci->pdev;
1048         u8 num_sdqs;
1049         u8 sdq_log2sz;
1050         u8 num_rdqs;
1051         u8 rdq_log2sz;
1052         u8 num_cqs;
1053         u8 cq_log2sz;
1054         u8 num_eqs;
1055         u8 eq_log2sz;
1056         int err;
1057
1058         mlxsw_cmd_mbox_zero(mbox);
1059         err = mlxsw_cmd_query_aq_cap(mlxsw_pci->core, mbox);
1060         if (err)
1061                 return err;
1062
1063         num_sdqs = mlxsw_cmd_mbox_query_aq_cap_max_num_sdqs_get(mbox);
1064         sdq_log2sz = mlxsw_cmd_mbox_query_aq_cap_log_max_sdq_sz_get(mbox);
1065         num_rdqs = mlxsw_cmd_mbox_query_aq_cap_max_num_rdqs_get(mbox);
1066         rdq_log2sz = mlxsw_cmd_mbox_query_aq_cap_log_max_rdq_sz_get(mbox);
1067         num_cqs = mlxsw_cmd_mbox_query_aq_cap_max_num_cqs_get(mbox);
1068         cq_log2sz = mlxsw_cmd_mbox_query_aq_cap_log_max_cq_sz_get(mbox);
1069         num_eqs = mlxsw_cmd_mbox_query_aq_cap_max_num_eqs_get(mbox);
1070         eq_log2sz = mlxsw_cmd_mbox_query_aq_cap_log_max_eq_sz_get(mbox);
1071
1072         if (num_sdqs + num_rdqs > num_cqs ||
1073             num_cqs > MLXSW_PCI_CQS_MAX || num_eqs != MLXSW_PCI_EQS_COUNT) {
1074                 dev_err(&pdev->dev, "Unsupported number of queues\n");
1075                 return -EINVAL;
1076         }
1077
1078         if ((1 << sdq_log2sz != MLXSW_PCI_WQE_COUNT) ||
1079             (1 << rdq_log2sz != MLXSW_PCI_WQE_COUNT) ||
1080             (1 << cq_log2sz != MLXSW_PCI_CQE_COUNT) ||
1081             (1 << eq_log2sz != MLXSW_PCI_EQE_COUNT)) {
1082                 dev_err(&pdev->dev, "Unsupported number of async queue descriptors\n");
1083                 return -EINVAL;
1084         }
1085
1086         err = mlxsw_pci_queue_group_init(mlxsw_pci, mbox, &mlxsw_pci_eq_ops,
1087                                          num_eqs);
1088         if (err) {
1089                 dev_err(&pdev->dev, "Failed to initialize event queues\n");
1090                 return err;
1091         }
1092
1093         err = mlxsw_pci_queue_group_init(mlxsw_pci, mbox, &mlxsw_pci_cq_ops,
1094                                          num_cqs);
1095         if (err) {
1096                 dev_err(&pdev->dev, "Failed to initialize completion queues\n");
1097                 goto err_cqs_init;
1098         }
1099
1100         err = mlxsw_pci_queue_group_init(mlxsw_pci, mbox, &mlxsw_pci_sdq_ops,
1101                                          num_sdqs);
1102         if (err) {
1103                 dev_err(&pdev->dev, "Failed to initialize send descriptor queues\n");
1104                 goto err_sdqs_init;
1105         }
1106
1107         err = mlxsw_pci_queue_group_init(mlxsw_pci, mbox, &mlxsw_pci_rdq_ops,
1108                                          num_rdqs);
1109         if (err) {
1110                 dev_err(&pdev->dev, "Failed to initialize receive descriptor queues\n");
1111                 goto err_rdqs_init;
1112         }
1113
1114         /* We have to poll in command interface until queues are initialized */
1115         mlxsw_pci->cmd.nopoll = true;
1116         return 0;
1117
1118 err_rdqs_init:
1119         mlxsw_pci_queue_group_fini(mlxsw_pci, &mlxsw_pci_sdq_ops);
1120 err_sdqs_init:
1121         mlxsw_pci_queue_group_fini(mlxsw_pci, &mlxsw_pci_cq_ops);
1122 err_cqs_init:
1123         mlxsw_pci_queue_group_fini(mlxsw_pci, &mlxsw_pci_eq_ops);
1124         return err;
1125 }
1126
1127 static void mlxsw_pci_aqs_fini(struct mlxsw_pci *mlxsw_pci)
1128 {
1129         mlxsw_pci->cmd.nopoll = false;
1130         mlxsw_pci_queue_group_fini(mlxsw_pci, &mlxsw_pci_rdq_ops);
1131         mlxsw_pci_queue_group_fini(mlxsw_pci, &mlxsw_pci_sdq_ops);
1132         mlxsw_pci_queue_group_fini(mlxsw_pci, &mlxsw_pci_cq_ops);
1133         mlxsw_pci_queue_group_fini(mlxsw_pci, &mlxsw_pci_eq_ops);
1134 }
1135
1136 static void
1137 mlxsw_pci_config_profile_swid_config(struct mlxsw_pci *mlxsw_pci,
1138                                      char *mbox, int index,
1139                                      const struct mlxsw_swid_config *swid)
1140 {
1141         u8 mask = 0;
1142
1143         if (swid->used_type) {
1144                 mlxsw_cmd_mbox_config_profile_swid_config_type_set(
1145                         mbox, index, swid->type);
1146                 mask |= 1;
1147         }
1148         if (swid->used_properties) {
1149                 mlxsw_cmd_mbox_config_profile_swid_config_properties_set(
1150                         mbox, index, swid->properties);
1151                 mask |= 2;
1152         }
1153         mlxsw_cmd_mbox_config_profile_swid_config_mask_set(mbox, index, mask);
1154 }
1155
1156 static int mlxsw_pci_config_profile(struct mlxsw_pci *mlxsw_pci, char *mbox,
1157                                     const struct mlxsw_config_profile *profile)
1158 {
1159         int i;
1160
1161         mlxsw_cmd_mbox_zero(mbox);
1162
1163         if (profile->used_max_vepa_channels) {
1164                 mlxsw_cmd_mbox_config_profile_set_max_vepa_channels_set(
1165                         mbox, 1);
1166                 mlxsw_cmd_mbox_config_profile_max_vepa_channels_set(
1167                         mbox, profile->max_vepa_channels);
1168         }
1169         if (profile->used_max_lag) {
1170                 mlxsw_cmd_mbox_config_profile_set_max_lag_set(
1171                         mbox, 1);
1172                 mlxsw_cmd_mbox_config_profile_max_lag_set(
1173                         mbox, profile->max_lag);
1174         }
1175         if (profile->used_max_port_per_lag) {
1176                 mlxsw_cmd_mbox_config_profile_set_max_port_per_lag_set(
1177                         mbox, 1);
1178                 mlxsw_cmd_mbox_config_profile_max_port_per_lag_set(
1179                         mbox, profile->max_port_per_lag);
1180         }
1181         if (profile->used_max_mid) {
1182                 mlxsw_cmd_mbox_config_profile_set_max_mid_set(
1183                         mbox, 1);
1184                 mlxsw_cmd_mbox_config_profile_max_mid_set(
1185                         mbox, profile->max_mid);
1186         }
1187         if (profile->used_max_pgt) {
1188                 mlxsw_cmd_mbox_config_profile_set_max_pgt_set(
1189                         mbox, 1);
1190                 mlxsw_cmd_mbox_config_profile_max_pgt_set(
1191                         mbox, profile->max_pgt);
1192         }
1193         if (profile->used_max_system_port) {
1194                 mlxsw_cmd_mbox_config_profile_set_max_system_port_set(
1195                         mbox, 1);
1196                 mlxsw_cmd_mbox_config_profile_max_system_port_set(
1197                         mbox, profile->max_system_port);
1198         }
1199         if (profile->used_max_vlan_groups) {
1200                 mlxsw_cmd_mbox_config_profile_set_max_vlan_groups_set(
1201                         mbox, 1);
1202                 mlxsw_cmd_mbox_config_profile_max_vlan_groups_set(
1203                         mbox, profile->max_vlan_groups);
1204         }
1205         if (profile->used_max_regions) {
1206                 mlxsw_cmd_mbox_config_profile_set_max_regions_set(
1207                         mbox, 1);
1208                 mlxsw_cmd_mbox_config_profile_max_regions_set(
1209                         mbox, profile->max_regions);
1210         }
1211         if (profile->used_flood_tables) {
1212                 mlxsw_cmd_mbox_config_profile_set_flood_tables_set(
1213                         mbox, 1);
1214                 mlxsw_cmd_mbox_config_profile_max_flood_tables_set(
1215                         mbox, profile->max_flood_tables);
1216                 mlxsw_cmd_mbox_config_profile_max_vid_flood_tables_set(
1217                         mbox, profile->max_vid_flood_tables);
1218         }
1219         if (profile->used_flood_mode) {
1220                 mlxsw_cmd_mbox_config_profile_set_flood_mode_set(
1221                         mbox, 1);
1222                 mlxsw_cmd_mbox_config_profile_flood_mode_set(
1223                         mbox, profile->flood_mode);
1224         }
1225         if (profile->used_max_ib_mc) {
1226                 mlxsw_cmd_mbox_config_profile_set_max_ib_mc_set(
1227                         mbox, 1);
1228                 mlxsw_cmd_mbox_config_profile_max_ib_mc_set(
1229                         mbox, profile->max_ib_mc);
1230         }
1231         if (profile->used_max_pkey) {
1232                 mlxsw_cmd_mbox_config_profile_set_max_pkey_set(
1233                         mbox, 1);
1234                 mlxsw_cmd_mbox_config_profile_max_pkey_set(
1235                         mbox, profile->max_pkey);
1236         }
1237         if (profile->used_ar_sec) {
1238                 mlxsw_cmd_mbox_config_profile_set_ar_sec_set(
1239                         mbox, 1);
1240                 mlxsw_cmd_mbox_config_profile_ar_sec_set(
1241                         mbox, profile->ar_sec);
1242         }
1243         if (profile->used_adaptive_routing_group_cap) {
1244                 mlxsw_cmd_mbox_config_profile_set_adaptive_routing_group_cap_set(
1245                         mbox, 1);
1246                 mlxsw_cmd_mbox_config_profile_adaptive_routing_group_cap_set(
1247                         mbox, profile->adaptive_routing_group_cap);
1248         }
1249
1250         for (i = 0; i < MLXSW_CONFIG_PROFILE_SWID_COUNT; i++)
1251                 mlxsw_pci_config_profile_swid_config(mlxsw_pci, mbox, i,
1252                                                      &profile->swid_config[i]);
1253
1254         return mlxsw_cmd_config_profile_set(mlxsw_pci->core, mbox);
1255 }
1256
1257 static int mlxsw_pci_boardinfo(struct mlxsw_pci *mlxsw_pci, char *mbox)
1258 {
1259         struct mlxsw_bus_info *bus_info = &mlxsw_pci->bus_info;
1260         int err;
1261
1262         mlxsw_cmd_mbox_zero(mbox);
1263         err = mlxsw_cmd_boardinfo(mlxsw_pci->core, mbox);
1264         if (err)
1265                 return err;
1266         mlxsw_cmd_mbox_boardinfo_vsd_memcpy_from(mbox, bus_info->vsd);
1267         mlxsw_cmd_mbox_boardinfo_psid_memcpy_from(mbox, bus_info->psid);
1268         return 0;
1269 }
1270
1271 static int mlxsw_pci_fw_area_init(struct mlxsw_pci *mlxsw_pci, char *mbox,
1272                                   u16 num_pages)
1273 {
1274         struct mlxsw_pci_mem_item *mem_item;
1275         int nent = 0;
1276         int i;
1277         int err;
1278
1279         mlxsw_pci->fw_area.items = kcalloc(num_pages, sizeof(*mem_item),
1280                                            GFP_KERNEL);
1281         if (!mlxsw_pci->fw_area.items)
1282                 return -ENOMEM;
1283         mlxsw_pci->fw_area.count = num_pages;
1284
1285         mlxsw_cmd_mbox_zero(mbox);
1286         for (i = 0; i < num_pages; i++) {
1287                 mem_item = &mlxsw_pci->fw_area.items[i];
1288
1289                 mem_item->size = MLXSW_PCI_PAGE_SIZE;
1290                 mem_item->buf = pci_alloc_consistent(mlxsw_pci->pdev,
1291                                                      mem_item->size,
1292                                                      &mem_item->mapaddr);
1293                 if (!mem_item->buf) {
1294                         err = -ENOMEM;
1295                         goto err_alloc;
1296                 }
1297                 mlxsw_cmd_mbox_map_fa_pa_set(mbox, nent, mem_item->mapaddr);
1298                 mlxsw_cmd_mbox_map_fa_log2size_set(mbox, nent, 0); /* 1 page */
1299                 if (++nent == MLXSW_CMD_MAP_FA_VPM_ENTRIES_MAX) {
1300                         err = mlxsw_cmd_map_fa(mlxsw_pci->core, mbox, nent);
1301                         if (err)
1302                                 goto err_cmd_map_fa;
1303                         nent = 0;
1304                         mlxsw_cmd_mbox_zero(mbox);
1305                 }
1306         }
1307
1308         if (nent) {
1309                 err = mlxsw_cmd_map_fa(mlxsw_pci->core, mbox, nent);
1310                 if (err)
1311                         goto err_cmd_map_fa;
1312         }
1313
1314         return 0;
1315
1316 err_cmd_map_fa:
1317 err_alloc:
1318         for (i--; i >= 0; i--) {
1319                 mem_item = &mlxsw_pci->fw_area.items[i];
1320
1321                 pci_free_consistent(mlxsw_pci->pdev, mem_item->size,
1322                                     mem_item->buf, mem_item->mapaddr);
1323         }
1324         kfree(mlxsw_pci->fw_area.items);
1325         return err;
1326 }
1327
1328 static void mlxsw_pci_fw_area_fini(struct mlxsw_pci *mlxsw_pci)
1329 {
1330         struct mlxsw_pci_mem_item *mem_item;
1331         int i;
1332
1333         mlxsw_cmd_unmap_fa(mlxsw_pci->core);
1334
1335         for (i = 0; i < mlxsw_pci->fw_area.count; i++) {
1336                 mem_item = &mlxsw_pci->fw_area.items[i];
1337
1338                 pci_free_consistent(mlxsw_pci->pdev, mem_item->size,
1339                                     mem_item->buf, mem_item->mapaddr);
1340         }
1341         kfree(mlxsw_pci->fw_area.items);
1342 }
1343
1344 static irqreturn_t mlxsw_pci_eq_irq_handler(int irq, void *dev_id)
1345 {
1346         struct mlxsw_pci *mlxsw_pci = dev_id;
1347         struct mlxsw_pci_queue *q;
1348         int i;
1349
1350         for (i = 0; i < MLXSW_PCI_EQS_COUNT; i++) {
1351                 q = mlxsw_pci_eq_get(mlxsw_pci, i);
1352                 mlxsw_pci_queue_tasklet_schedule(q);
1353         }
1354         return IRQ_HANDLED;
1355 }
1356
1357 static int mlxsw_pci_mbox_alloc(struct mlxsw_pci *mlxsw_pci,
1358                                 struct mlxsw_pci_mem_item *mbox)
1359 {
1360         struct pci_dev *pdev = mlxsw_pci->pdev;
1361         int err = 0;
1362
1363         mbox->size = MLXSW_CMD_MBOX_SIZE;
1364         mbox->buf = pci_alloc_consistent(pdev, MLXSW_CMD_MBOX_SIZE,
1365                                          &mbox->mapaddr);
1366         if (!mbox->buf) {
1367                 dev_err(&pdev->dev, "Failed allocating memory for mailbox\n");
1368                 err = -ENOMEM;
1369         }
1370
1371         return err;
1372 }
1373
1374 static void mlxsw_pci_mbox_free(struct mlxsw_pci *mlxsw_pci,
1375                                 struct mlxsw_pci_mem_item *mbox)
1376 {
1377         struct pci_dev *pdev = mlxsw_pci->pdev;
1378
1379         pci_free_consistent(pdev, MLXSW_CMD_MBOX_SIZE, mbox->buf,
1380                             mbox->mapaddr);
1381 }
1382
1383 static int mlxsw_pci_init(void *bus_priv, struct mlxsw_core *mlxsw_core,
1384                           const struct mlxsw_config_profile *profile)
1385 {
1386         struct mlxsw_pci *mlxsw_pci = bus_priv;
1387         struct pci_dev *pdev = mlxsw_pci->pdev;
1388         char *mbox;
1389         u16 num_pages;
1390         int err;
1391
1392         mutex_init(&mlxsw_pci->cmd.lock);
1393         init_waitqueue_head(&mlxsw_pci->cmd.wait);
1394
1395         mlxsw_pci->core = mlxsw_core;
1396
1397         mbox = mlxsw_cmd_mbox_alloc();
1398         if (!mbox)
1399                 return -ENOMEM;
1400
1401         err = mlxsw_pci_mbox_alloc(mlxsw_pci, &mlxsw_pci->cmd.in_mbox);
1402         if (err)
1403                 goto mbox_put;
1404
1405         err = mlxsw_pci_mbox_alloc(mlxsw_pci, &mlxsw_pci->cmd.out_mbox);
1406         if (err)
1407                 goto err_out_mbox_alloc;
1408
1409         err = mlxsw_cmd_query_fw(mlxsw_core, mbox);
1410         if (err)
1411                 goto err_query_fw;
1412
1413         mlxsw_pci->bus_info.fw_rev.major =
1414                 mlxsw_cmd_mbox_query_fw_fw_rev_major_get(mbox);
1415         mlxsw_pci->bus_info.fw_rev.minor =
1416                 mlxsw_cmd_mbox_query_fw_fw_rev_minor_get(mbox);
1417         mlxsw_pci->bus_info.fw_rev.subminor =
1418                 mlxsw_cmd_mbox_query_fw_fw_rev_subminor_get(mbox);
1419
1420         if (mlxsw_cmd_mbox_query_fw_cmd_interface_rev_get(mbox) != 1) {
1421                 dev_err(&pdev->dev, "Unsupported cmd interface revision ID queried from hw\n");
1422                 err = -EINVAL;
1423                 goto err_iface_rev;
1424         }
1425         if (mlxsw_cmd_mbox_query_fw_doorbell_page_bar_get(mbox) != 0) {
1426                 dev_err(&pdev->dev, "Unsupported doorbell page bar queried from hw\n");
1427                 err = -EINVAL;
1428                 goto err_doorbell_page_bar;
1429         }
1430
1431         mlxsw_pci->doorbell_offset =
1432                 mlxsw_cmd_mbox_query_fw_doorbell_page_offset_get(mbox);
1433
1434         num_pages = mlxsw_cmd_mbox_query_fw_fw_pages_get(mbox);
1435         err = mlxsw_pci_fw_area_init(mlxsw_pci, mbox, num_pages);
1436         if (err)
1437                 goto err_fw_area_init;
1438
1439         err = mlxsw_pci_boardinfo(mlxsw_pci, mbox);
1440         if (err)
1441                 goto err_boardinfo;
1442
1443         err = mlxsw_pci_config_profile(mlxsw_pci, mbox, profile);
1444         if (err)
1445                 goto err_config_profile;
1446
1447         err = mlxsw_pci_aqs_init(mlxsw_pci, mbox);
1448         if (err)
1449                 goto err_aqs_init;
1450
1451         err = request_irq(mlxsw_pci->msix_entry.vector,
1452                           mlxsw_pci_eq_irq_handler, 0,
1453                           mlxsw_pci_driver_name, mlxsw_pci);
1454         if (err) {
1455                 dev_err(&pdev->dev, "IRQ request failed\n");
1456                 goto err_request_eq_irq;
1457         }
1458
1459         goto mbox_put;
1460
1461 err_request_eq_irq:
1462         mlxsw_pci_aqs_fini(mlxsw_pci);
1463 err_aqs_init:
1464 err_config_profile:
1465 err_boardinfo:
1466         mlxsw_pci_fw_area_fini(mlxsw_pci);
1467 err_fw_area_init:
1468 err_doorbell_page_bar:
1469 err_iface_rev:
1470 err_query_fw:
1471         mlxsw_pci_mbox_free(mlxsw_pci, &mlxsw_pci->cmd.out_mbox);
1472 err_out_mbox_alloc:
1473         mlxsw_pci_mbox_free(mlxsw_pci, &mlxsw_pci->cmd.in_mbox);
1474 mbox_put:
1475         mlxsw_cmd_mbox_free(mbox);
1476         return err;
1477 }
1478
1479 static void mlxsw_pci_fini(void *bus_priv)
1480 {
1481         struct mlxsw_pci *mlxsw_pci = bus_priv;
1482
1483         free_irq(mlxsw_pci->msix_entry.vector, mlxsw_pci);
1484         mlxsw_pci_aqs_fini(mlxsw_pci);
1485         mlxsw_pci_fw_area_fini(mlxsw_pci);
1486         mlxsw_pci_mbox_free(mlxsw_pci, &mlxsw_pci->cmd.out_mbox);
1487         mlxsw_pci_mbox_free(mlxsw_pci, &mlxsw_pci->cmd.in_mbox);
1488 }
1489
1490 static struct mlxsw_pci_queue *
1491 mlxsw_pci_sdq_pick(struct mlxsw_pci *mlxsw_pci,
1492                    const struct mlxsw_tx_info *tx_info)
1493 {
1494         u8 sdqn = tx_info->local_port % mlxsw_pci_sdq_count(mlxsw_pci);
1495
1496         return mlxsw_pci_sdq_get(mlxsw_pci, sdqn);
1497 }
1498
1499 static bool mlxsw_pci_skb_transmit_busy(void *bus_priv,
1500                                         const struct mlxsw_tx_info *tx_info)
1501 {
1502         struct mlxsw_pci *mlxsw_pci = bus_priv;
1503         struct mlxsw_pci_queue *q = mlxsw_pci_sdq_pick(mlxsw_pci, tx_info);
1504
1505         return !mlxsw_pci_queue_elem_info_producer_get(q);
1506 }
1507
1508 static int mlxsw_pci_skb_transmit(void *bus_priv, struct sk_buff *skb,
1509                                   const struct mlxsw_tx_info *tx_info)
1510 {
1511         struct mlxsw_pci *mlxsw_pci = bus_priv;
1512         struct mlxsw_pci_queue *q;
1513         struct mlxsw_pci_queue_elem_info *elem_info;
1514         char *wqe;
1515         int i;
1516         int err;
1517
1518         if (skb_shinfo(skb)->nr_frags > MLXSW_PCI_WQE_SG_ENTRIES - 1) {
1519                 err = skb_linearize(skb);
1520                 if (err)
1521                         return err;
1522         }
1523
1524         q = mlxsw_pci_sdq_pick(mlxsw_pci, tx_info);
1525         spin_lock_bh(&q->lock);
1526         elem_info = mlxsw_pci_queue_elem_info_producer_get(q);
1527         if (!elem_info) {
1528                 /* queue is full */
1529                 err = -EAGAIN;
1530                 goto unlock;
1531         }
1532         elem_info->u.sdq.skb = skb;
1533
1534         wqe = elem_info->elem;
1535         mlxsw_pci_wqe_c_set(wqe, 1); /* always report completion */
1536         mlxsw_pci_wqe_lp_set(wqe, !!tx_info->is_emad);
1537         mlxsw_pci_wqe_type_set(wqe, MLXSW_PCI_WQE_TYPE_ETHERNET);
1538
1539         err = mlxsw_pci_wqe_frag_map(mlxsw_pci, wqe, 0, skb->data,
1540                                      skb_headlen(skb), DMA_TO_DEVICE);
1541         if (err)
1542                 goto unlock;
1543
1544         for (i = 0; i < skb_shinfo(skb)->nr_frags; i++) {
1545                 const skb_frag_t *frag = &skb_shinfo(skb)->frags[i];
1546
1547                 err = mlxsw_pci_wqe_frag_map(mlxsw_pci, wqe, i + 1,
1548                                              skb_frag_address(frag),
1549                                              skb_frag_size(frag),
1550                                              DMA_TO_DEVICE);
1551                 if (err)
1552                         goto unmap_frags;
1553         }
1554
1555         /* Set unused sq entries byte count to zero. */
1556         for (i++; i < MLXSW_PCI_WQE_SG_ENTRIES; i++)
1557                 mlxsw_pci_wqe_byte_count_set(wqe, i, 0);
1558
1559         /* Everything is set up, ring producer doorbell to get HW going */
1560         q->producer_counter++;
1561         mlxsw_pci_queue_doorbell_producer_ring(mlxsw_pci, q);
1562
1563         goto unlock;
1564
1565 unmap_frags:
1566         for (; i >= 0; i--)
1567                 mlxsw_pci_wqe_frag_unmap(mlxsw_pci, wqe, i, DMA_TO_DEVICE);
1568 unlock:
1569         spin_unlock_bh(&q->lock);
1570         return err;
1571 }
1572
1573 static int mlxsw_pci_cmd_exec(void *bus_priv, u16 opcode, u8 opcode_mod,
1574                               u32 in_mod, bool out_mbox_direct,
1575                               char *in_mbox, size_t in_mbox_size,
1576                               char *out_mbox, size_t out_mbox_size,
1577                               u8 *p_status)
1578 {
1579         struct mlxsw_pci *mlxsw_pci = bus_priv;
1580         dma_addr_t in_mapaddr = mlxsw_pci->cmd.in_mbox.mapaddr;
1581         dma_addr_t out_mapaddr = mlxsw_pci->cmd.out_mbox.mapaddr;
1582         bool evreq = mlxsw_pci->cmd.nopoll;
1583         unsigned long timeout = msecs_to_jiffies(MLXSW_PCI_CIR_TIMEOUT_MSECS);
1584         bool *p_wait_done = &mlxsw_pci->cmd.wait_done;
1585         int err;
1586
1587         *p_status = MLXSW_CMD_STATUS_OK;
1588
1589         err = mutex_lock_interruptible(&mlxsw_pci->cmd.lock);
1590         if (err)
1591                 return err;
1592
1593         if (in_mbox)
1594                 memcpy(mlxsw_pci->cmd.in_mbox.buf, in_mbox, in_mbox_size);
1595         mlxsw_pci_write32(mlxsw_pci, CIR_IN_PARAM_HI, in_mapaddr >> 32);
1596         mlxsw_pci_write32(mlxsw_pci, CIR_IN_PARAM_LO, in_mapaddr);
1597
1598         mlxsw_pci_write32(mlxsw_pci, CIR_OUT_PARAM_HI, out_mapaddr >> 32);
1599         mlxsw_pci_write32(mlxsw_pci, CIR_OUT_PARAM_LO, out_mapaddr);
1600
1601         mlxsw_pci_write32(mlxsw_pci, CIR_IN_MODIFIER, in_mod);
1602         mlxsw_pci_write32(mlxsw_pci, CIR_TOKEN, 0);
1603
1604         *p_wait_done = false;
1605
1606         wmb(); /* all needs to be written before we write control register */
1607         mlxsw_pci_write32(mlxsw_pci, CIR_CTRL,
1608                           MLXSW_PCI_CIR_CTRL_GO_BIT |
1609                           (evreq ? MLXSW_PCI_CIR_CTRL_EVREQ_BIT : 0) |
1610                           (opcode_mod << MLXSW_PCI_CIR_CTRL_OPCODE_MOD_SHIFT) |
1611                           opcode);
1612
1613         if (!evreq) {
1614                 unsigned long end;
1615
1616                 end = jiffies + timeout;
1617                 do {
1618                         u32 ctrl = mlxsw_pci_read32(mlxsw_pci, CIR_CTRL);
1619
1620                         if (!(ctrl & MLXSW_PCI_CIR_CTRL_GO_BIT)) {
1621                                 *p_wait_done = true;
1622                                 *p_status = ctrl >> MLXSW_PCI_CIR_CTRL_STATUS_SHIFT;
1623                                 break;
1624                         }
1625                         cond_resched();
1626                 } while (time_before(jiffies, end));
1627         } else {
1628                 wait_event_timeout(mlxsw_pci->cmd.wait, *p_wait_done, timeout);
1629                 *p_status = mlxsw_pci->cmd.comp.status;
1630         }
1631
1632         err = 0;
1633         if (*p_wait_done) {
1634                 if (*p_status)
1635                         err = -EIO;
1636         } else {
1637                 err = -ETIMEDOUT;
1638         }
1639
1640         if (!err && out_mbox && out_mbox_direct) {
1641                 /* Some commands don't use output param as address to mailbox
1642                  * but they store output directly into registers. In that case,
1643                  * copy registers into mbox buffer.
1644                  */
1645                 __be32 tmp;
1646
1647                 if (!evreq) {
1648                         tmp = cpu_to_be32(mlxsw_pci_read32(mlxsw_pci,
1649                                                            CIR_OUT_PARAM_HI));
1650                         memcpy(out_mbox, &tmp, sizeof(tmp));
1651                         tmp = cpu_to_be32(mlxsw_pci_read32(mlxsw_pci,
1652                                                            CIR_OUT_PARAM_LO));
1653                         memcpy(out_mbox + sizeof(tmp), &tmp, sizeof(tmp));
1654                 }
1655         } else if (!err && out_mbox)
1656                 memcpy(out_mbox, mlxsw_pci->cmd.out_mbox.buf, out_mbox_size);
1657
1658         mutex_unlock(&mlxsw_pci->cmd.lock);
1659
1660         return err;
1661 }
1662
1663 static const struct mlxsw_bus mlxsw_pci_bus = {
1664         .kind                   = "pci",
1665         .init                   = mlxsw_pci_init,
1666         .fini                   = mlxsw_pci_fini,
1667         .skb_transmit_busy      = mlxsw_pci_skb_transmit_busy,
1668         .skb_transmit           = mlxsw_pci_skb_transmit,
1669         .cmd_exec               = mlxsw_pci_cmd_exec,
1670 };
1671
1672 static int mlxsw_pci_sw_reset(struct mlxsw_pci *mlxsw_pci)
1673 {
1674         mlxsw_pci_write32(mlxsw_pci, SW_RESET, MLXSW_PCI_SW_RESET_RST_BIT);
1675         /* Current firware does not let us know when the reset is done.
1676          * So we just wait here for constant time and hope for the best.
1677          */
1678         msleep(MLXSW_PCI_SW_RESET_TIMEOUT_MSECS);
1679         return 0;
1680 }
1681
1682 static int mlxsw_pci_probe(struct pci_dev *pdev, const struct pci_device_id *id)
1683 {
1684         struct mlxsw_pci *mlxsw_pci;
1685         int err;
1686
1687         mlxsw_pci = kzalloc(sizeof(*mlxsw_pci), GFP_KERNEL);
1688         if (!mlxsw_pci)
1689                 return -ENOMEM;
1690
1691         err = pci_enable_device(pdev);
1692         if (err) {
1693                 dev_err(&pdev->dev, "pci_enable_device failed\n");
1694                 goto err_pci_enable_device;
1695         }
1696
1697         err = pci_request_regions(pdev, mlxsw_pci_driver_name);
1698         if (err) {
1699                 dev_err(&pdev->dev, "pci_request_regions failed\n");
1700                 goto err_pci_request_regions;
1701         }
1702
1703         err = pci_set_dma_mask(pdev, DMA_BIT_MASK(64));
1704         if (!err) {
1705                 err = pci_set_consistent_dma_mask(pdev, DMA_BIT_MASK(64));
1706                 if (err) {
1707                         dev_err(&pdev->dev, "pci_set_consistent_dma_mask failed\n");
1708                         goto err_pci_set_dma_mask;
1709                 }
1710         } else {
1711                 err = pci_set_dma_mask(pdev, DMA_BIT_MASK(32));
1712                 if (err) {
1713                         dev_err(&pdev->dev, "pci_set_dma_mask failed\n");
1714                         goto err_pci_set_dma_mask;
1715                 }
1716         }
1717
1718         if (pci_resource_len(pdev, 0) < MLXSW_PCI_BAR0_SIZE) {
1719                 dev_err(&pdev->dev, "invalid PCI region size\n");
1720                 err = -EINVAL;
1721                 goto err_pci_resource_len_check;
1722         }
1723
1724         mlxsw_pci->hw_addr = ioremap(pci_resource_start(pdev, 0),
1725                                      pci_resource_len(pdev, 0));
1726         if (!mlxsw_pci->hw_addr) {
1727                 dev_err(&pdev->dev, "ioremap failed\n");
1728                 err = -EIO;
1729                 goto err_ioremap;
1730         }
1731         pci_set_master(pdev);
1732
1733         mlxsw_pci->pdev = pdev;
1734         pci_set_drvdata(pdev, mlxsw_pci);
1735
1736         err = mlxsw_pci_sw_reset(mlxsw_pci);
1737         if (err) {
1738                 dev_err(&pdev->dev, "Software reset failed\n");
1739                 goto err_sw_reset;
1740         }
1741
1742         err = pci_enable_msix_exact(pdev, &mlxsw_pci->msix_entry, 1);
1743         if (err) {
1744                 dev_err(&pdev->dev, "MSI-X init failed\n");
1745                 goto err_msix_init;
1746         }
1747
1748         mlxsw_pci->bus_info.device_kind = mlxsw_pci_device_kind_get(id);
1749         mlxsw_pci->bus_info.device_name = pci_name(mlxsw_pci->pdev);
1750         mlxsw_pci->bus_info.dev = &pdev->dev;
1751
1752         mlxsw_pci->dbg_dir = debugfs_create_dir(mlxsw_pci->bus_info.device_name,
1753                                                 mlxsw_pci_dbg_root);
1754         if (!mlxsw_pci->dbg_dir) {
1755                 dev_err(&pdev->dev, "Failed to create debugfs dir\n");
1756                 err = -ENOMEM;
1757                 goto err_dbg_create_dir;
1758         }
1759
1760         err = mlxsw_core_bus_device_register(&mlxsw_pci->bus_info,
1761                                              &mlxsw_pci_bus, mlxsw_pci);
1762         if (err) {
1763                 dev_err(&pdev->dev, "cannot register bus device\n");
1764                 goto err_bus_device_register;
1765         }
1766
1767         return 0;
1768
1769 err_bus_device_register:
1770         debugfs_remove_recursive(mlxsw_pci->dbg_dir);
1771 err_dbg_create_dir:
1772         pci_disable_msix(mlxsw_pci->pdev);
1773 err_msix_init:
1774 err_sw_reset:
1775         iounmap(mlxsw_pci->hw_addr);
1776 err_ioremap:
1777 err_pci_resource_len_check:
1778 err_pci_set_dma_mask:
1779         pci_release_regions(pdev);
1780 err_pci_request_regions:
1781         pci_disable_device(pdev);
1782 err_pci_enable_device:
1783         kfree(mlxsw_pci);
1784         return err;
1785 }
1786
1787 static void mlxsw_pci_remove(struct pci_dev *pdev)
1788 {
1789         struct mlxsw_pci *mlxsw_pci = pci_get_drvdata(pdev);
1790
1791         mlxsw_core_bus_device_unregister(mlxsw_pci->core);
1792         debugfs_remove_recursive(mlxsw_pci->dbg_dir);
1793         pci_disable_msix(mlxsw_pci->pdev);
1794         iounmap(mlxsw_pci->hw_addr);
1795         pci_release_regions(mlxsw_pci->pdev);
1796         pci_disable_device(mlxsw_pci->pdev);
1797         kfree(mlxsw_pci);
1798 }
1799
1800 static struct pci_driver mlxsw_pci_driver = {
1801         .name           = mlxsw_pci_driver_name,
1802         .id_table       = mlxsw_pci_id_table,
1803         .probe          = mlxsw_pci_probe,
1804         .remove         = mlxsw_pci_remove,
1805 };
1806
1807 static int __init mlxsw_pci_module_init(void)
1808 {
1809         int err;
1810
1811         mlxsw_pci_dbg_root = debugfs_create_dir(mlxsw_pci_driver_name, NULL);
1812         if (!mlxsw_pci_dbg_root)
1813                 return -ENOMEM;
1814         err = pci_register_driver(&mlxsw_pci_driver);
1815         if (err)
1816                 goto err_register_driver;
1817         return 0;
1818
1819 err_register_driver:
1820         debugfs_remove_recursive(mlxsw_pci_dbg_root);
1821         return err;
1822 }
1823
1824 static void __exit mlxsw_pci_module_exit(void)
1825 {
1826         pci_unregister_driver(&mlxsw_pci_driver);
1827         debugfs_remove_recursive(mlxsw_pci_dbg_root);
1828 }
1829
1830 module_init(mlxsw_pci_module_init);
1831 module_exit(mlxsw_pci_module_exit);
1832
1833 MODULE_LICENSE("Dual BSD/GPL");
1834 MODULE_AUTHOR("Jiri Pirko <jiri@mellanox.com>");
1835 MODULE_DESCRIPTION("Mellanox switch PCI interface driver");
1836 MODULE_DEVICE_TABLE(pci, mlxsw_pci_id_table);