]> xenbits.xensource.com Git - libvirt.git/commitdiff
qemu: monitor: Remove support for "legacy" block jobs
authorPeter Krempa <pkrempa@redhat.com>
Wed, 13 Sep 2017 13:40:46 +0000 (15:40 +0200)
committerPeter Krempa <pkrempa@redhat.com>
Thu, 14 Sep 2017 08:03:38 +0000 (10:03 +0200)
Drop all the monitor code necessary to do the downstream block jobs.

Reviewed-by: Eric Blake <eblake@redhat.com>
src/qemu/qemu_driver.c
src/qemu/qemu_migration.c
src/qemu/qemu_monitor.c
src/qemu/qemu_monitor.h
src/qemu/qemu_monitor_json.c
src/qemu/qemu_monitor_json.h

index c7d93dcb2e420260dfa3136c8c95ea7d0a8dc2f2..b334cf20beee01add39f5cfaff144617070ea83b 100644 (file)
@@ -16494,7 +16494,7 @@ qemuDomainBlockPullCommon(virQEMUDriverPtr driver,
                                              baseSource);
     if (!baseSource || basePath)
         ret = qemuMonitorBlockStream(priv->mon, device, basePath, backingPath,
-                                     speed, true);
+                                     speed);
     if (qemuDomainObjExitMonitor(driver, vm) < 0)
         ret = -1;
 
@@ -16578,7 +16578,7 @@ qemuDomainBlockJobAbort(virDomainPtr dom,
         }
 
         qemuDomainObjEnterMonitor(driver, vm);
-        ret = qemuMonitorBlockJobCancel(qemuDomainGetMonitor(vm), device, true);
+        ret = qemuMonitorBlockJobCancel(qemuDomainGetMonitor(vm), device);
         if (qemuDomainObjExitMonitor(driver, vm) < 0) {
             ret = -1;
             goto endjob;
@@ -16798,8 +16798,7 @@ qemuDomainBlockJobSetSpeed(virDomainPtr dom,
     qemuDomainObjEnterMonitor(driver, vm);
     ret = qemuMonitorBlockJobSetSpeed(qemuDomainGetMonitor(vm),
                                       device,
-                                      speed,
-                                      true);
+                                      speed);
     if (qemuDomainObjExitMonitor(driver, vm) < 0)
         ret = -1;
 
index 272d525f11cb6355865409db769ac4ca3ef58777..492815b6093661071e12f2325d65a47e81d307e6 100644 (file)
@@ -762,7 +762,7 @@ qemuMigrationCancelOneDriveMirror(virQEMUDriverPtr driver,
     if (qemuDomainObjEnterMonitorAsync(driver, vm, asyncJob) < 0)
         goto cleanup;
 
-    rv = qemuMonitorBlockJobCancel(priv->mon, diskAlias, true);
+    rv = qemuMonitorBlockJobCancel(priv->mon, diskAlias);
 
     if (qemuDomainObjExitMonitor(driver, vm) < 0 || rv < 0)
         goto cleanup;
index 19082d8bf736f835bb7c1527ba87c78cc4c69de2..69f14d02885a6d2dc61d597651d31233024ff7a1 100644 (file)
@@ -3475,43 +3475,39 @@ qemuMonitorBlockStream(qemuMonitorPtr mon,
                        const char *device,
                        const char *base,
                        const char *backingName,
-                       unsigned long long bandwidth,
-                       bool modern)
+                       unsigned long long bandwidth)
 {
-    VIR_DEBUG("device=%s, base=%s, backingName=%s, bandwidth=%lluB, modern=%d",
-              device, NULLSTR(base), NULLSTR(backingName), bandwidth, modern);
+    VIR_DEBUG("device=%s, base=%s, backingName=%s, bandwidth=%lluB",
+              device, NULLSTR(base), NULLSTR(backingName), bandwidth);
 
     QEMU_CHECK_MONITOR_JSON(mon);
 
-    return qemuMonitorJSONBlockStream(mon, device, base, backingName,
-                                      bandwidth, modern);
+    return qemuMonitorJSONBlockStream(mon, device, base, backingName, bandwidth);
 }
 
 
 int
 qemuMonitorBlockJobCancel(qemuMonitorPtr mon,
-                          const char *device,
-                          bool modern)
+                          const char *device)
 {
-    VIR_DEBUG("device=%s, modern=%d", device, modern);
+    VIR_DEBUG("device=%s", device);
 
     QEMU_CHECK_MONITOR_JSON(mon);
 
-    return qemuMonitorJSONBlockJobCancel(mon, device, modern);
+    return qemuMonitorJSONBlockJobCancel(mon, device);
 }
 
 
 int
 qemuMonitorBlockJobSetSpeed(qemuMonitorPtr mon,
                             const char *device,
-                            unsigned long long bandwidth,
-                            bool modern)
+                            unsigned long long bandwidth)
 {
-    VIR_DEBUG("device=%s, bandwidth=%lluB, modern=%d", device, bandwidth, modern);
+    VIR_DEBUG("device=%s, bandwidth=%lluB", device, bandwidth);
 
     QEMU_CHECK_MONITOR_JSON(mon);
 
-    return qemuMonitorJSONBlockJobSetSpeed(mon, device, bandwidth, modern);
+    return qemuMonitorJSONBlockJobSetSpeed(mon, device, bandwidth);
 }
 
 
index 9805a3390816503f893f6b4e1c71bc134cd9051a..6414d2483ac967009f8ef420fac942d38f4e3e3b 100644 (file)
@@ -896,19 +896,16 @@ int qemuMonitorBlockStream(qemuMonitorPtr mon,
                            const char *device,
                            const char *base,
                            const char *backingName,
-                           unsigned long long bandwidth,
-                           bool modern)
+                           unsigned long long bandwidth)
     ATTRIBUTE_NONNULL(2);
 
 int qemuMonitorBlockJobCancel(qemuMonitorPtr mon,
-                              const char *device,
-                              bool modern)
+                              const char *device)
     ATTRIBUTE_NONNULL(2);
 
 int qemuMonitorBlockJobSetSpeed(qemuMonitorPtr mon,
                                 const char *device,
-                                unsigned long long bandwidth,
-                                bool modern);
+                                unsigned long long bandwidth);
 
 typedef struct _qemuMonitorBlockJobInfo qemuMonitorBlockJobInfo;
 typedef qemuMonitorBlockJobInfo *qemuMonitorBlockJobInfoPtr;
index df5fb7c8f6b47a3ee1ddf823d9bb67863188a272..0fc5d21222abefc30fb43647755b56aaa2d03a7c 100644 (file)
@@ -4474,13 +4474,12 @@ qemuMonitorJSONBlockStream(qemuMonitorPtr mon,
                            const char *device,
                            const char *base,
                            const char *backingName,
-                           unsigned long long speed,
-                           bool modern)
+                           unsigned long long speed)
 {
     int ret = -1;
     virJSONValuePtr cmd = NULL;
     virJSONValuePtr reply = NULL;
-    const char *cmd_name = modern ? "block-stream" : "block_stream";
+    const char *cmd_name = "block-stream";
 
     if (!(cmd = qemuMonitorJSONMakeCommand(cmd_name,
                                            "s:device", device,
@@ -4507,13 +4506,12 @@ qemuMonitorJSONBlockStream(qemuMonitorPtr mon,
 
 int
 qemuMonitorJSONBlockJobCancel(qemuMonitorPtr mon,
-                              const char *device,
-                              bool modern)
+                              const char *device)
 {
     int ret = -1;
     virJSONValuePtr cmd = NULL;
     virJSONValuePtr reply = NULL;
-    const char *cmd_name = modern ? "block-job-cancel" : "block_job_cancel";
+    const char *cmd_name = "block-job-cancel";
 
     if (!(cmd = qemuMonitorJSONMakeCommand(cmd_name,
                                            "s:device", device,
@@ -4538,17 +4536,16 @@ qemuMonitorJSONBlockJobCancel(qemuMonitorPtr mon,
 int
 qemuMonitorJSONBlockJobSetSpeed(qemuMonitorPtr mon,
                                 const char *device,
-                                unsigned long long speed,
-                                bool modern)
+                                unsigned long long speed)
 {
     int ret = -1;
     virJSONValuePtr cmd;
     virJSONValuePtr reply = NULL;
-    const char *cmd_name = modern ? "block-job-set-speed" : "block_job_set_speed";
+    const char *cmd_name = "block-job-set-speed";
 
     if (!(cmd = qemuMonitorJSONMakeCommand(cmd_name,
                                            "s:device", device,
-                                           modern ? "J:speed" : "J:value", speed,
+                                           "J:speed", speed,
                                            NULL)))
         return -1;
 
index 7462967b51771d966491f0ae719a1666018c81a3..0cdfc5eadb1b40f1287eee2ff8a4c958f0a29442 100644 (file)
@@ -300,19 +300,16 @@ int qemuMonitorJSONBlockStream(qemuMonitorPtr mon,
                                const char *device,
                                const char *base,
                                const char *backingName,
-                               unsigned long long speed,
-                               bool modern)
+                               unsigned long long speed)
     ATTRIBUTE_NONNULL(1) ATTRIBUTE_NONNULL(2);
 
 int qemuMonitorJSONBlockJobCancel(qemuMonitorPtr mon,
-                                  const char *device,
-                                  bool modern)
+                                  const char *device)
     ATTRIBUTE_NONNULL(1) ATTRIBUTE_NONNULL(2);
 
 int qemuMonitorJSONBlockJobSetSpeed(qemuMonitorPtr mon,
                                     const char *device,
-                                    unsigned long long speed,
-                                    bool modern)
+                                    unsigned long long speed)
     ATTRIBUTE_NONNULL(1) ATTRIBUTE_NONNULL(2);
 
 virHashTablePtr qemuMonitorJSONGetAllBlockJobInfo(qemuMonitorPtr mon)