]> git.proxmox.com Git - mirror_ubuntu-bionic-kernel.git/blobdiff - block/elevator.c
partitions/aix: fix usage of uninitialized lv_info and lvname structures
[mirror_ubuntu-bionic-kernel.git] / block / elevator.c
index 153926a909011e5f2a9759d19e90ab74ef00f405..7bda083d59684177bb66eec2e221177417c893ac 100644 (file)
@@ -83,12 +83,25 @@ bool elv_bio_merge_ok(struct request *rq, struct bio *bio)
 }
 EXPORT_SYMBOL(elv_bio_merge_ok);
 
-static struct elevator_type *elevator_find(const char *name)
+static bool elevator_match(const struct elevator_type *e, const char *name)
+{
+       if (!strcmp(e->elevator_name, name))
+               return true;
+       if (e->elevator_alias && !strcmp(e->elevator_alias, name))
+               return true;
+
+       return false;
+}
+
+/*
+ * Return scheduler with name 'name' and with matching 'mq capability
+ */
+static struct elevator_type *elevator_find(const char *name, bool mq)
 {
        struct elevator_type *e;
 
        list_for_each_entry(e, &elv_list, list) {
-               if (!strcmp(e->elevator_name, name))
+               if (elevator_match(e, name) && (mq == e->uses_mq))
                        return e;
        }
 
@@ -100,25 +113,25 @@ static void elevator_put(struct elevator_type *e)
        module_put(e->elevator_owner);
 }
 
-static struct elevator_type *elevator_get(const char *name, bool try_loading)
+static struct elevator_type *elevator_get(struct request_queue *q,
+                                         const char *name, bool try_loading)
 {
        struct elevator_type *e;
 
        spin_lock(&elv_list_lock);
 
-       e = elevator_find(name);
+       e = elevator_find(name, q->mq_ops != NULL);
        if (!e && try_loading) {
                spin_unlock(&elv_list_lock);
                request_module("%s-iosched", name);
                spin_lock(&elv_list_lock);
-               e = elevator_find(name);
+               e = elevator_find(name, q->mq_ops != NULL);
        }
 
        if (e && !try_module_get(e->elevator_owner))
                e = NULL;
 
        spin_unlock(&elv_list_lock);
-
        return e;
 }
 
@@ -144,8 +157,12 @@ void __init load_default_elevator_module(void)
        if (!chosen_elevator[0])
                return;
 
+       /*
+        * Boot parameter is deprecated, we haven't supported that for MQ.
+        * Only look for non-mq schedulers from here.
+        */
        spin_lock(&elv_list_lock);
-       e = elevator_find(chosen_elevator);
+       e = elevator_find(chosen_elevator, false);
        spin_unlock(&elv_list_lock);
 
        if (!e)
@@ -202,7 +219,7 @@ int elevator_init(struct request_queue *q, char *name)
        q->boundary_rq = NULL;
 
        if (name) {
-               e = elevator_get(name, true);
+               e = elevator_get(q, name, true);
                if (!e)
                        return -EINVAL;
        }
@@ -214,7 +231,7 @@ int elevator_init(struct request_queue *q, char *name)
         * allowed from async.
         */
        if (!e && !q->mq_ops && *chosen_elevator) {
-               e = elevator_get(chosen_elevator, false);
+               e = elevator_get(q, chosen_elevator, false);
                if (!e)
                        printk(KERN_ERR "I/O scheduler %s not found\n",
                                                        chosen_elevator);
@@ -229,17 +246,17 @@ int elevator_init(struct request_queue *q, char *name)
                 */
                if (q->mq_ops) {
                        if (q->nr_hw_queues == 1)
-                               e = elevator_get("mq-deadline", false);
+                               e = elevator_get(q, "mq-deadline", false);
                        if (!e)
                                return 0;
                } else
-                       e = elevator_get(CONFIG_DEFAULT_IOSCHED, false);
+                       e = elevator_get(q, CONFIG_DEFAULT_IOSCHED, false);
 
                if (!e) {
                        printk(KERN_ERR
                                "Default I/O scheduler not found. " \
                                "Using noop.\n");
-                       e = elevator_get("noop", false);
+                       e = elevator_get(q, "noop", false);
                }
        }
 
@@ -905,7 +922,7 @@ int elv_register(struct elevator_type *e)
 
        /* register, don't allow duplicate names */
        spin_lock(&elv_list_lock);
-       if (elevator_find(e->elevator_name)) {
+       if (elevator_find(e->elevator_name, e->uses_mq)) {
                spin_unlock(&elv_list_lock);
                if (e->icq_cache)
                        kmem_cache_destroy(e->icq_cache);
@@ -915,9 +932,9 @@ int elv_register(struct elevator_type *e)
        spin_unlock(&elv_list_lock);
 
        /* print pretty message */
-       if (!strcmp(e->elevator_name, chosen_elevator) ||
+       if (elevator_match(e, chosen_elevator) ||
                        (!*chosen_elevator &&
-                        !strcmp(e->elevator_name, CONFIG_DEFAULT_IOSCHED)))
+                        elevator_match(e, CONFIG_DEFAULT_IOSCHED)))
                                def = " (default)";
 
        printk(KERN_INFO "io scheduler %s registered%s\n", e->elevator_name,
@@ -1066,25 +1083,15 @@ static int __elevator_change(struct request_queue *q, const char *name)
                return elevator_switch(q, NULL);
 
        strlcpy(elevator_name, name, sizeof(elevator_name));
-       e = elevator_get(strstrip(elevator_name), true);
+       e = elevator_get(q, strstrip(elevator_name), true);
        if (!e)
                return -EINVAL;
 
-       if (q->elevator &&
-           !strcmp(elevator_name, q->elevator->type->elevator_name)) {
+       if (q->elevator && elevator_match(q->elevator->type, elevator_name)) {
                elevator_put(e);
                return 0;
        }
 
-       if (!e->uses_mq && q->mq_ops) {
-               elevator_put(e);
-               return -EINVAL;
-       }
-       if (e->uses_mq && !q->mq_ops) {
-               elevator_put(e);
-               return -EINVAL;
-       }
-
        return elevator_switch(q, e);
 }
 
@@ -1116,9 +1123,10 @@ ssize_t elv_iosched_show(struct request_queue *q, char *name)
        struct elevator_queue *e = q->elevator;
        struct elevator_type *elv = NULL;
        struct elevator_type *__e;
+       bool uses_mq = q->mq_ops != NULL;
        int len = 0;
 
-       if (!blk_queue_stackable(q))
+       if (!queue_is_rq_based(q))
                return sprintf(name, "none\n");
 
        if (!q->elevator)
@@ -1128,7 +1136,8 @@ ssize_t elv_iosched_show(struct request_queue *q, char *name)
 
        spin_lock(&elv_list_lock);
        list_for_each_entry(__e, &elv_list, list) {
-               if (elv && !strcmp(elv->elevator_name, __e->elevator_name)) {
+               if (elv && elevator_match(elv, __e->elevator_name) &&
+                   (__e->uses_mq == uses_mq)) {
                        len += sprintf(name+len, "[%s] ", elv->elevator_name);
                        continue;
                }