diff options
Diffstat (limited to 'cli/src/cli.h')
| -rw-r--r-- | cli/src/cli.h | 574 |
1 files changed, 437 insertions, 137 deletions
diff --git a/cli/src/cli.h b/cli/src/cli.h index 57be8c6f610..c0d933e8f8a 100644 --- a/cli/src/cli.h +++ b/cli/src/cli.h @@ -1,216 +1,516 @@ /* - Copyright (c) 2006-2010 Gluster, Inc. <http://www.gluster.com> + Copyright (c) 2006-2012 Red Hat, Inc. <http://www.redhat.com> This file is part of GlusterFS. - GlusterFS is free software; you can redistribute it and/or modify - it under the terms of the GNU Affero General Public License as published - by the Free Software Foundation; either version 3 of the License, - or (at your option) any later version. - - GlusterFS is distributed in the hope that it will be useful, but - WITHOUT ANY WARRANTY; without even the implied warranty of - MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU - Affero General Public License for more details. - - You should have received a copy of the GNU Affero General Public License - along with this program. If not, see - <http://www.gnu.org/licenses/>. + This file is licensed to you under your choice of the GNU Lesser + General Public License, version 3 or any later version (LGPLv3 or + later), or the GNU General Public License, version 2 (GPLv2), in all + cases as published by the Free Software Foundation. */ - #ifndef __CLI_H__ #define __CLI_H__ -#ifndef _CONFIG_H -#define _CONFIG_H -#include "config.h" -#endif - #include "rpc-clnt.h" -#include "glusterfs.h" +#include <glusterfs/glusterfs.h> #include "protocol-common.h" +#include <glusterfs/logging.h> +#include <glusterfs/quota-common-utils.h> -#define DEFAULT_EVENT_POOL_SIZE 16384 -#define CLI_GLUSTERD_PORT 24007 -#define CLI_DEFAULT_CONN_TIMEOUT 120 -#define CLI_DEFAULT_CMD_TIMEOUT 120 +#include "cli1-xdr.h" +#include "gd-common-utils.h" + +#if (HAVE_LIB_XML) +#include <libxml/encoding.h> +#include <libxml/xmlwriter.h> +#endif + +#define DEFAULT_EVENT_POOL_SIZE 16384 +#define CLI_GLUSTERD_PORT 24007 +#define DEFAULT_CLI_LOG_FILE_DIRECTORY DATADIR "/log/glusterfs" +#define CLI_VOL_STATUS_BRICK_LEN 43 +#define CLI_TAB_LENGTH 8 +#define CLI_BRICK_STATUS_LINE_LEN 78 + +/* Geo-rep command positional arguments' index */ +#define GEO_REP_CMD_INDEX 1 +#define GEO_REP_CMD_CONFIG_INDEX 4 enum argp_option_keys { - ARGP_DEBUG_KEY = 133, - ARGP_PORT_KEY = 'p', + ARGP_DEBUG_KEY = 133, + ARGP_PORT_KEY = 'p', }; -#define GLUSTER_MODE_SCRIPT (1 << 0) +extern int cli_default_conn_timeout; +extern int cli_ten_minutes_timeout; + +typedef enum { + COLD_BRICK_COUNT, + COLD_TYPE, + COLD_DIST_COUNT, + COLD_REPLICA_COUNT, + COLD_ARBITER_COUNT, + COLD_DISPERSE_COUNT, + COLD_REDUNDANCY_COUNT, + HOT_BRICK_COUNT, + HOT_TYPE, + HOT_REPLICA_COUNT, + MAX +} values; + +#define GLUSTER_MODE_SCRIPT (1 << 0) #define GLUSTER_MODE_ERR_FATAL (1 << 1) +#define GLUSTER_MODE_XML (1 << 2) +#define GLUSTER_MODE_WIGNORE (1 << 3) +#define GLUSTER_MODE_WIGNORE_PARTITION (1 << 4) +#define GLUSTER_MODE_GLFSHEAL_NOLOG (1 << 5) + +#define GLUSTERD_GET_QUOTA_LIST_MOUNT_PATH(abspath, volname, path) \ + do { \ + snprintf(abspath, sizeof(abspath) - 1, \ + DEFAULT_VAR_RUN_DIRECTORY "/%s_quota_list%s", volname, path); \ + } while (0) struct cli_state; struct cli_cmd_word; struct cli_cmd_tree; +struct cli_cmd; -typedef int (cli_cmd_cbk_t)(struct cli_state *state, - struct cli_cmd_word *word, - const char **words, - int wordcount); -typedef int (cli_cmd_match_t)(struct cli_cmd_word *word); -typedef int (cli_cmd_filler_t)(struct cli_cmd_word *word); +extern char *cli_vol_status_str[]; +extern char *cli_vol_task_status_str[]; + +typedef int(cli_cmd_cbk_t)(struct cli_state *state, struct cli_cmd_word *word, + const char **words, int wordcount); +typedef void(cli_cmd_reg_cbk_t)(struct cli_cmd *this); + +typedef int(cli_cmd_match_t)(struct cli_cmd_word *word); +typedef int(cli_cmd_filler_t)(struct cli_cmd_word *word); struct cli_cmd_word { - struct cli_cmd_tree *tree; - const char *word; - cli_cmd_filler_t *filler; - cli_cmd_match_t *match; - cli_cmd_cbk_t *cbkfn; - const char *desc; - - int nextwords_cnt; - struct cli_cmd_word **nextwords; + struct cli_cmd_tree *tree; + const char *word; + cli_cmd_filler_t *filler; + cli_cmd_match_t *match; + cli_cmd_cbk_t *cbkfn; + const char *desc; + const char *pattern; + int nextwords_cnt; + struct cli_cmd_word **nextwords; }; - struct cli_cmd_tree { - struct cli_state *state; - struct cli_cmd_word root; + struct cli_state *state; + struct cli_cmd_word root; }; - struct cli_state { - int argc; - char **argv; + int argc; + char **argv; + + char debug; - char debug; + /* for events dispatching */ + glusterfs_ctx_t *ctx; - /* for events dispatching */ - glusterfs_ctx_t *ctx; + /* registry of known commands */ + struct cli_cmd_tree tree; - /* registry of known commands */ - struct cli_cmd_tree tree; + /* the thread which "executes" the command in non-interactive mode */ + /* also the thread which reads from stdin in non-readline mode */ + pthread_t input; - /* the thread which "executes" the command in non-interactive mode */ - /* also the thread which reads from stdin in non-readline mode */ - pthread_t input; + /* terminal I/O */ + const char *prompt; + int rl_enabled; + int rl_async; + int rl_processing; - /* terminal I/O */ - const char *prompt; - int rl_enabled; - int rl_async; - int rl_processing; + /* autocompletion state */ + char **matches; + char **matchesp; - /* autocompletion state */ - char **matches; - char **matchesp; + char *remote_host; + int remote_port; + int mode; + int await_connected; - char *remote_host; - int remote_port; - int mode; + char *log_file; + gf_loglevel_t log_level; + + char *glusterd_sock; + char *address_family; }; struct cli_local { - union { - struct { - dict_t *dict; - } create_vol; - - struct { - char *volname; - int flags; - } start_vol; - - struct { - char *volname; - int flags; - } stop_vol; - - struct { - char *volname; - } delete_vol; - - struct { - char *volname; - int cmd; - } defrag_vol; - - struct { - char *volname; - dict_t *dict; - } replace_brick; - - struct { - char *volname; - int flags; - } get_vol; - } u; + struct { + char *volname; + int flags; + } get_vol; + + dict_t *dict; + const char **words; + /* Marker for volume status all */ + gf_boolean_t all; +#if (HAVE_LIB_XML) + xmlTextWriterPtr writer; + xmlDocPtr doc; + int vol_count; +#endif + gf_lock_t lock; + struct list_head dict_list; +}; + +struct cli_volume_status { + int port; + int rdma_port; + int online; + uint64_t block_size; + uint64_t total_inodes; + uint64_t free_inodes; + char *brick; + char *pid_str; + char *free; + char *total; + char *fs_name; + char *mount_options; + char *device; + char *inode_size; }; +struct snap_config_opt_vals_ { + char *op_name; + char *question; +}; + +typedef struct cli_volume_status cli_volume_status_t; + typedef struct cli_local cli_local_t; -typedef ssize_t (*cli_serialize_t) (struct iovec outmsg, void *args); +typedef ssize_t (*cli_serialize_t)(struct iovec outmsg, void *args); extern struct cli_state *global_state; /* use only in readline callback */ -int cli_cmd_register (struct cli_cmd_tree *tree, const char *template, - cli_cmd_cbk_t cbk, const char *desc); -int cli_cmds_register (struct cli_state *state); +extern struct rpc_clnt *global_quotad_rpc; + +extern struct rpc_clnt *global_rpc; + +extern rpc_clnt_prog_t *cli_rpc_prog; + +typedef const char *(*cli_selector_t)(void *wcon); + +char * +get_struct_variable(int mem_num, gf_gsync_status_t *sts_val); + +void * +cli_getunamb(const char *tok, void **choices, cli_selector_t sel); + +int +cli_cmd_register(struct cli_cmd_tree *tree, struct cli_cmd *cmd); +int +cli_cmds_register(struct cli_state *state); -int cli_input_init (struct cli_state *state); +int +cli_input_init(struct cli_state *state); -int cli_cmd_process (struct cli_state *state, int argc, char *argv[]); -int cli_cmd_process_line (struct cli_state *state, const char *line); +int +cli_cmd_process(struct cli_state *state, int argc, char *argv[]); +int +cli_cmd_process_line(struct cli_state *state, const char *line); + +int +cli_rl_enable(struct cli_state *state); +int +cli_rl_out(struct cli_state *state, const char *fmt, va_list ap); +int +cli_rl_err(struct cli_state *state, const char *fmt, va_list ap); -int cli_rl_enable (struct cli_state *state); -int cli_rl_out (struct cli_state *state, const char *fmt, va_list ap); +int +cli_usage_out(const char *usage); -int cli_out (const char *fmt, ...); +int +_cli_out(const char *fmt, ...); +int +_cli_err(const char *fmt, ...); + +#define cli_out(fmt...) \ + do { \ + FMT_WARN(fmt); \ + \ + _cli_out(fmt); \ + \ + } while (0) + +#define cli_err(fmt...) \ + do { \ + FMT_WARN(fmt); \ + \ + _cli_err(fmt); \ + \ + } while (0) + +#define usage() \ + do { \ + cli_out( \ + " Usage: gluster [options] <help> <peer>" \ + " <pool> <volume>\n" \ + " Options:\n" \ + " --help Shows the help information\n" \ + " --version Shows the version\n" \ + " --print-logdir Shows the log directory\n" \ + " --print-statedumpdir Shows the state dump directory\n"); \ + \ + } while (0) int -cli_submit_request (void *req, call_frame_t *frame, - rpc_clnt_prog_t *prog, - int procnum, struct iobref *iobref, - cli_serialize_t sfunc, xlator_t *this, - fop_cbk_fn_t cbkfn); +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); int32_t -cli_cmd_volume_create_parse (const char **words, int wordcount, - dict_t **options); +cli_cmd_volume_create_parse(struct cli_state *state, const char **words, + int wordcount, dict_t **options, char **bricks); int32_t -cli_cmd_volume_reset_parse (const char **words, int wordcount, dict_t **opt); +cli_cmd_volume_reset_parse(const char **words, int wordcount, dict_t **opt); int32_t -cli_cmd_volume_set_parse (const char **words, int wordcount, - dict_t **options); +cli_cmd_gsync_set_parse(struct cli_state *state, const char **words, + int wordcount, dict_t **opt, char **errstr); int32_t -cli_cmd_volume_add_brick_parse (const char **words, int wordcount, - dict_t **options); +cli_cmd_quota_parse(const char **words, int wordcount, dict_t **opt); int32_t -cli_cmd_volume_remove_brick_parse (const char **words, int wordcount, - dict_t **options); +cli_cmd_inode_quota_parse(const char **words, int wordcount, dict_t **opt); int32_t -cli_cmd_volume_replace_brick_parse (const char **words, int wordcount, +cli_cmd_bitrot_parse(const char **words, int wordcount, dict_t **opt); + +int32_t +cli_cmd_volume_set_parse(struct cli_state *state, const char **words, + int wordcount, dict_t **options, char **op_errstr); + +int32_t +cli_cmd_ganesha_parse(struct cli_state *state, const char **words, + int wordcount, dict_t **options, char **op_errstr); + +int32_t +cli_cmd_get_state_parse(struct cli_state *state, const char **words, + int wordcount, dict_t **options, char **op_errstr); + +int32_t +cli_cmd_volume_add_brick_parse(struct cli_state *state, const char **words, + int wordcount, dict_t **options, int *type); + +int32_t +cli_cmd_volume_remove_brick_parse(struct cli_state *state, const char **words, + int wordcount, dict_t **options, + int *question, int *brick_count, + int32_t *command); + +int32_t +cli_cmd_volume_replace_brick_parse(const char **words, int wordcount, dict_t **options); int32_t -cli_cmd_log_rotate_parse (const char **words, int wordcount, dict_t **options); +cli_cmd_volume_reset_brick_parse(const char **words, int wordcount, + dict_t **options); + +int32_t +cli_cmd_log_rotate_parse(const char **words, int wordcount, dict_t **options); int32_t -cli_cmd_log_locate_parse (const char **words, int wordcount, dict_t **options); +cli_cmd_log_locate_parse(const char **words, int wordcount, dict_t **options); int32_t -cli_cmd_log_filename_parse (const char **words, int wordcount, dict_t **options); +cli_cmd_log_filename_parse(const char **words, int wordcount, dict_t **options); -cli_local_t * cli_local_get (); +int32_t +cli_cmd_volume_statedump_options_parse(const char **words, int wordcount, + dict_t **options); +int32_t +cli_cmd_volume_clrlks_opts_parse(const char **words, int wordcount, + dict_t **options); + +cli_local_t * +cli_local_get(); void -cli_local_wipe (cli_local_t *local); +cli_local_wipe(cli_local_t *local); + +gf_boolean_t +cli_cmd_connected(); + +int32_t +cli_cmd_await_connected(unsigned timeout); + +int32_t +cli_cmd_broadcast_connected(gf_boolean_t status); + +int +cli_rpc_notify(struct rpc_clnt *rpc, void *mydata, rpc_clnt_event_t event, + void *data); + +int32_t +cli_cmd_volume_profile_parse(const char **words, int wordcount, + dict_t **options); +int32_t +cli_cmd_volume_top_parse(const char **words, int wordcount, dict_t **options); int32_t -cli_cmd_await_connected (); +cli_cmd_log_level_parse(const char **words, int wordcount, dict_t **options); + +int32_t +cli_cmd_volume_status_parse(const char **words, int wordcount, + dict_t **options); + +int +cli_cmd_volume_heal_options_parse(const char **words, int wordcount, + dict_t **options); +int +cli_cmd_volume_defrag_parse(const char **words, int wordcount, + dict_t **options); + +int +cli_print_brick_status(cli_volume_status_t *status); + +void +cli_print_detailed_status(cli_volume_status_t *status); + +int +cli_get_detail_status(dict_t *dict, int i, cli_volume_status_t *status); + +void +cli_print_line(int len); + +int +cli_xml_output_str(char *op, char *str, int op_ret, int op_errno, + char *op_errstr); + +int +cli_xml_output_dict(char *op, dict_t *dict, int op_ret, int op_errno, + char *op_errstr); + +int +cli_xml_output_vol_top(dict_t *dict, int op_ret, int op_errno, char *op_errstr); + +int +cli_xml_output_vol_profile(dict_t *dict, int op_ret, int op_errno, + char *op_errstr); + +int +cli_xml_output_vol_status_begin(cli_local_t *local, int op_ret, int op_errno, + char *op_errstr); + +int +cli_xml_output_vol_status_end(cli_local_t *local); + +int +cli_xml_output_vol_status(cli_local_t *local, dict_t *dict); + +int +cli_xml_output_vol_list(dict_t *dict, int op_ret, int op_errno, + char *op_errstr); + +int +cli_xml_output_vol_info_begin(cli_local_t *local, int op_ret, int op_errno, + char *op_errstr); + +int +cli_xml_output_vol_info_end(cli_local_t *local); + +int +cli_xml_output_vol_info(cli_local_t *local, dict_t *dict); + +int +cli_xml_output_vol_quota_limit_list_begin(cli_local_t *local, int op_ret, + int op_errno, char *op_errstr); +int +cli_xml_output_vol_quota_limit_list_end(cli_local_t *local); + +int +cli_quota_list_xml_error(cli_local_t *local, char *path, char *errstr); + +int +cli_quota_xml_output(cli_local_t *local, char *path, int64_t hl_str, + char *sl_final, int64_t sl_num, int64_t used, + int64_t avail, char *sl, char *hl, gf_boolean_t limit_set); + +int +cli_quota_object_xml_output(cli_local_t *local, char *path, char *sl_str, + int64_t sl_val, quota_limits_t *limits, + quota_meta_t *used_space, int64_t avail, char *sl, + char *hl, gf_boolean_t limit_set); + +int +cli_xml_output_peer_status(dict_t *dict, int op_ret, int op_errno, + char *op_errstr); + +int +cli_xml_output_vol_rebalance(gf_cli_defrag_type op, dict_t *dict, int op_ret, + int op_errno, char *op_errstr); + +int +cli_xml_output_vol_remove_brick(gf_boolean_t status_op, dict_t *dict, + int op_ret, int op_errno, char *op_errstr, + const char *op); + +int +cli_xml_output_vol_replace_brick(dict_t *dict, int op_ret, int op_errno, + char *op_errstr); + +int +cli_xml_output_vol_create(dict_t *dict, int op_ret, int op_errno, + char *op_errstr); + +int +cli_xml_output_generic_volume(char *op, dict_t *dict, int op_ret, int op_errno, + char *op_errstr); + +int +cli_xml_output_vol_gsync(dict_t *dict, int op_ret, int op_errno, + char *op_errstr); +int +cli_xml_output_vol_status_tasks_detail(cli_local_t *local, dict_t *dict); + +int +cli_xml_snapshot_delete(cli_local_t *local, dict_t *dict, gf_cli_rsp *rsp); + +int +cli_xml_snapshot_begin_composite_op(cli_local_t *local); + +int +cli_xml_snapshot_end_composite_op(cli_local_t *local); + +int +cli_xml_output_snap_delete_begin(cli_local_t *local, int op_ret, int op_errno, + char *op_errstr); +int +cli_xml_output_snap_delete_end(cli_local_t *local); + +int +cli_xml_output_snap_status_begin(cli_local_t *local, int op_ret, int op_errno, + char *op_errstr); +int +cli_xml_output_snap_status_end(cli_local_t *local); +int +cli_xml_output_snapshot(int cmd_type, dict_t *dict, int op_ret, int op_errno, + char *op_errstr); +int +cli_xml_snapshot_status_single_snap(cli_local_t *local, dict_t *dict, + char *key); int32_t -cli_cmd_broadcast_connected (); +cli_cmd_snapshot_parse(const char **words, int wordcount, dict_t **options, + struct cli_state *state); int -cli_rpc_notify (struct rpc_clnt *rpc, void *mydata, rpc_clnt_event_t event, - void *data); +cli_xml_output_vol_getopts(dict_t *dict, int op_ret, int op_errno, + char *op_errstr); + void -cli_path_strip_trailing_slashes (char *path); +print_quota_list_header(int type); + +void +print_quota_list_empty(char *path, int type); + +int +gf_gsync_status_t_comparator(const void *p, const void *q); #endif /* __CLI_H__ */ |