mirror of
https://github.com/gluster/glusterfs.git
synced 2026-02-06 18:48:16 +01:00
d3e2e1344a
CID 1506829 Use of 32-bit time_t cli/src/cli-cmd.c CID 1504519 DEADCODE xlators/mgmt/glusterd/src/glusterd-syncop.c CID 1502328 Improper use of -ve xlators/nfs/server/src/mount3.c CID 1502327 Uninitialized scalar variable xlators/storage/posix/src/posix-inode-fd-ops.c CID 1502326 Improper use of -ve xlators/nfs/server/src/mount3.c CID 1502325 Improper use of -ve xlators/nfs/server/src/mount3.c CID 1502324 Resource leak xlators/features/marker/src/marker.c CID 1502323 Improper use of -ve xlators/cluster/dht/src/dht-rebalance.c CID 1502322 Improper use of -ve xlators/features/changelog/lib/src/gf-history-changelog.c CID 1502321 Double free xlators/system/posix-acl/src/posix-acl.c CID 1502320 Improper use of -ve xlators/storage/posix/src/posix-inode-fd-ops.c CID 1502317 Improper use of -ve xlators/nfs/server/src/mount3.c CID 1502316 Dereference after NULL check libglusterfs/src/glusterfs/dict.h CID 1502315 Uninitialized scalar variable xlators/features/snapview-client/src/snapview-client.c CID 1502314 Uninitialized scalar variable xlators/features/snapview-server/src/snapview-server.c CID 1502313 Resource leak cli/src/cli-cmd-system.c CID 1502312 Resource leak api/src/glfs-fops.c CID 1502311 Use of 32-bit time_t xlators/cluster/ec/src/ec-common.c Updates #1060 Signed-off-by: Mohit Agrawal <moagrawa@redhat.com> Change-Id: Ic0a939d0bb4f568b5c3f60a5930c90ebeb6a28d4
522 lines
15 KiB
C
522 lines
15 KiB
C
/*
|
|
Copyright (c) 2006-2012 Red Hat, Inc. <http://www.redhat.com>
|
|
This file is part of GlusterFS.
|
|
|
|
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__
|
|
|
|
#include "rpc-clnt.h"
|
|
#include <glusterfs/quota-common-utils.h>
|
|
|
|
#include "cli1-xdr.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
|
|
|
|
// Quotad pid path.
|
|
#define QUOTAD_PID_PATH "/var/run/gluster/quotad/quotad.pid"
|
|
|
|
/* Geo-rep command positional arguments' index */
|
|
#define GEO_REP_CMD_INDEX 1
|
|
#define GEO_REP_CMD_CONFIG_INDEX 4
|
|
|
|
/* Default RPC call timeout, in seconds. */
|
|
#define CLI_DEFAULT_CONN_TIMEOUT 120
|
|
|
|
/* Special timeout for volume profile, volume
|
|
heal and ganesha RPC calls, in seconds. */
|
|
#define CLI_TEN_MINUTES_TIMEOUT 600
|
|
|
|
enum argp_option_keys {
|
|
ARGP_DEBUG_KEY = 133,
|
|
ARGP_PORT_KEY = 'p',
|
|
};
|
|
|
|
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;
|
|
|
|
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;
|
|
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 {
|
|
int argc;
|
|
char **argv;
|
|
|
|
char debug;
|
|
|
|
/* for events dispatching */
|
|
glusterfs_ctx_t *ctx;
|
|
|
|
/* Client to perform RPC calls to glusterd. */
|
|
struct rpc_clnt *rpc;
|
|
|
|
/* Client to perform RPC calls to quotad.
|
|
May be NULL if quotad is not running. */
|
|
struct rpc_clnt *quotad_rpc;
|
|
|
|
/* 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;
|
|
|
|
/* terminal I/O */
|
|
const char *prompt;
|
|
int rl_enabled;
|
|
int rl_async;
|
|
int rl_processing;
|
|
|
|
/* autocompletion state */
|
|
char **matches;
|
|
char **matchesp;
|
|
|
|
char *remote_host;
|
|
int remote_port;
|
|
int mode;
|
|
time_t await_connected;
|
|
|
|
time_t default_conn_timeout;
|
|
|
|
char *log_file;
|
|
gf_loglevel_t log_level;
|
|
|
|
char *glusterd_sock;
|
|
char *address_family;
|
|
};
|
|
|
|
struct cli_local {
|
|
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 struct cli_state cli_state_t;
|
|
|
|
typedef ssize_t (*cli_serialize_t)(struct iovec outmsg, void *args);
|
|
|
|
extern rpc_clnt_prog_t *cli_rpc_prog;
|
|
|
|
typedef const char *(*cli_selector_t)(void *wcon);
|
|
|
|
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_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_usage_out(const char *usage);
|
|
|
|
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(struct rpc_clnt *rpc, void *req, call_frame_t *frame,
|
|
rpc_clnt_prog_t *prog, int procnum, xlator_t *this,
|
|
fop_cbk_fn_t cbkfn, xdrproc_t xdrproc);
|
|
|
|
int32_t
|
|
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);
|
|
|
|
int32_t
|
|
cli_cmd_gsync_set_parse(struct cli_state *state, const char **words,
|
|
int wordcount, dict_t **opt, char **errstr);
|
|
|
|
int32_t
|
|
cli_cmd_quota_parse(const char **words, int wordcount, dict_t **opt);
|
|
|
|
int32_t
|
|
cli_cmd_inode_quota_parse(const char **words, int wordcount, dict_t **opt);
|
|
|
|
int32_t
|
|
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_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);
|
|
int32_t
|
|
cli_cmd_log_filename_parse(const char **words, int wordcount, dict_t **options);
|
|
|
|
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);
|
|
|
|
void
|
|
cli_local_wipe(cli_local_t *local);
|
|
|
|
gf_boolean_t
|
|
cli_cmd_connected(void);
|
|
|
|
int32_t
|
|
cli_cmd_await_connected(time_t 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_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_defrag_type_t 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_snapshot_parse(const char **words, int wordcount, dict_t **options,
|
|
struct cli_state *state);
|
|
|
|
int
|
|
cli_xml_output_vol_getopts(dict_t *dict, int op_ret, int op_errno,
|
|
char *op_errstr);
|
|
|
|
void
|
|
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__ */
|