diff options
Diffstat (limited to 'glusterfsd/src/glusterfsd.c')
| -rw-r--r-- | glusterfsd/src/glusterfsd.c | 1914 |
1 files changed, 957 insertions, 957 deletions
diff --git a/glusterfsd/src/glusterfsd.c b/glusterfsd/src/glusterfsd.c index 56292b654..68ae5b315 100644 --- a/glusterfsd/src/glusterfsd.c +++ b/glusterfsd/src/glusterfsd.c @@ -1,20 +1,20 @@ /* - Copyright (c) 2006-2009 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-2009 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/>. */ #include <stdio.h> @@ -80,88 +80,88 @@ gf_log_central_init (glusterfs_ctx_t *ctx, const char *remote_host, /* using argp for command line parsing */ static char gf_doc[] = ""; static char argp_doc[] = "--volfile-server=SERVER [MOUNT-POINT]\n" \ - "--volfile=VOLFILE [MOUNT-POINT]"; + "--volfile=VOLFILE [MOUNT-POINT]"; const char *argp_program_version = "" \ - PACKAGE_NAME" "PACKAGE_VERSION" built on "__DATE__" "__TIME__ \ - "\nRepository revision: " GLUSTERFS_REPOSITORY_REVISION "\n" \ - "Copyright (c) 2006-2009 Gluster Inc. " \ - "<http://www.gluster.com>\n" \ - "GlusterFS comes with ABSOLUTELY NO WARRANTY.\n" \ - "You may redistribute copies of GlusterFS under the terms of "\ - "the GNU General Public License."; + PACKAGE_NAME" "PACKAGE_VERSION" built on "__DATE__" "__TIME__ \ + "\nRepository revision: " GLUSTERFS_REPOSITORY_REVISION "\n" \ + "Copyright (c) 2006-2009 Gluster Inc. " \ + "<http://www.gluster.com>\n" \ + "GlusterFS comes with ABSOLUTELY NO WARRANTY.\n" \ + "You may redistribute copies of GlusterFS under the terms of "\ + "the GNU General Public License."; const char *argp_program_bug_address = "<" PACKAGE_BUGREPORT ">"; error_t parse_opts (int32_t key, char *arg, struct argp_state *_state); static struct argp_option gf_options[] = { - {0, 0, 0, 0, "Basic options:"}, - {"volfile-server", ARGP_VOLFILE_SERVER_KEY, "SERVER", 0, - "Server to get the volume file from. This option overrides " - "--volfile option"}, + {0, 0, 0, 0, "Basic options:"}, + {"volfile-server", ARGP_VOLFILE_SERVER_KEY, "SERVER", 0, + "Server to get the volume file from. This option overrides " + "--volfile option"}, {"volfile-max-fetch-attempts", ARGP_VOLFILE_MAX_FETCH_ATTEMPTS, "MAX-ATTEMPTS", 0, "Maximum number of connect attempts to server. " "This option should be provided with --volfile-server option" "[default: 1]"}, - {"volfile", ARGP_VOLUME_FILE_KEY, "VOLFILE", 0, - "File to use as VOLUME_FILE [default: "DEFAULT_CLIENT_VOLUME_FILE" or " - DEFAULT_SERVER_VOLUME_FILE"]"}, - {"spec-file", ARGP_VOLUME_FILE_KEY, "VOLFILE", OPTION_HIDDEN, - "File to use as VOLFILE [default : "DEFAULT_CLIENT_VOLUME_FILE" or " - DEFAULT_SERVER_VOLUME_FILE"]"}, - {"log-server", ARGP_LOG_SERVER_KEY, "LOG SERVER", 0, - "Server to use as the central log server." - "--log-server option"}, - - {"log-level", ARGP_LOG_LEVEL_KEY, "LOGLEVEL", 0, - "Logging severity. Valid options are DEBUG, NORMAL, WARNING, ERROR, " - "CRITICAL and NONE [default: NORMAL]"}, - {"log-file", ARGP_LOG_FILE_KEY, "LOGFILE", 0, - "File to use for logging [default: " - DEFAULT_LOG_FILE_DIRECTORY "/" PACKAGE_NAME ".log" "]"}, - - {0, 0, 0, 0, "Advanced Options:"}, - {"volfile-server-port", ARGP_VOLFILE_SERVER_PORT_KEY, "PORT", 0, - "Listening port number of volfile server"}, - {"volfile-server-transport", ARGP_VOLFILE_SERVER_TRANSPORT_KEY, - "TRANSPORT", 0, - "Transport type to get volfile from server [default: socket]"}, - {"volfile-id", ARGP_VOLFILE_ID_KEY, "KEY", 0, - "'key' of the volfile to be fetched from server"}, - {"log-server-port", ARGP_LOG_SERVER_PORT_KEY, "PORT", 0, - "Listening port number of log server"}, - {"pid-file", ARGP_PID_FILE_KEY, "PIDFILE", 0, - "File to use as pid file"}, - {"no-daemon", ARGP_NO_DAEMON_KEY, 0, 0, - "Run in foreground"}, - {"run-id", ARGP_RUN_ID_KEY, "RUN-ID", OPTION_HIDDEN, - "Run ID for the process, used by scripts to keep track of process " - "they started, defaults to none"}, - {"debug", ARGP_DEBUG_KEY, 0, 0, - "Run in debug mode. This option sets --no-daemon, --log-level " - "to DEBUG and --log-file to console"}, - {"volume-name", ARGP_VOLUME_NAME_KEY, "VOLUME-NAME", 0, - "Volume name to be used for MOUNT-POINT [default: top most volume " - "in VOLFILE]"}, - {"xlator-option", ARGP_XLATOR_OPTION_KEY,"VOLUME-NAME.OPTION=VALUE", 0, - "Add/override a translator option for a volume with specified value"}, - - {0, 0, 0, 0, "Fuse options:"}, - {"disable-direct-io-mode", ARGP_DISABLE_DIRECT_IO_MODE_KEY, 0, 0, - "Disable direct I/O mode in fuse kernel module" - " [default if big writes are supported]"}, - {"entry-timeout", ARGP_ENTRY_TIMEOUT_KEY, "SECONDS", 0, - "Set entry timeout to SECONDS in fuse kernel module [default: 1]"}, - {"attribute-timeout", ARGP_ATTRIBUTE_TIMEOUT_KEY, "SECONDS", 0, - "Set attribute timeout to SECONDS for inodes in fuse kernel module " - "[default: 1]"}, - {"volfile-check", ARGP_VOLFILE_CHECK_KEY, 0, 0, - "Enable strict volume file checking"}, + {"volfile", ARGP_VOLUME_FILE_KEY, "VOLFILE", 0, + "File to use as VOLUME_FILE [default: "DEFAULT_CLIENT_VOLUME_FILE" or " + DEFAULT_SERVER_VOLUME_FILE"]"}, + {"spec-file", ARGP_VOLUME_FILE_KEY, "VOLFILE", OPTION_HIDDEN, + "File to use as VOLFILE [default : "DEFAULT_CLIENT_VOLUME_FILE" or " + DEFAULT_SERVER_VOLUME_FILE"]"}, + {"log-server", ARGP_LOG_SERVER_KEY, "LOG SERVER", 0, + "Server to use as the central log server." + "--log-server option"}, + + {"log-level", ARGP_LOG_LEVEL_KEY, "LOGLEVEL", 0, + "Logging severity. Valid options are DEBUG, NORMAL, WARNING, ERROR, " + "CRITICAL and NONE [default: NORMAL]"}, + {"log-file", ARGP_LOG_FILE_KEY, "LOGFILE", 0, + "File to use for logging [default: " + DEFAULT_LOG_FILE_DIRECTORY "/" PACKAGE_NAME ".log" "]"}, + + {0, 0, 0, 0, "Advanced Options:"}, + {"volfile-server-port", ARGP_VOLFILE_SERVER_PORT_KEY, "PORT", 0, + "Listening port number of volfile server"}, + {"volfile-server-transport", ARGP_VOLFILE_SERVER_TRANSPORT_KEY, + "TRANSPORT", 0, + "Transport type to get volfile from server [default: socket]"}, + {"volfile-id", ARGP_VOLFILE_ID_KEY, "KEY", 0, + "'key' of the volfile to be fetched from server"}, + {"log-server-port", ARGP_LOG_SERVER_PORT_KEY, "PORT", 0, + "Listening port number of log server"}, + {"pid-file", ARGP_PID_FILE_KEY, "PIDFILE", 0, + "File to use as pid file"}, + {"no-daemon", ARGP_NO_DAEMON_KEY, 0, 0, + "Run in foreground"}, + {"run-id", ARGP_RUN_ID_KEY, "RUN-ID", OPTION_HIDDEN, + "Run ID for the process, used by scripts to keep track of process " + "they started, defaults to none"}, + {"debug", ARGP_DEBUG_KEY, 0, 0, + "Run in debug mode. This option sets --no-daemon, --log-level " + "to DEBUG and --log-file to console"}, + {"volume-name", ARGP_VOLUME_NAME_KEY, "VOLUME-NAME", 0, + "Volume name to be used for MOUNT-POINT [default: top most volume " + "in VOLFILE]"}, + {"xlator-option", ARGP_XLATOR_OPTION_KEY,"VOLUME-NAME.OPTION=VALUE", 0, + "Add/override a translator option for a volume with specified value"}, + + {0, 0, 0, 0, "Fuse options:"}, + {"disable-direct-io-mode", ARGP_DISABLE_DIRECT_IO_MODE_KEY, 0, 0, + "Disable direct I/O mode in fuse kernel module" + " [default if big writes are supported]"}, + {"entry-timeout", ARGP_ENTRY_TIMEOUT_KEY, "SECONDS", 0, + "Set entry timeout to SECONDS in fuse kernel module [default: 1]"}, + {"attribute-timeout", ARGP_ATTRIBUTE_TIMEOUT_KEY, "SECONDS", 0, + "Set attribute timeout to SECONDS for inodes in fuse kernel module " + "[default: 1]"}, + {"volfile-check", ARGP_VOLFILE_CHECK_KEY, 0, 0, + "Enable strict volume file checking"}, #ifdef GF_DARWIN_HOST_OS - {"non-local", ARGP_NON_LOCAL_KEY, 0, 0, - "Mount the macfuse volume without '-o local' option"}, + {"non-local", ARGP_NON_LOCAL_KEY, 0, 0, + "Mount the macfuse volume without '-o local' option"}, #endif - {0, 0, 0, 0, "Miscellaneous Options:"}, - {0, } + {0, 0, 0, 0, "Miscellaneous Options:"}, + {0, } }; @@ -171,7 +171,7 @@ static struct argp argp = { gf_options, parse_opts, argp_doc, gf_doc }; int gf_daemon (int *pipe_fd) { - pid_t pid = -1; + pid_t pid = -1; int ret = -1; int gf_daemon_buff = 0; @@ -182,8 +182,8 @@ gf_daemon (int *pipe_fd) } if ((pid = fork ()) < 0) { - gf_log ("glusterfs", GF_LOG_ERROR, "fork error: %s", - strerror (errno)); + gf_log ("glusterfs", GF_LOG_ERROR, "fork error: %s", + strerror (errno)); return -1; } else if (pid != 0) { close (pipe_fd[1]); @@ -209,16 +209,16 @@ gf_daemon (int *pipe_fd) /*child continues*/ close (pipe_fd[0]); - if (daemon (0, 0) == -1) { - gf_log ("glusterfs", GF_LOG_ERROR, - "unable to run in daemon mode: %s", - strerror (errno)); - return -1; - } + if (daemon (0, 0) == -1) { + gf_log ("glusterfs", GF_LOG_ERROR, + "unable to run in daemon mode: %s", + strerror (errno)); + return -1; + } return 0; } -static void +static void _gf_dump_details (int argc, char **argv) { extern FILE *gf_log_logfile; @@ -226,20 +226,20 @@ _gf_dump_details (int argc, char **argv) char timestr[256]; time_t utime = 0; struct tm *tm = NULL; - pid_t mypid = 0; - struct utsname uname_buf = {{0, }, }; - int uname_ret = -1; + pid_t mypid = 0; + struct utsname uname_buf = {{0, }, }; + int uname_ret = -1; - utime = time (NULL); - tm = localtime (&utime); - mypid = getpid (); - uname_ret = uname (&uname_buf); + utime = time (NULL); + tm = localtime (&utime); + mypid = getpid (); + uname_ret = uname (&uname_buf); /* Which git? What time? */ - strftime (timestr, 256, "%Y-%m-%d %H:%M:%S", tm); - fprintf (gf_log_logfile, - "========================================" - "========================================\n"); + strftime (timestr, 256, "%Y-%m-%d %H:%M:%S", tm); + fprintf (gf_log_logfile, + "========================================" + "========================================\n"); fprintf (gf_log_logfile, "Version : %s %s built on %s %s\n", PACKAGE_NAME, PACKAGE_VERSION, __DATE__, __TIME__); fprintf (gf_log_logfile, "git: %s\n", @@ -250,14 +250,14 @@ _gf_dump_details (int argc, char **argv) fprintf (gf_log_logfile, "%s ", argv[i]); } - fprintf (gf_log_logfile, "\nPID : %d\n", mypid); - - if (uname_ret == 0) { - fprintf (gf_log_logfile, "System name : %s\n", uname_buf.sysname); - fprintf (gf_log_logfile, "Nodename : %s\n", uname_buf.nodename); - fprintf (gf_log_logfile, "Kernel Release : %s\n", uname_buf.release); - fprintf (gf_log_logfile, "Hardware Identifier: %s\n", uname_buf.machine); - } + fprintf (gf_log_logfile, "\nPID : %d\n", mypid); + + if (uname_ret == 0) { + fprintf (gf_log_logfile, "System name : %s\n", uname_buf.sysname); + fprintf (gf_log_logfile, "Nodename : %s\n", uname_buf.nodename); + fprintf (gf_log_logfile, "Kernel Release : %s\n", uname_buf.release); + fprintf (gf_log_logfile, "Hardware Identifier: %s\n", uname_buf.machine); + } fprintf (gf_log_logfile, "\n"); @@ -268,722 +268,722 @@ static xlator_t * gf_get_first_xlator (xlator_t *list) { xlator_t *trav = NULL, *head = NULL; - + trav = list; do { if (trav->prev == NULL) { head = trav; } - + trav = trav->prev; } while (trav != NULL); - + return head; } static xlator_t * _add_fuse_mount (xlator_t *graph) { - int ret = 0; - cmd_args_t *cmd_args = NULL; - xlator_t *top = NULL; - glusterfs_ctx_t *ctx = NULL; - xlator_list_t *xlchild = NULL; - - ctx = graph->ctx; - cmd_args = &ctx->cmd_args; - - xlchild = CALLOC (sizeof (*xlchild), 1); - ERR_ABORT (xlchild); - xlchild->xlator = graph; - - top = CALLOC (1, sizeof (*top)); - top->name = strdup ("fuse"); - if (xlator_set_type (top, ZR_XLATOR_FUSE) == -1) { - fprintf (stderr, - "MOUNT-POINT %s initialization failed", - cmd_args->mount_point); - gf_log ("glusterfs", GF_LOG_ERROR, - "MOUNT-POINT %s initialization failed", - cmd_args->mount_point); - return NULL; - } - top->children = xlchild; - top->ctx = graph->ctx; - top->next = gf_get_first_xlator (graph); - top->options = get_new_dict (); - - ret = dict_set_static_ptr (top->options, ZR_MOUNTPOINT_OPT, - cmd_args->mount_point); - if (ret < 0) { - gf_log ("glusterfs", GF_LOG_DEBUG, - "failed to set mount-point to options dictionary"); - } - - if (cmd_args->fuse_attribute_timeout) - ret = dict_set_double (top->options, ZR_ATTR_TIMEOUT_OPT, - cmd_args->fuse_attribute_timeout); - if (cmd_args->fuse_entry_timeout) - ret = dict_set_double (top->options, ZR_ENTRY_TIMEOUT_OPT, - cmd_args->fuse_entry_timeout); - - if (cmd_args->volfile_check) - ret = dict_set_int32 (top->options, ZR_STRICT_VOLFILE_CHECK, + int ret = 0; + cmd_args_t *cmd_args = NULL; + xlator_t *top = NULL; + glusterfs_ctx_t *ctx = NULL; + xlator_list_t *xlchild = NULL; + + ctx = graph->ctx; + cmd_args = &ctx->cmd_args; + + xlchild = CALLOC (sizeof (*xlchild), 1); + ERR_ABORT (xlchild); + xlchild->xlator = graph; + + top = CALLOC (1, sizeof (*top)); + top->name = strdup ("fuse"); + if (xlator_set_type (top, ZR_XLATOR_FUSE) == -1) { + fprintf (stderr, + "MOUNT-POINT %s initialization failed", + cmd_args->mount_point); + gf_log ("glusterfs", GF_LOG_ERROR, + "MOUNT-POINT %s initialization failed", + cmd_args->mount_point); + return NULL; + } + top->children = xlchild; + top->ctx = graph->ctx; + top->next = gf_get_first_xlator (graph); + top->options = get_new_dict (); + + ret = dict_set_static_ptr (top->options, ZR_MOUNTPOINT_OPT, + cmd_args->mount_point); + if (ret < 0) { + gf_log ("glusterfs", GF_LOG_DEBUG, + "failed to set mount-point to options dictionary"); + } + + if (cmd_args->fuse_attribute_timeout) + ret = dict_set_double (top->options, ZR_ATTR_TIMEOUT_OPT, + cmd_args->fuse_attribute_timeout); + if (cmd_args->fuse_entry_timeout) + ret = dict_set_double (top->options, ZR_ENTRY_TIMEOUT_OPT, + cmd_args->fuse_entry_timeout); + + if (cmd_args->volfile_check) + ret = dict_set_int32 (top->options, ZR_STRICT_VOLFILE_CHECK, cmd_args->volfile_check); -#ifdef GF_DARWIN_HOST_OS - /* On Darwin machines, O_APPEND is not handled, - * which may corrupt the data - */ - if (cmd_args->fuse_direct_io_mode_flag == _gf_true) { - gf_log ("glusterfs", GF_LOG_DEBUG, - "'direct-io-mode' in fuse causes data corruption " - "if O_APPEND is used. disabling 'direct-io-mode'"); - } - ret = dict_set_static_ptr (top->options, ZR_DIRECT_IO_OPT, "disable"); - - if (cmd_args->non_local) - ret = dict_set_uint32 (top->options, "macfuse-local", - cmd_args->non_local); - +#ifdef GF_DARWIN_HOST_OS + /* On Darwin machines, O_APPEND is not handled, + * which may corrupt the data + */ + if (cmd_args->fuse_direct_io_mode_flag == _gf_true) { + gf_log ("glusterfs", GF_LOG_DEBUG, + "'direct-io-mode' in fuse causes data corruption " + "if O_APPEND is used. disabling 'direct-io-mode'"); + } + ret = dict_set_static_ptr (top->options, ZR_DIRECT_IO_OPT, "disable"); + + if (cmd_args->non_local) + ret = dict_set_uint32 (top->options, "macfuse-local", + cmd_args->non_local); + #else /* ! DARWIN HOST OS */ - if (cmd_args->fuse_direct_io_mode_flag == _gf_true) { - ret = dict_set_static_ptr (top->options, ZR_DIRECT_IO_OPT, - "enable"); - } else { - ret = dict_set_static_ptr (top->options, ZR_DIRECT_IO_OPT, - "disable"); - } + if (cmd_args->fuse_direct_io_mode_flag == _gf_true) { + ret = dict_set_static_ptr (top->options, ZR_DIRECT_IO_OPT, + "enable"); + } else { + ret = dict_set_static_ptr (top->options, ZR_DIRECT_IO_OPT, + "disable"); + } #endif /* GF_DARWIN_HOST_OS */ - - graph->parents = CALLOC (1, sizeof (xlator_list_t)); - graph->parents->xlator = top; - - return top; + + graph->parents = CALLOC (1, sizeof (xlator_list_t)); + graph->parents->xlator = top; + + return top; } static FILE * _get_specfp (glusterfs_ctx_t *ctx) { - int ret = 0; - cmd_args_t *cmd_args = NULL; - FILE *specfp = NULL; - struct stat statbuf; - - cmd_args = &ctx->cmd_args; - - if (cmd_args->volfile_server) { - specfp = fetch_spec (ctx); - - if (specfp == NULL) { - fprintf (stderr, - "error while getting volume file from " - "server %s\n", cmd_args->volfile_server); - gf_log ("glusterfs", GF_LOG_ERROR, - "error while getting volume file from " - "server %s", cmd_args->volfile_server); - } - else { - gf_log ("glusterfs", GF_LOG_DEBUG, - "loading volume file from server %s", - cmd_args->volfile_server); - } - - return specfp; - } - - ret = stat (cmd_args->volume_file, &statbuf); - if (ret == -1) { - fprintf (stderr, "%s: %s\n", - cmd_args->volume_file, strerror (errno)); - gf_log ("glusterfs", GF_LOG_ERROR, - "%s: %s", cmd_args->volume_file, strerror (errno)); - return NULL; - } - if (!(S_ISREG (statbuf.st_mode) || S_ISLNK (statbuf.st_mode))) { - fprintf (stderr, - "provide a valid volume file\n"); - gf_log ("glusterfs", GF_LOG_ERROR, - "provide a valid volume file"); - return NULL; - } - if ((specfp = fopen (cmd_args->volume_file, "r")) == NULL) { - fprintf (stderr, "volume file %s: %s\n", - cmd_args->volume_file, - strerror (errno)); - gf_log ("glusterfs", GF_LOG_ERROR, - "volume file %s: %s", - cmd_args->volume_file, - strerror (errno)); - return NULL; - } - - gf_log ("glusterfs", GF_LOG_DEBUG, - "loading volume file %s", cmd_args->volume_file); - - return specfp; + int ret = 0; + cmd_args_t *cmd_args = NULL; + FILE *specfp = NULL; + struct stat statbuf; + + cmd_args = &ctx->cmd_args; + + if (cmd_args->volfile_server) { + specfp = fetch_spec (ctx); + + if (specfp == NULL) { + fprintf (stderr, + "error while getting volume file from " + "server %s\n", cmd_args->volfile_server); + gf_log ("glusterfs", GF_LOG_ERROR, + "error while getting volume file from " + "server %s", cmd_args->volfile_server); + } + else { + gf_log ("glusterfs", GF_LOG_DEBUG, + "loading volume file from server %s", + cmd_args->volfile_server); + } + + return specfp; + } + + ret = stat (cmd_args->volume_file, &statbuf); + if (ret == -1) { + fprintf (stderr, "%s: %s\n", + cmd_args->volume_file, strerror (errno)); + gf_log ("glusterfs", GF_LOG_ERROR, + "%s: %s", cmd_args->volume_file, strerror (errno)); + return NULL; + } + if (!(S_ISREG (statbuf.st_mode) || S_ISLNK (statbuf.st_mode))) { + fprintf (stderr, + "provide a valid volume file\n"); + gf_log ("glusterfs", GF_LOG_ERROR, + "provide a valid volume file"); + return NULL; + } + if ((specfp = fopen (cmd_args->volume_file, "r")) == NULL) { + fprintf (stderr, "volume file %s: %s\n", + cmd_args->volume_file, + strerror (errno)); + gf_log ("glusterfs", GF_LOG_ERROR, + "volume file %s: %s", + cmd_args->volume_file, + strerror (errno)); + return NULL; + } + + gf_log ("glusterfs", GF_LOG_DEBUG, + "loading volume file %s", cmd_args->volume_file); + + return specfp; } static xlator_t * -_parse_specfp (glusterfs_ctx_t *ctx, - FILE *specfp) +_parse_specfp (glusterfs_ctx_t *ctx, + FILE *specfp) { int spec_fd = 0; - cmd_args_t *cmd_args = NULL; - xlator_t *tree = NULL, *trav = NULL, *new_tree = NULL; - - cmd_args = &ctx->cmd_args; - - fseek (specfp, 0L, SEEK_SET); - - tree = file_to_xlator_tree (ctx, specfp); - trav = tree; - - if (tree == NULL) { - if (cmd_args->volfile_server) { - fprintf (stderr, - "error in parsing volume file given by " - "server %s\n", cmd_args->volfile_server); - gf_log ("glusterfs", GF_LOG_ERROR, - "error in parsing volume file given by " - "server %s", cmd_args->volfile_server); - } - else { - fprintf (stderr, - "error in parsing volume file %s\n", - cmd_args->volume_file); - gf_log ("glusterfs", GF_LOG_ERROR, - "error in parsing volume file %s", - cmd_args->volume_file); - } - return NULL; - } - + cmd_args_t *cmd_args = NULL; + xlator_t *tree = NULL, *trav = NULL, *new_tree = NULL; + + cmd_args = &ctx->cmd_args; + + fseek (specfp, 0L, SEEK_SET); + + tree = file_to_xlator_tree (ctx, specfp); + trav = tree; + + if (tree == NULL) { + if (cmd_args->volfile_server) { + fprintf (stderr, + "error in parsing volume file given by " + "server %s\n", cmd_args->volfile_server); + gf_log ("glusterfs", GF_LOG_ERROR, + "error in parsing volume file given by " + "server %s", cmd_args->volfile_server); + } + else { + fprintf (stderr, + "error in parsing volume file %s\n", + cmd_args->volume_file); + gf_log ("glusterfs", GF_LOG_ERROR, + "error in parsing volume file %s", + cmd_args->volume_file); + } + return NULL; + } + spec_fd = fileno (specfp); get_checksum_for_file (spec_fd, &ctx->volfile_checksum); - /* if volume_name is given, then we attach to it */ - if (cmd_args->volume_name) { - while (trav) { - if (strcmp (trav->name, cmd_args->volume_name) == 0) { - new_tree = trav; - break; - } - trav = trav->next; - } - - if (!trav) { - if (cmd_args->volfile_server) { - fprintf (stderr, - "volume %s not found in volume " - "file given by server %s\n", - cmd_args->volume_name, - cmd_args->volfile_server); - gf_log ("glusterfs", GF_LOG_ERROR, - "volume %s not found in volume " - "file given by server %s", - cmd_args->volume_name, - cmd_args->volfile_server); - } else { - fprintf (stderr, - "volume %s not found in volume " - "file %s\n", - cmd_args->volume_name, - cmd_args->volume_file); - gf_log ("glusterfs", GF_LOG_ERROR, - "volume %s not found in volume " - "file %s", cmd_args->volume_name, - cmd_args->volume_file); - } - return NULL; - } - tree = trav; - } - return tree; + /* if volume_name is given, then we attach to it */ + if (cmd_args->volume_name) { + while (trav) { + if (strcmp (trav->name, cmd_args->volume_name) == 0) { + new_tree = trav; + break; + } + trav = trav->next; + } + + if (!trav) { + if (cmd_args->volfile_server) { + fprintf (stderr, + "volume %s not found in volume " + "file given by server %s\n", + cmd_args->volume_name, + cmd_args->volfile_server); + gf_log ("glusterfs", GF_LOG_ERROR, + "volume %s not found in volume " + "file given by server %s", + cmd_args->volume_name, + cmd_args->volfile_server); + } else { + fprintf (stderr, + "volume %s not found in volume " + "file %s\n", + cmd_args->volume_name, + cmd_args->volume_file); + gf_log ("glusterfs", GF_LOG_ERROR, + "volume %s not found in volume " + "file %s", cmd_args->volume_name, + cmd_args->volume_file); + } + return NULL; + } + tree = trav; + } + return tree; } static int _log_if_option_is_invalid (xlator_t *xl, data_pair_t *pair) { - volume_opt_list_t *vol_opt = NULL; - volume_option_t *opt = NULL; - int i = 0; - int index = 0; - int found = 0; - - /* Get the first volume_option */ - list_for_each_entry (vol_opt, &xl->volume_options, list) { - /* Warn for extra option */ - if (!vol_opt->given_opt) - break; - - opt = vol_opt->given_opt; - for (index = 0; - ((index < ZR_OPTION_MAX_ARRAY_SIZE) && - (opt[index].key && opt[index].key[0])); index++) - for (i = 0; (i < ZR_VOLUME_MAX_NUM_KEY) && - opt[index].key[i]; i++) { - if (fnmatch (opt[index].key[i], - pair->key, - FNM_NOESCAPE) == 0) { - found = 1; - break; - } - } - } - - if (!found) { - gf_log (xl->name, GF_LOG_WARNING, - "option '%s' is not recognized", - pair->key); - } - return 0; + volume_opt_list_t *vol_opt = NULL; + volume_option_t *opt = NULL; + int i = 0; + int index = 0; + int found = 0; + + /* Get the first volume_option */ + list_for_each_entry (vol_opt, &xl->volume_options, list) { + /* Warn for extra option */ + if (!vol_opt->given_opt) + break; + + opt = vol_opt->given_opt; + for (index = 0; + ((index < ZR_OPTION_MAX_ARRAY_SIZE) && + (opt[index].key && opt[index].key[0])); index++) + for (i = 0; (i < ZR_VOLUME_MAX_NUM_KEY) && + opt[index].key[i]; i++) { + if (fnmatch (opt[index].key[i], + pair->key, + FNM_NOESCAPE) == 0) { + found = 1; + break; + } + } + } + + if (!found) { + gf_log (xl->name, GF_LOG_WARNING, + "option '%s' is not recognized", + pair->key); + } + return 0; } -static int +static int _xlator_graph_init (xlator_t *xl) { - volume_opt_list_t *vol_opt = NULL; - data_pair_t *pair = NULL; - xlator_t *trav = NULL; - int ret = -1; - - trav = xl; - - while (trav->prev) - trav = trav->prev; - - /* Validate phase */ - while (trav) { - /* Get the first volume_option */ - list_for_each_entry (vol_opt, - &trav->volume_options, list) - break; - if ((ret = - validate_xlator_volume_options (trav, - vol_opt->given_opt)) < 0) { - gf_log (trav->name, GF_LOG_ERROR, - "validating translator failed"); - return ret; - } - trav = trav->next; - } - - - trav = xl; - while (trav->prev) - trav = trav->prev; - /* Initialization phase */ - while (trav) { - if (!trav->ready) { - if ((ret = xlator_tree_init (trav)) < 0) { - gf_log ("glusterfs", GF_LOG_ERROR, - "initializing translator failed"); - return ret; - } - } - trav = trav->next; - } - - /* No error in this phase, just bunch of warning if at all */ - trav = xl; - - while (trav->prev) - trav = trav->prev; - - /* Validate again phase */ - while (trav) { - pair = trav->options->members_list; - while (pair) { - _log_if_option_is_invalid (trav, pair); - pair = pair->next; - } - trav = trav->next; - } - - return ret; + volume_opt_list_t *vol_opt = NULL; + data_pair_t *pair = NULL; + xlator_t *trav = NULL; + int ret = -1; + + trav = xl; + + while (trav->prev) + trav = trav->prev; + + /* Validate phase */ + while (trav) { + /* Get the first volume_option */ + list_for_each_entry (vol_opt, + &trav->volume_options, list) + break; + if ((ret = + validate_xlator_volume_options (trav, + vol_opt->given_opt)) < 0) { + gf_log (trav->name, GF_LOG_ERROR, + "validating translator failed"); + return ret; + } + trav = trav->next; + } + + + trav = xl; + while (trav->prev) + trav = trav->prev; + /* Initialization phase */ + while (trav) { + if (!trav->ready) { + if ((ret = xlator_tree_init (trav)) < 0) { + gf_log ("glusterfs", GF_LOG_ERROR, + "initializing translator failed"); + return ret; + } + } + trav = trav->next; + } + + /* No error in this phase, just bunch of warning if at all */ + trav = xl; + + while (trav->prev) + trav = trav->prev; + + /* Validate again phase */ + while (trav) { + pair = trav->options->members_list; + while (pair) { + _log_if_option_is_invalid (trav, pair); + pair = pair->next; + } + trav = trav->next; + } + + return ret; } -int -glusterfs_graph_init (xlator_t *graph, int fuse) -{ - volume_opt_list_t *vol_opt = NULL; - - if (fuse) { - /* FUSE needs to be initialized earlier than the - other translators */ - list_for_each_entry (vol_opt, - &graph->volume_options, list) - break; - if (validate_xlator_volume_options (graph, - vol_opt->given_opt) == -1) { - gf_log (graph->name, GF_LOG_ERROR, - "validating translator failed"); - return -1; - } - if (xlator_init (graph) != 0) - return -1; - - graph->ready = 1; - } - if (_xlator_graph_init (graph) == -1) - return -1; - - /* check server or fuse is given */ - if (graph->ctx->top == NULL) { - fprintf (stderr, "no valid translator loaded at the top, or" - "no mount point given. exiting\n"); - gf_log ("glusterfs", GF_LOG_ERROR, - "no valid translator loaded at the top or " - "no mount point given. exiting"); - return -1; - } - - return 0; +int +glusterfs_graph_init (xlator_t *graph, int fuse) +{ + volume_opt_list_t *vol_opt = NULL; + + if (fuse) { + /* FUSE needs to be initialized earlier than the + other translators */ + list_for_each_entry (vol_opt, + &graph->volume_options, list) + break; + if (validate_xlator_volume_options (graph, + vol_opt->given_opt) == -1) { + gf_log (graph->name, GF_LOG_ERROR, + "validating translator failed"); + return -1; + } + if (xlator_init (graph) != 0) + return -1; + + graph->ready = 1; + } + if (_xlator_graph_init (graph) == -1) + return -1; + + /* check server or fuse is given */ + if (graph->ctx->top == NULL) { + fprintf (stderr, "no valid translator loaded at the top, or" + "no mount point given. exiting\n"); + gf_log ("glusterfs", GF_LOG_ERROR, + "no valid translator loaded at the top or " + "no mount point given. exiting"); + return -1; + } + + return 0; } static int gf_remember_xlator_option (struct list_head *options, char *arg) { - glusterfs_ctx_t *ctx = NULL; - cmd_args_t *cmd_args = NULL; - xlator_cmdline_option_t *option = NULL; - int ret = -1; - char *dot = NULL; - char *equals = NULL; + glusterfs_ctx_t *ctx = NULL; + cmd_args_t *cmd_args = NULL; + xlator_cmdline_option_t *option = NULL; + int ret = -1; + char *dot = NULL; + char *equals = NULL; + + ctx = get_global_ctx_ptr (); + cmd_args = &ctx->cmd_args; - ctx = get_global_ctx_ptr (); - cmd_args = &ctx->cmd_args; + option = CALLOC (1, sizeof (xlator_cmdline_option_t)); + INIT_LIST_HEAD (&option->cmd_args); - option = CALLOC (1, sizeof (xlator_cmdline_option_t)); - INIT_LIST_HEAD (&option->cmd_args); + dot = strchr (arg, '.'); + if (!dot) + goto out; - dot = strchr (arg, '.'); - if (!dot) - goto out; + option->volume = CALLOC ((dot - arg), sizeof (char)); + strncpy (option->volume, arg, (dot - arg)); - option->volume = CALLOC ((dot - arg), sizeof (char)); - strncpy (option->volume, arg, (dot - arg)); + equals = strchr (arg, '='); + if (!equals) + goto out; - equals = strchr (arg, '='); - if (!equals) - goto out; + option->key = CALLOC ((equals - dot), sizeof (char)); + strncpy (option->key, dot + 1, (equals - dot - 1)); - option->key = CALLOC ((equals - dot), sizeof (char)); - strncpy (option->key, dot + 1, (equals - dot - 1)); + if (!*(equals + 1)) + goto out; - if (!*(equals + 1)) - goto out; + option->value = strdup (equals + 1); - option->value = strdup (equals + 1); - - list_add (&option->cmd_args, &cmd_args->xlator_options); + list_add (&option->cmd_args, &cmd_args->xlator_options); - ret = 0; + ret = 0; out: - if (ret == -1) { - if (option) { - if (option->volume) - FREE (option->volume); - if (option->key) - FREE (option->key); - if (option->value) - FREE (option->value); - - FREE (option); - } - } - - return ret; + if (ret == -1) { + if (option) { + if (option->volume) + FREE (option->volume); + if (option->key) + FREE (option->key); + if (option->value) + FREE (option->value); + + FREE (option); + } + } + + return ret; } static void gf_add_cmdline_options (xlator_t *graph, cmd_args_t *cmd_args) { - int ret = 0; - xlator_t *trav = graph; - xlator_cmdline_option_t *cmd_option = NULL; - - while (trav) { - list_for_each_entry (cmd_option, - &cmd_args->xlator_options, cmd_args) { - if (!fnmatch (cmd_option->volume, - trav->name, FNM_NOESCAPE)) { - ret = dict_set_str (trav->options, - cmd_option->key, - cmd_option->value); - if (ret == 0) { - gf_log ("glusterfs", GF_LOG_WARNING, - "adding option '%s' for " - "volume '%s' with value '%s'", - cmd_option->key, trav->name, - cmd_option->value); - } else { - gf_log ("glusterfs", GF_LOG_WARNING, - "adding option '%s' for " - "volume '%s' failed: %s", - cmd_option->key, trav->name, - strerror (-ret)); - } - } - } - trav = trav->next; - } + int ret = 0; + xlator_t *trav = graph; + xlator_cmdline_option_t *cmd_option = NULL; + + while (trav) { + list_for_each_entry (cmd_option, + &cmd_args->xlator_options, cmd_args) { + if (!fnmatch (cmd_option->volume, + trav->name, FNM_NOESCAPE)) { + ret = dict_set_str (trav->options, + cmd_option->key, + cmd_option->value); + if (ret == 0) { + gf_log ("glusterfs", GF_LOG_WARNING, + "adding option '%s' for " + "volume '%s' with value '%s'", + cmd_option->key, trav->name, + cmd_option->value); + } else { + gf_log ("glusterfs", GF_LOG_WARNING, + "adding option '%s' for " + "volume '%s' failed: %s", + cmd_option->key, trav->name, + strerror (-ret)); + } + } + } + trav = trav->next; + } } -error_t +error_t parse_opts (int key, char *arg, struct argp_state *state) { - cmd_args_t *cmd_args = NULL; - uint32_t n = 0; - double d = 0.0; - - cmd_args = state->input; - - switch (key) { - case ARGP_VOLFILE_SERVER_KEY: - cmd_args->volfile_server = strdup (arg); - break; - + cmd_args_t *cmd_args = NULL; + uint32_t n = 0; + double d = 0.0; + + cmd_args = state->input; + + switch (key) { + case ARGP_VOLFILE_SERVER_KEY: + cmd_args->volfile_server = strdup (arg); + break; + case ARGP_VOLFILE_MAX_FETCH_ATTEMPTS: - n = 0; - - if (gf_string2uint_base10 (arg, &n) == 0) { - cmd_args->max_connect_attempts = n; - break; - } - - argp_failure (state, -1, 0, - "Invalid limit on connect attempts %s", arg); - break; - - case ARGP_VOLUME_FILE_KEY: - cmd_args->volume_file = strdup (arg); - break; - + n = 0; + + if (gf_string2uint_base10 (arg, &n) == 0) { + cmd_args->max_connect_attempts = n; + break; + } + + argp_failure (state, -1, 0, + "Invalid limit on connect attempts %s", arg); + break; + + case ARGP_VOLUME_FILE_KEY: + cmd_args->volume_file = strdup (arg); + break; + case ARGP_LOG_SERVER_KEY: - cmd_args->log_server = strdup (arg); - break; - - case ARGP_LOG_LEVEL_KEY: - if (strcasecmp (arg, ARGP_LOG_LEVEL_NONE_OPTION) == 0) { - cmd_args->log_level = GF_LOG_NONE; - break; - } - if (strcasecmp (arg, ARGP_LOG_LEVEL_CRITICAL_OPTION) == 0) { - cmd_args->log_level = GF_LOG_CRITICAL; - break; - } - if (strcasecmp (arg, ARGP_LOG_LEVEL_ERROR_OPTION) == 0) { - cmd_args->log_level = GF_LOG_ERROR; - break; - } - if (strcasecmp (arg, ARGP_LOG_LEVEL_WARNING_OPTION) == 0) { - cmd_args->log_level = GF_LOG_WARNING; - break; - } - if (strcasecmp (arg, ARGP_LOG_LEVEL_NORMAL_OPTION) == 0) { - cmd_args->log_level = GF_LOG_NORMAL; - break; - } - if (strcasecmp (arg, ARGP_LOG_LEVEL_DEBUG_OPTION) == 0) { - cmd_args->log_level = GF_LOG_DEBUG; - break; - } - if (strcasecmp (arg, ARGP_LOG_LEVEL_TRACE_OPTION) == 0) { - cmd_args->log_level = GF_LOG_TRACE; - break; - } - - argp_failure (state, -1, 0, "unknown log level %s", arg); - break; - - case ARGP_LOG_FILE_KEY: - cmd_args->log_file = strdup (arg); - break; - - case ARGP_VOLFILE_SERVER_PORT_KEY: - n = 0; - - if (gf_string2uint_base10 (arg, &n) == 0) { - cmd_args->volfile_server_port = n; - break; - } - - argp_failure (state, -1, 0, - "unknown volfile server port %s", arg); - break; - - case ARGP_LOG_SERVER_PORT_KEY: - n = 0; - - if (gf_string2uint_base10 (arg, &n) == 0) { - cmd_args->log_server_port = n; - break; - } - - argp_failure (state, -1, 0, - "unknown log server port %s", arg); - break; - - case ARGP_VOLFILE_SERVER_TRANSPORT_KEY: - cmd_args->volfile_server_transport = strdup (arg); - break; - - case ARGP_VOLFILE_ID_KEY: - cmd_args->volfile_id = strdup (arg); - break; - - case ARGP_PID_FILE_KEY: - cmd_args->pid_file = strdup (arg); - break; - - case ARGP_NO_DAEMON_KEY: - cmd_args->no_daemon_mode = ENABLE_NO_DAEMON_MODE; - break; - - case ARGP_RUN_ID_KEY: - cmd_args->run_id = strdup (arg); - break; - - case ARGP_DEBUG_KEY: - cmd_args->debug_mode = ENABLE_DEBUG_MODE; - break; - - case ARGP_DISABLE_DIRECT_IO_MODE_KEY: - cmd_args->fuse_direct_io_mode_flag = _gf_false; - break; - - case ARGP_ENTRY_TIMEOUT_KEY: - d = 0.0; - - gf_string2double (arg, &d); - if (!(d < 0.0)) { - cmd_args->fuse_entry_timeout = d; - break; - } - - argp_failure (state, -1, 0, "unknown entry timeout %s", arg); - break; - - case ARGP_ATTRIBUTE_TIMEOUT_KEY: - d = 0.0; - - gf_string2double (arg, &d); - if (!(d < 0.0)) { - cmd_args->fuse_attribute_timeout = d; - break; - } - - argp_failure (state, -1, 0, - "unknown attribute timeout %s", arg); - break; - - case ARGP_VOLFILE_CHECK_KEY: + cmd_args->log_server = strdup (arg); + break; + + case ARGP_LOG_LEVEL_KEY: + if (strcasecmp (arg, ARGP_LOG_LEVEL_NONE_OPTION) == 0) { + cmd_args->log_level = GF_LOG_NONE; + break; + } + if (strcasecmp (arg, ARGP_LOG_LEVEL_CRITICAL_OPTION) == 0) { + cmd_args->log_level = GF_LOG_CRITICAL; + break; + } + if (strcasecmp (arg, ARGP_LOG_LEVEL_ERROR_OPTION) == 0) { + cmd_args->log_level = GF_LOG_ERROR; + break; + } + if (strcasecmp (arg, ARGP_LOG_LEVEL_WARNING_OPTION) == 0) { + cmd_args->log_level = GF_LOG_WARNING; + break; + } + if (strcasecmp (arg, ARGP_LOG_LEVEL_NORMAL_OPTION) == 0) { + cmd_args->log_level = GF_LOG_NORMAL; + break; + } + if (strcasecmp (arg, ARGP_LOG_LEVEL_DEBUG_OPTION) == 0) { + cmd_args->log_level = GF_LOG_DEBUG; + break; + } + if (strcasecmp (arg, ARGP_LOG_LEVEL_TRACE_OPTION) == 0) { + cmd_args->log_level = GF_LOG_TRACE; + break; + } + + argp_failure (state, -1, 0, "unknown log level %s", arg); + break; + + case ARGP_LOG_FILE_KEY: + cmd_args->log_file = strdup (arg); + break; + + case ARGP_VOLFILE_SERVER_PORT_KEY: + n = 0; + + if (gf_string2uint_base10 (arg, &n) == 0) { + cmd_args->volfile_server_port = n; + break; + } + + argp_failure (state, -1, 0, + "unknown volfile server port %s", arg); + break; + + case ARGP_LOG_SERVER_PORT_KEY: + n = 0; + + if (gf_string2uint_base10 (arg, &n) == 0) { + cmd_args->log_server_port = n; + break; + } + + argp_failure (state, -1, 0, + "unknown log server port %s", arg); + break; + + case ARGP_VOLFILE_SERVER_TRANSPORT_KEY: + cmd_args->volfile_server_transport = strdup (arg); + break; + + case ARGP_VOLFILE_ID_KEY: + cmd_args->volfile_id = strdup (arg); + break; + + case ARGP_PID_FILE_KEY: + cmd_args->pid_file = strdup (arg); + break; + + case ARGP_NO_DAEMON_KEY: + cmd_args->no_daemon_mode = ENABLE_NO_DAEMON_MODE; + break; + + case ARGP_RUN_ID_KEY: + cmd_args->run_id = strdup (arg); + break; + + case ARGP_DEBUG_KEY: + cmd_args->debug_mode = ENABLE_DEBUG_MODE; + break; + + case ARGP_DISABLE_DIRECT_IO_MODE_KEY: + cmd_args->fuse_direct_io_mode_flag = _gf_false; + break; + + case ARGP_ENTRY_TIMEOUT_KEY: + d = 0.0; + + gf_string2double (arg, &d); + if (!(d < 0.0)) { + cmd_args->fuse_entry_timeout = d; + break; + } + + argp_failure (state, -1, 0, "unknown entry timeout %s", arg); + break; + + case ARGP_ATTRIBUTE_TIMEOUT_KEY: + d = 0.0; + + gf_string2double (arg, &d); + if (!(d < 0.0)) { + cmd_args->fuse_attribute_timeout = d; + break; + } + + argp_failure (state, -1, 0, + "unknown attribute timeout %s", arg); + break; + + case ARGP_VOLFILE_CHECK_KEY: cmd_args->volfile_check = 1; break; - case ARGP_VOLUME_NAME_KEY: - cmd_args->volume_name = strdup (arg); - break; + case ARGP_VOLUME_NAME_KEY: + cmd_args->volume_name = strdup (arg); + break; - case ARGP_XLATOR_OPTION_KEY: - gf_remember_xlator_option (&cmd_args->xlator_options, arg); - break; + case ARGP_XLATOR_OPTION_KEY: + gf_remember_xlator_option (&cmd_args->xlator_options, arg); + break; -#ifdef GF_DARWIN_HOST_OS - case ARGP_NON_LOCAL_KEY: - cmd_args->non_local = _gf_true; - break; +#ifdef GF_DARWIN_HOST_OS + case ARGP_NON_LOCAL_KEY: + cmd_args->non_local = _gf_true; + break; #endif /* DARWIN */ - case ARGP_KEY_NO_ARGS: - break; - - case ARGP_KEY_ARG: - if (state->arg_num >= 1) - argp_usage (state); - - cmd_args->mount_point = strdup (arg); - break; - } - - return 0; + case ARGP_KEY_NO_ARGS: + break; + + case ARGP_KEY_ARG: + if (state->arg_num >= 1) + argp_usage (state); + + cmd_args->mount_point = strdup (arg); + break; + } + + return 0; } -void +void cleanup_and_exit (int signum) { - glusterfs_ctx_t *ctx = NULL; - xlator_t *trav = NULL; - - ctx = get_global_ctx_ptr (); - - gf_log ("glusterfs", GF_LOG_WARNING, "shutting down"); - - if (ctx->pidfp) { - flock (fileno (ctx->pidfp), LOCK_UN); - fclose (ctx->pidfp); - ctx->pidfp = NULL; - } - - if (ctx->specfp) { - fclose (ctx->specfp); - ctx->specfp = NULL; - } - - if (ctx->cmd_args.pid_file) { - unlink (ctx->cmd_args.pid_file); - ctx->cmd_args.pid_file = NULL; - } - - if (ctx->graph) { - trav = ctx->graph; - ctx->graph = NULL; - while (trav) { - trav->fini (trav); - trav = trav->next; - } - exit (0); - } else { - gf_log ("glusterfs", GF_LOG_DEBUG, "no graph present"); - } + glusterfs_ctx_t *ctx = NULL; + xlator_t *trav = NULL; + + ctx = get_global_ctx_ptr (); + + gf_log ("glusterfs", GF_LOG_WARNING, "shutting down"); + + if (ctx->pidfp) { + flock (fileno (ctx->pidfp), LOCK_UN); + fclose (ctx->pidfp); + ctx->pidfp = NULL; + } + + if (ctx->specfp) { + fclose (ctx->specfp); + ctx->specfp = NULL; + } + + if (ctx->cmd_args.pid_file) { + unlink (ctx->cmd_args.pid_file); + ctx->cmd_args.pid_file = NULL; + } + + if (ctx->graph) { + trav = ctx->graph; + ctx->graph = NULL; + while (trav) { + trav->fini (trav); + trav = trav->next; + } + exit (0); + } else { + gf_log ("glusterfs", GF_LOG_DEBUG, "no graph present"); + } } static char * zr_build_process_uuid () { - char tmp_str[1024] = {0,}; - char hostname[256] = {0,}; - struct timeval tv = {0,}; - struct tm now = {0, }; - char now_str[32]; - - if (-1 == gettimeofday(&tv, NULL)) { - gf_log ("", GF_LOG_ERROR, - "gettimeofday: failed %s", - strerror (errno)); - } - - if (-1 == gethostname (hostname, 256)) { - gf_log ("", GF_LOG_ERROR, - "gethostname: failed %s", - strerror (errno)); - } - - localtime_r (&tv.tv_sec, &now); - strftime (now_str, 32, "%Y/%m/%d-%H:%M:%S", &now); - snprintf (tmp_str, 1024, "%s-%d-%s:%ld", - hostname, getpid(), now_str, tv.tv_usec); - - return strdup (tmp_str); + char tmp_str[1024] = {0,}; + char hostname[256] = {0,}; + struct timeval tv = {0,}; + struct tm now = {0, }; + char now_str[32]; + + if (-1 == gettimeofday(&tv, NULL)) { + gf_log ("", GF_LOG_ERROR, + "gettimeofday: failed %s", + strerror (errno)); + } + + if (-1 == gethostname (hostname, 256)) { + gf_log ("", GF_LOG_ERROR, + "gethostname: failed %s", + strerror (errno)); + } + + localtime_r (&tv.tv_sec, &now); + strftime (now_str, 32, "%Y/%m/%d-%H:%M:%S", &now); + snprintf (tmp_str, 1024, "%s-%d-%s:%ld", + hostname, getpid(), now_str, tv.tv_usec); + + return strdup (tmp_str); } #define GF_SERVER_PROCESS 0 @@ -992,24 +992,24 @@ zr_build_process_uuid () static uint8_t gf_get_process_mode (char *exec_name) { - char *dup_execname = NULL, *base = NULL; - uint8_t ret = 0; - - dup_execname = strdup (exec_name); - base = basename (dup_execname); - - if (!strncmp (base, "glusterfsd", 10)) { - ret = GF_SERVER_PROCESS; - } else { - ret = GF_CLIENT_PROCESS; - } - - free (dup_execname); - - return ret; + char *dup_execname = NULL, *base = NULL; + uint8_t ret = 0; + + dup_execname = strdup (exec_name); + base = basename (dup_execname); + + if (!strncmp (base, "glusterfsd", 10)) { + ret = GF_SERVER_PROCESS; + } else { + ret = GF_CLIENT_PROCESS; + } + + free (dup_execname); + + return ret; } -int +int set_log_file_path (cmd_args_t *cmd_args) { int i = 0; @@ -1017,14 +1017,14 @@ set_log_file_path (cmd_args_t *cmd_args) int port = 0; char *tmp_ptr = NULL; char tmp_str[1024] = {0,}; - + if (cmd_args->mount_point) { for (i = 1; i < strlen (cmd_args->mount_point); i++) { tmp_str[i-1] = cmd_args->mount_point[i]; if (cmd_args->mount_point[i] == '/') tmp_str[i-1] = '-'; } - ret = asprintf (&cmd_args->log_file, + ret = asprintf (&cmd_args->log_file, DEFAULT_LOG_FILE_DIRECTORY "/%s.log", tmp_str); if (-1 == ret) { @@ -1032,7 +1032,7 @@ set_log_file_path (cmd_args_t *cmd_args) "asprintf failed while setting up log-file"); } goto done; - } + } if (cmd_args->volume_file) { for (i = 0; i < strlen (cmd_args->volume_file); i++) { @@ -1040,16 +1040,16 @@ set_log_file_path (cmd_args_t *cmd_args) if (cmd_args->volume_file[i] == '/') tmp_str[i] = '-'; } - ret = asprintf (&cmd_args->log_file, + ret = asprintf (&cmd_args->log_file, DEFAULT_LOG_FILE_DIRECTORY "/%s.log", tmp_str); if (-1 == ret) { - gf_log ("glusterfsd", GF_LOG_ERROR, + gf_log ("glusterfsd", GF_LOG_ERROR, "asprintf failed while setting up log-file"); } goto done; } - + if (cmd_args->volfile_server) { port = 1; tmp_ptr = "default"; @@ -1059,39 +1059,39 @@ set_log_file_path (cmd_args_t *cmd_args) if (cmd_args->volfile_id) tmp_ptr = cmd_args->volfile_id; - ret = asprintf (&cmd_args->log_file, + ret = asprintf (&cmd_args->log_file, DEFAULT_LOG_FILE_DIRECTORY "/%s-%s-%d.log", cmd_args->volfile_server, tmp_ptr, port); if (-1 == ret) { - gf_log ("glusterfsd", GF_LOG_ERROR, + gf_log ("glusterfsd", GF_LOG_ERROR, "asprintf failed while setting up log-file"); } } - done: +done: return ret; } -int +int main (int argc, char *argv[]) { - glusterfs_ctx_t *ctx = NULL; - cmd_args_t *cmd_args = NULL; - call_pool_t *pool = NULL; - struct stat stbuf; - char tmp_logfile[1024] = { 0 }; - char *tmp_logfile_dyn = NULL; + glusterfs_ctx_t *ctx = NULL; + cmd_args_t *cmd_args = NULL; + call_pool_t *pool = NULL; + struct stat stbuf; + char tmp_logfile[1024] = { 0 }; + char *tmp_logfile_dyn = NULL; char *tmp_logfilebase = NULL; - char timestr[256] = { 0 }; - time_t utime; - struct tm *tm = NULL; - int ret = 0; - struct rlimit lim; - FILE *specfp = NULL; - xlator_t *graph = NULL; - xlator_t *trav = NULL; - int fuse_volume_found = 0; - int xl_count = 0; - uint8_t process_mode = 0; + char timestr[256] = { 0 }; + time_t utime; + struct tm *tm = NULL; + int ret = 0; + struct rlimit lim; + FILE *specfp = NULL; + xlator_t *graph = NULL; + xlator_t *trav = NULL; + int fuse_volume_found = 0; + int xl_count = 0; + uint8_t process_mode = 0; int pipe_fd[2]; int gf_success = 0; int gf_failure = -1; @@ -1100,36 +1100,36 @@ main (int argc, char *argv[]) if (ret) return ret; - utime = time (NULL); - ctx = glusterfs_ctx_get (); - process_mode = gf_get_process_mode (argv[0]); - set_global_ctx_ptr (ctx); - ctx->process_uuid = zr_build_process_uuid (); - cmd_args = &ctx->cmd_args; - - /* parsing command line arguments */ - cmd_args->log_level = DEFAULT_LOG_LEVEL; - cmd_args->fuse_direct_io_mode_flag = _gf_true; - - INIT_LIST_HEAD (&cmd_args->xlator_options); - - argp_parse (&argp, argc, argv, ARGP_IN_ORDER, NULL, cmd_args); - - if (ENABLE_DEBUG_MODE == cmd_args->debug_mode) { - cmd_args->log_level = GF_LOG_DEBUG; - cmd_args->log_file = "/dev/stdout"; - cmd_args->no_daemon_mode = ENABLE_NO_DAEMON_MODE; - } - - if ((cmd_args->volfile_server == NULL) - && (cmd_args->volume_file == NULL)) { - if (process_mode == GF_SERVER_PROCESS) - cmd_args->volume_file = strdup (DEFAULT_SERVER_VOLUME_FILE); - else - cmd_args->volume_file = strdup (DEFAULT_CLIENT_VOLUME_FILE); - } - - if (cmd_args->log_file == NULL) { + utime = time (NULL); + ctx = glusterfs_ctx_get (); + process_mode = gf_get_process_mode (argv[0]); + set_global_ctx_ptr (ctx); + ctx->process_uuid = zr_build_process_uuid (); + cmd_args = &ctx->cmd_args; + + /* parsing command line arguments */ + cmd_args->log_level = DEFAULT_LOG_LEVEL; + cmd_args->fuse_direct_io_mode_flag = _gf_true; + + INIT_LIST_HEAD (&cmd_args->xlator_options); + + argp_parse (&argp, argc, argv, ARGP_IN_ORDER, NULL, cmd_args); + + if (ENABLE_DEBUG_MODE == cmd_args->debug_mode) { + cmd_args->log_level = GF_LOG_DEBUG; + cmd_args->log_file = "/dev/stdout"; + cmd_args->no_daemon_mode = ENABLE_NO_DAEMON_MODE; + } + + if ((cmd_args->volfile_server == NULL) + && (cmd_args->volume_file == NULL)) { + if (process_mode == GF_SERVER_PROCESS) + cmd_args->volume_file = strdup (DEFAULT_SERVER_VOLUME_FILE); + else + cmd_args->volume_file = strdup (DEFAULT_CLIENT_VOLUME_FILE); + } + + if (cmd_args->log_file == NULL) { ret = set_log_file_path (cmd_args); if (-1 == ret) { fprintf (stderr, "failed to set the log file path.. " @@ -1140,34 +1140,34 @@ main (int argc, char *argv[]) ctx->page_size = 128 * GF_UNIT_KB; ctx->iobuf_pool = iobuf_pool_new (8 * GF_UNIT_MB, ctx->page_size + 4096); - ctx->event_pool = event_pool_new (DEFAULT_EVENT_POOL_SIZE); - pthread_mutex_init (&(ctx->lock), NULL); - pool = ctx->pool = CALLOC (1, sizeof (call_pool_t)); - ERR_ABORT (ctx->pool); - LOCK_INIT (&pool->lock); - INIT_LIST_HEAD (&pool->all_frames); + ctx->event_pool = event_pool_new (DEFAULT_EVENT_POOL_SIZE); + pthread_mutex_init (&(ctx->lock), NULL); + pool = ctx->pool = CALLOC (1, sizeof (call_pool_t)); + ERR_ABORT (ctx->pool); + LOCK_INIT (&pool->lock); + INIT_LIST_HEAD (&pool->all_frames); /* initializing logs */ - if (cmd_args->run_id) { - ret = stat (cmd_args->log_file, &stbuf); - /* If its /dev/null, or /dev/stdout, /dev/stderr, - * let it use the same, no need to alter - */ - if (((ret == 0) && - (S_ISREG (stbuf.st_mode) || S_ISLNK (stbuf.st_mode))) || - (ret == -1)) { - /* Have seperate logfile per run */ - tm = localtime (&utime); - strftime (timestr, 256, "%Y%m%d.%H%M%S", tm); - sprintf (tmp_logfile, "%s.%s.%d", - cmd_args->log_file, timestr, getpid ()); - - /* Create symlink to actual log file */ - unlink (cmd_args->log_file); + if (cmd_args->run_id) { + ret = stat (cmd_args->log_file, &stbuf); + /* If its /dev/null, or /dev/stdout, /dev/stderr, + * let it use the same, no need to alter + */ + if (((ret == 0) && + (S_ISREG (stbuf.st_mode) || S_ISLNK (stbuf.st_mode))) || + (ret == -1)) { + /* Have seperate logfile per run */ + tm = localtime (&utime); + strftime (timestr, 256, "%Y%m%d.%H%M%S", tm); + sprintf (tmp_logfile, "%s.%s.%d", + cmd_args->log_file, timestr, getpid ()); + + /* Create symlink to actual log file */ + unlink (cmd_args->log_file); tmp_logfile_dyn = strdup (tmp_logfile); tmp_logfilebase = basename (tmp_logfile_dyn); - ret = symlink (tmp_logfilebase, cmd_args->log_file); + ret = symlink (tmp_logfilebase, cmd_args->log_file); if (-1 == ret) { fprintf (stderr, "symlink of logfile failed"); } else { @@ -1176,98 +1176,98 @@ main (int argc, char *argv[]) } FREE (tmp_logfile_dyn); - } - } - - gf_global_variable_init (); - - if (gf_log_init (cmd_args->log_file) == -1) { - fprintf (stderr, - "failed to open logfile %s. exiting\n", - cmd_args->log_file); - return -1; - } - gf_log_set_loglevel (cmd_args->log_level); + } + } + + gf_global_variable_init (); + + if (gf_log_init (cmd_args->log_file) == -1) { + fprintf (stderr, + "failed to open logfile %s. exiting\n", + cmd_args->log_file); + return -1; + } + gf_log_set_loglevel (cmd_args->log_level); gf_proc_dump_init(); - - /* setting up environment */ - lim.rlim_cur = RLIM_INFINITY; - lim.rlim_max = RLIM_INFINITY; - if (setrlimit (RLIMIT_CORE, &lim) == -1) { - fprintf (stderr, "ignoring %s\n", - strerror (errno)); - } + + /* setting up environment */ + lim.rlim_cur = RLIM_INFINITY; + lim.rlim_max = RLIM_INFINITY; + if (setrlimit (RLIMIT_CORE, &lim) == -1) { + fprintf (stderr, "ignoring %s\n", + strerror (errno)); + } #ifdef DEBUG - mtrace (); + mtrace (); #endif - signal (SIGUSR1, (sighandler_t) gf_proc_dump_info); - signal (SIGSEGV, gf_print_trace); - signal (SIGABRT, gf_print_trace); - signal (SIGPIPE, SIG_IGN); - signal (SIGHUP, gf_log_logrotate); - signal (SIGTERM, cleanup_and_exit); - /* This is used to dump details */ - /* signal (SIGUSR2, (sighandler_t) glusterfs_stats); */ - - /* getting and parsing volume file */ - if ((specfp = _get_specfp (ctx)) == NULL) { - /* _get_specfp() prints necessary error message */ - gf_log ("glusterfs", GF_LOG_ERROR, "exiting\n"); - argp_help (&argp, stderr, ARGP_HELP_SEE, (char *) argv[0]); - return -1; - } - - if ((graph = _parse_specfp (ctx, specfp)) == NULL) { - /* _parse_specfp() prints necessary error message */ - fprintf (stderr, "exiting\n"); - gf_log ("glusterfs", GF_LOG_ERROR, "exiting"); - return -1; - } - ctx->specfp = specfp; - - /* check whether MOUNT-POINT argument and fuse volume are given - * at same time or not. If not, add argument MOUNT-POINT to graph - * as top volume if given - */ - trav = graph; - fuse_volume_found = 0; - - while (trav) { - if (strcmp (trav->type, ZR_XLATOR_FUSE) == 0) { - if (dict_get (trav->options, - ZR_MOUNTPOINT_OPT) != NULL) { - trav->ctx = graph->ctx; - fuse_volume_found = 1; - } - } - - xl_count++; /* Getting this value right is very important */ - trav = trav->next; - } - - ctx->xl_count = xl_count + 1; - - if (!fuse_volume_found && (cmd_args->mount_point != NULL)) { - if ((graph = _add_fuse_mount (graph)) == NULL) { - /* _add_fuse_mount() prints necessary - * error message - */ - fprintf (stderr, "exiting\n"); - gf_log ("glusterfs", GF_LOG_ERROR, "exiting"); - return -1; - } - } - - /* daemonize now */ - if (!cmd_args->no_daemon_mode) { + signal (SIGUSR1, (sighandler_t) gf_proc_dump_info); + signal (SIGSEGV, gf_print_trace); + signal (SIGABRT, gf_print_trace); + signal (SIGPIPE, SIG_IGN); + signal (SIGHUP, gf_log_logrotate); + signal (SIGTERM, cleanup_and_exit); + /* This is used to dump details */ + /* signal (SIGUSR2, (sighandler_t) glusterfs_stats); */ + + /* getting and parsing volume file */ + if ((specfp = _get_specfp (ctx)) == NULL) { + /* _get_specfp() prints necessary error message */ + gf_log ("glusterfs", GF_LOG_ERROR, "exiting\n"); + argp_help (&argp, stderr, ARGP_HELP_SEE, (char *) argv[0]); + return -1; + } + + if ((graph = _parse_specfp (ctx, specfp)) == NULL) { + /* _parse_specfp() prints necessary error message */ + fprintf (stderr, "exiting\n"); + gf_log ("glusterfs", GF_LOG_ERROR, "exiting"); + return -1; + } + ctx->specfp = specfp; + + /* check whether MOUNT-POINT argument and fuse volume are given + * at same time or not. If not, add argument MOUNT-POINT to graph + * as top volume if given + */ + trav = graph; + fuse_volume_found = 0; + + while (trav) { + if (strcmp (trav->type, ZR_XLATOR_FUSE) == 0) { + if (dict_get (trav->options, + ZR_MOUNTPOINT_OPT) != NULL) { + trav->ctx = graph->ctx; + fuse_volume_found = 1; + } + } + + xl_count++; /* Getting this value right is very important */ + trav = trav->next; + } + + ctx->xl_count = xl_count + 1; + + if (!fuse_volume_found && (cmd_args->mount_point != NULL)) { + if ((graph = _add_fuse_mount (graph)) == NULL) { + /* _add_fuse_mount() prints necessary + * error message + */ + fprintf (stderr, "exiting\n"); + gf_log ("glusterfs", GF_LOG_ERROR, "exiting"); + return -1; + } + } + + /* daemonize now */ + if (!cmd_args->no_daemon_mode) { if (gf_daemon (pipe_fd) == -1) { - gf_log ("glusterfs", GF_LOG_ERROR, - "unable to run in daemon mode: %s", - strerror (errno)); - return -1; - } - - /* we are daemon now */ + gf_log ("glusterfs", GF_LOG_ERROR, + "unable to run in daemon mode: %s", + strerror (errno)); + return -1; + } + + /* we are daemon now */ _gf_dump_details (argc, argv); if (cmd_args->pid_file != NULL) { ctx->pidfp = fopen (cmd_args->pid_file, "a+"); @@ -1288,7 +1288,7 @@ main (int argc, char *argv[]) (LOCK_EX | LOCK_NB)); if (ret == -1) { gf_log ("glusterfs", GF_LOG_ERROR, - "Is another instance of %s running?", + "Is another instance of %s running?", argv[0]); fclose (ctx->pidfp); if (write (pipe_fd[1], &gf_failure, @@ -1330,44 +1330,44 @@ main (int argc, char *argv[]) gf_log_volume_file (ctx->specfp); - gf_log ("glusterfs", GF_LOG_DEBUG, - "running in pid %d", getpid ()); - - gf_timer_registry_init (ctx); - - /* override xlator options with command line options - * where applicable - */ - gf_add_cmdline_options (graph, cmd_args); - - ctx->graph = graph; - if (glusterfs_graph_init (graph, fuse_volume_found) != 0) { - gf_log ("glusterfs", GF_LOG_ERROR, - "translator initialization failed. exiting"); - if (!cmd_args->no_daemon_mode && + gf_log ("glusterfs", GF_LOG_DEBUG, + "running in pid %d", getpid ()); + + gf_timer_registry_init (ctx); + + /* override xlator options with command line options + * where applicable + */ + gf_add_cmdline_options (graph, cmd_args); + + ctx->graph = graph; + if (glusterfs_graph_init (graph, fuse_volume_found) != 0) { + gf_log ("glusterfs", GF_LOG_ERROR, + "translator initialization failed. exiting"); + if (!cmd_args->no_daemon_mode && (write (pipe_fd[1], &gf_failure, sizeof (int)) < 0)) { - gf_log ("glusterfs", GF_LOG_ERROR, + gf_log ("glusterfs", GF_LOG_ERROR, "Write on pipe failed," "daemonize problem.exiting: %s", - strerror (errno)); - } - return -1; - } + strerror (errno)); + } + return -1; + } - /* Send PARENT_UP notify to all the translators now */ - graph->notify (graph, GF_EVENT_PARENT_UP, ctx->graph); + /* Send PARENT_UP notify to all the translators now */ + graph->notify (graph, GF_EVENT_PARENT_UP, ctx->graph); - gf_log ("glusterfs", GF_LOG_NORMAL, "Successfully started"); + gf_log ("glusterfs", GF_LOG_NORMAL, "Successfully started"); - if (!cmd_args->no_daemon_mode && + if (!cmd_args->no_daemon_mode && (write (pipe_fd[1], &gf_success, sizeof (int)) < 0)) { - gf_log ("glusterfs", GF_LOG_ERROR, + gf_log ("glusterfs", GF_LOG_ERROR, "Write on pipe failed," "daemonize problem. exiting: %s", - strerror (errno)); - return -1; - } - + strerror (errno)); + return -1; + } + if (cmd_args->log_server) { gf_log_central_init (ctx, cmd_args->log_server, "socket", cmd_args->log_server_port); @@ -1376,7 +1376,7 @@ main (int argc, char *argv[]) "socket", cmd_args->volfile_server_port); } - event_dispatch (ctx->event_pool); + event_dispatch (ctx->event_pool); - return 0; + return 0; } |