net/sfc: maintain management event queue

[dpdk.git] / drivers / net / sfc / sfc_ev.c

diff --git a/drivers/net/sfc/sfc_ev.c b/drivers/net/sfc/sfc_ev.c
index 2ee579a..a6a1ee2 100644 (file)
--- a/drivers/net/sfc/sfc_ev.c
+++ b/drivers/net/sfc/sfc_ev.c
@@ -85,8 +85,24 @@ sfc_ev_exception(void *arg, __rte_unused uint32_t code,
 {
        struct sfc_evq *evq = arg;
 
-       sfc_err(evq->sa, "EVQ %u unexpected exception event",
-               evq->evq_index);
+       if (code == EFX_EXCEPTION_UNKNOWN_SENSOREVT)
+               return B_FALSE;
+
+       evq->exception = B_TRUE;
+       sfc_warn(evq->sa,
+                "hardware exception %s (code=%u, data=%#x) on EVQ %u;"
+                " needs recovery",
+                (code == EFX_EXCEPTION_RX_RECOVERY) ? "RX_RECOVERY" :
+                (code == EFX_EXCEPTION_RX_DSC_ERROR) ? "RX_DSC_ERROR" :
+                (code == EFX_EXCEPTION_TX_DSC_ERROR) ? "TX_DSC_ERROR" :
+                (code == EFX_EXCEPTION_FWALERT_SRAM) ? "FWALERT_SRAM" :
+                (code == EFX_EXCEPTION_UNKNOWN_FWALERT) ? "UNKNOWN_FWALERT" :
+                (code == EFX_EXCEPTION_RX_ERROR) ? "RX_ERROR" :
+                (code == EFX_EXCEPTION_TX_ERROR) ? "TX_ERROR" :
+                (code == EFX_EXCEPTION_EV_ERROR) ? "EV_ERROR" :
+                "UNKNOWN",
+                code, data, evq->evq_index);
+
        return B_TRUE;
 }
 
@@ -199,6 +215,19 @@ sfc_ev_qpoll(struct sfc_evq *evq)
        /* Poll-mode driver does not re-prime the event queue for interrupts */
 }
 
+void
+sfc_ev_mgmt_qpoll(struct sfc_adapter *sa)
+{
+       if (rte_spinlock_trylock(&sa->mgmt_evq_lock)) {
+               struct sfc_evq *mgmt_evq = sa->evq_info[sa->mgmt_evq_index].evq;
+
+               if (mgmt_evq->init_state == SFC_EVQ_STARTED)
+                       sfc_ev_qpoll(mgmt_evq);
+
+               rte_spinlock_unlock(&sa->mgmt_evq_lock);
+       }
+}
+
 int
 sfc_ev_qprime(struct sfc_evq *evq)
 {
@@ -310,13 +339,26 @@ sfc_ev_start(struct sfc_adapter *sa)
        if (rc != 0)
                goto fail_ev_init;
 
+       /* Start management EVQ used for global events */
+       rte_spinlock_lock(&sa->mgmt_evq_lock);
+
+       rc = sfc_ev_qstart(sa, sa->mgmt_evq_index);
+       if (rc != 0)
+               goto fail_mgmt_evq_start;
+
+       rte_spinlock_unlock(&sa->mgmt_evq_lock);
+
        /*
-        * Rx/Tx event queues are started/stopped when corresponding queue
-        * is started/stopped.
+        * Rx/Tx event queues are started/stopped when corresponding
+        * Rx/Tx queue is started/stopped.
         */
 
        return 0;
 
+fail_mgmt_evq_start:
+       rte_spinlock_unlock(&sa->mgmt_evq_lock);
+       efx_ev_fini(sa->nic);
+
 fail_ev_init:
        sfc_log_init(sa, "failed %d", rc);
        return rc;
@@ -331,8 +373,16 @@ sfc_ev_stop(struct sfc_adapter *sa)
 
        /* Make sure that all event queues are stopped */
        sw_index = sa->evq_count;
-       while (sw_index-- > 0)
-               sfc_ev_qstop(sa, sw_index);
+       while (sw_index-- > 0) {
+               if (sw_index == sa->mgmt_evq_index) {
+                       /* Locks are required for the management EVQ */
+                       rte_spinlock_lock(&sa->mgmt_evq_lock);
+                       sfc_ev_qstop(sa, sa->mgmt_evq_index);
+                       rte_spinlock_unlock(&sa->mgmt_evq_lock);
+               } else {
+                       sfc_ev_qstop(sa, sw_index);
+               }
+       }
 
        efx_ev_fini(sa->nic);
 }
@@ -426,6 +476,7 @@ sfc_ev_init(struct sfc_adapter *sa)
 
        sa->evq_count = sfc_ev_qcount(sa);
        sa->mgmt_evq_index = 0;
+       rte_spinlock_init(&sa->mgmt_evq_lock);
 
        /* Allocate EVQ info array */
        rc = ENOMEM;
@@ -441,6 +492,11 @@ sfc_ev_init(struct sfc_adapter *sa)
                        goto fail_ev_qinit_info;
        }
 
+       rc = sfc_ev_qinit(sa, sa->mgmt_evq_index, SFC_MGMT_EVQ_ENTRIES,
+                         sa->socket_id);
+       if (rc != 0)
+               goto fail_mgmt_evq_init;
+
        /*
         * Rx/Tx event queues are created/destroyed when corresponding
         * Rx/Tx queue is created/destroyed.
@@ -448,6 +504,7 @@ sfc_ev_init(struct sfc_adapter *sa)
 
        return 0;
 
+fail_mgmt_evq_init:
 fail_ev_qinit_info:
        while (sw_index-- > 0)
                sfc_ev_qfini_info(sa, sw_index);