c313de
From 7fae41a63cd97501e3a4bf8fade48949d754f738 Mon Sep 17 00:00:00 2001
c313de
Message-Id: <7fae41a63cd97501e3a4bf8fade48949d754f738@dist-git>
c313de
From: Pavel Hrdina <phrdina@redhat.com>
c313de
Date: Mon, 1 Jul 2019 17:06:41 +0200
c313de
Subject: [PATCH] vircgroup: extract virCgroupV1(Set|Get)BlkioWeight
c313de
MIME-Version: 1.0
c313de
Content-Type: text/plain; charset=UTF-8
c313de
Content-Transfer-Encoding: 8bit
c313de
c313de
Reviewed-by: Fabiano Fidêncio <fidencio@redhat.com>
c313de
Reviewed-by: Ján Tomko <jtomko@redhat.com>
c313de
Signed-off-by: Pavel Hrdina <phrdina@redhat.com>
c313de
(cherry picked from commit c57b0be0cc200abb21cbe0473d96f447fd37b27d)
c313de
c313de
Resolves: https://bugzilla.redhat.com/show_bug.cgi?id=1689297
c313de
c313de
Signed-off-by: Pavel Hrdina <phrdina@redhat.com>
c313de
Message-Id: <23b514919f71ed2a44c04d7f62a031c4edc14365.1561993100.git.phrdina@redhat.com>
c313de
Reviewed-by: Ján Tomko <jtomko@redhat.com>
c313de
---
c313de
 src/util/vircgroup.c        | 14 ++------------
c313de
 src/util/vircgroupbackend.h | 20 ++++++++++++++++++++
c313de
 src/util/vircgroupv1.c      | 29 +++++++++++++++++++++++++++++
c313de
 3 files changed, 51 insertions(+), 12 deletions(-)
c313de
c313de
diff --git a/src/util/vircgroup.c b/src/util/vircgroup.c
c313de
index e57aecb08a..d2ffa8aefe 100644
c313de
--- a/src/util/vircgroup.c
c313de
+++ b/src/util/vircgroup.c
c313de
@@ -1510,10 +1510,7 @@ virCgroupGetBlkioIoDeviceServiced(virCgroupPtr group,
c313de
 int
c313de
 virCgroupSetBlkioWeight(virCgroupPtr group, unsigned int weight)
c313de
 {
c313de
-    return virCgroupSetValueU64(group,
c313de
-                                VIR_CGROUP_CONTROLLER_BLKIO,
c313de
-                                "blkio.weight",
c313de
-                                weight);
c313de
+    VIR_CGROUP_BACKEND_CALL(group, setBlkioWeight, -1, weight);
c313de
 }
c313de
 
c313de
 
c313de
@@ -1528,14 +1525,7 @@ virCgroupSetBlkioWeight(virCgroupPtr group, unsigned int weight)
c313de
 int
c313de
 virCgroupGetBlkioWeight(virCgroupPtr group, unsigned int *weight)
c313de
 {
c313de
-    unsigned long long tmp;
c313de
-    int ret;
c313de
-    ret = virCgroupGetValueU64(group,
c313de
-                               VIR_CGROUP_CONTROLLER_BLKIO,
c313de
-                               "blkio.weight", &tmp);
c313de
-    if (ret == 0)
c313de
-        *weight = tmp;
c313de
-    return ret;
c313de
+    VIR_CGROUP_BACKEND_CALL(group, getBlkioWeight, -1, weight);
c313de
 }
c313de
 
c313de
 /**
c313de
diff --git a/src/util/vircgroupbackend.h b/src/util/vircgroupbackend.h
c313de
index 74af796c2f..ccce65f1e2 100644
c313de
--- a/src/util/vircgroupbackend.h
c313de
+++ b/src/util/vircgroupbackend.h
c313de
@@ -137,6 +137,14 @@ typedef int
c313de
                        gid_t gid,
c313de
                        int controllers);
c313de
 
c313de
+typedef int
c313de
+(*virCgroupSetBlkioWeightCB)(virCgroupPtr group,
c313de
+                             unsigned int weight);
c313de
+
c313de
+typedef int
c313de
+(*virCgroupGetBlkioWeightCB)(virCgroupPtr group,
c313de
+                             unsigned int *weight);
c313de
+
c313de
 struct _virCgroupBackend {
c313de
     virCgroupBackendType type;
c313de
 
c313de
@@ -159,6 +167,10 @@ struct _virCgroupBackend {
c313de
     virCgroupHasEmptyTasksCB hasEmptyTasks;
c313de
     virCgroupBindMountCB bindMount;
c313de
     virCgroupSetOwnerCB setOwner;
c313de
+
c313de
+    /* Optional cgroup controller specific callbacks. */
c313de
+    virCgroupSetBlkioWeightCB setBlkioWeight;
c313de
+    virCgroupGetBlkioWeightCB getBlkioWeight;
c313de
 };
c313de
 typedef struct _virCgroupBackend virCgroupBackend;
c313de
 typedef virCgroupBackend *virCgroupBackendPtr;
c313de
@@ -169,4 +181,12 @@ virCgroupBackendRegister(virCgroupBackendPtr backend);
c313de
 virCgroupBackendPtr *
c313de
 virCgroupBackendGetAll(void);
c313de
 
c313de
+# define VIR_CGROUP_BACKEND_CALL(group, func, ret, ...) \
c313de
+    if (!group->backend->func) { \
c313de
+        virReportError(VIR_ERR_OPERATION_UNSUPPORTED, \
c313de
+                       _("operation '%s' not supported"), #func); \
c313de
+        return ret; \
c313de
+    } \
c313de
+    return group->backend->func(group, ##__VA_ARGS__);
c313de
+
c313de
 #endif /* __VIR_CGROUP_BACKEND_H__ */
c313de
diff --git a/src/util/vircgroupv1.c b/src/util/vircgroupv1.c
c313de
index c1e2583912..d67b3164ce 100644
c313de
--- a/src/util/vircgroupv1.c
c313de
+++ b/src/util/vircgroupv1.c
c313de
@@ -929,6 +929,32 @@ virCgroupV1SetOwner(virCgroupPtr cgroup,
c313de
 }
c313de
 
c313de
 
c313de
+static int
c313de
+virCgroupV1SetBlkioWeight(virCgroupPtr group,
c313de
+                          unsigned int weight)
c313de
+{
c313de
+    return virCgroupSetValueU64(group,
c313de
+                                VIR_CGROUP_CONTROLLER_BLKIO,
c313de
+                                "blkio.weight",
c313de
+                                weight);
c313de
+}
c313de
+
c313de
+
c313de
+static int
c313de
+virCgroupV1GetBlkioWeight(virCgroupPtr group,
c313de
+                          unsigned int *weight)
c313de
+{
c313de
+    unsigned long long tmp;
c313de
+    int ret;
c313de
+    ret = virCgroupGetValueU64(group,
c313de
+                               VIR_CGROUP_CONTROLLER_BLKIO,
c313de
+                               "blkio.weight", &tmp);
c313de
+    if (ret == 0)
c313de
+        *weight = tmp;
c313de
+    return ret;
c313de
+}
c313de
+
c313de
+
c313de
 virCgroupBackend virCgroupV1Backend = {
c313de
     .type = VIR_CGROUP_BACKEND_TYPE_V1,
c313de
 
c313de
@@ -950,6 +976,9 @@ virCgroupBackend virCgroupV1Backend = {
c313de
     .hasEmptyTasks = virCgroupV1HasEmptyTasks,
c313de
     .bindMount = virCgroupV1BindMount,
c313de
     .setOwner = virCgroupV1SetOwner,
c313de
+
c313de
+    .setBlkioWeight = virCgroupV1SetBlkioWeight,
c313de
+    .getBlkioWeight = virCgroupV1GetBlkioWeight,
c313de
 };
c313de
 
c313de
 
c313de
-- 
c313de
2.22.0
c313de