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 | |
| 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')
| -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,  | 
