1 /* 2 * Persistent reservation manager abstract class 3 * 4 * Copyright (c) 2017 Red Hat, Inc. 5 * 6 * Author: Paolo Bonzini <pbonzini@redhat.com> 7 * 8 * This code is licensed under the LGPL. 9 * 10 */ 11 12 #include "qemu/osdep.h" 13 #include <scsi/sg.h> 14 15 #include "qapi/error.h" 16 #include "block/aio.h" 17 #include "block/thread-pool.h" 18 #include "scsi/pr-manager.h" 19 #include "trace.h" 20 #include "qapi/qapi-types-block.h" 21 #include "qapi/qapi-commands-block.h" 22 23 #define PR_MANAGER_PATH "/objects" 24 25 typedef struct PRManagerData { 26 PRManager *pr_mgr; 27 struct sg_io_hdr *hdr; 28 int fd; 29 } PRManagerData; 30 31 static int pr_manager_worker(void *opaque) 32 { 33 PRManagerData *data = opaque; 34 PRManager *pr_mgr = data->pr_mgr; 35 PRManagerClass *pr_mgr_class = 36 PR_MANAGER_GET_CLASS(pr_mgr); 37 struct sg_io_hdr *hdr = data->hdr; 38 int fd = data->fd; 39 int r; 40 41 g_free(data); 42 trace_pr_manager_run(fd, hdr->cmdp[0], hdr->cmdp[1]); 43 44 /* The reference was taken in pr_manager_execute. */ 45 r = pr_mgr_class->run(pr_mgr, fd, hdr); 46 object_unref(OBJECT(pr_mgr)); 47 return r; 48 } 49 50 51 int coroutine_fn pr_manager_execute(PRManager *pr_mgr, AioContext *ctx, int fd, 52 struct sg_io_hdr *hdr) 53 { 54 ThreadPool *pool = aio_get_thread_pool(ctx); 55 PRManagerData data = { 56 .pr_mgr = pr_mgr, 57 .fd = fd, 58 .hdr = hdr, 59 }; 60 61 trace_pr_manager_execute(fd, hdr->cmdp[0], hdr->cmdp[1]); 62 63 /* The matching object_unref is in pr_manager_worker. */ 64 object_ref(OBJECT(pr_mgr)); 65 return thread_pool_submit_co(pool, pr_manager_worker, &data); 66 } 67 68 bool pr_manager_is_connected(PRManager *pr_mgr) 69 { 70 PRManagerClass *pr_mgr_class = 71 PR_MANAGER_GET_CLASS(pr_mgr); 72 73 return !pr_mgr_class->is_connected || pr_mgr_class->is_connected(pr_mgr); 74 } 75 76 static const TypeInfo pr_manager_info = { 77 .parent = TYPE_OBJECT, 78 .name = TYPE_PR_MANAGER, 79 .class_size = sizeof(PRManagerClass), 80 .abstract = true, 81 .interfaces = (InterfaceInfo[]) { 82 { TYPE_USER_CREATABLE }, 83 { } 84 } 85 }; 86 87 PRManager *pr_manager_lookup(const char *id, Error **errp) 88 { 89 Object *obj; 90 PRManager *pr_mgr; 91 92 obj = object_resolve_path_component(object_get_objects_root(), id); 93 if (!obj) { 94 error_setg(errp, "No persistent reservation manager with id '%s'", id); 95 return NULL; 96 } 97 98 pr_mgr = (PRManager *) 99 object_dynamic_cast(obj, 100 TYPE_PR_MANAGER); 101 if (!pr_mgr) { 102 error_setg(errp, 103 "Object with id '%s' is not a persistent reservation manager", 104 id); 105 return NULL; 106 } 107 108 return pr_mgr; 109 } 110 111 static void 112 pr_manager_register_types(void) 113 { 114 type_register_static(&pr_manager_info); 115 } 116 117 static int query_one_pr_manager(Object *object, void *opaque) 118 { 119 PRManagerInfoList ***prev = opaque; 120 PRManagerInfoList *elem; 121 PRManagerInfo *info; 122 PRManager *pr_mgr; 123 124 pr_mgr = (PRManager *)object_dynamic_cast(object, TYPE_PR_MANAGER); 125 if (!pr_mgr) { 126 return 0; 127 } 128 129 elem = g_new0(PRManagerInfoList, 1); 130 info = g_new0(PRManagerInfo, 1); 131 info->id = object_get_canonical_path_component(object); 132 info->connected = pr_manager_is_connected(pr_mgr); 133 elem->value = info; 134 elem->next = NULL; 135 136 **prev = elem; 137 *prev = &elem->next; 138 return 0; 139 } 140 141 PRManagerInfoList *qmp_query_pr_managers(Error **errp) 142 { 143 PRManagerInfoList *head = NULL; 144 PRManagerInfoList **prev = &head; 145 Object *container = container_get(object_get_root(), PR_MANAGER_PATH); 146 147 object_child_foreach(container, query_one_pr_manager, &prev); 148 return head; 149 } 150 151 type_init(pr_manager_register_types); 152