1 /**********************************************************************
4 * Contact: support@cavium.com
5 * Please include "LiquidIO" in the subject.
7 * Copyright (c) 2003-2016 Cavium, Inc.
9 * This file is free software; you can redistribute it and/or modify
10 * it under the terms of the GNU General Public License, Version 2, as
11 * published by the Free Software Foundation.
13 * This file is distributed in the hope that it will be useful, but
14 * AS-IS and WITHOUT ANY WARRANTY; without even the implied warranty
15 * of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE, TITLE, or
16 * NONINFRINGEMENT. See the GNU General Public License for more details.
17 ***********************************************************************/
18 #include <linux/module.h>
19 #include <linux/interrupt.h>
20 #include <linux/pci.h>
21 #include <net/vxlan.h>
22 #include "liquidio_common.h"
23 #include "octeon_droq.h"
24 #include "octeon_iq.h"
25 #include "response_manager.h"
26 #include "octeon_device.h"
27 #include "octeon_nic.h"
28 #include "octeon_main.h"
29 #include "octeon_network.h"
30 #include "cn23xx_vf_device.h"
32 MODULE_AUTHOR("Cavium Networks, <support@cavium.com>");
33 MODULE_DESCRIPTION("Cavium LiquidIO Intelligent Server Adapter Virtual Function Driver");
34 MODULE_LICENSE("GPL");
36 static int debug
= -1;
37 module_param(debug
, int, 0644);
38 MODULE_PARM_DESC(debug
, "NETIF_MSG debug bits");
40 #define DEFAULT_MSG_ENABLE (NETIF_MSG_DRV | NETIF_MSG_PROBE | NETIF_MSG_LINK)
42 struct oct_timestamp_resp
{
51 #ifdef __BIG_ENDIAN_BITFIELD
63 #define OCTNIC_GSO_MAX_HEADER_SIZE 128
64 #define OCTNIC_GSO_MAX_SIZE \
65 (CN23XX_DEFAULT_INPUT_JABBER - OCTNIC_GSO_MAX_HEADER_SIZE)
68 liquidio_vf_probe(struct pci_dev
*pdev
, const struct pci_device_id
*ent
);
69 static void liquidio_vf_remove(struct pci_dev
*pdev
);
70 static int octeon_device_init(struct octeon_device
*oct
);
71 static int liquidio_stop(struct net_device
*netdev
);
73 static int lio_wait_for_oq_pkts(struct octeon_device
*oct
)
75 struct octeon_device_priv
*oct_priv
=
76 (struct octeon_device_priv
*)oct
->priv
;
77 int retry
= MAX_IO_PENDING_PKT_COUNT
;
78 int pkt_cnt
= 0, pending_pkts
;
84 for (i
= 0; i
< MAX_OCTEON_OUTPUT_QUEUES(oct
); i
++) {
85 if (!(oct
->io_qmask
.oq
& BIT_ULL(i
)))
87 pkt_cnt
+= octeon_droq_check_hw_for_pkts(oct
->droq
[i
]);
90 pending_pkts
+= pkt_cnt
;
91 tasklet_schedule(&oct_priv
->droq_tasklet
);
94 schedule_timeout_uninterruptible(1);
96 } while (retry
-- && pending_pkts
);
102 * pcierror_quiesce_device - Cause device to go quiet so it can be safely removed/reset/etc
103 * @oct: Pointer to Octeon device
105 static void pcierror_quiesce_device(struct octeon_device
*oct
)
109 /* Disable the input and output queues now. No more packets will
110 * arrive from Octeon, but we should wait for all packet processing
114 /* To allow for in-flight requests */
115 schedule_timeout_uninterruptible(100);
117 if (wait_for_pending_requests(oct
))
118 dev_err(&oct
->pci_dev
->dev
, "There were pending requests\n");
120 /* Force all requests waiting to be fetched by OCTEON to complete. */
121 for (i
= 0; i
< MAX_OCTEON_INSTR_QUEUES(oct
); i
++) {
122 struct octeon_instr_queue
*iq
;
124 if (!(oct
->io_qmask
.iq
& BIT_ULL(i
)))
126 iq
= oct
->instr_queue
[i
];
128 if (atomic_read(&iq
->instr_pending
)) {
129 spin_lock_bh(&iq
->lock
);
131 iq
->octeon_read_index
= iq
->host_write_index
;
132 iq
->stats
.instr_processed
+=
133 atomic_read(&iq
->instr_pending
);
134 lio_process_iq_request_list(oct
, iq
, 0);
135 spin_unlock_bh(&iq
->lock
);
139 /* Force all pending ordered list requests to time out. */
140 lio_process_ordered_list(oct
, 1);
142 /* We do not need to wait for output queue packets to be processed. */
146 * cleanup_aer_uncorrect_error_status - Cleanup PCI AER uncorrectable error status
147 * @dev: Pointer to PCI device
149 static void cleanup_aer_uncorrect_error_status(struct pci_dev
*dev
)
154 pr_info("%s :\n", __func__
);
156 pci_read_config_dword(dev
, pos
+ PCI_ERR_UNCOR_STATUS
, &status
);
157 pci_read_config_dword(dev
, pos
+ PCI_ERR_UNCOR_SEVER
, &mask
);
158 if (dev
->error_state
== pci_channel_io_normal
)
159 status
&= ~mask
; /* Clear corresponding nonfatal bits */
161 status
&= mask
; /* Clear corresponding fatal bits */
162 pci_write_config_dword(dev
, pos
+ PCI_ERR_UNCOR_STATUS
, status
);
166 * stop_pci_io - Stop all PCI IO to a given device
167 * @oct: Pointer to Octeon device
169 static void stop_pci_io(struct octeon_device
*oct
)
171 struct msix_entry
*msix_entries
;
174 /* No more instructions will be forwarded. */
175 atomic_set(&oct
->status
, OCT_DEV_IN_RESET
);
177 for (i
= 0; i
< oct
->ifcount
; i
++)
178 netif_device_detach(oct
->props
[i
].netdev
);
180 /* Disable interrupts */
181 oct
->fn_list
.disable_interrupt(oct
, OCTEON_ALL_INTR
);
183 pcierror_quiesce_device(oct
);
185 msix_entries
= (struct msix_entry
*)oct
->msix_entries
;
186 for (i
= 0; i
< oct
->num_msix_irqs
; i
++) {
187 /* clear the affinity_cpumask */
188 irq_set_affinity_hint(msix_entries
[i
].vector
,
190 free_irq(msix_entries
[i
].vector
,
191 &oct
->ioq_vector
[i
]);
193 pci_disable_msix(oct
->pci_dev
);
194 kfree(oct
->msix_entries
);
195 oct
->msix_entries
= NULL
;
196 octeon_free_ioq_vector(oct
);
198 dev_dbg(&oct
->pci_dev
->dev
, "Device state is now %s\n",
199 lio_get_state_string(&oct
->status
));
201 /* making it a common function for all OCTEON models */
202 cleanup_aer_uncorrect_error_status(oct
->pci_dev
);
204 pci_disable_device(oct
->pci_dev
);
208 * liquidio_pcie_error_detected - called when PCI error is detected
209 * @pdev: Pointer to PCI device
210 * @state: The current pci connection state
212 * This function is called after a PCI bus error affecting
213 * this device has been detected.
215 static pci_ers_result_t
liquidio_pcie_error_detected(struct pci_dev
*pdev
,
216 pci_channel_state_t state
)
218 struct octeon_device
*oct
= pci_get_drvdata(pdev
);
220 /* Non-correctable Non-fatal errors */
221 if (state
== pci_channel_io_normal
) {
222 dev_err(&oct
->pci_dev
->dev
, "Non-correctable non-fatal error reported:\n");
223 cleanup_aer_uncorrect_error_status(oct
->pci_dev
);
224 return PCI_ERS_RESULT_CAN_RECOVER
;
227 /* Non-correctable Fatal errors */
228 dev_err(&oct
->pci_dev
->dev
, "Non-correctable FATAL reported by PCI AER driver\n");
231 return PCI_ERS_RESULT_DISCONNECT
;
234 /* For PCI-E Advanced Error Recovery (AER) Interface */
235 static const struct pci_error_handlers liquidio_vf_err_handler
= {
236 .error_detected
= liquidio_pcie_error_detected
,
239 static const struct pci_device_id liquidio_vf_pci_tbl
[] = {
241 PCI_VENDOR_ID_CAVIUM
, OCTEON_CN23XX_VF_VID
,
242 PCI_ANY_ID
, PCI_ANY_ID
, 0, 0, 0
248 MODULE_DEVICE_TABLE(pci
, liquidio_vf_pci_tbl
);
250 static struct pci_driver liquidio_vf_pci_driver
= {
251 .name
= "LiquidIO_VF",
252 .id_table
= liquidio_vf_pci_tbl
,
253 .probe
= liquidio_vf_probe
,
254 .remove
= liquidio_vf_remove
,
255 .err_handler
= &liquidio_vf_err_handler
, /* For AER */
259 * print_link_info - Print link information
260 * @netdev: network device
262 static void print_link_info(struct net_device
*netdev
)
264 struct lio
*lio
= GET_LIO(netdev
);
266 if (!ifstate_check(lio
, LIO_IFSTATE_RESETTING
) &&
267 ifstate_check(lio
, LIO_IFSTATE_REGISTERED
)) {
268 struct oct_link_info
*linfo
= &lio
->linfo
;
270 if (linfo
->link
.s
.link_up
) {
271 netif_info(lio
, link
, lio
->netdev
, "%d Mbps %s Duplex UP\n",
273 (linfo
->link
.s
.duplex
) ? "Full" : "Half");
275 netif_info(lio
, link
, lio
->netdev
, "Link Down\n");
281 * octnet_link_status_change - Routine to notify MTU change
282 * @work: work_struct data structure
284 static void octnet_link_status_change(struct work_struct
*work
)
286 struct cavium_wk
*wk
= (struct cavium_wk
*)work
;
287 struct lio
*lio
= (struct lio
*)wk
->ctxptr
;
289 /* lio->linfo.link.s.mtu always contains max MTU of the lio interface.
290 * this API is invoked only when new max-MTU of the interface is
291 * less than current MTU.
294 dev_set_mtu(lio
->netdev
, lio
->linfo
.link
.s
.mtu
);
299 * setup_link_status_change_wq - Sets up the mtu status change work
300 * @netdev: network device
302 static int setup_link_status_change_wq(struct net_device
*netdev
)
304 struct lio
*lio
= GET_LIO(netdev
);
305 struct octeon_device
*oct
= lio
->oct_dev
;
307 lio
->link_status_wq
.wq
= alloc_workqueue("link-status",
309 if (!lio
->link_status_wq
.wq
) {
310 dev_err(&oct
->pci_dev
->dev
, "unable to create cavium link status wq\n");
313 INIT_DELAYED_WORK(&lio
->link_status_wq
.wk
.work
,
314 octnet_link_status_change
);
315 lio
->link_status_wq
.wk
.ctxptr
= lio
;
320 static void cleanup_link_status_change_wq(struct net_device
*netdev
)
322 struct lio
*lio
= GET_LIO(netdev
);
324 if (lio
->link_status_wq
.wq
) {
325 cancel_delayed_work_sync(&lio
->link_status_wq
.wk
.work
);
326 destroy_workqueue(lio
->link_status_wq
.wq
);
331 * update_link_status - Update link status
332 * @netdev: network device
333 * @ls: link status structure
335 * Called on receipt of a link status response from the core application to
336 * update each interface's link status.
338 static void update_link_status(struct net_device
*netdev
,
339 union oct_link_status
*ls
)
341 struct lio
*lio
= GET_LIO(netdev
);
342 int current_max_mtu
= lio
->linfo
.link
.s
.mtu
;
343 struct octeon_device
*oct
= lio
->oct_dev
;
345 if ((lio
->intf_open
) && (lio
->linfo
.link
.u64
!= ls
->u64
)) {
346 lio
->linfo
.link
.u64
= ls
->u64
;
348 print_link_info(netdev
);
351 if (lio
->linfo
.link
.s
.link_up
) {
352 netif_carrier_on(netdev
);
355 netif_carrier_off(netdev
);
359 if (lio
->linfo
.link
.s
.mtu
!= current_max_mtu
) {
360 dev_info(&oct
->pci_dev
->dev
,
361 "Max MTU Changed from %d to %d\n",
362 current_max_mtu
, lio
->linfo
.link
.s
.mtu
);
363 netdev
->max_mtu
= lio
->linfo
.link
.s
.mtu
;
366 if (lio
->linfo
.link
.s
.mtu
< netdev
->mtu
) {
367 dev_warn(&oct
->pci_dev
->dev
,
368 "Current MTU is higher than new max MTU; Reducing the current mtu from %d to %d\n",
369 netdev
->mtu
, lio
->linfo
.link
.s
.mtu
);
370 queue_delayed_work(lio
->link_status_wq
.wq
,
371 &lio
->link_status_wq
.wk
.work
, 0);
377 * liquidio_vf_probe - PCI probe handler
378 * @pdev: PCI device structure
382 liquidio_vf_probe(struct pci_dev
*pdev
,
383 const struct pci_device_id __maybe_unused
*ent
)
385 struct octeon_device
*oct_dev
= NULL
;
387 oct_dev
= octeon_allocate_device(pdev
->device
,
388 sizeof(struct octeon_device_priv
));
391 dev_err(&pdev
->dev
, "Unable to allocate device\n");
394 oct_dev
->msix_on
= LIO_FLAG_MSIX_ENABLED
;
396 dev_info(&pdev
->dev
, "Initializing device %x:%x.\n",
397 (u32
)pdev
->vendor
, (u32
)pdev
->device
);
399 /* Assign octeon_device for this device to the private data area. */
400 pci_set_drvdata(pdev
, oct_dev
);
402 /* set linux specific device pointer */
403 oct_dev
->pci_dev
= pdev
;
405 oct_dev
->subsystem_id
= pdev
->subsystem_vendor
|
406 (pdev
->subsystem_device
<< 16);
408 if (octeon_device_init(oct_dev
)) {
409 liquidio_vf_remove(pdev
);
413 dev_dbg(&oct_dev
->pci_dev
->dev
, "Device is ready\n");
419 * octeon_pci_flr - PCI FLR for each Octeon device.
420 * @oct: octeon device
422 static void octeon_pci_flr(struct octeon_device
*oct
)
424 pci_save_state(oct
->pci_dev
);
426 pci_cfg_access_lock(oct
->pci_dev
);
428 /* Quiesce the device completely */
429 pci_write_config_word(oct
->pci_dev
, PCI_COMMAND
,
430 PCI_COMMAND_INTX_DISABLE
);
432 pcie_flr(oct
->pci_dev
);
434 pci_cfg_access_unlock(oct
->pci_dev
);
436 pci_restore_state(oct
->pci_dev
);
440 * octeon_destroy_resources - Destroy resources associated with octeon device
441 * @oct: octeon device
443 static void octeon_destroy_resources(struct octeon_device
*oct
)
445 struct octeon_device_priv
*oct_priv
=
446 (struct octeon_device_priv
*)oct
->priv
;
447 struct msix_entry
*msix_entries
;
450 switch (atomic_read(&oct
->status
)) {
451 case OCT_DEV_RUNNING
:
452 case OCT_DEV_CORE_OK
:
453 /* No more instructions will be forwarded. */
454 atomic_set(&oct
->status
, OCT_DEV_IN_RESET
);
456 oct
->app_mode
= CVM_DRV_INVALID_APP
;
457 dev_dbg(&oct
->pci_dev
->dev
, "Device state is now %s\n",
458 lio_get_state_string(&oct
->status
));
460 schedule_timeout_uninterruptible(HZ
/ 10);
463 case OCT_DEV_HOST_OK
:
464 case OCT_DEV_IO_QUEUES_DONE
:
465 if (lio_wait_for_instr_fetch(oct
))
466 dev_err(&oct
->pci_dev
->dev
, "IQ had pending instructions\n");
468 if (wait_for_pending_requests(oct
))
469 dev_err(&oct
->pci_dev
->dev
, "There were pending requests\n");
471 /* Disable the input and output queues now. No more packets will
472 * arrive from Octeon, but we should wait for all packet
473 * processing to finish.
475 oct
->fn_list
.disable_io_queues(oct
);
477 if (lio_wait_for_oq_pkts(oct
))
478 dev_err(&oct
->pci_dev
->dev
, "OQ had pending packets\n");
480 /* Force all requests waiting to be fetched by OCTEON to
483 for (i
= 0; i
< MAX_OCTEON_INSTR_QUEUES(oct
); i
++) {
484 struct octeon_instr_queue
*iq
;
486 if (!(oct
->io_qmask
.iq
& BIT_ULL(i
)))
488 iq
= oct
->instr_queue
[i
];
490 if (atomic_read(&iq
->instr_pending
)) {
491 spin_lock_bh(&iq
->lock
);
493 iq
->octeon_read_index
= iq
->host_write_index
;
494 iq
->stats
.instr_processed
+=
495 atomic_read(&iq
->instr_pending
);
496 lio_process_iq_request_list(oct
, iq
, 0);
497 spin_unlock_bh(&iq
->lock
);
501 lio_process_ordered_list(oct
, 1);
502 octeon_free_sc_done_list(oct
);
503 octeon_free_sc_zombie_list(oct
);
506 case OCT_DEV_INTR_SET_DONE
:
507 /* Disable interrupts */
508 oct
->fn_list
.disable_interrupt(oct
, OCTEON_ALL_INTR
);
511 msix_entries
= (struct msix_entry
*)oct
->msix_entries
;
512 for (i
= 0; i
< oct
->num_msix_irqs
; i
++) {
513 if (oct
->ioq_vector
[i
].vector
) {
514 irq_set_affinity_hint(
515 msix_entries
[i
].vector
,
517 free_irq(msix_entries
[i
].vector
,
518 &oct
->ioq_vector
[i
]);
519 oct
->ioq_vector
[i
].vector
= 0;
522 pci_disable_msix(oct
->pci_dev
);
523 kfree(oct
->msix_entries
);
524 oct
->msix_entries
= NULL
;
525 kfree(oct
->irq_name_storage
);
526 oct
->irq_name_storage
= NULL
;
528 /* Soft reset the octeon device before exiting */
529 if (oct
->pci_dev
->reset_fn
)
532 cn23xx_vf_ask_pf_to_do_flr(oct
);
535 case OCT_DEV_MSIX_ALLOC_VECTOR_DONE
:
536 octeon_free_ioq_vector(oct
);
539 case OCT_DEV_MBOX_SETUP_DONE
:
540 oct
->fn_list
.free_mbox(oct
);
543 case OCT_DEV_IN_RESET
:
544 case OCT_DEV_DROQ_INIT_DONE
:
546 for (i
= 0; i
< MAX_OCTEON_OUTPUT_QUEUES(oct
); i
++) {
547 if (!(oct
->io_qmask
.oq
& BIT_ULL(i
)))
549 octeon_delete_droq(oct
, i
);
553 case OCT_DEV_RESP_LIST_INIT_DONE
:
554 octeon_delete_response_list(oct
);
557 case OCT_DEV_INSTR_QUEUE_INIT_DONE
:
558 for (i
= 0; i
< MAX_OCTEON_INSTR_QUEUES(oct
); i
++) {
559 if (!(oct
->io_qmask
.iq
& BIT_ULL(i
)))
561 octeon_delete_instr_queue(oct
, i
);
565 case OCT_DEV_SC_BUFF_POOL_INIT_DONE
:
566 octeon_free_sc_buffer_pool(oct
);
569 case OCT_DEV_DISPATCH_INIT_DONE
:
570 octeon_delete_dispatch_list(oct
);
571 cancel_delayed_work_sync(&oct
->nic_poll_work
.work
);
574 case OCT_DEV_PCI_MAP_DONE
:
575 octeon_unmap_pci_barx(oct
, 0);
576 octeon_unmap_pci_barx(oct
, 1);
579 case OCT_DEV_PCI_ENABLE_DONE
:
580 pci_clear_master(oct
->pci_dev
);
581 /* Disable the device, releasing the PCI INT */
582 pci_disable_device(oct
->pci_dev
);
585 case OCT_DEV_BEGIN_STATE
:
586 /* Nothing to be done here either */
590 tasklet_kill(&oct_priv
->droq_tasklet
);
594 * send_rx_ctrl_cmd - Send Rx control command
595 * @lio: per-network private data
596 * @start_stop: whether to start or stop
598 static void send_rx_ctrl_cmd(struct lio
*lio
, int start_stop
)
600 struct octeon_device
*oct
= (struct octeon_device
*)lio
->oct_dev
;
601 struct octeon_soft_command
*sc
;
602 union octnet_cmd
*ncmd
;
605 if (oct
->props
[lio
->ifidx
].rx_on
== start_stop
)
608 sc
= (struct octeon_soft_command
*)
609 octeon_alloc_soft_command(oct
, OCTNET_CMD_SIZE
,
612 ncmd
= (union octnet_cmd
*)sc
->virtdptr
;
615 ncmd
->s
.cmd
= OCTNET_CMD_RX_CTL
;
616 ncmd
->s
.param1
= start_stop
;
618 octeon_swap_8B_data((u64
*)ncmd
, (OCTNET_CMD_SIZE
>> 3));
620 sc
->iq_no
= lio
->linfo
.txpciq
[0].s
.q_no
;
622 octeon_prepare_soft_command(oct
, sc
, OPCODE_NIC
,
623 OPCODE_NIC_CMD
, 0, 0, 0);
625 init_completion(&sc
->complete
);
626 sc
->sc_status
= OCTEON_REQUEST_PENDING
;
628 retval
= octeon_send_soft_command(oct
, sc
);
629 if (retval
== IQ_SEND_FAILED
) {
630 netif_info(lio
, rx_err
, lio
->netdev
, "Failed to send RX Control message\n");
631 octeon_free_soft_command(oct
, sc
);
633 /* Sleep on a wait queue till the cond flag indicates that the
634 * response arrived or timed-out.
636 retval
= wait_for_sc_completion_timeout(oct
, sc
, 0);
640 oct
->props
[lio
->ifidx
].rx_on
= start_stop
;
641 WRITE_ONCE(sc
->caller_is_done
, true);
646 * liquidio_destroy_nic_device - Destroy NIC device interface
647 * @oct: octeon device
648 * @ifidx: which interface to destroy
650 * Cleanup associated with each interface for an Octeon device when NIC
651 * module is being unloaded or if initialization fails during load.
653 static void liquidio_destroy_nic_device(struct octeon_device
*oct
, int ifidx
)
655 struct net_device
*netdev
= oct
->props
[ifidx
].netdev
;
656 struct octeon_device_priv
*oct_priv
=
657 (struct octeon_device_priv
*)oct
->priv
;
658 struct napi_struct
*napi
, *n
;
662 dev_err(&oct
->pci_dev
->dev
, "%s No netdevice ptr for index %d\n",
667 lio
= GET_LIO(netdev
);
669 dev_dbg(&oct
->pci_dev
->dev
, "NIC device cleanup\n");
671 if (atomic_read(&lio
->ifstate
) & LIO_IFSTATE_RUNNING
)
672 liquidio_stop(netdev
);
674 if (oct
->props
[lio
->ifidx
].napi_enabled
== 1) {
675 list_for_each_entry_safe(napi
, n
, &netdev
->napi_list
, dev_list
)
678 oct
->props
[lio
->ifidx
].napi_enabled
= 0;
680 oct
->droq
[0]->ops
.poll_mode
= 0;
684 list_for_each_entry_safe(napi
, n
, &netdev
->napi_list
, dev_list
)
685 netif_napi_del(napi
);
687 tasklet_enable(&oct_priv
->droq_tasklet
);
689 if (atomic_read(&lio
->ifstate
) & LIO_IFSTATE_REGISTERED
)
690 unregister_netdev(netdev
);
692 cleanup_rx_oom_poll_fn(netdev
);
694 cleanup_link_status_change_wq(netdev
);
696 lio_delete_glists(lio
);
700 oct
->props
[ifidx
].gmxport
= -1;
702 oct
->props
[ifidx
].netdev
= NULL
;
706 * liquidio_stop_nic_module - Stop complete NIC functionality
707 * @oct: octeon device
709 static int liquidio_stop_nic_module(struct octeon_device
*oct
)
714 dev_dbg(&oct
->pci_dev
->dev
, "Stopping network interfaces\n");
716 dev_err(&oct
->pci_dev
->dev
, "Init for Octeon was not completed\n");
720 spin_lock_bh(&oct
->cmd_resp_wqlock
);
721 oct
->cmd_resp_state
= OCT_DRV_OFFLINE
;
722 spin_unlock_bh(&oct
->cmd_resp_wqlock
);
724 for (i
= 0; i
< oct
->ifcount
; i
++) {
725 lio
= GET_LIO(oct
->props
[i
].netdev
);
726 for (j
= 0; j
< oct
->num_oqs
; j
++)
727 octeon_unregister_droq_ops(oct
,
728 lio
->linfo
.rxpciq
[j
].s
.q_no
);
731 for (i
= 0; i
< oct
->ifcount
; i
++)
732 liquidio_destroy_nic_device(oct
, i
);
734 dev_dbg(&oct
->pci_dev
->dev
, "Network interfaces stopped\n");
739 * liquidio_vf_remove - Cleans up resources at unload time
740 * @pdev: PCI device structure
742 static void liquidio_vf_remove(struct pci_dev
*pdev
)
744 struct octeon_device
*oct_dev
= pci_get_drvdata(pdev
);
746 dev_dbg(&oct_dev
->pci_dev
->dev
, "Stopping device\n");
748 if (oct_dev
->app_mode
== CVM_DRV_NIC_APP
)
749 liquidio_stop_nic_module(oct_dev
);
751 /* Reset the octeon device and cleanup all memory allocated for
752 * the octeon device by driver.
754 octeon_destroy_resources(oct_dev
);
756 dev_info(&oct_dev
->pci_dev
->dev
, "Device removed\n");
758 /* This octeon device has been removed. Update the global
759 * data structure to reflect this. Free the device structure.
761 octeon_free_device_mem(oct_dev
);
765 * octeon_pci_os_setup - PCI initialization for each Octeon device.
766 * @oct: octeon device
768 static int octeon_pci_os_setup(struct octeon_device
*oct
)
770 #ifdef CONFIG_PCI_IOV
771 /* setup PCI stuff first */
772 if (!oct
->pci_dev
->physfn
)
776 if (pci_enable_device(oct
->pci_dev
)) {
777 dev_err(&oct
->pci_dev
->dev
, "pci_enable_device failed\n");
781 if (dma_set_mask_and_coherent(&oct
->pci_dev
->dev
, DMA_BIT_MASK(64))) {
782 dev_err(&oct
->pci_dev
->dev
, "Unexpected DMA device capability\n");
783 pci_disable_device(oct
->pci_dev
);
787 /* Enable PCI DMA Master. */
788 pci_set_master(oct
->pci_dev
);
794 * free_netbuf - Unmap and free network buffer
797 static void free_netbuf(void *buf
)
799 struct octnet_buf_free_info
*finfo
;
803 finfo
= (struct octnet_buf_free_info
*)buf
;
807 dma_unmap_single(&lio
->oct_dev
->pci_dev
->dev
, finfo
->dptr
, skb
->len
,
814 * free_netsgbuf - Unmap and free gather buffer
817 static void free_netsgbuf(void *buf
)
819 struct octnet_buf_free_info
*finfo
;
820 struct octnic_gather
*g
;
825 finfo
= (struct octnet_buf_free_info
*)buf
;
829 frags
= skb_shinfo(skb
)->nr_frags
;
831 dma_unmap_single(&lio
->oct_dev
->pci_dev
->dev
,
832 g
->sg
[0].ptr
[0], (skb
->len
- skb
->data_len
),
837 skb_frag_t
*frag
= &skb_shinfo(skb
)->frags
[i
- 1];
839 pci_unmap_page((lio
->oct_dev
)->pci_dev
,
840 g
->sg
[(i
>> 2)].ptr
[(i
& 3)],
841 skb_frag_size(frag
), DMA_TO_DEVICE
);
845 iq
= skb_iq(lio
->oct_dev
, skb
);
847 spin_lock(&lio
->glist_lock
[iq
]);
848 list_add_tail(&g
->list
, &lio
->glist
[iq
]);
849 spin_unlock(&lio
->glist_lock
[iq
]);
855 * free_netsgbuf_with_resp - Unmap and free gather buffer with response
858 static void free_netsgbuf_with_resp(void *buf
)
860 struct octnet_buf_free_info
*finfo
;
861 struct octeon_soft_command
*sc
;
862 struct octnic_gather
*g
;
867 sc
= (struct octeon_soft_command
*)buf
;
868 skb
= (struct sk_buff
*)sc
->callback_arg
;
869 finfo
= (struct octnet_buf_free_info
*)&skb
->cb
;
873 frags
= skb_shinfo(skb
)->nr_frags
;
875 dma_unmap_single(&lio
->oct_dev
->pci_dev
->dev
,
876 g
->sg
[0].ptr
[0], (skb
->len
- skb
->data_len
),
881 skb_frag_t
*frag
= &skb_shinfo(skb
)->frags
[i
- 1];
883 pci_unmap_page((lio
->oct_dev
)->pci_dev
,
884 g
->sg
[(i
>> 2)].ptr
[(i
& 3)],
885 skb_frag_size(frag
), DMA_TO_DEVICE
);
889 iq
= skb_iq(lio
->oct_dev
, skb
);
891 spin_lock(&lio
->glist_lock
[iq
]);
892 list_add_tail(&g
->list
, &lio
->glist
[iq
]);
893 spin_unlock(&lio
->glist_lock
[iq
]);
895 /* Don't free the skb yet */
899 * liquidio_open - Net device open for LiquidIO
900 * @netdev: network device
902 static int liquidio_open(struct net_device
*netdev
)
904 struct lio
*lio
= GET_LIO(netdev
);
905 struct octeon_device
*oct
= lio
->oct_dev
;
906 struct octeon_device_priv
*oct_priv
=
907 (struct octeon_device_priv
*)oct
->priv
;
908 struct napi_struct
*napi
, *n
;
910 if (!oct
->props
[lio
->ifidx
].napi_enabled
) {
911 tasklet_disable(&oct_priv
->droq_tasklet
);
913 list_for_each_entry_safe(napi
, n
, &netdev
->napi_list
, dev_list
)
916 oct
->props
[lio
->ifidx
].napi_enabled
= 1;
918 oct
->droq
[0]->ops
.poll_mode
= 1;
921 ifstate_set(lio
, LIO_IFSTATE_RUNNING
);
923 /* Ready for link status updates */
926 netif_info(lio
, ifup
, lio
->netdev
, "Interface Open, ready for traffic\n");
929 INIT_DELAYED_WORK(&lio
->stats_wk
.work
, lio_fetch_stats
);
930 lio
->stats_wk
.ctxptr
= lio
;
931 schedule_delayed_work(&lio
->stats_wk
.work
, msecs_to_jiffies
932 (LIQUIDIO_NDEV_STATS_POLL_TIME_MS
));
934 /* tell Octeon to start forwarding packets to host */
935 send_rx_ctrl_cmd(lio
, 1);
937 dev_info(&oct
->pci_dev
->dev
, "%s interface is opened\n", netdev
->name
);
943 * liquidio_stop - jNet device stop for LiquidIO
944 * @netdev: network device
946 static int liquidio_stop(struct net_device
*netdev
)
948 struct lio
*lio
= GET_LIO(netdev
);
949 struct octeon_device
*oct
= lio
->oct_dev
;
950 struct octeon_device_priv
*oct_priv
=
951 (struct octeon_device_priv
*)oct
->priv
;
952 struct napi_struct
*napi
, *n
;
954 /* tell Octeon to stop forwarding packets to host */
955 send_rx_ctrl_cmd(lio
, 0);
957 netif_info(lio
, ifdown
, lio
->netdev
, "Stopping interface!\n");
958 /* Inform that netif carrier is down */
960 lio
->linfo
.link
.s
.link_up
= 0;
962 netif_carrier_off(netdev
);
965 ifstate_reset(lio
, LIO_IFSTATE_RUNNING
);
969 /* Wait for any pending Rx descriptors */
970 if (lio_wait_for_clean_oq(oct
))
971 netif_info(lio
, rx_err
, lio
->netdev
,
972 "Proceeding with stop interface after partial RX desc processing\n");
974 if (oct
->props
[lio
->ifidx
].napi_enabled
== 1) {
975 list_for_each_entry_safe(napi
, n
, &netdev
->napi_list
, dev_list
)
978 oct
->props
[lio
->ifidx
].napi_enabled
= 0;
980 oct
->droq
[0]->ops
.poll_mode
= 0;
982 tasklet_enable(&oct_priv
->droq_tasklet
);
985 cancel_delayed_work_sync(&lio
->stats_wk
.work
);
987 dev_info(&oct
->pci_dev
->dev
, "%s interface is stopped\n", netdev
->name
);
993 * get_new_flags - Converts a mask based on net device flags
994 * @netdev: network device
996 * This routine generates a octnet_ifflags mask from the net device flags
997 * received from the OS.
999 static enum octnet_ifflags
get_new_flags(struct net_device
*netdev
)
1001 enum octnet_ifflags f
= OCTNET_IFFLAG_UNICAST
;
1003 if (netdev
->flags
& IFF_PROMISC
)
1004 f
|= OCTNET_IFFLAG_PROMISC
;
1006 if (netdev
->flags
& IFF_ALLMULTI
)
1007 f
|= OCTNET_IFFLAG_ALLMULTI
;
1009 if (netdev
->flags
& IFF_MULTICAST
) {
1010 f
|= OCTNET_IFFLAG_MULTICAST
;
1012 /* Accept all multicast addresses if there are more than we
1015 if (netdev_mc_count(netdev
) > MAX_OCTEON_MULTICAST_ADDR
)
1016 f
|= OCTNET_IFFLAG_ALLMULTI
;
1019 if (netdev
->flags
& IFF_BROADCAST
)
1020 f
|= OCTNET_IFFLAG_BROADCAST
;
1025 static void liquidio_set_uc_list(struct net_device
*netdev
)
1027 struct lio
*lio
= GET_LIO(netdev
);
1028 struct octeon_device
*oct
= lio
->oct_dev
;
1029 struct octnic_ctrl_pkt nctrl
;
1030 struct netdev_hw_addr
*ha
;
1033 if (lio
->netdev_uc_count
== netdev_uc_count(netdev
))
1036 if (netdev_uc_count(netdev
) > MAX_NCTRL_UDD
) {
1037 dev_err(&oct
->pci_dev
->dev
, "too many MAC addresses in netdev uc list\n");
1041 lio
->netdev_uc_count
= netdev_uc_count(netdev
);
1043 memset(&nctrl
, 0, sizeof(struct octnic_ctrl_pkt
));
1044 nctrl
.ncmd
.s
.cmd
= OCTNET_CMD_SET_UC_LIST
;
1045 nctrl
.ncmd
.s
.more
= lio
->netdev_uc_count
;
1046 nctrl
.ncmd
.s
.param1
= oct
->vf_num
;
1047 nctrl
.iq_no
= lio
->linfo
.txpciq
[0].s
.q_no
;
1048 nctrl
.netpndev
= (u64
)netdev
;
1049 nctrl
.cb_fn
= liquidio_link_ctrl_cmd_completion
;
1051 /* copy all the addresses into the udd */
1052 mac
= &nctrl
.udd
[0];
1053 netdev_for_each_uc_addr(ha
, netdev
) {
1054 ether_addr_copy(((u8
*)mac
) + 2, ha
->addr
);
1058 octnet_send_nic_ctrl_pkt(lio
->oct_dev
, &nctrl
);
1062 * liquidio_set_mcast_list - Net device set_multicast_list
1063 * @netdev: network device
1065 static void liquidio_set_mcast_list(struct net_device
*netdev
)
1067 int mc_count
= min(netdev_mc_count(netdev
), MAX_OCTEON_MULTICAST_ADDR
);
1068 struct lio
*lio
= GET_LIO(netdev
);
1069 struct octeon_device
*oct
= lio
->oct_dev
;
1070 struct octnic_ctrl_pkt nctrl
;
1071 struct netdev_hw_addr
*ha
;
1075 memset(&nctrl
, 0, sizeof(struct octnic_ctrl_pkt
));
1077 /* Create a ctrl pkt command to be sent to core app. */
1079 nctrl
.ncmd
.s
.cmd
= OCTNET_CMD_SET_MULTI_LIST
;
1080 nctrl
.ncmd
.s
.param1
= get_new_flags(netdev
);
1081 nctrl
.ncmd
.s
.param2
= mc_count
;
1082 nctrl
.ncmd
.s
.more
= mc_count
;
1083 nctrl
.netpndev
= (u64
)netdev
;
1084 nctrl
.cb_fn
= liquidio_link_ctrl_cmd_completion
;
1086 /* copy all the addresses into the udd */
1088 netdev_for_each_mc_addr(ha
, netdev
) {
1090 ether_addr_copy(((u8
*)mc
) + 2, ha
->addr
);
1091 /* no need to swap bytes */
1092 if (++mc
> &nctrl
.udd
[mc_count
])
1096 nctrl
.iq_no
= lio
->linfo
.txpciq
[0].s
.q_no
;
1098 /* Apparently, any activity in this call from the kernel has to
1099 * be atomic. So we won't wait for response.
1102 ret
= octnet_send_nic_ctrl_pkt(lio
->oct_dev
, &nctrl
);
1104 dev_err(&oct
->pci_dev
->dev
, "DEVFLAGS change failed in core (ret: 0x%x)\n",
1108 liquidio_set_uc_list(netdev
);
1112 * liquidio_set_mac - Net device set_mac_address
1113 * @netdev: network device
1114 * @p: opaque pointer to sockaddr
1116 static int liquidio_set_mac(struct net_device
*netdev
, void *p
)
1118 struct sockaddr
*addr
= (struct sockaddr
*)p
;
1119 struct lio
*lio
= GET_LIO(netdev
);
1120 struct octeon_device
*oct
= lio
->oct_dev
;
1121 struct octnic_ctrl_pkt nctrl
;
1124 if (!is_valid_ether_addr(addr
->sa_data
))
1125 return -EADDRNOTAVAIL
;
1127 if (ether_addr_equal(addr
->sa_data
, netdev
->dev_addr
))
1130 if (lio
->linfo
.macaddr_is_admin_asgnd
)
1133 memset(&nctrl
, 0, sizeof(struct octnic_ctrl_pkt
));
1136 nctrl
.ncmd
.s
.cmd
= OCTNET_CMD_CHANGE_MACADDR
;
1137 nctrl
.ncmd
.s
.param1
= 0;
1138 nctrl
.ncmd
.s
.more
= 1;
1139 nctrl
.iq_no
= lio
->linfo
.txpciq
[0].s
.q_no
;
1140 nctrl
.netpndev
= (u64
)netdev
;
1143 /* The MAC Address is presented in network byte order. */
1144 ether_addr_copy((u8
*)&nctrl
.udd
[0] + 2, addr
->sa_data
);
1146 ret
= octnet_send_nic_ctrl_pkt(lio
->oct_dev
, &nctrl
);
1148 dev_err(&oct
->pci_dev
->dev
, "MAC Address change failed\n");
1152 if (nctrl
.sc_status
==
1153 FIRMWARE_STATUS_CODE(OCTEON_REQUEST_NO_PERMISSION
)) {
1154 dev_err(&oct
->pci_dev
->dev
, "MAC Address change failed: no permission\n");
1158 memcpy(netdev
->dev_addr
, addr
->sa_data
, netdev
->addr_len
);
1159 ether_addr_copy(((u8
*)&lio
->linfo
.hw_addr
) + 2, addr
->sa_data
);
1165 liquidio_get_stats64(struct net_device
*netdev
,
1166 struct rtnl_link_stats64
*lstats
)
1168 struct lio
*lio
= GET_LIO(netdev
);
1169 struct octeon_device
*oct
;
1170 u64 pkts
= 0, drop
= 0, bytes
= 0;
1171 struct oct_droq_stats
*oq_stats
;
1172 struct oct_iq_stats
*iq_stats
;
1173 int i
, iq_no
, oq_no
;
1177 if (ifstate_check(lio
, LIO_IFSTATE_RESETTING
))
1180 for (i
= 0; i
< oct
->num_iqs
; i
++) {
1181 iq_no
= lio
->linfo
.txpciq
[i
].s
.q_no
;
1182 iq_stats
= &oct
->instr_queue
[iq_no
]->stats
;
1183 pkts
+= iq_stats
->tx_done
;
1184 drop
+= iq_stats
->tx_dropped
;
1185 bytes
+= iq_stats
->tx_tot_bytes
;
1188 lstats
->tx_packets
= pkts
;
1189 lstats
->tx_bytes
= bytes
;
1190 lstats
->tx_dropped
= drop
;
1196 for (i
= 0; i
< oct
->num_oqs
; i
++) {
1197 oq_no
= lio
->linfo
.rxpciq
[i
].s
.q_no
;
1198 oq_stats
= &oct
->droq
[oq_no
]->stats
;
1199 pkts
+= oq_stats
->rx_pkts_received
;
1200 drop
+= (oq_stats
->rx_dropped
+
1201 oq_stats
->dropped_nodispatch
+
1202 oq_stats
->dropped_toomany
+
1203 oq_stats
->dropped_nomem
);
1204 bytes
+= oq_stats
->rx_bytes_received
;
1207 lstats
->rx_bytes
= bytes
;
1208 lstats
->rx_packets
= pkts
;
1209 lstats
->rx_dropped
= drop
;
1211 lstats
->multicast
= oct
->link_stats
.fromwire
.fw_total_mcast
;
1213 /* detailed rx_errors: */
1214 lstats
->rx_length_errors
= oct
->link_stats
.fromwire
.l2_err
;
1215 /* recved pkt with crc error */
1216 lstats
->rx_crc_errors
= oct
->link_stats
.fromwire
.fcs_err
;
1217 /* recv'd frame alignment error */
1218 lstats
->rx_frame_errors
= oct
->link_stats
.fromwire
.frame_err
;
1220 lstats
->rx_errors
= lstats
->rx_length_errors
+ lstats
->rx_crc_errors
+
1221 lstats
->rx_frame_errors
;
1223 /* detailed tx_errors */
1224 lstats
->tx_aborted_errors
= oct
->link_stats
.fromhost
.fw_err_pko
;
1225 lstats
->tx_carrier_errors
= oct
->link_stats
.fromhost
.fw_err_link
;
1227 lstats
->tx_errors
= lstats
->tx_aborted_errors
+
1228 lstats
->tx_carrier_errors
;
1232 * hwtstamp_ioctl - Handler for SIOCSHWTSTAMP ioctl
1233 * @netdev: network device
1234 * @ifr: interface request
1236 static int hwtstamp_ioctl(struct net_device
*netdev
, struct ifreq
*ifr
)
1238 struct lio
*lio
= GET_LIO(netdev
);
1239 struct hwtstamp_config conf
;
1241 if (copy_from_user(&conf
, ifr
->ifr_data
, sizeof(conf
)))
1247 switch (conf
.tx_type
) {
1248 case HWTSTAMP_TX_ON
:
1249 case HWTSTAMP_TX_OFF
:
1255 switch (conf
.rx_filter
) {
1256 case HWTSTAMP_FILTER_NONE
:
1258 case HWTSTAMP_FILTER_ALL
:
1259 case HWTSTAMP_FILTER_SOME
:
1260 case HWTSTAMP_FILTER_PTP_V1_L4_EVENT
:
1261 case HWTSTAMP_FILTER_PTP_V1_L4_SYNC
:
1262 case HWTSTAMP_FILTER_PTP_V1_L4_DELAY_REQ
:
1263 case HWTSTAMP_FILTER_PTP_V2_L4_EVENT
:
1264 case HWTSTAMP_FILTER_PTP_V2_L4_SYNC
:
1265 case HWTSTAMP_FILTER_PTP_V2_L4_DELAY_REQ
:
1266 case HWTSTAMP_FILTER_PTP_V2_L2_EVENT
:
1267 case HWTSTAMP_FILTER_PTP_V2_L2_SYNC
:
1268 case HWTSTAMP_FILTER_PTP_V2_L2_DELAY_REQ
:
1269 case HWTSTAMP_FILTER_PTP_V2_EVENT
:
1270 case HWTSTAMP_FILTER_PTP_V2_SYNC
:
1271 case HWTSTAMP_FILTER_PTP_V2_DELAY_REQ
:
1272 case HWTSTAMP_FILTER_NTP_ALL
:
1273 conf
.rx_filter
= HWTSTAMP_FILTER_ALL
;
1279 if (conf
.rx_filter
== HWTSTAMP_FILTER_ALL
)
1280 ifstate_set(lio
, LIO_IFSTATE_RX_TIMESTAMP_ENABLED
);
1283 ifstate_reset(lio
, LIO_IFSTATE_RX_TIMESTAMP_ENABLED
);
1285 return copy_to_user(ifr
->ifr_data
, &conf
, sizeof(conf
)) ? -EFAULT
: 0;
1289 * liquidio_ioctl - ioctl handler
1290 * @netdev: network device
1291 * @ifr: interface request
1294 static int liquidio_ioctl(struct net_device
*netdev
, struct ifreq
*ifr
, int cmd
)
1298 return hwtstamp_ioctl(netdev
, ifr
);
1304 static void handle_timestamp(struct octeon_device
*oct
, u32 status
, void *buf
)
1306 struct sk_buff
*skb
= (struct sk_buff
*)buf
;
1307 struct octnet_buf_free_info
*finfo
;
1308 struct oct_timestamp_resp
*resp
;
1309 struct octeon_soft_command
*sc
;
1312 finfo
= (struct octnet_buf_free_info
*)skb
->cb
;
1316 resp
= (struct oct_timestamp_resp
*)sc
->virtrptr
;
1318 if (status
!= OCTEON_REQUEST_DONE
) {
1319 dev_err(&oct
->pci_dev
->dev
, "Tx timestamp instruction failed. Status: %llx\n",
1320 CVM_CAST64(status
));
1321 resp
->timestamp
= 0;
1324 octeon_swap_8B_data(&resp
->timestamp
, 1);
1326 if (unlikely(skb_shinfo(skb
)->tx_flags
& SKBTX_IN_PROGRESS
)) {
1327 struct skb_shared_hwtstamps ts
;
1328 u64 ns
= resp
->timestamp
;
1330 netif_info(lio
, tx_done
, lio
->netdev
,
1331 "Got resulting SKBTX_HW_TSTAMP skb=%p ns=%016llu\n",
1332 skb
, (unsigned long long)ns
);
1333 ts
.hwtstamp
= ns_to_ktime(ns
+ lio
->ptp_adjust
);
1334 skb_tstamp_tx(skb
, &ts
);
1337 octeon_free_soft_command(oct
, sc
);
1338 tx_buffer_free(skb
);
1341 /* send_nic_timestamp_pkt - Send a data packet that will be timestamped
1342 * @oct: octeon device
1343 * @ndata: pointer to network data
1344 * @finfo: pointer to private network data
1346 static int send_nic_timestamp_pkt(struct octeon_device
*oct
,
1347 struct octnic_data_pkt
*ndata
,
1348 struct octnet_buf_free_info
*finfo
,
1351 struct octeon_soft_command
*sc
;
1359 sc
= octeon_alloc_soft_command_resp(oct
, &ndata
->cmd
,
1360 sizeof(struct oct_timestamp_resp
));
1364 dev_err(&oct
->pci_dev
->dev
, "No memory for timestamped data packet\n");
1365 return IQ_SEND_FAILED
;
1368 if (ndata
->reqtype
== REQTYPE_NORESP_NET
)
1369 ndata
->reqtype
= REQTYPE_RESP_NET
;
1370 else if (ndata
->reqtype
== REQTYPE_NORESP_NET_SG
)
1371 ndata
->reqtype
= REQTYPE_RESP_NET_SG
;
1373 sc
->callback
= handle_timestamp
;
1374 sc
->callback_arg
= finfo
->skb
;
1375 sc
->iq_no
= ndata
->q_no
;
1377 len
= (u32
)((struct octeon_instr_ih3
*)(&sc
->cmd
.cmd3
.ih3
))->dlengsz
;
1379 ring_doorbell
= !xmit_more
;
1381 retval
= octeon_send_command(oct
, sc
->iq_no
, ring_doorbell
, &sc
->cmd
,
1382 sc
, len
, ndata
->reqtype
);
1384 if (retval
== IQ_SEND_FAILED
) {
1385 dev_err(&oct
->pci_dev
->dev
, "timestamp data packet failed status: %x\n",
1387 octeon_free_soft_command(oct
, sc
);
1389 netif_info(lio
, tx_queued
, lio
->netdev
, "Queued timestamp packet\n");
1396 * liquidio_xmit - Transmit networks packets to the Octeon interface
1397 * @skb: skbuff struct to be passed to network layer.
1398 * @netdev: pointer to network device
1399 * @returns whether the packet was transmitted to the device okay or not
1400 * (NETDEV_TX_OK or NETDEV_TX_BUSY)
1402 static netdev_tx_t
liquidio_xmit(struct sk_buff
*skb
, struct net_device
*netdev
)
1404 struct octnet_buf_free_info
*finfo
;
1405 union octnic_cmd_setup cmdsetup
;
1406 struct octnic_data_pkt ndata
;
1407 struct octeon_instr_irh
*irh
;
1408 struct oct_iq_stats
*stats
;
1409 struct octeon_device
*oct
;
1410 int q_idx
= 0, iq_no
= 0;
1411 union tx_info
*tx_info
;
1419 lio
= GET_LIO(netdev
);
1422 q_idx
= skb_iq(lio
->oct_dev
, skb
);
1424 iq_no
= lio
->linfo
.txpciq
[q_idx
].s
.q_no
;
1426 stats
= &oct
->instr_queue
[iq_no
]->stats
;
1428 /* Check for all conditions in which the current packet cannot be
1431 if (!(atomic_read(&lio
->ifstate
) & LIO_IFSTATE_RUNNING
) ||
1432 (!lio
->linfo
.link
.s
.link_up
) || (skb
->len
<= 0)) {
1433 netif_info(lio
, tx_err
, lio
->netdev
, "Transmit failed link_status : %d\n",
1434 lio
->linfo
.link
.s
.link_up
);
1435 goto lio_xmit_failed
;
1438 /* Use space in skb->cb to store info used to unmap and
1441 finfo
= (struct octnet_buf_free_info
*)skb
->cb
;
1446 /* Prepare the attributes for the data to be passed to OSI. */
1447 memset(&ndata
, 0, sizeof(struct octnic_data_pkt
));
1453 if (octnet_iq_is_full(oct
, ndata
.q_no
)) {
1454 /* defer sending if queue is full */
1455 netif_info(lio
, tx_err
, lio
->netdev
, "Transmit failed iq:%d full\n",
1457 stats
->tx_iq_busy
++;
1458 return NETDEV_TX_BUSY
;
1461 ndata
.datasize
= skb
->len
;
1464 cmdsetup
.s
.iq_no
= iq_no
;
1466 if (skb
->ip_summed
== CHECKSUM_PARTIAL
) {
1467 if (skb
->encapsulation
) {
1468 cmdsetup
.s
.tnl_csum
= 1;
1471 cmdsetup
.s
.transport_csum
= 1;
1474 if (unlikely(skb_shinfo(skb
)->tx_flags
& SKBTX_HW_TSTAMP
)) {
1475 skb_shinfo(skb
)->tx_flags
|= SKBTX_IN_PROGRESS
;
1476 cmdsetup
.s
.timestamp
= 1;
1479 if (!skb_shinfo(skb
)->nr_frags
) {
1480 cmdsetup
.s
.u
.datasize
= skb
->len
;
1481 octnet_prepare_pci_cmd(oct
, &ndata
.cmd
, &cmdsetup
, tag
);
1482 /* Offload checksum calculation for TCP/UDP packets */
1483 dptr
= dma_map_single(&oct
->pci_dev
->dev
,
1487 if (dma_mapping_error(&oct
->pci_dev
->dev
, dptr
)) {
1488 dev_err(&oct
->pci_dev
->dev
, "%s DMA mapping error 1\n",
1490 return NETDEV_TX_BUSY
;
1493 ndata
.cmd
.cmd3
.dptr
= dptr
;
1495 ndata
.reqtype
= REQTYPE_NORESP_NET
;
1499 struct octnic_gather
*g
;
1502 spin_lock(&lio
->glist_lock
[q_idx
]);
1503 g
= (struct octnic_gather
*)
1504 lio_list_delete_head(&lio
->glist
[q_idx
]);
1505 spin_unlock(&lio
->glist_lock
[q_idx
]);
1508 netif_info(lio
, tx_err
, lio
->netdev
,
1509 "Transmit scatter gather: glist null!\n");
1510 goto lio_xmit_failed
;
1513 cmdsetup
.s
.gather
= 1;
1514 cmdsetup
.s
.u
.gatherptrs
= (skb_shinfo(skb
)->nr_frags
+ 1);
1515 octnet_prepare_pci_cmd(oct
, &ndata
.cmd
, &cmdsetup
, tag
);
1517 memset(g
->sg
, 0, g
->sg_size
);
1519 g
->sg
[0].ptr
[0] = dma_map_single(&oct
->pci_dev
->dev
,
1521 (skb
->len
- skb
->data_len
),
1523 if (dma_mapping_error(&oct
->pci_dev
->dev
, g
->sg
[0].ptr
[0])) {
1524 dev_err(&oct
->pci_dev
->dev
, "%s DMA mapping error 2\n",
1526 return NETDEV_TX_BUSY
;
1528 add_sg_size(&g
->sg
[0], (skb
->len
- skb
->data_len
), 0);
1530 frags
= skb_shinfo(skb
)->nr_frags
;
1533 frag
= &skb_shinfo(skb
)->frags
[i
- 1];
1535 g
->sg
[(i
>> 2)].ptr
[(i
& 3)] =
1536 skb_frag_dma_map(&oct
->pci_dev
->dev
,
1537 frag
, 0, skb_frag_size(frag
),
1539 if (dma_mapping_error(&oct
->pci_dev
->dev
,
1540 g
->sg
[i
>> 2].ptr
[i
& 3])) {
1541 dma_unmap_single(&oct
->pci_dev
->dev
,
1543 skb
->len
- skb
->data_len
,
1545 for (j
= 1; j
< i
; j
++) {
1546 frag
= &skb_shinfo(skb
)->frags
[j
- 1];
1547 dma_unmap_page(&oct
->pci_dev
->dev
,
1548 g
->sg
[j
>> 2].ptr
[j
& 3],
1549 skb_frag_size(frag
),
1552 dev_err(&oct
->pci_dev
->dev
, "%s DMA mapping error 3\n",
1554 return NETDEV_TX_BUSY
;
1557 add_sg_size(&g
->sg
[(i
>> 2)], skb_frag_size(frag
),
1562 dptr
= g
->sg_dma_ptr
;
1564 ndata
.cmd
.cmd3
.dptr
= dptr
;
1568 ndata
.reqtype
= REQTYPE_NORESP_NET_SG
;
1571 irh
= (struct octeon_instr_irh
*)&ndata
.cmd
.cmd3
.irh
;
1572 tx_info
= (union tx_info
*)&ndata
.cmd
.cmd3
.ossp
[0];
1574 if (skb_shinfo(skb
)->gso_size
) {
1575 tx_info
->s
.gso_size
= skb_shinfo(skb
)->gso_size
;
1576 tx_info
->s
.gso_segs
= skb_shinfo(skb
)->gso_segs
;
1579 /* HW insert VLAN tag */
1580 if (skb_vlan_tag_present(skb
)) {
1581 irh
->priority
= skb_vlan_tag_get(skb
) >> VLAN_PRIO_SHIFT
;
1582 irh
->vlan
= skb_vlan_tag_get(skb
) & VLAN_VID_MASK
;
1585 xmit_more
= netdev_xmit_more();
1587 if (unlikely(cmdsetup
.s
.timestamp
))
1588 status
= send_nic_timestamp_pkt(oct
, &ndata
, finfo
, xmit_more
);
1590 status
= octnet_send_nic_data_pkt(oct
, &ndata
, xmit_more
);
1591 if (status
== IQ_SEND_FAILED
)
1592 goto lio_xmit_failed
;
1594 netif_info(lio
, tx_queued
, lio
->netdev
, "Transmit queued successfully\n");
1596 if (status
== IQ_SEND_STOP
) {
1597 dev_err(&oct
->pci_dev
->dev
, "Rcvd IQ_SEND_STOP signal; stopping IQ-%d\n",
1599 netif_stop_subqueue(netdev
, q_idx
);
1602 netif_trans_update(netdev
);
1604 if (tx_info
->s
.gso_segs
)
1605 stats
->tx_done
+= tx_info
->s
.gso_segs
;
1608 stats
->tx_tot_bytes
+= ndata
.datasize
;
1610 return NETDEV_TX_OK
;
1613 stats
->tx_dropped
++;
1614 netif_info(lio
, tx_err
, lio
->netdev
, "IQ%d Transmit dropped:%llu\n",
1615 iq_no
, stats
->tx_dropped
);
1617 dma_unmap_single(&oct
->pci_dev
->dev
, dptr
,
1618 ndata
.datasize
, DMA_TO_DEVICE
);
1620 octeon_ring_doorbell_locked(oct
, iq_no
);
1622 tx_buffer_free(skb
);
1623 return NETDEV_TX_OK
;
1627 * liquidio_tx_timeout - Network device Tx timeout
1628 * @netdev: pointer to network device
1629 * @txqueue: index of the hung transmit queue
1631 static void liquidio_tx_timeout(struct net_device
*netdev
, unsigned int txqueue
)
1635 lio
= GET_LIO(netdev
);
1637 netif_info(lio
, tx_err
, lio
->netdev
,
1638 "Transmit timeout tx_dropped:%ld, waking up queues now!!\n",
1639 netdev
->stats
.tx_dropped
);
1640 netif_trans_update(netdev
);
1645 liquidio_vlan_rx_add_vid(struct net_device
*netdev
,
1646 __be16 proto
__attribute__((unused
)), u16 vid
)
1648 struct lio
*lio
= GET_LIO(netdev
);
1649 struct octeon_device
*oct
= lio
->oct_dev
;
1650 struct octnic_ctrl_pkt nctrl
;
1653 memset(&nctrl
, 0, sizeof(struct octnic_ctrl_pkt
));
1656 nctrl
.ncmd
.s
.cmd
= OCTNET_CMD_ADD_VLAN_FILTER
;
1657 nctrl
.ncmd
.s
.param1
= vid
;
1658 nctrl
.iq_no
= lio
->linfo
.txpciq
[0].s
.q_no
;
1659 nctrl
.netpndev
= (u64
)netdev
;
1660 nctrl
.cb_fn
= liquidio_link_ctrl_cmd_completion
;
1662 ret
= octnet_send_nic_ctrl_pkt(lio
->oct_dev
, &nctrl
);
1664 dev_err(&oct
->pci_dev
->dev
, "Add VLAN filter failed in core (ret: 0x%x)\n",
1673 liquidio_vlan_rx_kill_vid(struct net_device
*netdev
,
1674 __be16 proto
__attribute__((unused
)), u16 vid
)
1676 struct lio
*lio
= GET_LIO(netdev
);
1677 struct octeon_device
*oct
= lio
->oct_dev
;
1678 struct octnic_ctrl_pkt nctrl
;
1681 memset(&nctrl
, 0, sizeof(struct octnic_ctrl_pkt
));
1684 nctrl
.ncmd
.s
.cmd
= OCTNET_CMD_DEL_VLAN_FILTER
;
1685 nctrl
.ncmd
.s
.param1
= vid
;
1686 nctrl
.iq_no
= lio
->linfo
.txpciq
[0].s
.q_no
;
1687 nctrl
.netpndev
= (u64
)netdev
;
1688 nctrl
.cb_fn
= liquidio_link_ctrl_cmd_completion
;
1690 ret
= octnet_send_nic_ctrl_pkt(lio
->oct_dev
, &nctrl
);
1692 dev_err(&oct
->pci_dev
->dev
, "Del VLAN filter failed in core (ret: 0x%x)\n",
1700 /** Sending command to enable/disable RX checksum offload
1701 * @param netdev pointer to network device
1702 * @param command OCTNET_CMD_TNL_RX_CSUM_CTL
1703 * @param rx_cmd_bit OCTNET_CMD_RXCSUM_ENABLE/
1704 * OCTNET_CMD_RXCSUM_DISABLE
1705 * @returns SUCCESS or FAILURE
1707 static int liquidio_set_rxcsum_command(struct net_device
*netdev
, int command
,
1710 struct lio
*lio
= GET_LIO(netdev
);
1711 struct octeon_device
*oct
= lio
->oct_dev
;
1712 struct octnic_ctrl_pkt nctrl
;
1715 memset(&nctrl
, 0, sizeof(struct octnic_ctrl_pkt
));
1718 nctrl
.ncmd
.s
.cmd
= command
;
1719 nctrl
.ncmd
.s
.param1
= rx_cmd
;
1720 nctrl
.iq_no
= lio
->linfo
.txpciq
[0].s
.q_no
;
1721 nctrl
.netpndev
= (u64
)netdev
;
1722 nctrl
.cb_fn
= liquidio_link_ctrl_cmd_completion
;
1724 ret
= octnet_send_nic_ctrl_pkt(lio
->oct_dev
, &nctrl
);
1726 dev_err(&oct
->pci_dev
->dev
, "DEVFLAGS RXCSUM change failed in core (ret:0x%x)\n",
1734 /** Sending command to add/delete VxLAN UDP port to firmware
1735 * @param netdev pointer to network device
1736 * @param command OCTNET_CMD_VXLAN_PORT_CONFIG
1737 * @param vxlan_port VxLAN port to be added or deleted
1738 * @param vxlan_cmd_bit OCTNET_CMD_VXLAN_PORT_ADD,
1739 * OCTNET_CMD_VXLAN_PORT_DEL
1740 * @returns SUCCESS or FAILURE
1742 static int liquidio_vxlan_port_command(struct net_device
*netdev
, int command
,
1743 u16 vxlan_port
, u8 vxlan_cmd_bit
)
1745 struct lio
*lio
= GET_LIO(netdev
);
1746 struct octeon_device
*oct
= lio
->oct_dev
;
1747 struct octnic_ctrl_pkt nctrl
;
1750 memset(&nctrl
, 0, sizeof(struct octnic_ctrl_pkt
));
1753 nctrl
.ncmd
.s
.cmd
= command
;
1754 nctrl
.ncmd
.s
.more
= vxlan_cmd_bit
;
1755 nctrl
.ncmd
.s
.param1
= vxlan_port
;
1756 nctrl
.iq_no
= lio
->linfo
.txpciq
[0].s
.q_no
;
1757 nctrl
.netpndev
= (u64
)netdev
;
1758 nctrl
.cb_fn
= liquidio_link_ctrl_cmd_completion
;
1760 ret
= octnet_send_nic_ctrl_pkt(lio
->oct_dev
, &nctrl
);
1762 dev_err(&oct
->pci_dev
->dev
,
1763 "DEVFLAGS VxLAN port add/delete failed in core (ret : 0x%x)\n",
1771 static int liquidio_udp_tunnel_set_port(struct net_device
*netdev
,
1772 unsigned int table
, unsigned int entry
,
1773 struct udp_tunnel_info
*ti
)
1775 return liquidio_vxlan_port_command(netdev
,
1776 OCTNET_CMD_VXLAN_PORT_CONFIG
,
1778 OCTNET_CMD_VXLAN_PORT_ADD
);
1781 static int liquidio_udp_tunnel_unset_port(struct net_device
*netdev
,
1784 struct udp_tunnel_info
*ti
)
1786 return liquidio_vxlan_port_command(netdev
,
1787 OCTNET_CMD_VXLAN_PORT_CONFIG
,
1789 OCTNET_CMD_VXLAN_PORT_DEL
);
1792 static const struct udp_tunnel_nic_info liquidio_udp_tunnels
= {
1793 .set_port
= liquidio_udp_tunnel_set_port
,
1794 .unset_port
= liquidio_udp_tunnel_unset_port
,
1796 { .n_entries
= 1024, .tunnel_types
= UDP_TUNNEL_TYPE_VXLAN
, },
1800 /** \brief Net device fix features
1801 * @param netdev pointer to network device
1802 * @param request features requested
1803 * @returns updated features list
1805 static netdev_features_t
liquidio_fix_features(struct net_device
*netdev
,
1806 netdev_features_t request
)
1808 struct lio
*lio
= netdev_priv(netdev
);
1810 if ((request
& NETIF_F_RXCSUM
) &&
1811 !(lio
->dev_capability
& NETIF_F_RXCSUM
))
1812 request
&= ~NETIF_F_RXCSUM
;
1814 if ((request
& NETIF_F_HW_CSUM
) &&
1815 !(lio
->dev_capability
& NETIF_F_HW_CSUM
))
1816 request
&= ~NETIF_F_HW_CSUM
;
1818 if ((request
& NETIF_F_TSO
) && !(lio
->dev_capability
& NETIF_F_TSO
))
1819 request
&= ~NETIF_F_TSO
;
1821 if ((request
& NETIF_F_TSO6
) && !(lio
->dev_capability
& NETIF_F_TSO6
))
1822 request
&= ~NETIF_F_TSO6
;
1824 if ((request
& NETIF_F_LRO
) && !(lio
->dev_capability
& NETIF_F_LRO
))
1825 request
&= ~NETIF_F_LRO
;
1827 /* Disable LRO if RXCSUM is off */
1828 if (!(request
& NETIF_F_RXCSUM
) && (netdev
->features
& NETIF_F_LRO
) &&
1829 (lio
->dev_capability
& NETIF_F_LRO
))
1830 request
&= ~NETIF_F_LRO
;
1835 /** \brief Net device set features
1836 * @param netdev pointer to network device
1837 * @param features features to enable/disable
1839 static int liquidio_set_features(struct net_device
*netdev
,
1840 netdev_features_t features
)
1842 struct lio
*lio
= netdev_priv(netdev
);
1844 if (!((netdev
->features
^ features
) & NETIF_F_LRO
))
1847 if ((features
& NETIF_F_LRO
) && (lio
->dev_capability
& NETIF_F_LRO
))
1848 liquidio_set_feature(netdev
, OCTNET_CMD_LRO_ENABLE
,
1849 OCTNIC_LROIPV4
| OCTNIC_LROIPV6
);
1850 else if (!(features
& NETIF_F_LRO
) &&
1851 (lio
->dev_capability
& NETIF_F_LRO
))
1852 liquidio_set_feature(netdev
, OCTNET_CMD_LRO_DISABLE
,
1853 OCTNIC_LROIPV4
| OCTNIC_LROIPV6
);
1854 if (!(netdev
->features
& NETIF_F_RXCSUM
) &&
1855 (lio
->enc_dev_capability
& NETIF_F_RXCSUM
) &&
1856 (features
& NETIF_F_RXCSUM
))
1857 liquidio_set_rxcsum_command(netdev
, OCTNET_CMD_TNL_RX_CSUM_CTL
,
1858 OCTNET_CMD_RXCSUM_ENABLE
);
1859 else if ((netdev
->features
& NETIF_F_RXCSUM
) &&
1860 (lio
->enc_dev_capability
& NETIF_F_RXCSUM
) &&
1861 !(features
& NETIF_F_RXCSUM
))
1862 liquidio_set_rxcsum_command(netdev
, OCTNET_CMD_TNL_RX_CSUM_CTL
,
1863 OCTNET_CMD_RXCSUM_DISABLE
);
1868 static const struct net_device_ops lionetdevops
= {
1869 .ndo_open
= liquidio_open
,
1870 .ndo_stop
= liquidio_stop
,
1871 .ndo_start_xmit
= liquidio_xmit
,
1872 .ndo_get_stats64
= liquidio_get_stats64
,
1873 .ndo_set_mac_address
= liquidio_set_mac
,
1874 .ndo_set_rx_mode
= liquidio_set_mcast_list
,
1875 .ndo_tx_timeout
= liquidio_tx_timeout
,
1876 .ndo_vlan_rx_add_vid
= liquidio_vlan_rx_add_vid
,
1877 .ndo_vlan_rx_kill_vid
= liquidio_vlan_rx_kill_vid
,
1878 .ndo_change_mtu
= liquidio_change_mtu
,
1879 .ndo_do_ioctl
= liquidio_ioctl
,
1880 .ndo_fix_features
= liquidio_fix_features
,
1881 .ndo_set_features
= liquidio_set_features
,
1882 .ndo_udp_tunnel_add
= udp_tunnel_nic_add_port
,
1883 .ndo_udp_tunnel_del
= udp_tunnel_nic_del_port
,
1886 static int lio_nic_info(struct octeon_recv_info
*recv_info
, void *buf
)
1888 struct octeon_device
*oct
= (struct octeon_device
*)buf
;
1889 struct octeon_recv_pkt
*recv_pkt
= recv_info
->recv_pkt
;
1890 union oct_link_status
*ls
;
1894 if (recv_pkt
->buffer_size
[0] != (sizeof(*ls
) + OCT_DROQ_INFO_SIZE
)) {
1895 dev_err(&oct
->pci_dev
->dev
, "Malformed NIC_INFO, len=%d, ifidx=%d\n",
1896 recv_pkt
->buffer_size
[0],
1897 recv_pkt
->rh
.r_nic_info
.gmxport
);
1901 gmxport
= recv_pkt
->rh
.r_nic_info
.gmxport
;
1902 ls
= (union oct_link_status
*)(get_rbd(recv_pkt
->buffer_ptr
[0]) +
1903 OCT_DROQ_INFO_SIZE
);
1905 octeon_swap_8B_data((u64
*)ls
, (sizeof(union oct_link_status
)) >> 3);
1907 for (i
= 0; i
< oct
->ifcount
; i
++) {
1908 if (oct
->props
[i
].gmxport
== gmxport
) {
1909 update_link_status(oct
->props
[i
].netdev
, ls
);
1915 for (i
= 0; i
< recv_pkt
->buffer_count
; i
++)
1916 recv_buffer_free(recv_pkt
->buffer_ptr
[i
]);
1917 octeon_free_recv_info(recv_info
);
1922 * setup_nic_devices - Setup network interfaces
1923 * @octeon_dev: octeon device
1925 * Called during init time for each device. It assumes the NIC
1926 * is already up and running. The link information for each
1927 * interface is passed in link_info.
1929 static int setup_nic_devices(struct octeon_device
*octeon_dev
)
1931 int retval
, num_iqueues
, num_oqueues
;
1932 u32 resp_size
, data_size
;
1933 struct liquidio_if_cfg_resp
*resp
;
1934 struct octeon_soft_command
*sc
;
1935 union oct_nic_if_cfg if_cfg
;
1936 struct octdev_props
*props
;
1937 struct net_device
*netdev
;
1938 struct lio_version
*vdata
;
1939 struct lio
*lio
= NULL
;
1940 u8 mac
[ETH_ALEN
], i
, j
;
1943 ifidx_or_pfnum
= octeon_dev
->pf_num
;
1945 /* This is to handle link status changes */
1946 octeon_register_dispatch_fn(octeon_dev
, OPCODE_NIC
, OPCODE_NIC_INFO
,
1947 lio_nic_info
, octeon_dev
);
1949 /* REQTYPE_RESP_NET and REQTYPE_SOFT_COMMAND do not have free functions.
1950 * They are handled directly.
1952 octeon_register_reqtype_free_fn(octeon_dev
, REQTYPE_NORESP_NET
,
1955 octeon_register_reqtype_free_fn(octeon_dev
, REQTYPE_NORESP_NET_SG
,
1958 octeon_register_reqtype_free_fn(octeon_dev
, REQTYPE_RESP_NET_SG
,
1959 free_netsgbuf_with_resp
);
1961 for (i
= 0; i
< octeon_dev
->ifcount
; i
++) {
1962 resp_size
= sizeof(struct liquidio_if_cfg_resp
);
1963 data_size
= sizeof(struct lio_version
);
1964 sc
= (struct octeon_soft_command
*)
1965 octeon_alloc_soft_command(octeon_dev
, data_size
,
1967 resp
= (struct liquidio_if_cfg_resp
*)sc
->virtrptr
;
1968 vdata
= (struct lio_version
*)sc
->virtdptr
;
1970 *((u64
*)vdata
) = 0;
1971 vdata
->major
= cpu_to_be16(LIQUIDIO_BASE_MAJOR_VERSION
);
1972 vdata
->minor
= cpu_to_be16(LIQUIDIO_BASE_MINOR_VERSION
);
1973 vdata
->micro
= cpu_to_be16(LIQUIDIO_BASE_MICRO_VERSION
);
1977 if_cfg
.s
.num_iqueues
= octeon_dev
->sriov_info
.rings_per_vf
;
1978 if_cfg
.s
.num_oqueues
= octeon_dev
->sriov_info
.rings_per_vf
;
1979 if_cfg
.s
.base_queue
= 0;
1983 octeon_prepare_soft_command(octeon_dev
, sc
, OPCODE_NIC
,
1984 OPCODE_NIC_IF_CFG
, 0, if_cfg
.u64
,
1987 init_completion(&sc
->complete
);
1988 sc
->sc_status
= OCTEON_REQUEST_PENDING
;
1990 retval
= octeon_send_soft_command(octeon_dev
, sc
);
1991 if (retval
== IQ_SEND_FAILED
) {
1992 dev_err(&octeon_dev
->pci_dev
->dev
,
1993 "iq/oq config failed status: %x\n", retval
);
1994 /* Soft instr is freed by driver in case of failure. */
1995 octeon_free_soft_command(octeon_dev
, sc
);
1999 /* Sleep on a wait queue till the cond flag indicates that the
2000 * response arrived or timed-out.
2002 retval
= wait_for_sc_completion_timeout(octeon_dev
, sc
, 0);
2006 retval
= resp
->status
;
2008 dev_err(&octeon_dev
->pci_dev
->dev
,
2009 "iq/oq config failed, retval = %d\n", retval
);
2010 WRITE_ONCE(sc
->caller_is_done
, true);
2014 snprintf(octeon_dev
->fw_info
.liquidio_firmware_version
,
2016 resp
->cfg_info
.liquidio_firmware_version
);
2018 octeon_swap_8B_data((u64
*)(&resp
->cfg_info
),
2019 (sizeof(struct liquidio_if_cfg_info
)) >> 3);
2021 num_iqueues
= hweight64(resp
->cfg_info
.iqmask
);
2022 num_oqueues
= hweight64(resp
->cfg_info
.oqmask
);
2024 if (!(num_iqueues
) || !(num_oqueues
)) {
2025 dev_err(&octeon_dev
->pci_dev
->dev
,
2026 "Got bad iqueues (%016llx) or oqueues (%016llx) from firmware.\n",
2027 resp
->cfg_info
.iqmask
, resp
->cfg_info
.oqmask
);
2028 WRITE_ONCE(sc
->caller_is_done
, true);
2029 goto setup_nic_dev_done
;
2031 dev_dbg(&octeon_dev
->pci_dev
->dev
,
2032 "interface %d, iqmask %016llx, oqmask %016llx, numiqueues %d, numoqueues %d\n",
2033 i
, resp
->cfg_info
.iqmask
, resp
->cfg_info
.oqmask
,
2034 num_iqueues
, num_oqueues
);
2036 netdev
= alloc_etherdev_mq(LIO_SIZE
, num_iqueues
);
2039 dev_err(&octeon_dev
->pci_dev
->dev
, "Device allocation failed\n");
2040 WRITE_ONCE(sc
->caller_is_done
, true);
2041 goto setup_nic_dev_done
;
2044 SET_NETDEV_DEV(netdev
, &octeon_dev
->pci_dev
->dev
);
2046 /* Associate the routines that will handle different
2049 netdev
->netdev_ops
= &lionetdevops
;
2051 lio
= GET_LIO(netdev
);
2053 memset(lio
, 0, sizeof(struct lio
));
2055 lio
->ifidx
= ifidx_or_pfnum
;
2057 props
= &octeon_dev
->props
[i
];
2058 props
->gmxport
= resp
->cfg_info
.linfo
.gmxport
;
2059 props
->netdev
= netdev
;
2061 lio
->linfo
.num_rxpciq
= num_oqueues
;
2062 lio
->linfo
.num_txpciq
= num_iqueues
;
2064 for (j
= 0; j
< num_oqueues
; j
++) {
2065 lio
->linfo
.rxpciq
[j
].u64
=
2066 resp
->cfg_info
.linfo
.rxpciq
[j
].u64
;
2068 for (j
= 0; j
< num_iqueues
; j
++) {
2069 lio
->linfo
.txpciq
[j
].u64
=
2070 resp
->cfg_info
.linfo
.txpciq
[j
].u64
;
2073 lio
->linfo
.hw_addr
= resp
->cfg_info
.linfo
.hw_addr
;
2074 lio
->linfo
.gmxport
= resp
->cfg_info
.linfo
.gmxport
;
2075 lio
->linfo
.link
.u64
= resp
->cfg_info
.linfo
.link
.u64
;
2076 lio
->linfo
.macaddr_is_admin_asgnd
=
2077 resp
->cfg_info
.linfo
.macaddr_is_admin_asgnd
;
2078 lio
->linfo
.macaddr_spoofchk
=
2079 resp
->cfg_info
.linfo
.macaddr_spoofchk
;
2081 lio
->msg_enable
= netif_msg_init(debug
, DEFAULT_MSG_ENABLE
);
2083 lio
->dev_capability
= NETIF_F_HIGHDMA
2084 | NETIF_F_IP_CSUM
| NETIF_F_IPV6_CSUM
2085 | NETIF_F_SG
| NETIF_F_RXCSUM
2086 | NETIF_F_TSO
| NETIF_F_TSO6
2089 netif_set_gso_max_size(netdev
, OCTNIC_GSO_MAX_SIZE
);
2091 /* Copy of transmit encapsulation capabilities:
2092 * TSO, TSO6, Checksums for this device
2094 lio
->enc_dev_capability
= NETIF_F_IP_CSUM
2096 | NETIF_F_GSO_UDP_TUNNEL
2097 | NETIF_F_HW_CSUM
| NETIF_F_SG
2099 | NETIF_F_TSO
| NETIF_F_TSO6
2102 netdev
->hw_enc_features
=
2103 (lio
->enc_dev_capability
& ~NETIF_F_LRO
);
2104 netdev
->udp_tunnel_nic_info
= &liquidio_udp_tunnels
;
2106 netdev
->vlan_features
= lio
->dev_capability
;
2107 /* Add any unchangeable hw features */
2108 lio
->dev_capability
|= NETIF_F_HW_VLAN_CTAG_FILTER
|
2109 NETIF_F_HW_VLAN_CTAG_RX
|
2110 NETIF_F_HW_VLAN_CTAG_TX
;
2112 netdev
->features
= (lio
->dev_capability
& ~NETIF_F_LRO
);
2114 netdev
->hw_features
= lio
->dev_capability
;
2115 netdev
->hw_features
&= ~NETIF_F_HW_VLAN_CTAG_RX
;
2117 /* MTU range: 68 - 16000 */
2118 netdev
->min_mtu
= LIO_MIN_MTU_SIZE
;
2119 netdev
->max_mtu
= LIO_MAX_MTU_SIZE
;
2121 WRITE_ONCE(sc
->caller_is_done
, true);
2123 /* Point to the properties for octeon device to which this
2124 * interface belongs.
2126 lio
->oct_dev
= octeon_dev
;
2127 lio
->octprops
= props
;
2128 lio
->netdev
= netdev
;
2130 dev_dbg(&octeon_dev
->pci_dev
->dev
,
2131 "if%d gmx: %d hw_addr: 0x%llx\n", i
,
2132 lio
->linfo
.gmxport
, CVM_CAST64(lio
->linfo
.hw_addr
));
2134 /* 64-bit swap required on LE machines */
2135 octeon_swap_8B_data(&lio
->linfo
.hw_addr
, 1);
2136 for (j
= 0; j
< ETH_ALEN
; j
++)
2137 mac
[j
] = *((u8
*)(((u8
*)&lio
->linfo
.hw_addr
) + 2 + j
));
2139 /* Copy MAC Address to OS network device structure */
2140 ether_addr_copy(netdev
->dev_addr
, mac
);
2142 if (liquidio_setup_io_queues(octeon_dev
, i
,
2143 lio
->linfo
.num_txpciq
,
2144 lio
->linfo
.num_rxpciq
)) {
2145 dev_err(&octeon_dev
->pci_dev
->dev
, "I/O queues creation failed\n");
2146 goto setup_nic_dev_free
;
2149 ifstate_set(lio
, LIO_IFSTATE_DROQ_OPS
);
2151 /* For VFs, enable Octeon device interrupts here,
2152 * as this is contingent upon IO queue setup
2154 octeon_dev
->fn_list
.enable_interrupt(octeon_dev
,
2157 /* By default all interfaces on a single Octeon uses the same
2160 lio
->txq
= lio
->linfo
.txpciq
[0].s
.q_no
;
2161 lio
->rxq
= lio
->linfo
.rxpciq
[0].s
.q_no
;
2163 lio
->tx_qsize
= octeon_get_tx_qsize(octeon_dev
, lio
->txq
);
2164 lio
->rx_qsize
= octeon_get_rx_qsize(octeon_dev
, lio
->rxq
);
2166 if (lio_setup_glists(octeon_dev
, lio
, num_iqueues
)) {
2167 dev_err(&octeon_dev
->pci_dev
->dev
,
2168 "Gather list allocation failed\n");
2169 goto setup_nic_dev_free
;
2172 /* Register ethtool support */
2173 liquidio_set_ethtool_ops(netdev
);
2174 if (lio
->oct_dev
->chip_id
== OCTEON_CN23XX_VF_VID
)
2175 octeon_dev
->priv_flags
= OCT_PRIV_FLAG_DEFAULT
;
2177 octeon_dev
->priv_flags
= 0x0;
2179 if (netdev
->features
& NETIF_F_LRO
)
2180 liquidio_set_feature(netdev
, OCTNET_CMD_LRO_ENABLE
,
2181 OCTNIC_LROIPV4
| OCTNIC_LROIPV6
);
2183 if (setup_link_status_change_wq(netdev
))
2184 goto setup_nic_dev_free
;
2186 if (setup_rx_oom_poll_fn(netdev
))
2187 goto setup_nic_dev_free
;
2189 /* Register the network device with the OS */
2190 if (register_netdev(netdev
)) {
2191 dev_err(&octeon_dev
->pci_dev
->dev
, "Device registration failed\n");
2192 goto setup_nic_dev_free
;
2195 dev_dbg(&octeon_dev
->pci_dev
->dev
,
2196 "Setup NIC ifidx:%d mac:%02x%02x%02x%02x%02x%02x\n",
2197 i
, mac
[0], mac
[1], mac
[2], mac
[3], mac
[4], mac
[5]);
2198 netif_carrier_off(netdev
);
2199 lio
->link_changes
++;
2201 ifstate_set(lio
, LIO_IFSTATE_REGISTERED
);
2203 /* Sending command to firmware to enable Rx checksum offload
2204 * by default at the time of setup of Liquidio driver for
2207 liquidio_set_rxcsum_command(netdev
, OCTNET_CMD_TNL_RX_CSUM_CTL
,
2208 OCTNET_CMD_RXCSUM_ENABLE
);
2209 liquidio_set_feature(netdev
, OCTNET_CMD_TNL_TX_CSUM_CTL
,
2210 OCTNET_CMD_TXCSUM_ENABLE
);
2212 dev_dbg(&octeon_dev
->pci_dev
->dev
,
2213 "NIC ifidx:%d Setup successful\n", i
);
2215 octeon_dev
->no_speed_setting
= 1;
2223 dev_err(&octeon_dev
->pci_dev
->dev
,
2224 "NIC ifidx:%d Setup failed\n", i
);
2225 liquidio_destroy_nic_device(octeon_dev
, i
);
2234 * liquidio_init_nic_module - initialize the NIC
2235 * @oct: octeon device
2237 * This initialization routine is called once the Octeon device application is
2240 static int liquidio_init_nic_module(struct octeon_device
*oct
)
2242 int num_nic_ports
= 1;
2245 dev_dbg(&oct
->pci_dev
->dev
, "Initializing network interfaces\n");
2247 /* only default iq and oq were initialized
2248 * initialize the rest as well run port_config command for each port
2250 oct
->ifcount
= num_nic_ports
;
2251 memset(oct
->props
, 0,
2252 sizeof(struct octdev_props
) * num_nic_ports
);
2254 for (i
= 0; i
< MAX_OCTEON_LINKS
; i
++)
2255 oct
->props
[i
].gmxport
= -1;
2257 retval
= setup_nic_devices(oct
);
2259 dev_err(&oct
->pci_dev
->dev
, "Setup NIC devices failed\n");
2260 goto octnet_init_failure
;
2263 dev_dbg(&oct
->pci_dev
->dev
, "Network interfaces ready\n");
2267 octnet_init_failure
:
2275 * octeon_device_init - Device initialization for each Octeon device that is probed
2276 * @oct: octeon device
2278 static int octeon_device_init(struct octeon_device
*oct
)
2283 atomic_set(&oct
->status
, OCT_DEV_BEGIN_STATE
);
2285 /* Enable access to the octeon device and make its DMA capability
2288 if (octeon_pci_os_setup(oct
))
2290 atomic_set(&oct
->status
, OCT_DEV_PCI_ENABLE_DONE
);
2292 oct
->chip_id
= OCTEON_CN23XX_VF_VID
;
2293 pci_read_config_dword(oct
->pci_dev
, 8, &rev_id
);
2294 oct
->rev_id
= rev_id
& 0xff;
2296 if (cn23xx_setup_octeon_vf_device(oct
))
2299 atomic_set(&oct
->status
, OCT_DEV_PCI_MAP_DONE
);
2301 oct
->app_mode
= CVM_DRV_NIC_APP
;
2303 /* Initialize the dispatch mechanism used to push packets arriving on
2304 * Octeon Output queues.
2306 if (octeon_init_dispatch_list(oct
))
2309 atomic_set(&oct
->status
, OCT_DEV_DISPATCH_INIT_DONE
);
2311 if (octeon_set_io_queues_off(oct
)) {
2312 dev_err(&oct
->pci_dev
->dev
, "setting io queues off failed\n");
2316 if (oct
->fn_list
.setup_device_regs(oct
)) {
2317 dev_err(&oct
->pci_dev
->dev
, "device registers configuration failed\n");
2321 /* Initialize soft command buffer pool */
2322 if (octeon_setup_sc_buffer_pool(oct
)) {
2323 dev_err(&oct
->pci_dev
->dev
, "sc buffer pool allocation failed\n");
2326 atomic_set(&oct
->status
, OCT_DEV_SC_BUFF_POOL_INIT_DONE
);
2328 /* Setup the data structures that manage this Octeon's Input queues. */
2329 if (octeon_setup_instr_queues(oct
)) {
2330 dev_err(&oct
->pci_dev
->dev
, "instruction queue initialization failed\n");
2333 atomic_set(&oct
->status
, OCT_DEV_INSTR_QUEUE_INIT_DONE
);
2335 /* Initialize lists to manage the requests of different types that
2336 * arrive from user & kernel applications for this octeon device.
2338 if (octeon_setup_response_list(oct
)) {
2339 dev_err(&oct
->pci_dev
->dev
, "Response list allocation failed\n");
2342 atomic_set(&oct
->status
, OCT_DEV_RESP_LIST_INIT_DONE
);
2344 if (octeon_setup_output_queues(oct
)) {
2345 dev_err(&oct
->pci_dev
->dev
, "Output queue initialization failed\n");
2348 atomic_set(&oct
->status
, OCT_DEV_DROQ_INIT_DONE
);
2350 if (oct
->fn_list
.setup_mbox(oct
)) {
2351 dev_err(&oct
->pci_dev
->dev
, "Mailbox setup failed\n");
2354 atomic_set(&oct
->status
, OCT_DEV_MBOX_SETUP_DONE
);
2356 if (octeon_allocate_ioq_vector(oct
, oct
->sriov_info
.rings_per_vf
)) {
2357 dev_err(&oct
->pci_dev
->dev
, "ioq vector allocation failed\n");
2360 atomic_set(&oct
->status
, OCT_DEV_MSIX_ALLOC_VECTOR_DONE
);
2362 dev_info(&oct
->pci_dev
->dev
, "OCTEON_CN23XX VF: %d ioqs\n",
2363 oct
->sriov_info
.rings_per_vf
);
2365 /* Setup the interrupt handler and record the INT SUM register address*/
2366 if (octeon_setup_interrupt(oct
, oct
->sriov_info
.rings_per_vf
))
2369 atomic_set(&oct
->status
, OCT_DEV_INTR_SET_DONE
);
2371 /* ***************************************************************
2372 * The interrupts need to be enabled for the PF<-->VF handshake.
2373 * They are [re]-enabled after the PF<-->VF handshake so that the
2374 * correct OQ tick value is used (i.e. the value retrieved from
2375 * the PF as part of the handshake).
2378 /* Enable Octeon device interrupts */
2379 oct
->fn_list
.enable_interrupt(oct
, OCTEON_ALL_INTR
);
2381 if (cn23xx_octeon_pfvf_handshake(oct
))
2384 /* Here we [re]-enable the interrupts so that the correct OQ tick value
2385 * is used (i.e. the value that was retrieved during the handshake)
2388 /* Enable Octeon device interrupts */
2389 oct
->fn_list
.enable_interrupt(oct
, OCTEON_ALL_INTR
);
2390 /* *************************************************************** */
2392 /* Enable the input and output queues for this Octeon device */
2393 if (oct
->fn_list
.enable_io_queues(oct
)) {
2394 dev_err(&oct
->pci_dev
->dev
, "enabling io queues failed\n");
2398 atomic_set(&oct
->status
, OCT_DEV_IO_QUEUES_DONE
);
2400 atomic_set(&oct
->status
, OCT_DEV_HOST_OK
);
2402 /* Send Credit for Octeon Output queues. Credits are always sent after
2403 * the output queue is enabled.
2405 for (j
= 0; j
< oct
->num_oqs
; j
++)
2406 writel(oct
->droq
[j
]->max_count
, oct
->droq
[j
]->pkts_credit_reg
);
2408 /* Packets can start arriving on the output queues from this point. */
2410 atomic_set(&oct
->status
, OCT_DEV_CORE_OK
);
2412 atomic_set(&oct
->status
, OCT_DEV_RUNNING
);
2414 if (liquidio_init_nic_module(oct
))
2420 static int __init
liquidio_vf_init(void)
2422 octeon_init_device_list(0);
2423 return pci_register_driver(&liquidio_vf_pci_driver
);
2426 static void __exit
liquidio_vf_exit(void)
2428 pci_unregister_driver(&liquidio_vf_pci_driver
);
2430 pr_info("LiquidIO_VF network module is now unloaded\n");
2433 module_init(liquidio_vf_init
);
2434 module_exit(liquidio_vf_exit
);