MQ RX changes queue lifecycle from one adapter-level register/free pair
to a mixed model:

  - queue 0: registered via h_register_logical_lan*()
  - queues 1..N: registered via H_REG_LOGICAL_LAN_QUEUE

This patch extracts the queue-0 control-plane helpers used by open/close
today and wires them in the same commit:

  ibmveth_register_rx_queues()
  ibmveth_free_all_queues()

H_FREE_LOGICAL_LAN tears down the primary LAN and any subordinate queues
registered under it (PAPR/PHYP full-teardown contract). Close and
open-fail use that one free_lan. Incremental scale-down uses per-queue
H_FREE_LOGICAL_LAN_QUEUE instead; that path arrives with resize.

Also update ibmveth_register_logical_lan() so that when multi_queue is
later enabled, queue 0 uses h_register_logical_lan_with_handle() and
stores queue_handle[0]. Runtime remains single-queue: multi_queue is
still false, so queue 0 keeps the legacy h_register_logical_lan() flow
and no subordinate queue is registered. Subordinate register helpers
arrive with MQ enablement; deregister arrives with resize at first use.

Introduce adapter->hcall_stats here for register/free path accounting
(first use).

Open/close unwind:
  - failures after successful LAN registration enter
    out_unregister_queues, then fall through to out_free_buffer_pools,
    so RX pools are not leaked;
  - free_all_queues() runs before free_buffer_pools() on open failure
    and close, so PHYP cannot retain a registered LAN while its
    DMA-backed RX pools are released.

Failures before registration go directly to out_free_buffer_pools.
RX interrupt masking before napi_disable is already handled by
cleanup_rx_interrupts() from the IRQ-helper patch.

As of this patch, open/close follow the MQ-ready pipeline below
(still single-queue). The MQ enablement patch changes open's kick
(replenish-all before setup_rx_interrupts, then restart_rx_queue per
queue for SQ and MQ) and should restate that open path there. Close
shape stays the same through enablement.

ibmveth_open() (this commit):

  1. ibmveth_alloc_filter_list()
  2. ibmveth_alloc_rx_queues()       - buffer lists + RX rings
  3. ibmveth_alloc_buffer_pools()   - guest RX memory before PHYP
  4. ibmveth_register_rx_queues()   - PHYP registration (no IRQ enable)
  5. netif_set_real_num_rx_queues()
  6. ibmveth_setup_rx_interrupts()  - request_irq + napi_enable
  7. initial kick                   - schedule_rx_queue(0)
  8. ibmveth_alloc_tx_resources()
  9. netif_tx_start_all_queues(); adapter->opened = true

ibmveth_close() (this commit):

  0. if (!opened) return; opened = false
  1. netif_tx_disable()
  2. ibmveth_cleanup_rx_interrupts() - mask PHYP, napi_disable, free_irq
  3. synchronize_net()
  4. ibmveth_update_rx_no_buffer()   - last glimpse while LAN registered
  5. ibmveth_free_all_queues()       - H_FREE_LOGICAL_LAN (this patch)
  6. ibmveth_free_tx_resources()
  7. ibmveth_free_buffer_pools()
  8. ibmveth_cleanup_rx_resources()
  9. ibmveth_free_filter_list()

Per-queue NULL-safe update_rx_no_buffer() lands in the MQ enablement
patch. Idempotent close (opened / rx_irq_setup) is owned by the
IRQ-helper patch.

Signed-off-by: Mingming Cao <[email protected]>
Reviewed-by: Dave Marquardt <[email protected]>
Tested-by: Shaik Abdulla <[email protected]>
---

Changes in v5:
- Document H_FREE_LOGICAL_LAN full-teardown contract in kdoc/changelog:
  one free_lan drops primary + any subordinate queues
  (H_FREE_LOGICAL_LAN_QUEUE is for incremental scale-down only) - v4
  helper text did not spell the subordinate semantics
- Call out close() update_rx_no_buffer() before free_lan as intentional
  last-glimpse accounting while the LAN is still registered (order
  already in v4; v4 step list omitted it); NULL-safe per-queue form
  lands with MQ enablement
- opened / rx_irq_setup idempotent close is owned by the IRQ-helper
  patch (same failed-reopen / second napi_disable hang raised here)
- Poll re-arm during teardown not claimed here (same race as IRQ patch;
  lands with poll harden)

Changes in v4:
- Introduce register/free helpers in the same patch that wires their
  first open/close callers; keep subordinate-only helpers deferred
  until MQ enablement.
- Introduce adapter->hcall_stats here (first use); not in patch 2.
- Correct open/close unwind so free_all_queues() precedes
  free_buffer_pools().
- Drop the orphaned big-bang "open/close pipeline" patch from v3; that
  wiring is incremental across helper patches 3-7 instead.

 drivers/net/ethernet/ibm/ibmveth.c | 169 +++++++++++++++++++++--------
 drivers/net/ethernet/ibm/ibmveth.h |  14 +++
 2 files changed, 137 insertions(+), 46 deletions(-)

diff --git a/drivers/net/ethernet/ibm/ibmveth.c 
b/drivers/net/ethernet/ibm/ibmveth.c
index b39e8c53cbfd..8519cad50322 100644
--- a/drivers/net/ethernet/ibm/ibmveth.c
+++ b/drivers/net/ethernet/ibm/ibmveth.c
@@ -1260,9 +1260,14 @@ static void ibmveth_free_tx_resources(struct 
ibmveth_adapter *adapter)
 }
 
 static int ibmveth_register_logical_lan(struct ibmveth_adapter *adapter,
-        union ibmveth_buf_desc rxq_desc, u64 mac_address)
+                                       union ibmveth_buf_desc rxq_desc,
+                                       u64 mac_address)
 {
        int rc, try_again = 1;
+       unsigned long ua = adapter->vdev->unit_address;
+       unsigned long buf_dma = adapter->buffer_list_dma[0];
+       unsigned long filter_dma = adapter->filter_list_dma;
+       unsigned long qh0;
 
        /*
         * After a kexec the adapter will still be open, so our attempt to
@@ -1270,13 +1275,27 @@ static int ibmveth_register_logical_lan(struct 
ibmveth_adapter *adapter,
         * try again, but only once.
         */
 retry:
-       rc = h_register_logical_lan(adapter->vdev->unit_address,
-                                   adapter->buffer_list_dma[0], rxq_desc.desc,
-                                   adapter->filter_list_dma, mac_address);
+       /* In multi-queue mode, obtain a queue handle for queue 0 so all RX
+        * queues can use the same per-queue buffer hypercalls.
+        */
+       if (adapter->multi_queue) {
+               rc = h_register_logical_lan_with_handle(ua, buf_dma,
+                                                       rxq_desc.desc,
+                                                       filter_dma,
+                                                       mac_address,
+                                                       &qh0);
+               if (rc == H_SUCCESS)
+                       adapter->queue_handle[0] = qh0;
+       } else {
+               rc = h_register_logical_lan(ua, buf_dma, rxq_desc.desc,
+                                           filter_dma, mac_address);
+       }
+       adapter->hcall_stats.reg_lan++;
 
        if (rc != H_SUCCESS && try_again) {
                do {
                        rc = h_free_logical_lan(adapter->vdev->unit_address);
+                       adapter->hcall_stats.free_lan++;
                } while (H_IS_LONG_BUSY(rc) || (rc == H_BUSY));
 
                try_again = 0;
@@ -1286,14 +1305,93 @@ static int ibmveth_register_logical_lan(struct 
ibmveth_adapter *adapter,
        return rc;
 }
 
+/**
+ * ibmveth_free_all_queues - Free all RX queues at once
+ * @adapter: ibmveth adapter structure
+ *
+ * Issues one H_FREE_LOGICAL_LAN for full adapter teardown. Per PAPR/PHYP,
+ * that drops the primary LAN and any subordinate queues registered under
+ * it. Incremental scale-down uses H_FREE_LOGICAL_LAN_QUEUE per queue
+ * instead; do not use this helper for partial live-set shrink.
+ *
+ * Used during interface close and registration error cleanup.
+ *
+ * Clears queue handles only; queue_irq[] is released by
+ * ibmveth_cleanup_rx_interrupts().
+ */
+static void ibmveth_free_all_queues(struct ibmveth_adapter *adapter)
+{
+       unsigned long lpar_rc;
+       int i;
+
+       netdev_dbg(adapter->netdev, "freeing all RX queues at once\n");
+
+       do {
+               lpar_rc = h_free_logical_lan(adapter->vdev->unit_address);
+               adapter->hcall_stats.free_lan++;
+       } while (H_IS_LONG_BUSY(lpar_rc) || (lpar_rc == H_BUSY));
+
+       if (lpar_rc != H_SUCCESS) {
+               netdev_err(adapter->netdev,
+                          "h_free_logical_lan failed: %ld\n", lpar_rc);
+       }
+
+       for (i = 0; i < adapter->num_rx_queues; i++)
+               adapter->queue_handle[i] = 0;
+}
+
+/**
+ * ibmveth_register_rx_queues - Register RX queues with hypervisor
+ * @adapter: ibmveth adapter structure
+ * @mac_address: MAC address for device registration
+ *
+ * Registers queue 0 via ibmveth_register_logical_lan(). Subordinate queue
+ * registration is added when multi-queue RX is enabled.
+ *
+ * Return: 0 on success, -ENONET if queue 0 registration fails
+ */
+static int
+ibmveth_register_rx_queues(struct ibmveth_adapter *adapter, u64 mac_address)
+{
+       struct net_device *netdev = adapter->netdev;
+       union ibmveth_buf_desc rxq_desc;
+       unsigned long lpar_rc;
+       int rc;
+
+       rxq_desc.fields.flags_len = IBMVETH_BUF_VALID |
+                                   adapter->rx_queue[0].queue_len;
+       rxq_desc.fields.address = adapter->rx_queue[0].queue_dma;
+       adapter->queue_irq[0] = netdev->irq;
+
+       rc = ibmveth_disable_irq(adapter, 0);
+       if (rc)
+               netdev_dbg(netdev,
+                          "Failed to disable IRQ for queue 0 before 
registration, rc=%d\n",
+                          rc);
+
+       lpar_rc = ibmveth_register_logical_lan(adapter, rxq_desc, mac_address);
+       if (lpar_rc != H_SUCCESS) {
+               netdev_err(netdev,
+                          "h_register_logical_lan failed: %ld\n", lpar_rc);
+               netdev_err(netdev,
+                          "buffer TCE:0x%llx filter TCE:0x%llx rxq desc:0x%llx 
MAC:0x%llx\n",
+                          adapter->buffer_list_dma[0],
+                          adapter->filter_list_dma,
+                          rxq_desc.desc, mac_address);
+               return -ENONET;
+       }
+
+       netdev_dbg(netdev,
+                  "registered 1 RX queue with hypervisor (single-queue 
mode)\n");
+       return 0;
+}
+
 static int ibmveth_open(struct net_device *netdev)
 {
        struct ibmveth_adapter *adapter = netdev_priv(netdev);
-       u64 mac_address;
+       u64 mac_address = ether_addr_to_u64(netdev->dev_addr);
        int rxq_entries = 1;
-       unsigned long lpar_rc;
        int rc;
-       union ibmveth_buf_desc rxq_desc;
        int i;
 
        netdev_dbg(netdev, "open starting\n");
@@ -1309,37 +1407,23 @@ static int ibmveth_open(struct net_device *netdev)
        if (rc)
                goto out_free_filter_list;
 
-       mac_address = ether_addr_to_u64(netdev->dev_addr);
-
-       rxq_desc.fields.flags_len = IBMVETH_BUF_VALID |
-                                       adapter->rx_queue[0].queue_len;
-       rxq_desc.fields.address = adapter->rx_queue[0].queue_dma;
-
-       adapter->queue_irq[0] = netdev->irq;
-       ibmveth_disable_irq(adapter, 0);
-
-       lpar_rc = ibmveth_register_logical_lan(adapter, rxq_desc, mac_address);
-
-       if (lpar_rc != H_SUCCESS) {
-               netdev_err(netdev, "h_register_logical_lan failed with %ld\n",
-                          lpar_rc);
-               netdev_err(netdev, "buffer TCE:0x%llx filter TCE:0x%llx rxq "
-                          "desc:0x%llx MAC:0x%llx\n",
-                                    adapter->buffer_list_dma[0],
-                                    adapter->filter_list_dma,
-                                    rxq_desc.desc,
-                                    mac_address);
-               rc = -ENONET;
+       rc = ibmveth_alloc_buffer_pools(adapter);
+       if (rc)
                goto out_free_queue_mem;
-       }
 
-       rc = ibmveth_alloc_buffer_pools(adapter);
+       rc = ibmveth_register_rx_queues(adapter, mac_address);
        if (rc)
-               goto out_unregister_lan;
+               goto out_free_buffer_pools;
+
+       rc = netif_set_real_num_rx_queues(netdev, adapter->num_rx_queues);
+       if (rc) {
+               netdev_err(netdev, "failed to set number of rx queues\n");
+               goto out_unregister_queues;
+       }
 
        rc = ibmveth_setup_rx_interrupts(adapter);
        if (rc)
-               goto out_unregister_lan;
+               goto out_free_all_queues; /* setup already disposed IRQs */
 
        netdev_dbg(netdev, "initial replenish cycle\n");
        ibmveth_schedule_rx_queue(adapter, 0);
@@ -1357,10 +1441,12 @@ static int ibmveth_open(struct net_device *netdev)
 
 out_cleanup_rx_interrupts:
        ibmveth_cleanup_rx_interrupts(adapter);
-out_unregister_lan:
-       do {
-               lpar_rc = h_free_logical_lan(adapter->vdev->unit_address);
-       } while (H_IS_LONG_BUSY(lpar_rc) || (lpar_rc == H_BUSY));
+       goto out_free_all_queues; /* cleanup already disposed IRQs */
+out_unregister_queues:
+       ibmveth_dispose_subordinate_irq_mappings(adapter);
+out_free_all_queues:
+       ibmveth_free_all_queues(adapter);
+out_free_buffer_pools:
        ibmveth_free_buffer_pools(adapter);
 out_free_queue_mem:
        ibmveth_cleanup_rx_resources(adapter);
@@ -1373,7 +1459,6 @@ static int ibmveth_open(struct net_device *netdev)
 static int ibmveth_close(struct net_device *netdev)
 {
        struct ibmveth_adapter *adapter = netdev_priv(netdev);
-       long lpar_rc;
 
        /* Gate on opened, not IFF_UP: pool_store/change_mtu close+open can
         * leave IFF_UP set after a failed reopen.
@@ -1395,15 +1480,7 @@ static int ibmveth_close(struct net_device *netdev)
        synchronize_net();
 
        ibmveth_update_rx_no_buffer(adapter);
-       /* Full LAN teardown (subordinates arrive with register helpers). */
-       do {
-               lpar_rc = h_free_logical_lan(adapter->vdev->unit_address);
-       } while (H_IS_LONG_BUSY(lpar_rc) || (lpar_rc == H_BUSY));
-       if (lpar_rc != H_SUCCESS) {
-               netdev_err(adapter->netdev,
-                          "h_free_logical_lan failed with %lx, continuing\n",
-                          lpar_rc);
-       }
+       ibmveth_free_all_queues(adapter);
        /* Free TX LTBs after quiesce and after H_FREE_LOGICAL_LAN so xmit
         * cannot touch unmapped bounce buffers while the LAN is live.
         */
diff --git a/drivers/net/ethernet/ibm/ibmveth.h 
b/drivers/net/ethernet/ibm/ibmveth.h
index bf5dd5703773..fae3473cc498 100644
--- a/drivers/net/ethernet/ibm/ibmveth.h
+++ b/drivers/net/ethernet/ibm/ibmveth.h
@@ -268,6 +268,17 @@ static int pool_active[] = { 1, 1, 0, 0, 1};
 
 #define IBM_VETH_INVALID_MAP ((u16)0xffff)
 
+struct ibmveth_hcall_stats {
+       u64 reg_lan_queue;      /* H_REG_LOGICAL_LAN_QUEUE */
+       u64 reg_lan;            /* H_REGISTER_LOGICAL_LAN */
+       u64 add_bufs_queue;     /* H_ADD_LOGICAL_LAN_BUFFERS_QUEUE */
+       u64 add_bufs;           /* H_ADD_LOGICAL_LAN_BUFFERS */
+       u64 add_buf;            /* H_ADD_LOGICAL_LAN_BUFFER */
+       u64 free_lan_queue;     /* H_FREE_LOGICAL_LAN_QUEUE */
+       u64 free_lan;           /* H_FREE_LOGICAL_LAN */
+       u64 send_lan;           /* H_SEND_LOGICAL_LAN */
+};
+
 struct ibmveth_buff_pool {
     u32 size;
     u32 index;
@@ -335,6 +346,9 @@ struct ibmveth_adapter {
        u64 tx_send_failed;
        u64 tx_large_packets;
        u64 rx_large_packets;
+
+       /* Hypercall statistics */
+       struct ibmveth_hcall_stats hcall_stats;
        /* Ethtool settings */
        u8 duplex;
        u32 speed;
-- 
2.50.1 (Apple Git-155)


Reply via email to