diff options
author | Amar Tumballi <amar@gluster.com> | 2011-11-16 12:25:28 +0530 |
---|---|---|
committer | Vijay Bellur <vijay@gluster.com> | 2011-11-16 03:43:53 -0800 |
commit | 217842180858afff79d06c24389752299c5ed716 (patch) | |
tree | 6a61f3237eab3bd0c8c5db0e0536a30d3268821a /xlators/mgmt/glusterd | |
parent | 7e3faaf682bf8f35fea9e2b4d930cbb68dae213e (diff) |
mgmt/glusterd: more cleanup
* 'GD_OP_RENAME_VOLUME' removed
* unused handler function for rebalance is removed.
Change-Id: Id081cb02a6445c09347bacc0fdf9cd600ff94e5d
BUG: 3158
Reviewed-on: http://review.gluster.com/734
Tested-by: Gluster Build System <jenkins@build.gluster.com>
Reviewed-by: Vijay Bellur <vijay@gluster.com>
Diffstat (limited to 'xlators/mgmt/glusterd')
-rw-r--r-- | xlators/mgmt/glusterd/src/glusterd-handler.c | 2 | ||||
-rw-r--r-- | xlators/mgmt/glusterd/src/glusterd-rebalance.c | 197 | ||||
-rw-r--r-- | xlators/mgmt/glusterd/src/glusterd-rpc-ops.c | 1 | ||||
-rw-r--r-- | xlators/mgmt/glusterd/src/glusterd.h | 1 |
4 files changed, 4 insertions, 197 deletions
diff --git a/xlators/mgmt/glusterd/src/glusterd-handler.c b/xlators/mgmt/glusterd/src/glusterd-handler.c index 402e4d511..1d311649c 100644 --- a/xlators/mgmt/glusterd/src/glusterd-handler.c +++ b/xlators/mgmt/glusterd/src/glusterd-handler.c @@ -2780,7 +2780,7 @@ struct rpcsvc_program gd_svc_peer_prog = { rpcsvc_actor_t gd_svc_cli_actors[] = { [GLUSTER_CLI_PROBE] = { "CLI_PROBE", GLUSTER_CLI_PROBE, glusterd_handle_cli_probe, NULL, NULL}, [GLUSTER_CLI_CREATE_VOLUME] = { "CLI_CREATE_VOLUME", GLUSTER_CLI_CREATE_VOLUME, glusterd_handle_create_volume, NULL,NULL}, - [GLUSTER_CLI_DEFRAG_VOLUME] = { "CLI_DEFRAG_VOLUME", GLUSTER_CLI_DEFRAG_VOLUME, glusterd_handle_defrag_volume_v2, NULL,NULL}, + [GLUSTER_CLI_DEFRAG_VOLUME] = { "CLI_DEFRAG_VOLUME", GLUSTER_CLI_DEFRAG_VOLUME, glusterd_handle_defrag_volume, NULL,NULL}, [GLUSTER_CLI_DEPROBE] = { "FRIEND_REMOVE", GLUSTER_CLI_DEPROBE, glusterd_handle_cli_deprobe, NULL, NULL}, [GLUSTER_CLI_LIST_FRIENDS] = { "LIST_FRIENDS", GLUSTER_CLI_LIST_FRIENDS, glusterd_handle_cli_list_friends, NULL, NULL}, [GLUSTER_CLI_START_VOLUME] = { "START_VOLUME", GLUSTER_CLI_START_VOLUME, glusterd_handle_cli_start_volume, NULL, NULL}, diff --git a/xlators/mgmt/glusterd/src/glusterd-rebalance.c b/xlators/mgmt/glusterd/src/glusterd-rebalance.c index a50180ea5..a556e335b 100644 --- a/xlators/mgmt/glusterd/src/glusterd-rebalance.c +++ b/xlators/mgmt/glusterd/src/glusterd-rebalance.c @@ -411,8 +411,8 @@ out: } int -glusterd_defrag_status_get_v2 (glusterd_volinfo_t *volinfo, - dict_t *dict) +glusterd_defrag_status_get (glusterd_volinfo_t *volinfo, + dict_t *dict) { int ret = 0; uint64_t files = 0; @@ -464,57 +464,6 @@ out: return 0; } -int -glusterd_defrag_status_get (glusterd_volinfo_t *volinfo, - dict_t *rsp) -{ - uint64_t files = 0; - uint64_t size = 0; - uint64_t lookedup_files = 0; - int ret = -1; - - if (!volinfo || !rsp) - goto out; - - if (volinfo->defrag) { - LOCK (&volinfo->defrag->lock); - { - files = volinfo->defrag->total_files; - size = volinfo->defrag->total_data; - lookedup_files = volinfo->defrag->num_files_lookedup; - } - UNLOCK (&volinfo->defrag->lock); - } else { - files = volinfo->rebalance_files; - size = volinfo->rebalance_data; - lookedup_files = volinfo->lookedup_files; - } - - ret = dict_set_uint64 (rsp, "files", files); - if (ret) { - gf_log (THIS->name, GF_LOG_ERROR, - "Failed to set dict"); - goto out; - } - - ret = dict_set_uint64 (rsp, "size", size); - if (ret) { - gf_log (THIS->name, GF_LOG_ERROR, - "Failed to set dict"); - goto out; - } - ret = dict_set_uint64 (rsp, "lookedup-files", lookedup_files); - if (ret) { - gf_log (THIS->name, GF_LOG_ERROR, - "Failed to set dict"); - goto out; - } - - return volinfo->defrag_status; -out: - return ret; -} - void glusterd_rebalance_cmd_attempted_log (int cmd, char *volname) { @@ -706,146 +655,6 @@ out: int glusterd_handle_defrag_volume (rpcsvc_request_t *req) { - int32_t ret = -1; - gf_cli_req cli_req = {{0,}}; - glusterd_conf_t *priv = NULL; - char cmd_str[4096] = {0,}; - glusterd_volinfo_t *volinfo = NULL; - gf_cli_rsp rsp = {0,}; - char msg[2048] = {0}; - dict_t *dict = NULL; - char *volname = NULL; - gf_cli_defrag_type cmd = 0; - uint64_t files = 0; - uint64_t size = 0; - - GF_ASSERT (req); - - priv = THIS->private; - - if (!xdr_to_generic (req->msg[0], &cli_req, - (xdrproc_t)xdr_gf_cli_req)) { - //failed to decode msg; - req->rpc_err = GARBAGE_ARGS; - goto out; - } - - if (cli_req.dict.dict_len) { - /* Unserialize the dictionary */ - dict = dict_new (); - - ret = dict_unserialize (cli_req.dict.dict_val, - cli_req.dict.dict_len, - &dict); - if (ret < 0) { - gf_log ("glusterd", GF_LOG_ERROR, - "failed to " - "unserialize req-buffer to dictionary"); - goto out; - } - } - - ret = dict_get_str (dict, "volname", &volname); - if (ret) { - gf_log (THIS->name, GF_LOG_ERROR, - "Failed to get volname"); - goto out; - } - - ret = dict_get_int32 (dict, "rebalance-command", (int32_t*)&cmd); - if (ret) { - gf_log (THIS->name, GF_LOG_ERROR, - "Failed to get command"); - goto out; - } - - glusterd_rebalance_cmd_attempted_log (cmd, volname); - - rsp.op_ret = -1; - - ret = glusterd_rebalance_cmd_validate (cmd, volname, - &volinfo, msg, sizeof (msg)); - if (ret) - goto out; - switch (cmd) { - case GF_DEFRAG_CMD_START: - case GF_DEFRAG_CMD_START_LAYOUT_FIX: - case GF_DEFRAG_CMD_START_MIGRATE_DATA: - case GF_DEFRAG_CMD_START_MIGRATE_DATA_FORCE: - { - ret = glusterd_handle_defrag_start (volinfo, msg, sizeof (msg), - cmd, NULL); - rsp.op_ret = ret; - break; - } - case GF_DEFRAG_CMD_STOP: - ret = glusterd_defrag_stop (volinfo, &files, &size, - msg, sizeof (msg)); - ret = dict_set_uint64 (dict, "files", files); - if (ret) { - gf_log (THIS->name, GF_LOG_ERROR, - "Failed to set files argument"); - rsp.op_ret = ret; - goto out; - } - - ret = dict_set_uint64 (dict, "size", size); - if (ret) { - gf_log (THIS->name, GF_LOG_ERROR, - "Failed to set size argument"); - rsp.op_ret = ret; - goto out; - } - - rsp.op_ret = ret; - break; - case GF_DEFRAG_CMD_STATUS: - ret = glusterd_defrag_status_get (volinfo, dict); - if (ret != -1) { - rsp.op_errno = ret; - rsp.op_ret = 0; - ret = 0; - } - - break; - default: - break; - } - if (ret) - gf_log("glusterd", GF_LOG_DEBUG, "command: %s failed",cmd_str); - - if (cmd != GF_DEFRAG_CMD_STATUS) { - gf_cmd_log ("volume rebalance"," on volname: %s %d %s", - volname, - cmd, ((ret)?"FAILED":"SUCCESS")); - } - -out: - ret = dict_allocate_and_serialize (dict, - &rsp.dict.dict_val, - (size_t *) &rsp.dict.dict_len); - if (ret < 0) { - gf_log (THIS->name, GF_LOG_ERROR, - "failed to serialize the data"); - - goto out; - } - - ret = glusterd_submit_reply (req, &rsp, NULL, 0, NULL, - (xdrproc_t)xdr_gf_cli_rsp); - if (cli_req.dict.dict_val) - free (cli_req.dict.dict_val);//malloced by xdr - - if (dict) - dict_unref (dict); - - - return 0; -} - -int -glusterd_handle_defrag_volume_v2 (rpcsvc_request_t *req) -{ int32_t ret = -1; gf_cli_req cli_req = {{0,}}; glusterd_conf_t *priv = NULL; @@ -1057,7 +866,7 @@ glusterd_op_rebalance (dict_t *dict, char **op_errstr, dict_t *rsp_dict) if (!tmp_dict) tmp_dict = glusterd_op_get_ctx (GD_OP_REBALANCE); - ret = glusterd_defrag_status_get_v2 (volinfo, tmp_dict); + ret = glusterd_defrag_status_get (volinfo, tmp_dict); break; default: break; diff --git a/xlators/mgmt/glusterd/src/glusterd-rpc-ops.c b/xlators/mgmt/glusterd/src/glusterd-rpc-ops.c index b22938c92..8b572afbf 100644 --- a/xlators/mgmt/glusterd/src/glusterd-rpc-ops.c +++ b/xlators/mgmt/glusterd/src/glusterd-rpc-ops.c @@ -163,7 +163,6 @@ done: break; } - case GD_OP_RENAME_VOLUME: case GD_OP_START_BRICK: case GD_OP_STOP_BRICK: { diff --git a/xlators/mgmt/glusterd/src/glusterd.h b/xlators/mgmt/glusterd/src/glusterd.h index 1ce5962bc..4723aec79 100644 --- a/xlators/mgmt/glusterd/src/glusterd.h +++ b/xlators/mgmt/glusterd/src/glusterd.h @@ -62,7 +62,6 @@ typedef enum glusterd_op_ { GD_OP_DELETE_VOLUME, GD_OP_START_VOLUME, GD_OP_STOP_VOLUME, - GD_OP_RENAME_VOLUME, GD_OP_DEFRAG_VOLUME, GD_OP_ADD_BRICK, GD_OP_REMOVE_BRICK, |