1 /* SPDX-License-Identifier: BSD-3-Clause 2 * Copyright (c) Intel Corporation. 3 * All rights reserved. 4 * Copyright (c) croit GmbH. 5 * All rights reserved. 6 */ 7 8 #include "bdev_daos.h" 9 #include "spdk/rpc.h" 10 #include "spdk/util.h" 11 #include "spdk/uuid.h" 12 #include "spdk/string.h" 13 #include "spdk/log.h" 14 15 struct rpc_construct_daos { 16 char *name; 17 char *uuid; 18 char *pool; 19 char *cont; 20 char *oclass; 21 uint64_t num_blocks; 22 uint32_t block_size; 23 }; 24 25 static void 26 free_rpc_construct_daos(struct rpc_construct_daos *r) 27 { 28 free(r->name); 29 free(r->uuid); 30 free(r->pool); 31 free(r->cont); 32 } 33 34 static const struct spdk_json_object_decoder rpc_construct_daos_decoders[] = { 35 {"name", offsetof(struct rpc_construct_daos, name), spdk_json_decode_string}, 36 {"uuid", offsetof(struct rpc_construct_daos, uuid), spdk_json_decode_string, true}, 37 {"pool", offsetof(struct rpc_construct_daos, pool), spdk_json_decode_string}, 38 {"cont", offsetof(struct rpc_construct_daos, cont), spdk_json_decode_string}, 39 {"oclass", offsetof(struct rpc_construct_daos, oclass), spdk_json_decode_string, true}, 40 {"num_blocks", offsetof(struct rpc_construct_daos, num_blocks), spdk_json_decode_uint64}, 41 {"block_size", offsetof(struct rpc_construct_daos, block_size), spdk_json_decode_uint32}, 42 }; 43 44 static void 45 rpc_bdev_daos_create(struct spdk_jsonrpc_request *request, 46 const struct spdk_json_val *params) 47 { 48 struct rpc_construct_daos req = {NULL}; 49 struct spdk_json_write_ctx *w; 50 struct spdk_uuid *uuid = NULL; 51 struct spdk_uuid decoded_uuid; 52 struct spdk_bdev *bdev; 53 int rc = 0; 54 55 if (spdk_json_decode_object(params, rpc_construct_daos_decoders, 56 SPDK_COUNTOF(rpc_construct_daos_decoders), 57 &req)) { 58 SPDK_DEBUGLOG(bdev_daos, "spdk_json_decode_object failed\n"); 59 spdk_jsonrpc_send_error_response(request, SPDK_JSONRPC_ERROR_PARSE_ERROR, 60 "spdk_json_decode_object failed"); 61 goto cleanup; 62 } 63 64 if (req.uuid) { 65 if (spdk_uuid_parse(&decoded_uuid, req.uuid)) { 66 spdk_jsonrpc_send_error_response(request, -EINVAL, 67 "Failed to parse bdev UUID"); 68 goto cleanup; 69 } 70 uuid = &decoded_uuid; 71 } 72 73 rc = create_bdev_daos(&bdev, req.name, uuid, req.pool, req.cont, req.oclass, 74 req.num_blocks, req.block_size); 75 if (rc) { 76 spdk_jsonrpc_send_error_response(request, rc, spdk_strerror(-rc)); 77 goto cleanup; 78 } 79 80 free_rpc_construct_daos(&req); 81 82 w = spdk_jsonrpc_begin_result(request); 83 spdk_json_write_string(w, spdk_bdev_get_name(bdev)); 84 spdk_jsonrpc_end_result(request, w); 85 return; 86 87 cleanup: 88 free_rpc_construct_daos(&req); 89 } 90 SPDK_RPC_REGISTER("bdev_daos_create", rpc_bdev_daos_create, SPDK_RPC_RUNTIME) 91 SPDK_RPC_REGISTER_ALIAS_DEPRECATED(bdev_daos_create, construct_daos_bdev) 92 93 struct rpc_delete_daos { 94 char *name; 95 }; 96 97 static void 98 free_rpc_delete_daos(struct rpc_delete_daos *r) 99 { 100 free(r->name); 101 } 102 103 static const struct spdk_json_object_decoder rpc_delete_daos_decoders[] = { 104 {"name", offsetof(struct rpc_delete_daos, name), spdk_json_decode_string}, 105 }; 106 107 static void 108 rpc_bdev_daos_delete_cb(void *cb_arg, int bdeverrno) 109 { 110 struct spdk_jsonrpc_request *request = cb_arg; 111 112 spdk_jsonrpc_send_bool_response(request, bdeverrno == 0); 113 } 114 115 static void 116 rpc_bdev_daos_delete(struct spdk_jsonrpc_request *request, 117 const struct spdk_json_val *params) 118 { 119 struct rpc_delete_daos req = {NULL}; 120 struct spdk_bdev *bdev; 121 122 if (spdk_json_decode_object(params, rpc_delete_daos_decoders, 123 SPDK_COUNTOF(rpc_delete_daos_decoders), 124 &req)) { 125 SPDK_DEBUGLOG(bdev_daos, "spdk_json_decode_object failed\n"); 126 spdk_jsonrpc_send_error_response(request, SPDK_JSONRPC_ERROR_PARSE_ERROR, 127 "spdk_json_decode_object failed"); 128 goto cleanup; 129 } 130 131 bdev = spdk_bdev_get_by_name(req.name); 132 if (bdev == NULL) { 133 SPDK_INFOLOG(bdev_daos, "bdev '%s' does not exist\n", req.name); 134 spdk_jsonrpc_send_error_response(request, -ENODEV, spdk_strerror(ENODEV)); 135 goto cleanup; 136 } 137 138 delete_bdev_daos(bdev, rpc_bdev_daos_delete_cb, request); 139 140 cleanup: 141 free_rpc_delete_daos(&req); 142 } 143 144 SPDK_RPC_REGISTER("bdev_daos_delete", rpc_bdev_daos_delete, SPDK_RPC_RUNTIME) 145 SPDK_RPC_REGISTER_ALIAS_DEPRECATED(bdev_daos_delete, delete_daos_bdev) 146 147 struct rpc_bdev_daos_resize { 148 char *name; 149 uint64_t new_size; 150 }; 151 152 static const struct spdk_json_object_decoder rpc_bdev_daos_resize_decoders[] = { 153 {"name", offsetof(struct rpc_bdev_daos_resize, name), spdk_json_decode_string}, 154 {"new_size", offsetof(struct rpc_bdev_daos_resize, new_size), spdk_json_decode_uint64} 155 }; 156 157 static void 158 free_rpc_bdev_daos_resize(struct rpc_bdev_daos_resize *req) 159 { 160 free(req->name); 161 } 162 163 static void 164 rpc_bdev_daos_resize(struct spdk_jsonrpc_request *request, 165 const struct spdk_json_val *params) 166 { 167 struct rpc_bdev_daos_resize req = {}; 168 int rc; 169 170 if (spdk_json_decode_object(params, rpc_bdev_daos_resize_decoders, 171 SPDK_COUNTOF(rpc_bdev_daos_resize_decoders), 172 &req)) { 173 spdk_jsonrpc_send_error_response(request, SPDK_JSONRPC_ERROR_INTERNAL_ERROR, 174 "spdk_json_decode_object failed"); 175 goto cleanup; 176 } 177 178 rc = bdev_daos_resize(req.name, req.new_size); 179 if (rc) { 180 spdk_jsonrpc_send_error_response(request, rc, spdk_strerror(-rc)); 181 goto cleanup; 182 } 183 184 spdk_jsonrpc_send_bool_response(request, true); 185 cleanup: 186 free_rpc_bdev_daos_resize(&req); 187 } 188 SPDK_RPC_REGISTER("bdev_daos_resize", rpc_bdev_daos_resize, SPDK_RPC_RUNTIME) 189