ivampiresp/Spdk
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

lib/iscsi: Factor out internal of rpc_iscsi_delete_portal_group

Browse Source 
Factor out the internal of rpc_iscsi_delete_portal_group() into
a function _rpc_iscsi_change_portal_group() and rename the related
data structure to use them for the upcoming RPC,
iscsi_start_portal_group.

Signed-off-by: Shuhei Matsumoto <shuhei.matsumoto.xt@hitachi.com>
Change-Id: I965f1e52f04fb54c6a89987836f89c508441a37e
Reviewed-on: https://review.spdk.io/gerrit/c/spdk/spdk/+/5089
Tested-by: SPDK CI Jenkins <sys_sgci@intel.com>
Community-CI: Mellanox Build Bot
Reviewed-by: Jim Harris <james.r.harris@intel.com>
Reviewed-by: Changpeng Liu <changpeng.liu@intel.com>
This commit is contained in:
Shuhei Matsumoto 2020-11-16 16:37:14 +09:00 committed by Tomasz Zawadzki
parent 8381b98ef4
commit 7ac4961b33
1 changed files with 38 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

54
lib/iscsi/iscsi_rpc.c
View File

@ -820,42 +820,64 @@ out:
SPDK_RPC_REGISTER("iscsi_create_portal_group", rpc_iscsi_create_portal_group, SPDK_RPC_RUNTIME)
SPDK_RPC_REGISTER_ALIAS_DEPRECATED(iscsi_create_portal_group, add_portal_group)
struct rpc_iscsi_delete_portal_group {
struct rpc_iscsi_change_portal_group {
int32_t tag;
};
static const struct spdk_json_object_decoder rpc_iscsi_delete_portal_group_decoders[] = {
{"tag", offsetof(struct rpc_iscsi_delete_portal_group, tag), spdk_json_decode_int32},
static const struct spdk_json_object_decoder rpc_iscsi_change_portal_group_decoders[] = {
{"tag", offsetof(struct rpc_iscsi_change_portal_group, tag), spdk_json_decode_int32},
};
static void
rpc_iscsi_delete_portal_group(struct spdk_jsonrpc_request *request,
const struct spdk_json_val *params)
{
struct rpc_iscsi_delete_portal_group req = {};
struct spdk_iscsi_portal_grp *pg;
typedef int (*iscsi_change_portal_grp_fn)(int pg_tag);
if (spdk_json_decode_object(params, rpc_iscsi_delete_portal_group_decoders,
SPDK_COUNTOF(rpc_iscsi_delete_portal_group_decoders),
static void
_rpc_iscsi_change_portal_group(struct spdk_jsonrpc_request *request,
const struct spdk_json_val *params,
iscsi_change_portal_grp_fn fn)
{
struct rpc_iscsi_change_portal_group req = {};
int rc;
if (spdk_json_decode_object(params, rpc_iscsi_change_portal_group_decoders,
SPDK_COUNTOF(rpc_iscsi_change_portal_group_decoders),
&req)) {
SPDK_ERRLOG("spdk_json_decode_object failed\n");
goto invalid;
}
pg = iscsi_portal_grp_unregister(req.tag);
if (!pg) {
rc = fn(req.tag);
if (rc != 0) {
goto invalid;
}
iscsi_tgt_node_delete_map(pg, NULL);
iscsi_portal_grp_release(pg);
spdk_jsonrpc_send_bool_response(request, true);
return;
invalid:
spdk_jsonrpc_send_error_response(request, SPDK_JSONRPC_ERROR_INVALID_PARAMS, "Invalid parameters");
}
static int
_rpc_iscsi_delete_portal_group(int pg_tag)
{
struct spdk_iscsi_portal_grp *pg;
pg = iscsi_portal_grp_unregister(pg_tag);
if (!pg) {
return -ENODEV;
}
iscsi_tgt_node_delete_map(pg, NULL);
iscsi_portal_grp_release(pg);
return 0;
}
static void
rpc_iscsi_delete_portal_group(struct spdk_jsonrpc_request *request,
const struct spdk_json_val *params)
{
_rpc_iscsi_change_portal_group(request, params, _rpc_iscsi_delete_portal_group);
}
SPDK_RPC_REGISTER("iscsi_delete_portal_group", rpc_iscsi_delete_portal_group, SPDK_RPC_RUNTIME)
SPDK_RPC_REGISTER_ALIAS_DEPRECATED(iscsi_delete_portal_group, delete_portal_group)