3e5111
From ec733f7eb1f88d9d030952c764c1ee635ab9060b Mon Sep 17 00:00:00 2001
3e5111
Message-Id: <ec733f7eb1f88d9d030952c764c1ee635ab9060b@dist-git>
3e5111
From: Martin Kletzander <mkletzan@redhat.com>
3e5111
Date: Fri, 16 Jun 2017 13:45:30 +0200
3e5111
Subject: [PATCH] qemu: Allow live-updates of coalesce settings
3e5111
3e5111
Change the settings from qemuDomainUpdateDeviceLive() as otherwise the
3e5111
call would succeed even though nothing has changed.
3e5111
3e5111
Resolves: https://bugzilla.redhat.com/show_bug.cgi?id=1414627
3e5111
3e5111
Signed-off-by: Martin Kletzander <mkletzan@redhat.com>
3e5111
(cherry picked from commit 307a205e25ad7db7c895c42ab2e8f59f3839c058)
3e5111
Signed-off-by: Martin Kletzander <mkletzan@redhat.com>
3e5111
3e5111
 Conflicts:
3e5111
	src/util/virnetdev.c - non-Linux stubs
3e5111
Signed-off-by: Jiri Denemark <jdenemar@redhat.com>
3e5111
---
3e5111
 src/qemu/qemu_hotplug.c | 13 +++++++
3e5111
 src/util/virnetdev.c    | 93 ++++++++++++++++++++++++++++++++-----------------
3e5111
 src/util/virnetdev.h    |  3 +-
3e5111
 src/util/virnetdevtap.c |  2 +-
3e5111
 4 files changed, 77 insertions(+), 34 deletions(-)
3e5111
3e5111
diff --git a/src/qemu/qemu_hotplug.c b/src/qemu/qemu_hotplug.c
3e5111
index ab23a575d8..fbc9177669 100644
3e5111
--- a/src/qemu/qemu_hotplug.c
3e5111
+++ b/src/qemu/qemu_hotplug.c
3e5111
@@ -3005,6 +3005,7 @@ qemuDomainChangeNet(virQEMUDriverPtr driver,
3e5111
     bool needLinkStateChange = false;
3e5111
     bool needReplaceDevDef = false;
3e5111
     bool needBandwidthSet = false;
3e5111
+    bool needCoalesceChange = false;
3e5111
     int ret = -1;
3e5111
     int changeidx = -1;
3e5111
 
3e5111
@@ -3293,6 +3294,12 @@ qemuDomainChangeNet(virQEMUDriverPtr driver,
3e5111
                                  virDomainNetGetActualBandwidth(newdev)))
3e5111
         needBandwidthSet = true;
3e5111
 
3e5111
+    if (!!olddev->coalesce != !!newdev->coalesce ||
3e5111
+        (olddev->coalesce && newdev->coalesce &&
3e5111
+         !memcmp(olddev->coalesce, newdev->coalesce,
3e5111
+                 sizeof(*olddev->coalesce))))
3e5111
+        needCoalesceChange = true;
3e5111
+
3e5111
     /* FINALLY - actually perform the required actions */
3e5111
 
3e5111
     if (needReconnect) {
3e5111
@@ -3328,6 +3335,12 @@ qemuDomainChangeNet(virQEMUDriverPtr driver,
3e5111
         needReplaceDevDef = true;
3e5111
     }
3e5111
 
3e5111
+    if (needCoalesceChange) {
3e5111
+        if (virNetDevSetCoalesce(newdev->ifname, newdev->coalesce, true) < 0)
3e5111
+            goto cleanup;
3e5111
+        needReplaceDevDef = true;
3e5111
+    }
3e5111
+
3e5111
     if (needLinkStateChange &&
3e5111
         qemuDomainChangeNetLinkState(driver, vm, olddev, newdev->linkstate) < 0) {
3e5111
         goto cleanup;
3e5111
diff --git a/src/util/virnetdev.c b/src/util/virnetdev.c
3e5111
index eb97b705e2..2beb39bb60 100644
3e5111
--- a/src/util/virnetdev.c
3e5111
+++ b/src/util/virnetdev.c
3e5111
@@ -3093,7 +3093,8 @@ virNetDevGetEthtoolGFeatures(virBitmapPtr bitmap ATTRIBUTE_UNUSED,
3e5111
 /**
3e5111
  * virNetDevSetCoalesce:
3e5111
  * @ifname: interface name to modify
3e5111
- * @coalesce: Coalesce settings to set and update
3e5111
+ * @coalesce: Coalesce settings to set or update
3e5111
+ * @update: Whether this is an update for existing settings or not
3e5111
  *
3e5111
  * This function sets the various coalesce settings for a given interface
3e5111
  * @ifname and updates them back into @coalesce.
3e5111
@@ -3101,40 +3102,44 @@ virNetDevGetEthtoolGFeatures(virBitmapPtr bitmap ATTRIBUTE_UNUSED,
3e5111
  * Returns 0 in case of success or -1 on failure
3e5111
  */
3e5111
 int virNetDevSetCoalesce(const char *ifname,
3e5111
-                         virNetDevCoalescePtr coalesce)
3e5111
+                         virNetDevCoalescePtr coalesce,
3e5111
+                         bool update)
3e5111
 {
3e5111
     int fd = -1;
3e5111
     int ret = -1;
3e5111
     struct ifreq ifr;
3e5111
     struct ethtool_coalesce coal = {0};
3e5111
 
3e5111
-    if (!coalesce)
3e5111
+    if (!coalesce && !update)
3e5111
         return 0;
3e5111
 
3e5111
-    coal = (struct ethtool_coalesce) {
3e5111
-        .cmd = ETHTOOL_SCOALESCE,
3e5111
-        .rx_max_coalesced_frames = coalesce->rx_max_coalesced_frames,
3e5111
-        .rx_coalesce_usecs_irq = coalesce->rx_coalesce_usecs_irq,
3e5111
-        .rx_max_coalesced_frames_irq = coalesce->rx_max_coalesced_frames_irq,
3e5111
-        .tx_coalesce_usecs = coalesce->tx_coalesce_usecs,
3e5111
-        .tx_max_coalesced_frames = coalesce->tx_max_coalesced_frames,
3e5111
-        .tx_coalesce_usecs_irq = coalesce->tx_coalesce_usecs_irq,
3e5111
-        .tx_max_coalesced_frames_irq = coalesce->tx_max_coalesced_frames_irq,
3e5111
-        .stats_block_coalesce_usecs = coalesce->stats_block_coalesce_usecs,
3e5111
-        .use_adaptive_rx_coalesce = coalesce->use_adaptive_rx_coalesce,
3e5111
-        .use_adaptive_tx_coalesce = coalesce->use_adaptive_tx_coalesce,
3e5111
-        .pkt_rate_low = coalesce->pkt_rate_low,
3e5111
-        .rx_coalesce_usecs_low = coalesce->rx_coalesce_usecs_low,
3e5111
-        .rx_max_coalesced_frames_low = coalesce->rx_max_coalesced_frames_low,
3e5111
-        .tx_coalesce_usecs_low = coalesce->tx_coalesce_usecs_low,
3e5111
-        .tx_max_coalesced_frames_low = coalesce->tx_max_coalesced_frames_low,
3e5111
-        .pkt_rate_high = coalesce->pkt_rate_high,
3e5111
-        .rx_coalesce_usecs_high = coalesce->rx_coalesce_usecs_high,
3e5111
-        .rx_max_coalesced_frames_high = coalesce->rx_max_coalesced_frames_high,
3e5111
-        .tx_coalesce_usecs_high = coalesce->tx_coalesce_usecs_high,
3e5111
-        .tx_max_coalesced_frames_high = coalesce->tx_max_coalesced_frames_high,
3e5111
-        .rate_sample_interval = coalesce->rate_sample_interval,
3e5111
-    };
3e5111
+    if (coalesce) {
3e5111
+        coal = (struct ethtool_coalesce) {
3e5111
+            .rx_max_coalesced_frames = coalesce->rx_max_coalesced_frames,
3e5111
+            .rx_coalesce_usecs_irq = coalesce->rx_coalesce_usecs_irq,
3e5111
+            .rx_max_coalesced_frames_irq = coalesce->rx_max_coalesced_frames_irq,
3e5111
+            .tx_coalesce_usecs = coalesce->tx_coalesce_usecs,
3e5111
+            .tx_max_coalesced_frames = coalesce->tx_max_coalesced_frames,
3e5111
+            .tx_coalesce_usecs_irq = coalesce->tx_coalesce_usecs_irq,
3e5111
+            .tx_max_coalesced_frames_irq = coalesce->tx_max_coalesced_frames_irq,
3e5111
+            .stats_block_coalesce_usecs = coalesce->stats_block_coalesce_usecs,
3e5111
+            .use_adaptive_rx_coalesce = coalesce->use_adaptive_rx_coalesce,
3e5111
+            .use_adaptive_tx_coalesce = coalesce->use_adaptive_tx_coalesce,
3e5111
+            .pkt_rate_low = coalesce->pkt_rate_low,
3e5111
+            .rx_coalesce_usecs_low = coalesce->rx_coalesce_usecs_low,
3e5111
+            .rx_max_coalesced_frames_low = coalesce->rx_max_coalesced_frames_low,
3e5111
+            .tx_coalesce_usecs_low = coalesce->tx_coalesce_usecs_low,
3e5111
+            .tx_max_coalesced_frames_low = coalesce->tx_max_coalesced_frames_low,
3e5111
+            .pkt_rate_high = coalesce->pkt_rate_high,
3e5111
+            .rx_coalesce_usecs_high = coalesce->rx_coalesce_usecs_high,
3e5111
+            .rx_max_coalesced_frames_high = coalesce->rx_max_coalesced_frames_high,
3e5111
+            .tx_coalesce_usecs_high = coalesce->tx_coalesce_usecs_high,
3e5111
+            .tx_max_coalesced_frames_high = coalesce->tx_max_coalesced_frames_high,
3e5111
+            .rate_sample_interval = coalesce->rate_sample_interval,
3e5111
+        };
3e5111
+    }
3e5111
+
3e5111
+    coal.cmd = ETHTOOL_SCOALESCE;
3e5111
 
3e5111
     if ((fd = virNetDevSetupControl(ifname, &ifr)) < 0)
3e5111
         return -1;
3e5111
@@ -3148,12 +3153,36 @@ int virNetDevSetCoalesce(const char *ifname,
3e5111
         goto cleanup;
3e5111
     }
3e5111
 
3e5111
-    coal = (struct ethtool_coalesce) {
3e5111
-        .cmd = ETHTOOL_GCOALESCE,
3e5111
-    };
3e5111
+    if (coalesce) {
3e5111
+        coal = (struct ethtool_coalesce) {
3e5111
+            .cmd = ETHTOOL_GCOALESCE,
3e5111
+        };
3e5111
 
3e5111
-    /* Don't fail if the update itself fails */
3e5111
-    virNetDevSendEthtoolIoctl(fd, &ifr);
3e5111
+        /* Don't fail if the update itself fails */
3e5111
+        if (virNetDevSendEthtoolIoctl(fd, &ifr) == 0) {
3e5111
+            coalesce->rx_max_coalesced_frames = coal.rx_max_coalesced_frames;
3e5111
+            coalesce->rx_coalesce_usecs_irq = coal.rx_coalesce_usecs_irq;
3e5111
+            coalesce->rx_max_coalesced_frames_irq = coal.rx_max_coalesced_frames_irq;
3e5111
+            coalesce->tx_coalesce_usecs = coal.tx_coalesce_usecs;
3e5111
+            coalesce->tx_max_coalesced_frames = coal.tx_max_coalesced_frames;
3e5111
+            coalesce->tx_coalesce_usecs_irq = coal.tx_coalesce_usecs_irq;
3e5111
+            coalesce->tx_max_coalesced_frames_irq = coal.tx_max_coalesced_frames_irq;
3e5111
+            coalesce->stats_block_coalesce_usecs = coal.stats_block_coalesce_usecs;
3e5111
+            coalesce->use_adaptive_rx_coalesce = coal.use_adaptive_rx_coalesce;
3e5111
+            coalesce->use_adaptive_tx_coalesce = coal.use_adaptive_tx_coalesce;
3e5111
+            coalesce->pkt_rate_low = coal.pkt_rate_low;
3e5111
+            coalesce->rx_coalesce_usecs_low = coal.rx_coalesce_usecs_low;
3e5111
+            coalesce->rx_max_coalesced_frames_low = coal.rx_max_coalesced_frames_low;
3e5111
+            coalesce->tx_coalesce_usecs_low = coal.tx_coalesce_usecs_low;
3e5111
+            coalesce->tx_max_coalesced_frames_low = coal.tx_max_coalesced_frames_low;
3e5111
+            coalesce->pkt_rate_high = coal.pkt_rate_high;
3e5111
+            coalesce->rx_coalesce_usecs_high = coal.rx_coalesce_usecs_high;
3e5111
+            coalesce->rx_max_coalesced_frames_high = coal.rx_max_coalesced_frames_high;
3e5111
+            coalesce->tx_coalesce_usecs_high = coal.tx_coalesce_usecs_high;
3e5111
+            coalesce->tx_max_coalesced_frames_high = coal.tx_max_coalesced_frames_high;
3e5111
+            coalesce->rate_sample_interval = coal.rate_sample_interval;
3e5111
+        }
3e5111
+    }
3e5111
 
3e5111
     ret = 0;
3e5111
  cleanup:
3e5111
diff --git a/src/util/virnetdev.h b/src/util/virnetdev.h
3e5111
index 97236c170d..c2c09af636 100644
3e5111
--- a/src/util/virnetdev.h
3e5111
+++ b/src/util/virnetdev.h
3e5111
@@ -180,7 +180,8 @@ int virNetDevRestoreMacAddress(const char *linkdev,
3e5111
     ATTRIBUTE_NONNULL(1) ATTRIBUTE_NONNULL(2) ATTRIBUTE_RETURN_CHECK;
3e5111
 
3e5111
 int virNetDevSetCoalesce(const char *ifname,
3e5111
-                         virNetDevCoalescePtr coalesce)
3e5111
+                         virNetDevCoalescePtr coalesce,
3e5111
+                         bool update)
3e5111
     ATTRIBUTE_NONNULL(1) ATTRIBUTE_RETURN_CHECK;
3e5111
 
3e5111
 int virNetDevSetMTU(const char *ifname,
3e5111
diff --git a/src/util/virnetdevtap.c b/src/util/virnetdevtap.c
3e5111
index c8dacfe27b..175dc2bfaa 100644
3e5111
--- a/src/util/virnetdevtap.c
3e5111
+++ b/src/util/virnetdevtap.c
3e5111
@@ -663,7 +663,7 @@ int virNetDevTapCreateInBridgePort(const char *brname,
3e5111
     if (virNetDevSetOnline(*ifname, !!(flags & VIR_NETDEV_TAP_CREATE_IFUP)) < 0)
3e5111
         goto error;
3e5111
 
3e5111
-    if (virNetDevSetCoalesce(*ifname, coalesce) < 0)
3e5111
+    if (virNetDevSetCoalesce(*ifname, coalesce, false) < 0)
3e5111
         goto error;
3e5111
 
3e5111
     return 0;
3e5111
-- 
3e5111
2.13.1
3e5111