diff options
Diffstat (limited to 'cli/src/cli.c')
| -rw-r--r-- | cli/src/cli.c | 1115 |
1 files changed, 557 insertions, 558 deletions
diff --git a/cli/src/cli.c b/cli/src/cli.c index 025f72c9748..39a0984a134 100644 --- a/cli/src/cli.c +++ b/cli/src/cli.c @@ -64,16 +64,17 @@ extern int connected; /* using argp for command line parsing */ -const char *argp_program_version = "" \ - PACKAGE_NAME" "PACKAGE_VERSION \ - "\nRepository revision: " GLUSTERFS_REPOSITORY_REVISION "\n" \ - "Copyright (c) 2006-2016 Red Hat, Inc. " \ - "<https://www.gluster.org/>\n" \ - "GlusterFS comes with ABSOLUTELY NO WARRANTY.\n" \ - "It is licensed to you under your choice of the GNU Lesser\n" \ - "General Public License, version 3 or any later version (LGPLv3\n" \ - "or later), or the GNU General Public License, version 2 (GPLv2),\n" \ - "in all cases as published by the Free Software Foundation."; +const char *argp_program_version = + "" PACKAGE_NAME " " PACKAGE_VERSION + "\nRepository revision: " GLUSTERFS_REPOSITORY_REVISION + "\n" + "Copyright (c) 2006-2016 Red Hat, Inc. " + "<https://www.gluster.org/>\n" + "GlusterFS comes with ABSOLUTELY NO WARRANTY.\n" + "It is licensed to you under your choice of the GNU Lesser\n" + "General Public License, version 3 or any later version (LGPLv3\n" + "or later), or the GNU General Public License, version 2 (GPLv2),\n" + "in all cases as published by the Free Software Foundation."; const char *argp_program_bug_address = "<" PACKAGE_BUGREPORT ">"; struct rpc_clnt *global_quotad_rpc; @@ -81,231 +82,228 @@ struct rpc_clnt *global_rpc; rpc_clnt_prog_t *cli_rpc_prog; - extern struct rpc_clnt_program cli_prog; static int -glusterfs_ctx_defaults_init (glusterfs_ctx_t *ctx) +glusterfs_ctx_defaults_init(glusterfs_ctx_t *ctx) { - cmd_args_t *cmd_args = NULL; - struct rlimit lim = {0, }; - call_pool_t *pool = NULL; - int ret = -1; - - ret = xlator_mem_acct_init (THIS, cli_mt_end); - if (ret != 0) { - return ret; - } + cmd_args_t *cmd_args = NULL; + struct rlimit lim = { + 0, + }; + call_pool_t *pool = NULL; + int ret = -1; + + ret = xlator_mem_acct_init(THIS, cli_mt_end); + if (ret != 0) { + return ret; + } - ctx->process_uuid = generate_glusterfs_ctx_id (); - if (!ctx->process_uuid) - return -1; + ctx->process_uuid = generate_glusterfs_ctx_id(); + if (!ctx->process_uuid) + return -1; - ctx->page_size = 128 * GF_UNIT_KB; + ctx->page_size = 128 * GF_UNIT_KB; - ctx->iobuf_pool = iobuf_pool_new (); - if (!ctx->iobuf_pool) - return -1; + ctx->iobuf_pool = iobuf_pool_new(); + if (!ctx->iobuf_pool) + return -1; - ctx->event_pool = event_pool_new (DEFAULT_EVENT_POOL_SIZE, - STARTING_EVENT_THREADS); - if (!ctx->event_pool) - return -1; + ctx->event_pool = event_pool_new(DEFAULT_EVENT_POOL_SIZE, + STARTING_EVENT_THREADS); + if (!ctx->event_pool) + return -1; - pool = GF_CALLOC (1, sizeof (call_pool_t), - cli_mt_call_pool_t); - if (!pool) - return -1; + pool = GF_CALLOC(1, sizeof(call_pool_t), cli_mt_call_pool_t); + if (!pool) + return -1; - /* frame_mem_pool size 112 * 64 */ - pool->frame_mem_pool = mem_pool_new (call_frame_t, 32); - if (!pool->frame_mem_pool) - return -1; + /* frame_mem_pool size 112 * 64 */ + pool->frame_mem_pool = mem_pool_new(call_frame_t, 32); + if (!pool->frame_mem_pool) + return -1; - /* stack_mem_pool size 256 * 128 */ - pool->stack_mem_pool = mem_pool_new (call_stack_t, 16); + /* stack_mem_pool size 256 * 128 */ + pool->stack_mem_pool = mem_pool_new(call_stack_t, 16); - if (!pool->stack_mem_pool) - return -1; + if (!pool->stack_mem_pool) + return -1; - ctx->stub_mem_pool = mem_pool_new (call_stub_t, 16); - if (!ctx->stub_mem_pool) - return -1; + ctx->stub_mem_pool = mem_pool_new(call_stub_t, 16); + if (!ctx->stub_mem_pool) + return -1; - ctx->dict_pool = mem_pool_new (dict_t, 32); - if (!ctx->dict_pool) - return -1; + ctx->dict_pool = mem_pool_new(dict_t, 32); + if (!ctx->dict_pool) + return -1; - ctx->dict_pair_pool = mem_pool_new (data_pair_t, 512); - if (!ctx->dict_pair_pool) - return -1; + ctx->dict_pair_pool = mem_pool_new(data_pair_t, 512); + if (!ctx->dict_pair_pool) + return -1; - ctx->dict_data_pool = mem_pool_new (data_t, 512); - if (!ctx->dict_data_pool) - return -1; + ctx->dict_data_pool = mem_pool_new(data_t, 512); + if (!ctx->dict_data_pool) + return -1; - ctx->logbuf_pool = mem_pool_new (log_buf_t, 256); - if (!ctx->logbuf_pool) - return -1; + ctx->logbuf_pool = mem_pool_new(log_buf_t, 256); + if (!ctx->logbuf_pool) + return -1; - INIT_LIST_HEAD (&pool->all_frames); - LOCK_INIT (&pool->lock); - ctx->pool = pool; + INIT_LIST_HEAD(&pool->all_frames); + LOCK_INIT(&pool->lock); + ctx->pool = pool; - cmd_args = &ctx->cmd_args; + cmd_args = &ctx->cmd_args; - INIT_LIST_HEAD (&cmd_args->xlator_options); + INIT_LIST_HEAD(&cmd_args->xlator_options); - lim.rlim_cur = RLIM_INFINITY; - lim.rlim_max = RLIM_INFINITY; - setrlimit (RLIMIT_CORE, &lim); + lim.rlim_cur = RLIM_INFINITY; + lim.rlim_max = RLIM_INFINITY; + setrlimit(RLIMIT_CORE, &lim); - return 0; + return 0; } - static int -logging_init (glusterfs_ctx_t *ctx, struct cli_state *state) +logging_init(glusterfs_ctx_t *ctx, struct cli_state *state) { - char *log_file = state->log_file ? state->log_file : - DEFAULT_CLI_LOG_FILE_DIRECTORY "/cli.log"; - - /* passing ident as NULL means to use default ident for syslog */ - if (gf_log_init (ctx, log_file, NULL) == -1) { - fprintf (stderr, "ERROR: failed to open logfile %s\n", - log_file); - return -1; - } + char *log_file = state->log_file ? state->log_file + : DEFAULT_CLI_LOG_FILE_DIRECTORY + "/cli.log"; - /* CLI should not have something to DEBUG after the release, - hence defaulting to INFO loglevel */ - gf_log_set_loglevel (ctx, (state->log_level == GF_LOG_NONE) ? - GF_LOG_INFO : state->log_level); + /* passing ident as NULL means to use default ident for syslog */ + if (gf_log_init(ctx, log_file, NULL) == -1) { + fprintf(stderr, "ERROR: failed to open logfile %s\n", log_file); + return -1; + } - return 0; + /* CLI should not have something to DEBUG after the release, + hence defaulting to INFO loglevel */ + gf_log_set_loglevel(ctx, (state->log_level == GF_LOG_NONE) + ? GF_LOG_INFO + : state->log_level); + + return 0; } int -cli_submit_request (struct rpc_clnt *rpc, void *req, call_frame_t *frame, - rpc_clnt_prog_t *prog, - int procnum, struct iobref *iobref, - xlator_t *this, fop_cbk_fn_t cbkfn, xdrproc_t xdrproc) +cli_submit_request(struct rpc_clnt *rpc, void *req, call_frame_t *frame, + rpc_clnt_prog_t *prog, int procnum, struct iobref *iobref, + xlator_t *this, fop_cbk_fn_t cbkfn, xdrproc_t xdrproc) { - int ret = -1; - int count = 0; - struct iovec iov = {0, }; - struct iobuf *iobuf = NULL; - char new_iobref = 0; - ssize_t xdr_size = 0; - - GF_ASSERT (this); - - if (req) { - xdr_size = xdr_sizeof (xdrproc, req); - iobuf = iobuf_get2 (this->ctx->iobuf_pool, xdr_size); - if (!iobuf) { - goto out; - }; - - if (!iobref) { - iobref = iobref_new (); - if (!iobref) { - goto out; - } - - new_iobref = 1; - } - - iobref_add (iobref, iobuf); - - iov.iov_base = iobuf->ptr; - iov.iov_len = iobuf_size (iobuf); - - - /* Create the xdr payload */ - ret = xdr_serialize_generic (iov, req, xdrproc); - if (ret == -1) { - goto out; - } - iov.iov_len = ret; - count = 1; + int ret = -1; + int count = 0; + struct iovec iov = { + 0, + }; + struct iobuf *iobuf = NULL; + char new_iobref = 0; + ssize_t xdr_size = 0; + + GF_ASSERT(this); + + if (req) { + xdr_size = xdr_sizeof(xdrproc, req); + iobuf = iobuf_get2(this->ctx->iobuf_pool, xdr_size); + if (!iobuf) { + goto out; + }; + + if (!iobref) { + iobref = iobref_new(); + if (!iobref) { + goto out; + } + + new_iobref = 1; + } + + iobref_add(iobref, iobuf); + + iov.iov_base = iobuf->ptr; + iov.iov_len = iobuf_size(iobuf); + + /* Create the xdr payload */ + ret = xdr_serialize_generic(iov, req, xdrproc); + if (ret == -1) { + goto out; } + iov.iov_len = ret; + count = 1; + } - if (!rpc) - rpc = global_rpc; - /* Send the msg */ - ret = rpc_clnt_submit (rpc, prog, procnum, cbkfn, - &iov, count, - NULL, 0, iobref, frame, NULL, 0, NULL, 0, NULL); - ret = 0; + if (!rpc) + rpc = global_rpc; + /* Send the msg */ + ret = rpc_clnt_submit(rpc, prog, procnum, cbkfn, &iov, count, NULL, 0, + iobref, frame, NULL, 0, NULL, 0, NULL); + ret = 0; out: - if (new_iobref) - iobref_unref (iobref); - if (iobuf) - iobuf_unref (iobuf); - return ret; + if (new_iobref) + iobref_unref(iobref); + if (iobuf) + iobuf_unref(iobuf); + return ret; } int -cli_rpc_notify (struct rpc_clnt *rpc, void *mydata, rpc_clnt_event_t event, - void *data) +cli_rpc_notify(struct rpc_clnt *rpc, void *mydata, rpc_clnt_event_t event, + void *data) { - xlator_t *this = NULL; - int ret = 0; - - this = mydata; + xlator_t *this = NULL; + int ret = 0; - switch (event) { - case RPC_CLNT_CONNECT: - { + this = mydata; - cli_cmd_broadcast_connected (); - gf_log (this->name, GF_LOG_TRACE, "got RPC_CLNT_CONNECT"); - break; + switch (event) { + case RPC_CLNT_CONNECT: { + cli_cmd_broadcast_connected(); + gf_log(this->name, GF_LOG_TRACE, "got RPC_CLNT_CONNECT"); + break; } - case RPC_CLNT_DISCONNECT: - { - gf_log (this->name, GF_LOG_TRACE, "got RPC_CLNT_DISCONNECT"); - connected = 0; - if (!global_state->prompt && global_state->await_connected) { - ret = 1; - cli_out ("Connection failed. Please check if gluster " - "daemon is operational."); - exit (ret); - } - break; + case RPC_CLNT_DISCONNECT: { + gf_log(this->name, GF_LOG_TRACE, "got RPC_CLNT_DISCONNECT"); + connected = 0; + if (!global_state->prompt && global_state->await_connected) { + ret = 1; + cli_out( + "Connection failed. Please check if gluster " + "daemon is operational."); + exit(ret); + } + break; } default: - gf_log (this->name, GF_LOG_TRACE, - "got some other RPC event %d", event); - ret = 0; - break; - } + gf_log(this->name, GF_LOG_TRACE, "got some other RPC event %d", + event); + ret = 0; + break; + } - return ret; + return ret; } static gf_boolean_t -is_valid_int (char *str) +is_valid_int(char *str) { - if (*str == '-') - ++str; + if (*str == '-') + ++str; - /* Handle empty string or just "-".*/ - if (!*str) - return _gf_false; + /* Handle empty string or just "-".*/ + if (!*str) + return _gf_false; - /* Check for non-digit chars in the rest of the string */ - while (*str) { - if (!isdigit(*str)) - return _gf_false; + /* Check for non-digit chars in the rest of the string */ + while (*str) { + if (!isdigit(*str)) + return _gf_false; else - ++str; - } - return _gf_true; + ++str; + } + return _gf_true; } /* @@ -315,527 +313,528 @@ is_valid_int (char *str) * -2: parsing issue (avoid unknown option error) */ int -cli_opt_parse (char *opt, struct cli_state *state) +cli_opt_parse(char *opt, struct cli_state *state) { - char *oarg = NULL; - gf_boolean_t secure_mgmt_tmp = 0; + char *oarg = NULL; + gf_boolean_t secure_mgmt_tmp = 0; - if (strcmp (opt, "") == 0) - return 1; + if (strcmp(opt, "") == 0) + return 1; - if (strcmp (opt, "version") == 0) { - cli_out ("%s", argp_program_version); - exit (0); - } + if (strcmp(opt, "version") == 0) { + cli_out("%s", argp_program_version); + exit(0); + } - if (strcmp (opt, "print-logdir") == 0) { - cli_out ("%s", DEFAULT_LOG_FILE_DIRECTORY); - exit (0); - } + if (strcmp(opt, "print-logdir") == 0) { + cli_out("%s", DEFAULT_LOG_FILE_DIRECTORY); + exit(0); + } - if (strcmp (opt, "print-statedumpdir") == 0) { - cli_out ("%s", DEFAULT_VAR_RUN_DIRECTORY); - exit (0); - } + if (strcmp(opt, "print-statedumpdir") == 0) { + cli_out("%s", DEFAULT_VAR_RUN_DIRECTORY); + exit(0); + } - if (strcmp (opt, "xml") == 0) { + if (strcmp(opt, "xml") == 0) { #if (HAVE_LIB_XML) - state->mode |= GLUSTER_MODE_XML; + state->mode |= GLUSTER_MODE_XML; #else - cli_err ("XML output not supported. Ignoring '--xml' option"); + cli_err("XML output not supported. Ignoring '--xml' option"); #endif - return 0; - } - - if (strcmp (opt, "wignore-partition") == 0) { - state->mode |= GLUSTER_MODE_WIGNORE_PARTITION; - return 0; - } - - if (strcmp (opt, "wignore") == 0) { - state->mode |= GLUSTER_MODE_WIGNORE; - return 0; - } + return 0; + } - oarg = strtail (opt, "mode="); - if (oarg) { - if (strcmp (oarg, "script") == 0) { - state->mode |= GLUSTER_MODE_SCRIPT; - return 0; - } + if (strcmp(opt, "wignore-partition") == 0) { + state->mode |= GLUSTER_MODE_WIGNORE_PARTITION; + return 0; + } - if (strcmp (oarg, "interactive") == 0) - return 0; + if (strcmp(opt, "wignore") == 0) { + state->mode |= GLUSTER_MODE_WIGNORE; + return 0; + } - return -1; + oarg = strtail(opt, "mode="); + if (oarg) { + if (strcmp(oarg, "script") == 0) { + state->mode |= GLUSTER_MODE_SCRIPT; + return 0; } - oarg = strtail (opt, "remote-host="); - if (oarg) { - state->remote_host = oarg; - return 0; - } + if (strcmp(oarg, "interactive") == 0) + return 0; - oarg = strtail (opt, "log-file="); - if (oarg) { - state->log_file = oarg; - return 0; - } - oarg = strtail (opt, "timeout="); - if (oarg) { - if (!is_valid_int (oarg) || atoi(oarg) <= 0) { - cli_err ("timeout value should be a positive integer"); - return -2; /* -2 instead of -1 to avoid unknown option - error */ - } - cli_default_conn_timeout = atoi(oarg); - return 0; - } + return -1; + } - oarg = strtail (opt, "log-level="); - if (oarg) { - int log_level = glusterd_check_log_level(oarg); - if (log_level == -1) - return -1; - state->log_level = (gf_loglevel_t) log_level; - return 0; - } + oarg = strtail(opt, "remote-host="); + if (oarg) { + state->remote_host = oarg; + return 0; + } - oarg = strtail (opt, "glusterd-sock="); - if (oarg) { - state->glusterd_sock = oarg; - return 0; - } + oarg = strtail(opt, "log-file="); + if (oarg) { + state->log_file = oarg; + return 0; + } + oarg = strtail(opt, "timeout="); + if (oarg) { + if (!is_valid_int(oarg) || atoi(oarg) <= 0) { + cli_err("timeout value should be a positive integer"); + return -2; /* -2 instead of -1 to avoid unknown option + error */ + } + cli_default_conn_timeout = atoi(oarg); + return 0; + } + + oarg = strtail(opt, "log-level="); + if (oarg) { + int log_level = glusterd_check_log_level(oarg); + if (log_level == -1) + return -1; + state->log_level = (gf_loglevel_t)log_level; + return 0; + } + + oarg = strtail(opt, "glusterd-sock="); + if (oarg) { + state->glusterd_sock = oarg; + return 0; + } - oarg = strtail (opt, "secure-mgmt="); - if (oarg) { - if (gf_string2boolean(oarg,&secure_mgmt_tmp) == 0) { - if (secure_mgmt_tmp) { - /* See declaration for why this is an int. */ - state->ctx->secure_mgmt = 1; - } - } - else { - cli_err ("invalid secure-mgmt value (ignored)"); - } - return 0; + oarg = strtail(opt, "secure-mgmt="); + if (oarg) { + if (gf_string2boolean(oarg, &secure_mgmt_tmp) == 0) { + if (secure_mgmt_tmp) { + /* See declaration for why this is an int. */ + state->ctx->secure_mgmt = 1; + } + } else { + cli_err("invalid secure-mgmt value (ignored)"); } + return 0; + } - return -1; + return -1; } int -parse_cmdline (int argc, char *argv[], struct cli_state *state) +parse_cmdline(int argc, char *argv[], struct cli_state *state) { - int ret = 0; - int i = 0; - int j = 0; - char *opt = NULL; - gf_boolean_t geo_rep_config = _gf_false; - - state->argc=argc-1; - state->argv=&argv[1]; - - /* Do this first so that an option can override. */ - if (sys_access (SECURE_ACCESS_FILE, F_OK) == 0) { - state->ctx->secure_mgmt = 1; - state->ctx->ssl_cert_depth = glusterfs_read_secure_access_file (); - } - - if (state->argc > GEO_REP_CMD_CONFIG_INDEX && - strtail (state->argv[GEO_REP_CMD_INDEX], "geo") && - strtail (state->argv[GEO_REP_CMD_CONFIG_INDEX], "co")) - geo_rep_config = _gf_true; - - for (i = 0; i < state->argc; i++) { - opt = strtail (state->argv[i], "--"); - if (opt && !geo_rep_config) { - ret = cli_opt_parse (opt, state); - if (ret == -1) { - cli_out ("unrecognized option --%s", opt); - return ret; - } else if (ret == -2) { - return ret; - } - for (j = i; j < state->argc - 1; j++) - state->argv[j] = state->argv[j + 1]; - state->argc--; - /* argv shifted, next check should be at i again */ - i--; - if (ret == 1) { - /* end of cli options */ - ret = 0; - break; - } - } + int ret = 0; + int i = 0; + int j = 0; + char *opt = NULL; + gf_boolean_t geo_rep_config = _gf_false; + + state->argc = argc - 1; + state->argv = &argv[1]; + + /* Do this first so that an option can override. */ + if (sys_access(SECURE_ACCESS_FILE, F_OK) == 0) { + state->ctx->secure_mgmt = 1; + state->ctx->ssl_cert_depth = glusterfs_read_secure_access_file(); + } + + if (state->argc > GEO_REP_CMD_CONFIG_INDEX && + strtail(state->argv[GEO_REP_CMD_INDEX], "geo") && + strtail(state->argv[GEO_REP_CMD_CONFIG_INDEX], "co")) + geo_rep_config = _gf_true; + + for (i = 0; i < state->argc; i++) { + opt = strtail(state->argv[i], "--"); + if (opt && !geo_rep_config) { + ret = cli_opt_parse(opt, state); + if (ret == -1) { + cli_out("unrecognized option --%s", opt); + return ret; + } else if (ret == -2) { + return ret; + } + for (j = i; j < state->argc - 1; j++) + state->argv[j] = state->argv[j + 1]; + state->argc--; + /* argv shifted, next check should be at i again */ + i--; + if (ret == 1) { + /* end of cli options */ + ret = 0; + break; + } } + } - state->argv[state->argc] = NULL; + state->argv[state->argc] = NULL; - return ret; + return ret; } - int -cli_cmd_tree_init (struct cli_cmd_tree *tree) +cli_cmd_tree_init(struct cli_cmd_tree *tree) { - struct cli_cmd_word *root = NULL; - int ret = 0; + struct cli_cmd_word *root = NULL; + int ret = 0; - root = &tree->root; - root->tree = tree; + root = &tree->root; + root->tree = tree; - return ret; + return ret; } - int -cli_state_init (struct cli_state *state) +cli_state_init(struct cli_state *state) { - struct cli_cmd_tree *tree = NULL; - int ret = 0; - + struct cli_cmd_tree *tree = NULL; + int ret = 0; - state->log_level = GF_LOG_NONE; + state->log_level = GF_LOG_NONE; - tree = &state->tree; - tree->state = state; + tree = &state->tree; + tree->state = state; - ret = cli_cmd_tree_init (tree); + ret = cli_cmd_tree_init(tree); - return ret; + return ret; } int -cli_usage_out (const char *usage) +cli_usage_out(const char *usage) { - GF_ASSERT (usage); + GF_ASSERT(usage); - if (!usage || usage[0] == '\0') - return -1; + if (!usage || usage[0] == '\0') + return -1; - cli_err ("\nUsage:\n%s\n", usage); - return 0; + cli_err("\nUsage:\n%s\n", usage); + return 0; } int -_cli_err (const char *fmt, ...) +_cli_err(const char *fmt, ...) { - va_list ap; - int ret = 0; + va_list ap; + int ret = 0; #ifdef HAVE_READLINE - struct cli_state *state = global_state; + struct cli_state *state = global_state; #endif - va_start (ap, fmt); + va_start(ap, fmt); #ifdef HAVE_READLINE - if (state->rl_enabled && !state->rl_processing) { - ret = cli_rl_err (state, fmt, ap); - va_end (ap); - return ret; - } + if (state->rl_enabled && !state->rl_processing) { + ret = cli_rl_err(state, fmt, ap); + va_end(ap); + return ret; + } #endif - ret = vfprintf (stderr, fmt, ap); - fprintf (stderr, "\n"); - va_end (ap); + ret = vfprintf(stderr, fmt, ap); + fprintf(stderr, "\n"); + va_end(ap); - return ret; + return ret; } - int -_cli_out (const char *fmt, ...) +_cli_out(const char *fmt, ...) { - va_list ap; - int ret = 0; + va_list ap; + int ret = 0; #ifdef HAVE_READLINE - struct cli_state *state = global_state; + struct cli_state *state = global_state; #endif - va_start (ap, fmt); + va_start(ap, fmt); #ifdef HAVE_READLINE - if (state->rl_enabled && !state->rl_processing) { - ret = cli_rl_out (state, fmt, ap); - va_end (ap); - return ret; - } + if (state->rl_enabled && !state->rl_processing) { + ret = cli_rl_out(state, fmt, ap); + va_end(ap); + return ret; + } #endif - ret = vprintf (fmt, ap); - printf ("\n"); - va_end (ap); + ret = vprintf(fmt, ap); + printf("\n"); + va_end(ap); - return ret; + return ret; } struct rpc_clnt * -cli_quotad_clnt_rpc_init (void) +cli_quotad_clnt_rpc_init(void) { - struct rpc_clnt *rpc = NULL; - dict_t *rpc_opts = NULL; - int ret = -1; - - rpc_opts = dict_new (); - if (!rpc_opts) { - ret = -1; - goto out; - } - - ret = dict_set_str (rpc_opts, "transport.address-family", "unix"); - if (ret) - goto out; - - ret = dict_set_str (rpc_opts, "transport-type", "socket"); - if (ret) - goto out; - - ret = dict_set_str (rpc_opts, "transport.socket.connect-path", - "/var/run/gluster/quotad.socket"); - if (ret) - goto out; - - rpc = cli_quotad_clnt_init (THIS, rpc_opts); - if (!rpc) - goto out; - - global_quotad_rpc = rpc; + struct rpc_clnt *rpc = NULL; + dict_t *rpc_opts = NULL; + int ret = -1; + + rpc_opts = dict_new(); + if (!rpc_opts) { + ret = -1; + goto out; + } + + ret = dict_set_str(rpc_opts, "transport.address-family", "unix"); + if (ret) + goto out; + + ret = dict_set_str(rpc_opts, "transport-type", "socket"); + if (ret) + goto out; + + ret = dict_set_str(rpc_opts, "transport.socket.connect-path", + "/var/run/gluster/quotad.socket"); + if (ret) + goto out; + + rpc = cli_quotad_clnt_init(THIS, rpc_opts); + if (!rpc) + goto out; + + global_quotad_rpc = rpc; out: - if (ret) { - if (rpc_opts) - dict_unref(rpc_opts); - } - return rpc; + if (ret) { + if (rpc_opts) + dict_unref(rpc_opts); + } + return rpc; } struct rpc_clnt * -cli_rpc_init (struct cli_state *state) +cli_rpc_init(struct cli_state *state) { - struct rpc_clnt *rpc = NULL; - dict_t *options = NULL; - int ret = -1; - int port = CLI_GLUSTERD_PORT; - xlator_t *this = NULL; + struct rpc_clnt *rpc = NULL; + dict_t *options = NULL; + int ret = -1; + int port = CLI_GLUSTERD_PORT; + xlator_t *this = NULL; #ifdef IPV6_DEFAULT - char *addr_family = "inet6"; + char *addr_family = "inet6"; #else - char *addr_family = "inet"; + char *addr_family = "inet"; #endif - this = THIS; - cli_rpc_prog = &cli_prog; - options = dict_new (); - if (!options) - goto out; - - /* Connect to glusterd using the specified method, giving preference - * to a unix socket connection. If nothing is specified, connect to - * the default glusterd socket. - */ - if (state->glusterd_sock) { - gf_log ("cli", GF_LOG_INFO, "Connecting to glusterd using " - "sockfile %s", state->glusterd_sock); - ret = rpc_transport_unix_options_build (&options, - state->glusterd_sock, - 0); - if (ret) - goto out; - } - else if (state->remote_host) { - gf_log ("cli", GF_LOG_INFO, "Connecting to remote glusterd at " - "%s", state->remote_host); - ret = dict_set_str (options, "remote-host", state->remote_host); - if (ret) - goto out; + this = THIS; + cli_rpc_prog = &cli_prog; + options = dict_new(); + if (!options) + goto out; + + /* Connect to glusterd using the specified method, giving preference + * to a unix socket connection. If nothing is specified, connect to + * the default glusterd socket. + */ + if (state->glusterd_sock) { + gf_log("cli", GF_LOG_INFO, + "Connecting to glusterd using " + "sockfile %s", + state->glusterd_sock); + ret = rpc_transport_unix_options_build(&options, state->glusterd_sock, + 0); + if (ret) + goto out; + } else if (state->remote_host) { + gf_log("cli", GF_LOG_INFO, + "Connecting to remote glusterd at " + "%s", + state->remote_host); + ret = dict_set_str(options, "remote-host", state->remote_host); + if (ret) + goto out; - if (state->remote_port) - port = state->remote_port; + if (state->remote_port) + port = state->remote_port; - ret = dict_set_int32 (options, "remote-port", port); - if (ret) - goto out; + ret = dict_set_int32(options, "remote-port", port); + if (ret) + goto out; - ret = dict_set_str (options, "transport.address-family", - addr_family); + ret = dict_set_str(options, "transport.address-family", addr_family); - if (ret) - goto out; - } - else { - gf_log ("cli", GF_LOG_DEBUG, "Connecting to glusterd using " - "default socket"); - ret = rpc_transport_unix_options_build - (&options, DEFAULT_GLUSTERD_SOCKFILE, 0); - if (ret) - goto out; - } + if (ret) + goto out; + } else { + gf_log("cli", GF_LOG_DEBUG, + "Connecting to glusterd using " + "default socket"); + ret = rpc_transport_unix_options_build(&options, + DEFAULT_GLUSTERD_SOCKFILE, 0); + if (ret) + goto out; + } - rpc = rpc_clnt_new (options, this, this->name, 16); - if (!rpc) - goto out; + rpc = rpc_clnt_new(options, this, this->name, 16); + if (!rpc) + goto out; - ret = rpc_clnt_register_notify (rpc, cli_rpc_notify, this); - if (ret) { - gf_log ("cli", GF_LOG_ERROR, "failed to register notify"); - goto out; - } + ret = rpc_clnt_register_notify(rpc, cli_rpc_notify, this); + if (ret) { + gf_log("cli", GF_LOG_ERROR, "failed to register notify"); + goto out; + } - ret = rpc_clnt_start (rpc); + ret = rpc_clnt_start(rpc); out: - if (ret) { - if (rpc) - rpc_clnt_unref (rpc); - rpc = NULL; - } - return rpc; + if (ret) { + if (rpc) + rpc_clnt_unref(rpc); + rpc = NULL; + } + return rpc; } cli_local_t * -cli_local_get () +cli_local_get() { - cli_local_t *local = NULL; + cli_local_t *local = NULL; - local = GF_CALLOC (1, sizeof (*local), cli_mt_cli_local_t); - LOCK_INIT (&local->lock); - INIT_LIST_HEAD (&local->dict_list); + local = GF_CALLOC(1, sizeof(*local), cli_mt_cli_local_t); + LOCK_INIT(&local->lock); + INIT_LIST_HEAD(&local->dict_list); - return local; + return local; } void -cli_local_wipe (cli_local_t *local) +cli_local_wipe(cli_local_t *local) { - if (local) { - GF_FREE (local->get_vol.volname); - if (local->dict) - dict_unref (local->dict); - GF_FREE (local); - } - - return; + if (local) { + GF_FREE(local->get_vol.volname); + if (local->dict) + dict_unref(local->dict); + GF_FREE(local); + } + + return; } struct cli_state *global_state; int -main (int argc, char *argv[]) +main(int argc, char *argv[]) { - struct cli_state state = {0, }; - int ret = -1; - glusterfs_ctx_t *ctx = NULL; + struct cli_state state = { + 0, + }; + int ret = -1; + glusterfs_ctx_t *ctx = NULL; - mem_pools_init_early (); - mem_pools_init_late (); + mem_pools_init_early(); + mem_pools_init_late(); - ctx = glusterfs_ctx_new (); - if (!ctx) - return ENOMEM; + ctx = glusterfs_ctx_new(); + if (!ctx) + return ENOMEM; #ifdef DEBUG - gf_mem_acct_enable_set (ctx); + gf_mem_acct_enable_set(ctx); #endif - ret = glusterfs_globals_init (ctx); - if (ret) - return ret; + ret = glusterfs_globals_init(ctx); + if (ret) + return ret; - THIS->ctx = ctx; + THIS->ctx = ctx; - ret = glusterfs_ctx_defaults_init (ctx); - if (ret) - goto out; + ret = glusterfs_ctx_defaults_init(ctx); + if (ret) + goto out; - cli_default_conn_timeout = 120; - cli_ten_minutes_timeout = 600; + cli_default_conn_timeout = 120; + cli_ten_minutes_timeout = 600; - ret = cli_state_init (&state); - if (ret) - goto out; + ret = cli_state_init(&state); + if (ret) + goto out; - state.ctx = ctx; - global_state = &state; + state.ctx = ctx; + global_state = &state; - ret = parse_cmdline (argc, argv, &state); - if (ret) - goto out; + ret = parse_cmdline(argc, argv, &state); + if (ret) + goto out; - ret = logging_init (ctx, &state); - if (ret) - goto out; + ret = logging_init(ctx, &state); + if (ret) + goto out; - gf_log ("cli", GF_LOG_INFO, "Started running %s with version %s", - argv[0], PACKAGE_VERSION); + gf_log("cli", GF_LOG_INFO, "Started running %s with version %s", argv[0], + PACKAGE_VERSION); - global_rpc = cli_rpc_init (&state); - if (!global_rpc) - goto out; + global_rpc = cli_rpc_init(&state); + if (!global_rpc) + goto out; - global_quotad_rpc = cli_quotad_clnt_rpc_init (); - if (!global_quotad_rpc) - goto out; + global_quotad_rpc = cli_quotad_clnt_rpc_init(); + if (!global_quotad_rpc) + goto out; - ret = cli_cmds_register (&state); - if (ret) - goto out; + ret = cli_cmds_register(&state); + if (ret) + goto out; - ret = cli_cmd_cond_init (); - if (ret) - goto out; + ret = cli_cmd_cond_init(); + if (ret) + goto out; - ret = cli_input_init (&state); - if (ret) - goto out; + ret = cli_input_init(&state); + if (ret) + goto out; - ret = event_dispatch (ctx->event_pool); + ret = event_dispatch(ctx->event_pool); out: -// glusterfs_ctx_destroy (ctx); + // glusterfs_ctx_destroy (ctx); - mem_pools_fini (); + mem_pools_fini(); - return ret; + return ret; } void -cli_print_line (int len) +cli_print_line(int len) { - GF_ASSERT (len > 0); + GF_ASSERT(len > 0); - while (len--) - printf ("-"); + while (len--) + printf("-"); - printf ("\n"); + printf("\n"); } void -print_quota_list_header (int type) +print_quota_list_header(int type) { - if (type == GF_QUOTA_OPTION_TYPE_LIST) { - cli_out (" Path Hard-limit " - " Soft-limit Used Available Soft-limit " - "exceeded? Hard-limit exceeded?"); - cli_out ("-----------------------------------------------------" - "-----------------------------------------------------" - "---------------------"); - } else { - cli_out (" Path Hard-limit " - " Soft-limit Files Dirs Available " - "Soft-limit exceeded? Hard-limit exceeded?"); - cli_out ("-----------------------------------------------------" - "-----------------------------------------------------" - "-------------------------------------"); - } + if (type == GF_QUOTA_OPTION_TYPE_LIST) { + cli_out( + " Path Hard-limit " + " Soft-limit Used Available Soft-limit " + "exceeded? Hard-limit exceeded?"); + cli_out( + "-----------------------------------------------------" + "-----------------------------------------------------" + "---------------------"); + } else { + cli_out( + " Path Hard-limit " + " Soft-limit Files Dirs Available " + "Soft-limit exceeded? Hard-limit exceeded?"); + cli_out( + "-----------------------------------------------------" + "-----------------------------------------------------" + "-------------------------------------"); + } } void -print_quota_list_empty (char *path, int type) +print_quota_list_empty(char *path, int type) { - if (type == GF_QUOTA_OPTION_TYPE_LIST) - cli_out ("%-40s %7s %9s %10s %7s %15s %20s", path, - "N/A", "N/A", "N/A", "N/A", "N/A", "N/A"); - else - cli_out ("%-40s %9s %9s %12s %10s %10s %15s %20s", path, - "N/A", "N/A", "N/A", "N/A", "N/A", "N/A", "N/A"); + if (type == GF_QUOTA_OPTION_TYPE_LIST) + cli_out("%-40s %7s %9s %10s %7s %15s %20s", path, "N/A", "N/A", "N/A", + "N/A", "N/A", "N/A"); + else + cli_out("%-40s %9s %9s %12s %10s %10s %15s %20s", path, "N/A", "N/A", + "N/A", "N/A", "N/A", "N/A", "N/A"); } - |