diff options
Diffstat (limited to 'xlators/mgmt/glusterd/src/glusterd-utils.h')
| -rw-r--r-- | xlators/mgmt/glusterd/src/glusterd-utils.h | 911 |
1 files changed, 693 insertions, 218 deletions
diff --git a/xlators/mgmt/glusterd/src/glusterd-utils.h b/xlators/mgmt/glusterd/src/glusterd-utils.h index 13ac026018f..bf6ac295e26 100644 --- a/xlators/mgmt/glusterd/src/glusterd-utils.h +++ b/xlators/mgmt/glusterd/src/glusterd-utils.h @@ -1,390 +1,865 @@ /* - Copyright (c) 2006-2011 Gluster, Inc. <http://www.gluster.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 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 - General Public License for more details. - - You should have received a copy of the GNU General Public License - along with this program. If not, see - <http://www.gnu.org/licenses/>. -*/ + 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 _GLUSTERD_UTILS_H -#define _GLUSTERD_UTILS_H_ - -#ifndef _CONFIG_H -#define _CONFIG_H -#include "config.h" -#endif +#define _GLUSTERD_UTILS_H #include <pthread.h> -#include "uuid.h" - -#include "glusterfs.h" -#include "xlator.h" -#include "logging.h" -#include "call-stub.h" -#include "fd.h" -#include "byte-order.h" +#include <glusterfs/compat-uuid.h> + +#include <glusterfs/glusterfs.h> +#include <glusterfs/xlator.h> +#include <glusterfs/logging.h> +#include <glusterfs/call-stub.h> +#include <glusterfs/byte-order.h> #include "glusterd.h" #include "rpc-clnt.h" #include "protocol-common.h" -/* For brick search using path: partial or complete */ -typedef enum { - GF_PATH_COMPLETE = 0, - GF_PATH_PARTIAL -} gf_path_match_t; +#include "glusterfs3-xdr.h" +#include "glusterd-peer-utils.h" + +#define GLUSTERD_SOCK_DIR "/var/run/gluster" +#define GLUSTERD_ASSIGN_BRICKID_TO_BRICKINFO(brickinfo, volinfo, brickid) \ + do { \ + sprintf(brickinfo->brick_id, "%s-client-%d", volinfo->volname, \ + brickid); \ + } while (0) + +#define GLUSTERD_ASSIGN_BRICKID_TO_TA_BRICKINFO(ta_brickinfo, volinfo, \ + brickid) \ + do { \ + sprintf(ta_brickinfo->brick_id, "%s-ta-%d", volinfo->volname, \ + brickid); \ + } while (0) + +#define ALL_VOLUME_OPTION_CHECK(volname, get_opt, key, ret, op_errstr, label) \ + do { \ + gf_boolean_t _all = !strcmp("all", volname); \ + gf_boolean_t _key_all = !strcmp(key, "all"); \ + gf_boolean_t _is_valid_opt = _gf_false; \ + int32_t i = 0; \ + \ + if (!get_opt && \ + (_key_all || !strcmp(key, GLUSTERD_MAX_OP_VERSION_KEY))) { \ + ret = -1; \ + *op_errstr = gf_strdup("Not a valid option to set"); \ + goto out; \ + } \ + if (_key_all) { \ + _is_valid_opt = _gf_true; \ + } else { \ + for (i = 0; valid_all_vol_opts[i].option; i++) { \ + if (!strcmp(key, valid_all_vol_opts[i].option)) { \ + _is_valid_opt = _gf_true; \ + break; \ + } \ + } \ + } \ + if (_all && !_is_valid_opt) { \ + ret = -1; \ + *op_errstr = gf_strdup("Not a valid option for all volumes"); \ + goto label; \ + } else if (!_all && _is_valid_opt) { \ + ret = -1; \ + *op_errstr = gf_strdup("Not a valid option for single volume"); \ + goto label; \ + } \ + } while (0) struct glusterd_lock_ { - uuid_t owner; - time_t timestamp; + uuid_t owner; + time_t timestamp; }; -typedef struct glusterd_voldict_ctx_ { - dict_t *dict; - int count; - int opt_count; - char *key_name; - char *val_name; -} glusterd_voldict_ctx_t; - -typedef int (*glusterd_condition_func) (glusterd_volinfo_t *volinfo, - glusterd_brickinfo_t *brickinfo, - void *ctx); +typedef struct glusterd_dict_ctx_ { + dict_t *dict; + int opt_count; + char *key_name; + char *val_name; + char *prefix; +} glusterd_dict_ctx_t; + +gf_boolean_t +is_brick_mx_enabled(void); + +int +glusterd_compare_lines(const void *a, const void *b); + +typedef int (*glusterd_condition_func)(glusterd_volinfo_t *volinfo, + glusterd_brickinfo_t *brickinfo, + void *ctx); typedef struct glusterd_lock_ glusterd_lock_t; int32_t -glusterd_get_lock_owner (uuid_t *cur_owner); +glusterd_get_lock_owner(uuid_t *cur_owner); int32_t -glusterd_lock (uuid_t new_owner); +glusterd_lock(uuid_t new_owner); int32_t -glusterd_unlock (uuid_t owner); +glusterd_unlock(uuid_t owner); int32_t -glusterd_get_uuid (uuid_t *uuid); +glusterd_get_uuid(uuid_t *uuid); + +char * +gd_get_shd_key(int type); + +int +glusterd_submit_reply(rpcsvc_request_t *req, void *arg, struct iovec *payload, + int payloadcount, struct iobref *iobref, + xdrproc_t xdrproc); int -glusterd_submit_reply (rpcsvc_request_t *req, void *arg, - struct iovec *payload, int payloadcount, - struct iobref *iobref, xdrproc_t xdrproc); +glusterd_to_cli(rpcsvc_request_t *req, gf_cli_rsp *arg, struct iovec *payload, + int payloadcount, struct iobref *iobref, xdrproc_t xdrproc, + dict_t *dict); int -glusterd_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); +glusterd_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 -glusterd_volinfo_new (glusterd_volinfo_t **volinfo); +glusterd_volinfo_new(glusterd_volinfo_t **volinfo); -gf_boolean_t -glusterd_check_volume_exists (char *volname); +int32_t +glusterd_volinfo_dup(glusterd_volinfo_t *volinfo, + glusterd_volinfo_t **dup_volinfo, + gf_boolean_t set_userauth); + +char * +glusterd_auth_get_username(glusterd_volinfo_t *volinfo); + +char * +glusterd_auth_get_password(glusterd_volinfo_t *volinfo); int32_t -glusterd_brickinfo_new (glusterd_brickinfo_t **brickinfo); +glusterd_auth_set_username(glusterd_volinfo_t *volinfo, char *username); int32_t -glusterd_brickinfo_from_brick (char *brick, glusterd_brickinfo_t **brickinfo); +glusterd_auth_set_password(glusterd_volinfo_t *volinfo, char *password); + +void +glusterd_auth_cleanup(glusterd_volinfo_t *volinfo); int32_t -glusterd_friend_cleanup (glusterd_peerinfo_t *peerinfo); +glusterd_brickprocess_new(glusterd_brick_proc_t **brickprocess); int32_t -glusterd_peer_destroy (glusterd_peerinfo_t *peerinfo); +glusterd_brickinfo_new(glusterd_brickinfo_t **brickinfo); int32_t -glusterd_peer_hostname_new (char *hostname, glusterd_peer_hostname_t **name); +glusterd_brickinfo_new_from_brick(char *brick, glusterd_brickinfo_t **brickinfo, + gf_boolean_t construct_real_path, + char **op_errstr); int32_t -glusterd_volinfo_find (char *volname, glusterd_volinfo_t **volinfo); +glusterd_volinfo_find(const char *volname, glusterd_volinfo_t **volinfo); + +gf_boolean_t +glusterd_volume_exists(const char *volname); + +int +glusterd_volinfo_find_by_volume_id(uuid_t volume_id, + glusterd_volinfo_t **volinfo); int32_t glusterd_service_stop(const char *service, char *pidfile, int sig, gf_boolean_t force_kill); int32_t -glusterd_resolve_brick (glusterd_brickinfo_t *brickinfo); +glusterd_service_stop_nolock(const char *service, char *pidfile, int sig, + gf_boolean_t force_kill); + +int +glusterd_get_next_available_brickid(glusterd_volinfo_t *volinfo); + +int32_t +glusterd_resolve_brick(glusterd_brickinfo_t *brickinfo); + +int +glusterd_brick_process_add_brick(glusterd_brickinfo_t *brickinfo, + glusterd_brickinfo_t *parent_brickinfo); + +int +glusterd_brick_process_remove_brick(glusterd_brickinfo_t *brickinfo, + int *last_brick); + +int +glusterd_brick_proc_for_port(int port, glusterd_brick_proc_t **brickprocess); int32_t -glusterd_volume_start_glusterfs (glusterd_volinfo_t *volinfo, - glusterd_brickinfo_t *brickinfo); +glusterd_volume_start_glusterfs(glusterd_volinfo_t *volinfo, + glusterd_brickinfo_t *brickinfo, + gf_boolean_t wait); int32_t -glusterd_volume_stop_glusterfs (glusterd_volinfo_t *volinfo, - glusterd_brickinfo_t *brickinfo); +glusterd_volume_stop_glusterfs(glusterd_volinfo_t *volinfo, + glusterd_brickinfo_t *brickinfo, + gf_boolean_t del_brick); + +int +send_attach_req(xlator_t *this, struct rpc_clnt *rpc, char *path, + glusterd_brickinfo_t *brick, glusterd_brickinfo_t *other_brick, + int op); + +glusterd_volinfo_t * +glusterd_volinfo_ref(glusterd_volinfo_t *volinfo); + +glusterd_volinfo_t * +glusterd_volinfo_unref(glusterd_volinfo_t *volinfo); int32_t -glusterd_volinfo_delete (glusterd_volinfo_t *volinfo); +glusterd_volinfo_delete(glusterd_volinfo_t *volinfo); int32_t -glusterd_brickinfo_delete (glusterd_brickinfo_t *brickinfo); +glusterd_brickinfo_delete(glusterd_brickinfo_t *brickinfo); gf_boolean_t -glusterd_is_cli_op_req (int32_t op); +glusterd_is_cli_op_req(int32_t op); int32_t -glusterd_volume_brickinfo_get_by_brick (char *brick, - glusterd_volinfo_t *volinfo, - glusterd_brickinfo_t **brickinfo, - gf_path_match_t path_match); +glusterd_volume_brickinfo_get_by_brick(char *brick, glusterd_volinfo_t *volinfo, + glusterd_brickinfo_t **brickinfo, + gf_boolean_t construct_real_path); + int32_t -glusterd_is_local_addr (char *hostname); +glusterd_add_volumes_to_export_dict(dict_t *peer_data, char **buf, + u_int *length); int32_t -glusterd_build_volume_dict (dict_t **vols); +glusterd_compare_friend_data(dict_t *peer_data, int32_t *status, + char *hostname); + +int +glusterd_compute_cksum(glusterd_volinfo_t *volinfo, gf_boolean_t is_quota_conf); + +void +glusterd_set_socket_filepath(char *sock_filepath, char *sockpath, size_t len); + +struct rpc_clnt * +glusterd_pending_node_get_rpc(glusterd_pending_node_t *pending_node); + +void +glusterd_pending_node_put_rpc(glusterd_pending_node_t *pending_node); + +int +glusterd_remote_hostname_get(rpcsvc_request_t *req, char *remote_host, int len); + +int32_t +glusterd_import_friend_volumes_synctask(void *opaque); int32_t -glusterd_compare_friend_data (dict_t *vols, int32_t *status); +glusterd_import_friend_volumes(dict_t *peer_data); +void +glusterd_set_volume_status(glusterd_volinfo_t *volinfo, + glusterd_volume_status status); +int32_t +glusterd_volume_count_get(void); +int32_t +glusterd_add_volume_to_dict(glusterd_volinfo_t *volinfo, dict_t *dict, + int32_t count, char *prefix); int -glusterd_volume_compute_cksum (glusterd_volinfo_t *volinfo); +glusterd_get_brickinfo(xlator_t *this, const char *brickname, int port, + glusterd_brickinfo_t **brickinfo); void -glusterd_get_nodesvc_volfile (char *server, char *workdir, - char *volfile, size_t len); +glusterd_set_brick_status(glusterd_brickinfo_t *brickinfo, + gf_brick_status_t status); gf_boolean_t -glusterd_is_service_running (char *pidfile, int *pid); +glusterd_is_brick_started(glusterd_brickinfo_t *brickinfo); -gf_boolean_t -glusterd_is_nodesvc_running (); +int +glusterd_friend_brick_belongs(glusterd_volinfo_t *volinfo, + glusterd_brickinfo_t *brickinfo, void *uuid); +int +glusterd_all_volume_cond_check(glusterd_condition_func func, int status, + void *ctx); +int +glusterd_brick_start(glusterd_volinfo_t *volinfo, + glusterd_brickinfo_t *brickinfo, gf_boolean_t wait, + gf_boolean_t only_connect); +int +glusterd_brick_stop(glusterd_volinfo_t *volinfo, + glusterd_brickinfo_t *brickinfo, gf_boolean_t del_brick); -gf_boolean_t -glusterd_is_nodesvc_running (); +int +glusterd_is_defrag_on(glusterd_volinfo_t *volinfo); -void -glusterd_get_nodesvc_dir (char *server, char *workdir, - char *path, size_t len); int32_t -glusterd_nfs_server_start (); +glusterd_volinfo_bricks_delete(glusterd_volinfo_t *volinfo); +int +glusterd_new_brick_validate(char *brick, glusterd_brickinfo_t *brickinfo, + char *op_errstr, size_t len, char *op); int32_t -glusterd_nfs_server_stop (); +glusterd_volume_brickinfos_delete(glusterd_volinfo_t *volinfo); int32_t -glusterd_shd_start (); +glusterd_volume_brickinfo_get(uuid_t uuid, char *hostname, char *path, + glusterd_volinfo_t *volinfo, + glusterd_brickinfo_t **brickinfo); +int +glusterd_brickinfo_get(uuid_t uuid, char *hostname, char *path, + glusterd_brickinfo_t **brickinfo); + +int +glusterd_rb_check_bricks(glusterd_volinfo_t *volinfo, + glusterd_brickinfo_t *src_brick, + glusterd_brickinfo_t *dst_brick); + +int +glusterd_check_and_set_brick_xattr(char *host, char *path, uuid_t uuid, + char **op_errstr, gf_boolean_t is_force); + +int +glusterd_validate_and_create_brickpath(glusterd_brickinfo_t *brickinfo, + uuid_t volume_id, char *volname, + char **op_errstr, gf_boolean_t is_force, + gf_boolean_t ignore_partition); +int +glusterd_sm_tr_log_transition_add(glusterd_sm_tr_log_t *log, int old_state, + int new_state, int event); +int +glusterd_sm_tr_log_init(glusterd_sm_tr_log_t *log, char *(*state_name_get)(int), + char *(*event_name_get)(int), size_t size); +void +glusterd_sm_tr_log_delete(glusterd_sm_tr_log_t *log); + +int +glusterd_sm_tr_log_add_to_dict(dict_t *dict, + glusterd_sm_tr_log_t *circular_log); +int +glusterd_remove_pending_entry(struct cds_list_head *list, void *elem); +int +glusterd_clear_pending_nodes(struct cds_list_head *list); +int32_t +glusterd_brick_connect(glusterd_volinfo_t *volinfo, + glusterd_brickinfo_t *brickinfo, char *socketpath); +int32_t +glusterd_brick_disconnect(glusterd_brickinfo_t *brickinfo); int32_t -glusterd_shd_stop (); +glusterd_delete_volume(glusterd_volinfo_t *volinfo); +int32_t +glusterd_delete_brick(glusterd_volinfo_t *volinfo, + glusterd_brickinfo_t *brickinfo); int32_t -glusterd_shd_set_socket_filepath (char *rundir, uuid_t uuid, - char *socketpath, int len); +glusterd_delete_all_bricks(glusterd_volinfo_t *volinfo); -struct rpc_clnt* -glusterd_pending_node_get_rpc (glusterd_pending_node_t *pending_node); +int +glusterd_spawn_daemons(void *opaque); -struct rpc_clnt* -glusterd_shd_get_rpc (void); +int +glusterd_restart_gsyncds(glusterd_conf_t *conf); +int +glusterd_start_gsync(glusterd_volinfo_t *master_vol, char *slave, + char *path_list, char *conf_path, char *glusterd_uuid_str, + char **op_errstr, gf_boolean_t is_pause); +int +glusterd_get_local_brickpaths(glusterd_volinfo_t *volinfo, char **pathlist); + +int32_t +glusterd_recreate_bricks(glusterd_conf_t *conf); int32_t -glusterd_shd_set_rpc (struct rpc_clnt *rpc); +glusterd_handle_upgrade_downgrade(dict_t *options, glusterd_conf_t *conf, + gf_boolean_t upgrade, gf_boolean_t downgrade); + +int +glusterd_add_brick_detail_to_dict(glusterd_volinfo_t *volinfo, + glusterd_brickinfo_t *brickinfo, dict_t *dict, + int32_t count); int32_t -glusterd_shd_connect (char *socketpath); +glusterd_add_brick_to_dict(glusterd_volinfo_t *volinfo, + glusterd_brickinfo_t *brickinfo, dict_t *dict, + int32_t count); -void -glusterd_shd_set_running (gf_boolean_t status); +int32_t +glusterd_get_all_volnames(dict_t *dict); gf_boolean_t -glusterd_shd_is_running (); +glusterd_is_fuse_available(); int -glusterd_remote_hostname_get (rpcsvc_request_t *req, - char *remote_host, int len); -int32_t -glusterd_import_friend_volumes (dict_t *vols); -void -glusterd_set_volume_status (glusterd_volinfo_t *volinfo, - glusterd_volume_status status); +glusterd_brick_statedump(glusterd_volinfo_t *volinfo, + glusterd_brickinfo_t *brickinfo, char *options, + int option_cnt, char **op_errstr); + int -glusterd_check_generate_start_nfs (void); +glusterd_brick_terminate(glusterd_volinfo_t *volinfo, + glusterd_brickinfo_t *brickinfo, char *options, + int option_cnt, char **op_errstr); +#ifdef BUILD_GNFS int -glusterd_check_generate_start_shd (void); +glusterd_nfs_statedump(char *options, int option_cnt, char **op_errstr); +#endif int -glusterd_nodesvcs_handle_graph_change (glusterd_volinfo_t *volinfo); +glusterd_client_statedump(char *volname, char *options, int option_cnt, + char **op_errstr); int -glusterd_nodesvcs_handle_reconfigure (glusterd_volinfo_t *volinfo); +glusterd_quotad_statedump(char *options, int option_cnt, char **op_errstr); +gf_boolean_t +glusterd_is_volume_replicate(glusterd_volinfo_t *volinfo); + +gf_boolean_t +glusterd_is_brick_decommissioned(glusterd_volinfo_t *volinfo, char *hostname, + char *path); int -glusterd_nodesvcs_start (glusterd_volinfo_t *volinfo); +glusterd_friend_contains_vol_bricks(glusterd_volinfo_t *volinfo, + uuid_t friend_uuid); int -glusterd_nodesvcs_stop (glusterd_volinfo_t *volinfo); +glusterd_friend_contains_snap_bricks(glusterd_snap_t *snapinfo, + uuid_t friend_uuid); +int +glusterd_friend_remove_cleanup_vols(uuid_t uuid); -int32_t -glusterd_volume_count_get (void); -int32_t -glusterd_add_volume_to_dict (glusterd_volinfo_t *volinfo, - dict_t *dict, int32_t count); int -glusterd_get_brickinfo (xlator_t *this, const char *brickname, - int port, gf_boolean_t localhost, - glusterd_brickinfo_t **brickinfo); +glusterd_get_client_filepath(char *filepath, glusterd_volinfo_t *volinfo, + gf_transport_type type); +int +glusterd_get_trusted_client_filepath(char *filepath, + glusterd_volinfo_t *volinfo, + gf_transport_type type); +int +glusterd_restart_rebalance(glusterd_conf_t *conf); + +int +glusterd_restart_rebalance_for_volume(glusterd_volinfo_t *volinfo); void -glusterd_set_brick_status (glusterd_brickinfo_t *brickinfo, - gf_brick_status_t status); +glusterd_defrag_info_set(glusterd_volinfo_t *volinfo, dict_t *dict, int cmd, + int status, int op); -gf_boolean_t -glusterd_is_brick_started (glusterd_brickinfo_t *brickinfo); +int32_t +glusterd_add_bricks_hname_path_to_dict(dict_t *dict, + glusterd_volinfo_t *volinfo); int -glusterd_friend_find_by_hostname (const char *hoststr, - glusterd_peerinfo_t **peerinfo); +glusterd_add_node_to_dict(char *server, dict_t *dict, int count, + dict_t *vol_opts); + int -glusterd_hostname_to_uuid (char *hostname, uuid_t uuid); +glusterd_calc_dist_leaf_count(int rcount, int scount); int -glusterd_friend_brick_belongs (glusterd_volinfo_t *volinfo, - glusterd_brickinfo_t *brickinfo, void *uuid); +glusterd_get_dist_leaf_count(glusterd_volinfo_t *volinfo); + +glusterd_brickinfo_t * +glusterd_get_brickinfo_by_position(glusterd_volinfo_t *volinfo, uint32_t pos); + +gf_boolean_t +glusterd_is_local_brick(xlator_t *this, glusterd_volinfo_t *volinfo, + glusterd_brickinfo_t *brickinfo); int -glusterd_all_volume_cond_check (glusterd_condition_func func, int status, - void *ctx); +glusterd_validate_volume_id(dict_t *op_dict, glusterd_volinfo_t *volinfo); + int -glusterd_brick_start (glusterd_volinfo_t *volinfo, - glusterd_brickinfo_t *brickinfo); +glusterd_defrag_volume_status_update(glusterd_volinfo_t *volinfo, + dict_t *rsp_dict, int32_t cmd); + int -glusterd_brick_stop (glusterd_volinfo_t *volinfo, - glusterd_brickinfo_t *brickinfo); +glusterd_check_files_identical(char *filename1, char *filename2, + gf_boolean_t *identical); + +int +glusterd_check_topology_identical(const char *filename1, const char *filename2, + gf_boolean_t *identical); +void +glusterd_volinfo_reset_defrag_stats(glusterd_volinfo_t *volinfo); int -glusterd_is_defrag_on (glusterd_volinfo_t *volinfo); +glusterd_volset_help(dict_t *dict, char **op_errstr); int32_t -glusterd_volinfo_bricks_delete (glusterd_volinfo_t *volinfo); +glusterd_sync_use_rsp_dict(dict_t *aggr, dict_t *rsp_dict); +int32_t +glusterd_gsync_use_rsp_dict(dict_t *aggr, dict_t *rsp_dict, char *op_errstr); +int32_t +glusterd_rb_use_rsp_dict(dict_t *aggr, dict_t *rsp_dict); +int +glusterd_profile_volume_use_rsp_dict(dict_t *aggr, dict_t *rsp_dict); +int +glusterd_volume_status_copy_to_op_ctx_dict(dict_t *aggr, dict_t *rsp_dict); +int +glusterd_volume_rebalance_use_rsp_dict(dict_t *aggr, dict_t *rsp_dict); +int +glusterd_volume_heal_use_rsp_dict(dict_t *aggr, dict_t *rsp_dict); +int +glusterd_use_rsp_dict(dict_t *aggr, dict_t *rsp_dict); +int +glusterd_sys_exec_output_rsp_dict(dict_t *aggr, dict_t *rsp_dict); +int32_t +glusterd_handle_node_rsp(dict_t *req_ctx, void *pending_entry, glusterd_op_t op, + dict_t *rsp_dict, dict_t *op_ctx, char **op_errstr, + gd_node_type type); +int +glusterd_max_opversion_use_rsp_dict(dict_t *dst, dict_t *src); + int -glusterd_friend_find_by_uuid (uuid_t uuid, - glusterd_peerinfo_t **peerinfo); +glusterd_volume_bitrot_scrub_use_rsp_dict(dict_t *aggr, dict_t *rsp_dict); + int -glusterd_new_brick_validate (char *brick, glusterd_brickinfo_t *brickinfo, - char *op_errstr, size_t len); +glusterd_volume_heal_use_rsp_dict(dict_t *aggr, dict_t *rsp_dict); + int32_t -glusterd_volume_brickinfos_delete (glusterd_volinfo_t *volinfo); +glusterd_check_if_quota_trans_enabled(glusterd_volinfo_t *volinfo); + +int +glusterd_volume_quota_copy_to_op_ctx_dict(dict_t *aggr, dict_t *rsp); +int +_profile_volume_add_brick_rsp(dict_t *this, char *key, data_t *value, + void *data); +int +glusterd_profile_volume_brick_rsp(void *pending_entry, dict_t *rsp_dict, + dict_t *op_ctx, char **op_errstr, + gd_node_type type); + int32_t -glusterd_volume_brickinfo_get (uuid_t uuid, char *hostname, char *path, - glusterd_volinfo_t *volinfo, - glusterd_brickinfo_t **brickinfo, - gf_path_match_t path_match); +glusterd_set_originator_uuid(dict_t *dict); + +/* Should be used only when an operation is in progress, as that is the only + * time a lock_owner is set + */ +gf_boolean_t +is_origin_glusterd(dict_t *dict); + int -glusterd_brickinfo_get (uuid_t uuid, char *hostname, char *path, - glusterd_brickinfo_t **brickinfo); +glusterd_get_next_global_opt_version_str(dict_t *opts, char **version_str); + int -glusterd_is_rb_started (glusterd_volinfo_t *volinfo); +glusterd_generate_and_set_task_id(dict_t *dict, char *key, const int keylen); int -glusterd_is_rb_paused (glusterd_volinfo_t *volinfo); +glusterd_validate_and_set_gfid(dict_t *op_ctx, dict_t *req_dict, + char **op_errstr); int -glusterd_set_rb_status (glusterd_volinfo_t *volinfo, gf_rb_status_t status); +glusterd_copy_uuid_to_dict(uuid_t uuid, dict_t *dict, char *key, + const int keylen); gf_boolean_t -glusterd_is_rb_ongoing (glusterd_volinfo_t *volinfo); +glusterd_is_same_address(char *name1, char *name2); + +void +gd_update_volume_op_versions(glusterd_volinfo_t *volinfo); int -glusterd_is_replace_running (glusterd_volinfo_t *volinfo, glusterd_brickinfo_t *brickinfo); +op_version_check(xlator_t *this, int min_op_version, char *msg, int msglen); + +gf_boolean_t +gd_is_remove_brick_committed(glusterd_volinfo_t *volinfo); int -glusterd_rb_check_bricks (glusterd_volinfo_t *volinfo, - glusterd_brickinfo_t *src_brick, glusterd_brickinfo_t *dst_brick); +glusterd_remove_brick_validate_bricks(gf1_op_commands cmd, int32_t brick_count, + dict_t *dict, glusterd_volinfo_t *volinfo, + char **errstr, gf_cli_defrag_type); int -glusterd_brick_create_path (char *host, char *path, uuid_t uuid, mode_t mode, - char **op_errstr); +glusterd_get_slave_details_confpath(glusterd_volinfo_t *volinfo, dict_t *dict, + char **slave_url, char **slave_host, + char **slave_vol, char **conf_path, + char **op_errstr); + int -glusterd_sm_tr_log_transition_add (glusterd_sm_tr_log_t *log, - int old_state, int new_state, - int event); +glusterd_get_slave_info(char *slave, char **slave_url, char **hostname, + char **slave_vol, char **op_errstr); + int -glusterd_peerinfo_new (glusterd_peerinfo_t **peerinfo, - glusterd_friend_sm_state_t state, - uuid_t *uuid, const char *hostname); +glusterd_get_statefile_name(glusterd_volinfo_t *volinfo, char *slave, + char *conf_path, char **statefile, + gf_boolean_t *is_template_in_use); + int -glusterd_sm_tr_log_init (glusterd_sm_tr_log_t *log, - char * (*state_name_get) (int), - char * (*event_name_get) (int), - size_t size); -void -glusterd_sm_tr_log_delete (glusterd_sm_tr_log_t *log); +glusterd_gsync_read_frm_status(char *path, char *buf, size_t blen); + +int +glusterd_create_status_file(char *master, char *slave, char *slave_url, + char *slave_vol, char *status); + +int +glusterd_check_restart_gsync_session(glusterd_volinfo_t *volinfo, char *slave, + dict_t *resp_dict, char *path_list, + char *conf_path, gf_boolean_t is_force); + +int +glusterd_check_gsync_running_local(char *master, char *slave, char *conf_path, + gf_boolean_t *is_run); + +gf_boolean_t +glusterd_is_status_tasks_op(glusterd_op_t op, dict_t *dict); + +gf_boolean_t +gd_should_i_start_rebalance(glusterd_volinfo_t *volinfo); int -glusterd_sm_tr_log_add_to_dict (dict_t *dict, - glusterd_sm_tr_log_t *circular_log); +glusterd_is_volume_quota_enabled(glusterd_volinfo_t *volinfo); + +int +glusterd_is_volume_inode_quota_enabled(glusterd_volinfo_t *volinfo); + int -glusterd_remove_pending_entry (struct list_head *list, void *elem); +glusterd_is_bitrot_enabled(glusterd_volinfo_t *volinfo); + +gf_boolean_t +glusterd_all_volumes_with_quota_stopped(); + +void +glusterd_clean_up_quota_store(glusterd_volinfo_t *volinfo); + int -glusterd_clear_pending_nodes (struct list_head *list); +glusterd_remove_auxiliary_mount(char *volname); + gf_boolean_t -glusterd_peerinfo_is_uuid_unknown (glusterd_peerinfo_t *peerinfo); +glusterd_status_has_tasks(int cmd); + +int +gd_stop_rebalance_process(glusterd_volinfo_t *volinfo); + +rpc_clnt_t * +glusterd_rpc_clnt_unref(glusterd_conf_t *conf, rpc_clnt_t *rpc); + int32_t -glusterd_brick_connect (glusterd_volinfo_t *volinfo, - glusterd_brickinfo_t *brickinfo); +glusterd_compare_volume_name(struct cds_list_head *, struct cds_list_head *); + +char * +glusterd_get_brick_mount_device(char *brick_path); + +struct mntent * +glusterd_get_mnt_entry_info(char *mnt_pt, char *buff, int buflen, + struct mntent *entry_ptr); + +int +glusterd_get_brick_root(char *path, char **mount_point); + int32_t -glusterd_brick_disconnect (glusterd_brickinfo_t *brickinfo); +glusterd_lvm_snapshot_remove(dict_t *rsp_dict, glusterd_volinfo_t *snap_vol); + +gf_boolean_t +gd_vol_is_geo_rep_active(glusterd_volinfo_t *volinfo); + int32_t -glusterd_delete_volume (glusterd_volinfo_t *volinfo); +glusterd_get_brick_mount_dir(char *brickpath, char *hostname, char *mount_dir); + int32_t -glusterd_delete_brick (glusterd_volinfo_t* volinfo, - glusterd_brickinfo_t *brickinfo); +glusterd_aggr_brick_mount_dirs(dict_t *aggr, dict_t *rsp_dict); + int32_t -glusterd_delete_all_bricks (glusterd_volinfo_t* volinfo); +glusterd_take_lvm_snapshot(glusterd_brickinfo_t *brickinfo, + char *origin_brick_path); + +void +glusterd_launch_synctask(synctask_fn_t fn, void *opaque); + int -glusterd_restart_gsyncds (glusterd_conf_t *conf); +glusterd_enable_default_options(glusterd_volinfo_t *volinfo, char *option); + int -glusterd_start_gsync (glusterd_volinfo_t *master_vol, char *slave, - char *glusterd_uuid_str, char **op_errstr); -int32_t -glusterd_recreate_bricks (glusterd_conf_t *conf); +glusterd_unlink_file(char *sock_file_path); + int32_t -glusterd_handle_upgrade_downgrade (dict_t *options, glusterd_conf_t *conf); +glusterd_find_brick_mount_path(char *brick_path, char **brick_mount_path); + +/* + * Function to retrieve list of snap volnames and their uuids + */ +int +glusterd_snapshot_get_volnames_uuids(dict_t *dict, char *volname, + gf_getsnap_name_uuid_rsp *snap_info_rsp); + +int +glusterd_update_mntopts(char *brick_path, glusterd_brickinfo_t *brickinfo); + +int +glusterd_update_fs_label(glusterd_brickinfo_t *brickinfo); int -glusterd_get_brick_root (char *path, char **mount_point); +glusterd_get_volopt_content(dict_t *dict, gf_boolean_t xml_out); int -glusterd_add_brick_detail_to_dict (glusterd_volinfo_t *volinfo, - glusterd_brickinfo_t *brickinfo, - dict_t *dict, int32_t count); +glusterd_get_global_max_op_version(rpcsvc_request_t *req, dict_t *ctx, + int count); + +int +glusterd_get_global_options_for_all_vols(rpcsvc_request_t *req, dict_t *dict, + char **op_errstr); + +int +glusterd_get_default_val_for_volopt(dict_t *dict, gf_boolean_t all_opts, + char *key, char *orig_key, + glusterd_volinfo_t *volinfo, + char **err_str); + +int +glusterd_check_client_op_version_support(char *volname, uint32_t op_version, + char **op_errstr); + +gf_boolean_t +glusterd_have_peers(); + +gf_boolean_t +glusterd_have_volumes(); + +void +glusterd_get_rebalance_volfile(glusterd_volinfo_t *volinfo, char *path, + int path_len); + +void +glusterd_get_gfproxy_client_volfile(glusterd_volinfo_t *volinfo, char *path, + int path_len); int32_t -glusterd_add_brick_to_dict (glusterd_volinfo_t *volinfo, - glusterd_brickinfo_t *brickinfo, - dict_t *dict, int32_t count); +glusterd_brickinfo_dup(glusterd_brickinfo_t *brickinfo, + glusterd_brickinfo_t *dup_brickinfo); + +int +glusterd_vol_add_quota_conf_to_dict(glusterd_volinfo_t *volinfo, dict_t *load, + int vol_idx, char *prefix); int32_t -glusterd_get_all_volnames (dict_t *dict); +glusterd_import_volinfo(dict_t *peer_data, int count, + glusterd_volinfo_t **volinfo, char *prefix); + +int +glusterd_import_quota_conf(dict_t *peer_data, int vol_idx, + glusterd_volinfo_t *new_volinfo, char *prefix); gf_boolean_t -glusterd_is_fuse_available (); +glusterd_is_shd_compatible_volume(glusterd_volinfo_t *volinfo); -int -glusterd_brick_statedump (glusterd_volinfo_t *volinfo, - glusterd_brickinfo_t *brickinfo, - char *options, int option_cnt); +gf_boolean_t +glusterd_is_shd_compatible_type(int type); gf_boolean_t -glusterd_is_volume_replicate (glusterd_volinfo_t *volinfo); +glusterd_are_all_volumes_stopped(); + gf_boolean_t -glusterd_is_brick_decommissioned (glusterd_volinfo_t *volinfo, char *hostname, - char *path); +glusterd_all_shd_compatible_volumes_stopped(); + +void +glusterd_nfs_pmap_deregister(); + gf_boolean_t -glusterd_friend_contains_vol_bricks (glusterd_volinfo_t *volinfo, - uuid_t friend_uuid); +glusterd_is_volume_started(glusterd_volinfo_t *volinfo); + +int +glusterd_volume_get_type_str(glusterd_volinfo_t *volinfo, char **vol_type_str); + +int +glusterd_volume_get_status_str(glusterd_volinfo_t *volinfo, char *status_str); + +void +glusterd_brick_get_status_str(glusterd_brickinfo_t *brickinfo, + char *status_str); + +int +glusterd_volume_get_transport_type_str(glusterd_volinfo_t *volinfo, + char *transport_type_str); + int -glusterd_friend_remove_cleanup_vols (uuid_t uuid); +glusterd_volume_get_quorum_status_str(glusterd_volinfo_t *volinfo, + char *quorum_status_str); + +int +glusterd_volume_get_rebalance_status_str(glusterd_volinfo_t *volinfo, + char *rebal_status_str); + +void +glusterd_list_add_order(struct cds_list_head *new, struct cds_list_head *head, + int (*compare)(struct cds_list_head *, + struct cds_list_head *)); + +struct rpc_clnt * +glusterd_defrag_rpc_get(glusterd_defrag_info_t *defrag); + +struct rpc_clnt * +glusterd_defrag_rpc_put(glusterd_defrag_info_t *defrag); + +int32_t +glusterd_count_connected_peers(int32_t *count); + +int +glusterd_volume_brick_for_each(glusterd_volinfo_t *volinfo, void *data, + int (*fn)(glusterd_volinfo_t *, + glusterd_brickinfo_t *, + dict_t *mod_dict, void *)); + +int +glusterd_get_dummy_client_filepath(char *filepath, glusterd_volinfo_t *volinfo, + gf_transport_type type); + +int +glusterd_handle_replicate_brick_ops(glusterd_volinfo_t *volinfo, + glusterd_brickinfo_t *brickinfo, + glusterd_op_t op); +void +assign_brick_groups(glusterd_volinfo_t *volinfo); + +glusterd_brickinfo_t * +get_last_brick_of_brick_group(glusterd_volinfo_t *volinfo, + glusterd_brickinfo_t *brickinfo); +int +glusterd_get_rb_dst_brickinfo(glusterd_volinfo_t *volinfo, + glusterd_brickinfo_t **brickinfo); +int +rb_update_dstbrick_port(glusterd_brickinfo_t *dst_brickinfo, dict_t *rsp_dict, + dict_t *req_dict); +int +glusterd_op_perform_replace_brick(glusterd_volinfo_t *volinfo, char *old_brick, + char *new_brick, dict_t *dict); +int32_t +glusterd_brick_unlink_socket_file(glusterd_volinfo_t *volinfo, + glusterd_brickinfo_t *brickinfo); +char * +gd_rb_op_to_str(char *op); + +glusterd_op_t +gd_cli_to_gd_op(char *cli_op); + +int +glusterd_get_dst_brick_info(char **dst_brick, char *volname, char **op_errstr, + glusterd_brickinfo_t **dst_brickinfo, char **host, + dict_t *dict, char **dup_dstbrick); + +int +glusterd_brick_op_prerequisites(dict_t *dict, char **op, glusterd_op_t *gd_op, + char **volname, glusterd_volinfo_t **volinfo, + char **src_brick, + glusterd_brickinfo_t **src_brickinfo, + char *pidfile, char **op_errstr, + dict_t *rsp_dict); + +int +glusterd_get_volinfo_from_brick(char *brick, glusterd_volinfo_t **volinfo); gf_boolean_t -glusterd_chk_peers_connected_befriended (uuid_t skip_uuid); +glusterd_is_profile_on(glusterd_volinfo_t *volinfo); + +char * +search_brick_path_from_proc(pid_t brick_pid, char *brickpath); + +int32_t +glusterd_add_shd_to_dict(glusterd_volinfo_t *volinfo, dict_t *dict, + int32_t count); +int32_t +glusterd_check_brick_order(dict_t *dict, char *err_str, int32_t type, + char **volname, char **bricks, int32_t *brick_count, + int32_t sub_count); + #endif |