/* Copyright (c) 2006-2012 Red Hat, Inc. 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 #include #include "uuid.h" #include "glusterfs.h" #include "xlator.h" #include "logging.h" #include "call-stub.h" #include "fd.h" #include "byte-order.h" #include "glusterd.h" #include "rpc-clnt.h" #include "protocol-common.h" #include "glusterfs3-xdr.h" #include "glusterd-peer-utils.h" #define GLUSTERD_SOCK_DIR "/var/run" #define GLUSTERD_ASSIGN_BRICKID_TO_BRICKINFO(brickinfo, volinfo, brickid) do {\ sprintf (brickinfo->brick_id, "%s-client-%d",\ volinfo->volname, brickid);\ } while (0) #define glusterd_quorum_count(peerinfo, inquorum_count, active_count, _exit)\ if (peerinfo->quorum_contrib == QUORUM_WAITING)\ goto _exit;\ if (_is_contributing_to_quorum (peerinfo->quorum_contrib))\ inquorum_count = inquorum_count + 1;\ if (active_count && (peerinfo->quorum_contrib == QUORUM_UP))\ *active_count = *active_count + 1;\ #define list_for_each_local_xaction_peers(xact_peer, xact_peers_head) \ glusterd_local_peers_t *pos = NULL; \ for (pos = list_entry ((xact_peers_head)->next, \ glusterd_local_peers_t, op_peers_list), \ xact_peer = pos->peerinfo; \ &pos->op_peers_list != (xact_peers_head); \ pos = list_entry(pos->op_peers_list.next, \ glusterd_local_peers_t, op_peers_list), \ xact_peer = pos->peerinfo) struct glusterd_lock_ { uuid_t owner; time_t timestamp; }; typedef struct glusterd_dict_ctx_ { dict_t *dict; int opt_count; char *key_name; char *val_name; char *prefix; } glusterd_dict_ctx_t; 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); int32_t glusterd_lock (uuid_t new_owner); int32_t glusterd_unlock (uuid_t owner); int32_t glusterd_get_uuid (uuid_t *uuid); int glusterd_submit_reply (rpcsvc_request_t *req, void *arg, struct iovec *payload, int payloadcount, struct iobref *iobref, xdrproc_t xdrproc); int 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); int32_t glusterd_volinfo_new (glusterd_volinfo_t **volinfo); 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_auth_set_username (glusterd_volinfo_t *volinfo, char *username); int32_t glusterd_auth_set_password (glusterd_volinfo_t *volinfo, char *password); void glusterd_auth_cleanup (glusterd_volinfo_t *volinfo); gf_boolean_t glusterd_check_volume_exists (char *volname); int32_t glusterd_brickinfo_new (glusterd_brickinfo_t **brickinfo); int32_t glusterd_brickinfo_new_from_brick (char *brick, glusterd_brickinfo_t **brickinfo); int32_t glusterd_snap_volinfo_find (char *volname, glusterd_snap_t *snap, glusterd_volinfo_t **volinfo); int32_t glusterd_snap_volinfo_find_from_parent_volname (char *origin_volname, glusterd_snap_t *snap, glusterd_volinfo_t **volinfo); int32_t glusterd_volinfo_find (char *volname, glusterd_volinfo_t **volinfo); int glusterd_volinfo_find_by_volume_id (uuid_t volume_id, glusterd_volinfo_t **volinfo); int glusterd_snap_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); int glusterd_get_next_available_brickid (glusterd_volinfo_t *volinfo); int32_t glusterd_resolve_brick (glusterd_brickinfo_t *brickinfo); int32_t 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, gf_boolean_t del_brick); 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); int32_t glusterd_brickinfo_delete (glusterd_brickinfo_t *brickinfo); gf_boolean_t 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); int32_t glusterd_add_volumes_to_export_dict (dict_t **peer_data); int32_t 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_get_nodesvc_volfile (char *server, char *workdir, char *volfile, size_t len); gf_boolean_t glusterd_is_nodesvc_running (); gf_boolean_t glusterd_is_nodesvc_running (); void glusterd_get_nodesvc_dir (char *server, char *workdir, char *path, size_t len); int32_t glusterd_nfs_server_start (); int32_t glusterd_nfs_server_stop (); int32_t glusterd_shd_start (); int32_t glusterd_shd_stop (); int32_t glusterd_quotad_start (); int32_t glusterd_quotad_start_wait (); int32_t glusterd_quotad_stop (); void glusterd_set_socket_filepath (char *sock_filepath, char *sockpath, size_t len); int32_t glusterd_nodesvc_set_socket_filepath (char *rundir, uuid_t uuid, char *socketpath, int len); struct rpc_clnt* glusterd_pending_node_get_rpc (glusterd_pending_node_t *pending_node); struct rpc_clnt* glusterd_nodesvc_get_rpc (char *server); int32_t glusterd_nodesvc_set_rpc (char *server, struct rpc_clnt *rpc); int32_t glusterd_nodesvc_connect (char *server, char *socketpath); void glusterd_nodesvc_set_online_status (char *server, gf_boolean_t status); gf_boolean_t glusterd_is_nodesvc_online (char *server); int glusterd_remote_hostname_get (rpcsvc_request_t *req, char *remote_host, int len); int32_t glusterd_import_friend_volumes (dict_t *peer_data); void glusterd_set_volume_status (glusterd_volinfo_t *volinfo, glusterd_volume_status status); int glusterd_check_generate_start_nfs (void); int glusterd_check_generate_start_shd (void); int glusterd_check_generate_start_quotad (void); int glusterd_check_generate_start_quotad_wait (void); int glusterd_nodesvcs_handle_graph_change (glusterd_volinfo_t *volinfo); int glusterd_nodesvcs_handle_reconfigure (glusterd_volinfo_t *volinfo); int glusterd_nodesvcs_start (glusterd_volinfo_t *volinfo); int glusterd_nodesvcs_stop (glusterd_volinfo_t *volinfo); 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_get_brickinfo (xlator_t *this, const char *brickname, int port, gf_boolean_t localhost, glusterd_brickinfo_t **brickinfo); void glusterd_set_brick_status (glusterd_brickinfo_t *brickinfo, gf_brick_status_t status); gf_boolean_t glusterd_is_brick_started (glusterd_brickinfo_t *brickinfo); 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); int glusterd_brick_stop (glusterd_volinfo_t *volinfo, glusterd_brickinfo_t *brickinfo, gf_boolean_t del_brick); int glusterd_is_defrag_on (glusterd_volinfo_t *volinfo); int32_t 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); int32_t glusterd_volume_brickinfos_delete (glusterd_volinfo_t *volinfo); int32_t 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_is_rb_started (glusterd_volinfo_t *volinfo); int glusterd_is_rb_paused (glusterd_volinfo_t *volinfo); int glusterd_set_rb_status (glusterd_volinfo_t *volinfo, gf_rb_status_t status); gf_boolean_t glusterd_is_rb_ongoing (glusterd_volinfo_t *volinfo); 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 **op_errstr, gf_boolean_t is_force); 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 list_head *list, void *elem); int glusterd_clear_pending_nodes (struct 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_delete_volume (glusterd_volinfo_t *volinfo); int32_t glusterd_delete_brick (glusterd_volinfo_t* volinfo, glusterd_brickinfo_t *brickinfo); int32_t glusterd_delete_all_bricks (glusterd_volinfo_t* volinfo); int glusterd_spawn_daemons (void *opaque); 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_handle_upgrade_downgrade (dict_t *options, glusterd_conf_t *conf); int glusterd_add_brick_detail_to_dict (glusterd_volinfo_t *volinfo, glusterd_brickinfo_t *brickinfo, dict_t *dict, int32_t count); int32_t glusterd_add_brick_to_dict (glusterd_volinfo_t *volinfo, glusterd_brickinfo_t *brickinfo, dict_t *dict, int32_t count); int32_t glusterd_add_snapd_to_dict (glusterd_volinfo_t *volinfo, dict_t *dict, int32_t count); int32_t glusterd_get_all_volnames (dict_t *dict); gf_boolean_t glusterd_is_fuse_available (); int glusterd_brick_statedump (glusterd_volinfo_t *volinfo, glusterd_brickinfo_t *brickinfo, char *options, int option_cnt, char **op_errstr); int glusterd_nfs_statedump (char *options, int option_cnt, char **op_errstr); int 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_friend_contains_vol_bricks (glusterd_volinfo_t *volinfo, uuid_t friend_uuid); int glusterd_friend_remove_cleanup_vols (uuid_t uuid); void glusterd_get_client_filepath (char *filepath, glusterd_volinfo_t *volinfo, gf_transport_type type); void glusterd_get_trusted_client_filepath (char *filepath, glusterd_volinfo_t *volinfo, gf_transport_type type); int glusterd_restart_rebalance (glusterd_conf_t *conf); int32_t glusterd_add_bricks_hname_path_to_dict (dict_t *dict, glusterd_volinfo_t *volinfo); int glusterd_add_node_to_dict (char *server, dict_t *dict, int count, dict_t *vol_opts); int 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_validate_volume_id (dict_t *op_dict, glusterd_volinfo_t *volinfo); int glusterd_defrag_volume_status_update (glusterd_volinfo_t *volinfo, dict_t *rsp_dict); int 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_volset_help (dict_t *dict, char **op_errstr); int32_t 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); int glusterd_snap_use_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_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); int32_t 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_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); gf_boolean_t glusterd_is_quorum_changed (dict_t *options, char *option, char *value); int glusterd_do_quorum_action (); int glusterd_get_quorum_cluster_counts (xlator_t *this, int *active_count, int *quorum_count, struct list_head *peer_list, gf_boolean_t _local__xaction_peers); int glusterd_get_next_global_opt_version_str (dict_t *opts, char **version_str); gf_boolean_t glusterd_is_quorum_option (char *option); gf_boolean_t glusterd_is_volume_in_server_quorum (glusterd_volinfo_t *volinfo); gf_boolean_t glusterd_is_any_volume_in_server_quorum (xlator_t *this); gf_boolean_t does_gd_meet_server_quorum (xlator_t *this, struct list_head *peers_list, gf_boolean_t _local__xaction_peers); int glusterd_generate_and_set_task_id (dict_t *dict, char *key); int glusterd_validate_and_set_gfid (dict_t *op_ctx, dict_t *req_dict, char **op_errstr); int glusterd_copy_uuid_to_dict (uuid_t uuid, dict_t *dict, char *key); gf_boolean_t glusterd_is_same_address (char *name1, char *name2); void gd_update_volume_op_versions (glusterd_volinfo_t *volinfo); int 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_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_get_slave_info (char *slave, char **slave_url, char **hostname, char **slave_vol, char **op_errstr); int glusterd_get_statefile_name (glusterd_volinfo_t *volinfo, char *slave, char *conf_path, char **statefile, gf_boolean_t *is_template_in_use); int 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_is_volume_quota_enabled (glusterd_volinfo_t *volinfo); gf_boolean_t glusterd_all_volumes_with_quota_stopped (); int glusterd_reconfigure_quotad (); void glusterd_clean_up_quota_store (glusterd_volinfo_t *volinfo); int glusterd_store_quota_conf_skip_header (xlator_t *this, int fd); int glusterd_store_quota_conf_stamp_header (xlator_t *this, int fd); int glusterd_remove_auxiliary_mount (char *volname); gf_boolean_t 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_compare_volume_name(struct list_head *, struct 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); int glusterd_compare_snap_time(struct list_head *, struct list_head *); int glusterd_compare_snap_vol_time(struct list_head *, struct list_head *); int32_t glusterd_snap_volinfo_restore (dict_t *dict, dict_t *rsp_dict, glusterd_volinfo_t *new_volinfo, glusterd_volinfo_t *snap_volinfo, int32_t volcount); int32_t glusterd_lvm_snapshot_remove (dict_t *rsp_dict, glusterd_volinfo_t *snap_vol); int32_t glusterd_missed_snapinfo_new (glusterd_missed_snap_info **missed_snapinfo); int32_t glusterd_missed_snap_op_new (glusterd_snap_op_t **snap_op); int32_t glusterd_add_missed_snaps_to_dict (dict_t *rsp_dict, glusterd_volinfo_t *snap_vol, glusterd_brickinfo_t *brickinfo, int32_t brick_number, int32_t op); int32_t glusterd_add_missed_snaps_to_export_dict (dict_t *peer_data); int32_t glusterd_import_friend_missed_snap_list (dict_t *peer_data); int gd_restore_snap_volume (dict_t *dict, dict_t *rsp_dict, glusterd_volinfo_t *orig_vol, glusterd_volinfo_t *snap_vol, int32_t volcount); int32_t glusterd_mount_lvm_snapshot (glusterd_brickinfo_t *brickinfo, char *brick_mount_path); int32_t glusterd_umount (const char *path); int32_t glusterd_add_snapshots_to_export_dict (dict_t *peer_data); int32_t glusterd_compare_friend_snapshots (dict_t *peer_data, glusterd_peerinfo_t *peerinfo); int32_t glusterd_snapobject_delete (glusterd_snap_t *snap); int32_t glusterd_snap_volume_remove (dict_t *rsp_dict, glusterd_volinfo_t *snap_vol, gf_boolean_t remove_lvm, gf_boolean_t force); int32_t glusterd_store_create_snap_dir (glusterd_snap_t *snap); int32_t glusterd_copy_file (const char *source, const char *destination); int32_t glusterd_copy_folder (const char *source, const char *destination); int32_t glusterd_get_geo_rep_session (char *slave_key, char *origin_volname, dict_t *gsync_slaves_dict, char *session, char *slave); int32_t glusterd_restore_geo_rep_files (glusterd_volinfo_t *snap_vol); gf_boolean_t gd_vol_is_geo_rep_active (glusterd_volinfo_t *volinfo); int32_t glusterd_copy_quota_files (glusterd_volinfo_t *src_vol, glusterd_volinfo_t *dest_vol); int glusterd_recursive_rmdir (const char *delete_path); int32_t glusterd_get_brick_mount_dir (char *brickpath, char *hostname, char *mount_dir); int32_t glusterd_aggr_brick_mount_dirs (dict_t *aggr, dict_t *rsp_dict); int32_t glusterd_take_lvm_snapshot (glusterd_brickinfo_t *brickinfo, char *origin_brick_path); int32_t glusterd_snap_quorum_check (dict_t *dict, gf_boolean_t snap_volume, char **op_errstr, struct list_head *peers_list); int32_t glusterd_snap_quorum_check_for_create (dict_t *dict, gf_boolean_t snap_volume, char **op_errstr, struct list_head *peers_list); int32_t glusterd_volume_quorum_check (glusterd_volinfo_t *volinfo, int64_t index, dict_t *dict, char *key_prefix, int8_t snap_force, int32_t quorum_count, char *quorum_type, char **op_errstr); gf_boolean_t glusterd_volume_quorum_calculate (glusterd_volinfo_t *volinfo, dict_t *dict, int down_count, gf_boolean_t first_brick_on, int8_t snap_force, int32_t quorum_count, char *quorum_type, char **op_errstr); int glusterd_merge_brick_status (dict_t *dst, dict_t *src); int32_t glusterd_snap_brick_create (glusterd_volinfo_t *snap_volinfo, glusterd_brickinfo_t *brickinfo, int32_t brick_count); void glusterd_launch_synctask (synctask_fn_t fn, void *opaque); int glusterd_enable_default_options (glusterd_volinfo_t *volinfo, char *option); int glusterd_snapshot_restore_cleanup (dict_t *rsp_dict, glusterd_volinfo_t *volinfo, glusterd_snap_t *snap); int glusterd_unlink_file (char *sock_file_path); /* Snapd functions */ int glusterd_handle_snapd_option (glusterd_volinfo_t *volinfo); int32_t glusterd_snapd_disconnect (glusterd_volinfo_t *volinfo); void glusterd_get_snapd_dir (glusterd_volinfo_t *volinfo, char *path, int path_len); void glusterd_get_snapd_rundir (glusterd_volinfo_t *volinfo, char *path, int path_len); void glusterd_get_snapd_volfile (glusterd_volinfo_t *volinfo, char *path, int path_len); void glusterd_get_snapd_pidfile (glusterd_volinfo_t *volinfo, char *path, int path_len); void glusterd_set_snapd_socket_filepath (glusterd_volinfo_t *volinfo, char *path, int path_len); gf_boolean_t glusterd_is_snapd_running (glusterd_volinfo_t *volinfo); int glusterd_snapd_stop (glusterd_volinfo_t *volinfo); int glusterd_snapd_start (glusterd_volinfo_t *volinfo, gf_boolean_t wait); int glusterd_is_snapd_enabled (glusterd_volinfo_t *volinfo); gf_boolean_t glusterd_is_snapd_online (glusterd_volinfo_t *volinfo); void glusterd_snapd_set_online_status (glusterd_volinfo_t *volinfo, gf_boolean_t status); int glusterd_restart_snapds (glusterd_conf_t *priv); /* End snapd functions */ int32_t glusterd_check_and_set_config_limit (glusterd_conf_t *priv); int32_t glusterd_is_snap_soft_limit_reached (glusterd_volinfo_t *volinfo, dict_t *dict); int32_t glusterd_find_brick_mount_path (char *brick_path, int32_t brick_count, 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); void gd_get_snap_conf_values_if_present (dict_t *opts, uint64_t *sys_hard_limit, uint64_t *sys_soft_limit); gf_boolean_t glusterd_have_peers (); void gd_cleanup_local_xaction_peers_list (struct list_head *peers); #endif