diff options
Diffstat (limited to 'xlators/mgmt/glusterd/src/glusterd-utils.c')
| -rw-r--r-- | xlators/mgmt/glusterd/src/glusterd-utils.c | 244 |
1 files changed, 151 insertions, 93 deletions
diff --git a/xlators/mgmt/glusterd/src/glusterd-utils.c b/xlators/mgmt/glusterd/src/glusterd-utils.c index 0e24aca77ed..0b3507da29d 100644 --- a/xlators/mgmt/glusterd/src/glusterd-utils.c +++ b/xlators/mgmt/glusterd/src/glusterd-utils.c @@ -37,6 +37,7 @@ #include "statedump.h" #include "glusterd-mem-types.h" #include "glusterd.h" +#include "glusterd-op-sm.h" #include "glusterd-sm.h" #include "glusterd-utils.h" #include "glusterd-store.h" @@ -1109,11 +1110,13 @@ glusterd_volume_compute_cksum (glusterd_volinfo_t *volinfo) char path[PATH_MAX] = {0,}; char cksum_path[PATH_MAX] = {0,}; char filepath[PATH_MAX] = {0,}; - DIR *dir = NULL; - struct dirent *entry = NULL; int fd = -1; uint32_t cksum = 0; char buf[4096] = {0,}; + char sort_filepath[PATH_MAX] = {0}; + gf_boolean_t unlink_sortfile = _gf_false; + char sort_cmd[2*PATH_MAX + 32]; + int sort_fd = 0; GF_ASSERT (volinfo); @@ -1134,50 +1137,34 @@ glusterd_volume_compute_cksum (glusterd_volinfo_t *volinfo) goto out; } - - dir = opendir (path); - - glusterd_for_each_entry (entry, dir); - -/* while (entry) { - - snprintf (filepath, sizeof (filepath), "%s/%s", path, - entry->d_name); - - if (!strcmp (entry->d_name, "bricks") || - !strcmp (entry->d_name, "run")) { - glusterd_for_each_entry (entry, dir); - continue; - } - - ret = get_checksum_for_path (filepath, &cksum); - - if (ret) { - gf_log ("", GF_LOG_ERROR, "Unable to get checksum" - " for path: %s", filepath); - goto out; - } - - snprintf (buf, sizeof (buf), "%s=%u\n", entry->d_name, cksum); - ret = write (fd, buf, strlen (buf)); - - if (ret <= 0) { - ret = -1; - goto out; - } - - glusterd_for_each_entry (entry, dir); - } -*/ - snprintf (filepath, sizeof (filepath), "%s/%s", path, GLUSTERD_VOLUME_INFO_FILE); + snprintf (sort_filepath, sizeof (sort_filepath), "/tmp/%s.XXXXXX", + volinfo->volname); + sort_fd = mkstemp(sort_filepath); + if (sort_fd < 0) { + gf_log ("", GF_LOG_ERROR, "Could not generate temp file, " + "reason: %s for volume: %s", strerror (errno), + volinfo->volname); + goto out; + } else { + unlink_sortfile = _gf_true; + close (sort_fd); + } - ret = get_checksum_for_path (filepath, &cksum); + snprintf (sort_cmd, sizeof (sort_cmd), "sort %s -o %s", + filepath, sort_filepath); + ret = system (sort_cmd); + if (ret) { + gf_log ("", GF_LOG_ERROR, "failed to sort file %s to %s", + filepath, sort_filepath); + goto out; + } + ret = get_checksum_for_path (sort_filepath, &cksum); if (ret) { gf_log ("", GF_LOG_ERROR, "Unable to get checksum" - " for path: %s", filepath); + " for path: %s", sort_filepath); goto out; } @@ -1200,14 +1187,43 @@ out: if (fd > 0) close (fd); - if (dir) - closedir (dir); - + if (unlink_sortfile) + unlink (sort_filepath); gf_log ("", GF_LOG_DEBUG, "Returning with %d", ret); return ret; } +void +_add_volume_option_to_dict (dict_t *this, char *key, data_t *value, void *data) +{ + int exists = 0; + glusterd_volopt_ctx_t *ctx = NULL; + char optkey[512] = {0,}; + int ret = -1; + + exists = glusterd_check_option_exists (key, NULL); + if (0 == exists) + return; + + ctx = data; + snprintf (optkey, sizeof (optkey), "volume%d.key%d", ctx->count, + ctx->opt_count); + ret = dict_set_str (ctx->dict, optkey, key); + if (ret) + gf_log ("", GF_LOG_ERROR, "option add for key%d %s", + ctx->count, key); + snprintf (optkey, sizeof (optkey), "volume%d.value%d", ctx->count, + ctx->opt_count); + ret = dict_set_str (ctx->dict, optkey, value->data); + if (ret) + gf_log ("", GF_LOG_ERROR, "option add for value%d %s", + ctx->count, value->data); + ctx->opt_count++; + + return; +} + int32_t glusterd_add_volume_to_dict (glusterd_volinfo_t *volinfo, dict_t *dict, int32_t count) @@ -1218,6 +1234,7 @@ glusterd_add_volume_to_dict (glusterd_volinfo_t *volinfo, int32_t i = 1; char uuid_str[50] = {0,}; char *volume_id_str = NULL; + glusterd_volopt_ctx_t ctx = {0}; GF_ASSERT (dict); GF_ASSERT (volinfo); @@ -1227,37 +1244,37 @@ glusterd_add_volume_to_dict (glusterd_volinfo_t *volinfo, if (ret) goto out; - memset (&key, 0, sizeof (key)); + memset (key, 0, sizeof (key)); snprintf (key, sizeof (key), "volume%d.type", count); ret = dict_set_int32 (dict, key, volinfo->type); if (ret) goto out; - memset (&key, 0, sizeof (key)); + memset (key, 0, sizeof (key)); snprintf (key, sizeof (key), "volume%d.brick_count", count); ret = dict_set_int32 (dict, key, volinfo->brick_count); if (ret) goto out; - memset (&key, 0, sizeof (key)); + memset (key, 0, sizeof (key)); snprintf (key, sizeof (key), "volume%d.version", count); ret = dict_set_int32 (dict, key, volinfo->version); if (ret) goto out; - memset (&key, 0, sizeof (key)); + memset (key, 0, sizeof (key)); snprintf (key, sizeof (key), "volume%d.status", count); ret = dict_set_int32 (dict, key, volinfo->status); if (ret) goto out; - memset (&key, 0, sizeof (key)); + memset (key, 0, sizeof (key)); snprintf (key, sizeof (key), "volume%d.sub_count", count); ret = dict_set_int32 (dict, key, volinfo->sub_count); if (ret) goto out; - memset (&key, 0, sizeof (key)); + memset (key, 0, sizeof (key)); snprintf (key, sizeof (key), "volume%d.ckusm", count); ret = dict_set_int64 (dict, key, volinfo->cksum); if (ret) @@ -1268,21 +1285,34 @@ glusterd_add_volume_to_dict (glusterd_volinfo_t *volinfo, if (!volume_id_str) goto out; - memset (&key, 0, sizeof (key)); + memset (key, 0, sizeof (key)); snprintf (key, 256, "volume%d.volume_id", count); ret = dict_set_dynstr (dict, key, volume_id_str); if (ret) goto out; + ctx.dict = dict; + ctx.count = count; + ctx.opt_count = 1; + GF_ASSERT (volinfo->dict); + + dict_foreach (volinfo->dict, _add_volume_option_to_dict, &ctx); + ctx.opt_count--; + memset (key, 0, sizeof (key)); + snprintf (key, sizeof (key), "volume%d.opt-count", count); + ret = dict_set_int32 (dict, key, ctx.opt_count); + if (ret) + goto out; + list_for_each_entry (brickinfo, &volinfo->bricks, brick_list) { - memset (&key, 0, sizeof (key)); + memset (key, 0, sizeof (key)); snprintf (key, sizeof (key), "volume%d.brick%d.hostname", count, i); ret = dict_set_str (dict, key, brickinfo->hostname); if (ret) goto out; - memset (&key, 0, sizeof (key)); + memset (key, 0, sizeof (key)); snprintf (key, sizeof (key), "volume%d.brick%d.path", count, i); ret = dict_set_str (dict, key, brickinfo->path); @@ -1363,7 +1393,7 @@ glusterd_compare_friend_volume (dict_t *vols, int32_t count, int32_t *status) goto out; } - memset (&key, 0, sizeof (key)); + memset (key, 0, sizeof (key)); snprintf (key, sizeof (key), "volume%d.version", count); ret = dict_get_int32 (vols, key, &version); if (ret) @@ -1384,7 +1414,7 @@ glusterd_compare_friend_volume (dict_t *vols, int32_t count, int32_t *status) //Now, versions are same, compare cksums. // - memset (&key, 0, sizeof (key)); + memset (key, 0, sizeof (key)); snprintf (key, sizeof (key), "volume%d.ckusm", count); ret = dict_get_uint32 (vols, key, &cksum); if (ret) @@ -1408,6 +1438,60 @@ out: } int32_t +glusterd_import_friend_volume_opts (dict_t *vols, int count, + glusterd_volinfo_t *volinfo, + int new_volinfo) +{ + char key[512] = {0,}; + int32_t ret = -1; + int i = 1; + int opt_count = 0; + char *opt_key = NULL; + char *opt_val = NULL; + char *dup_opt_val = NULL; + + memset (key, 0, sizeof (key)); + snprintf (key, sizeof (key), "volume%d.opt-count", count); + ret = dict_get_int32 (vols, key, &opt_count); + if (ret) + goto out; + if (!new_volinfo) { + ret = glusterd_options_reset (volinfo); + if (ret) { + gf_log ("", GF_LOG_ERROR, "options reset failed"); + goto out; + } + } + while (i <= opt_count) { + memset (key, 0, sizeof (key)); + snprintf (key, sizeof (key), "volume%d.key%d", + count, i); + ret = dict_get_str (vols, key, &opt_key); + if (ret) + goto out; + + memset (key, 0, sizeof (key)); + snprintf (key, sizeof (key), "volume%d.value%d", + count, i); + ret = dict_get_str (vols, key, &opt_val); + if (ret) + goto out; + dup_opt_val = gf_strdup (opt_val); + if (!dup_opt_val) { + ret = -1; + goto out; + } + ret = dict_set_dynstr (volinfo->dict, opt_key, dup_opt_val); + if (ret) + goto out; + i++; + } +out: + gf_log ("", GF_LOG_DEBUG, "Returning with %d", ret); + return ret; +} + +int32_t glusterd_import_friend_volume (dict_t *vols, int count) { @@ -1444,43 +1528,43 @@ glusterd_import_friend_volume (dict_t *vols, int count) } - memset (&key, 0, sizeof (key)); + memset (key, 0, sizeof (key)); snprintf (key, sizeof (key), "volume%d.type", count); ret = dict_get_int32 (vols, key, &volinfo->type); if (ret) goto out; - memset (&key, 0, sizeof (key)); + memset (key, 0, sizeof (key)); snprintf (key, sizeof (key), "volume%d.brick_count", count); ret = dict_get_int32 (vols, key, &volinfo->brick_count); if (ret) goto out; - memset (&key, 0, sizeof (key)); + memset (key, 0, sizeof (key)); snprintf (key, sizeof (key), "volume%d.version", count); ret = dict_get_int32 (vols, key, &volinfo->version); if (ret) goto out; - memset (&key, 0, sizeof (key)); + memset (key, 0, sizeof (key)); snprintf (key, sizeof (key), "volume%d.status", count); ret = dict_get_int32 (vols, key, (int32_t *)&volinfo->status); if (ret) goto out; - memset (&key, 0, sizeof (key)); + memset (key, 0, sizeof (key)); snprintf (key, sizeof (key), "volume%d.sub_count", count); ret = dict_get_int32 (vols, key, &volinfo->sub_count); if (ret) goto out; - memset (&key, 0, sizeof (key)); + memset (key, 0, sizeof (key)); snprintf (key, sizeof (key), "volume%d.ckusm", count); ret = dict_get_uint32 (vols, key, &volinfo->cksum); if (ret) goto out; - memset (&key, 0, sizeof (key)); + memset (key, 0, sizeof (key)); snprintf (key, sizeof (key), "volume%d.volume_id", count); ret = dict_get_str (vols, key, &volume_id_str); if (ret) @@ -1496,14 +1580,14 @@ glusterd_import_friend_volume (dict_t *vols, int count) while (i <= volinfo->brick_count) { - memset (&key, 0, sizeof (key)); + memset (key, 0, sizeof (key)); snprintf (key, sizeof (key), "volume%d.brick%d.hostname", count, i); ret = dict_get_str (vols, key, &hostname); if (ret) goto out; - memset (&key, 0, sizeof (key)); + memset (key, 0, sizeof (key)); snprintf (key, sizeof (key), "volume%d.brick%d.path", count, i); ret = dict_get_str (vols, key, &path); @@ -1522,6 +1606,10 @@ glusterd_import_friend_volume (dict_t *vols, int count) i++; } + ret = glusterd_import_friend_volume_opts (vols, count, volinfo, + new_volinfo); + if (ret) + goto out; if (new_volinfo) { list_add_tail (&volinfo->vol_list, &priv->volumes); ret = glusterd_store_create_volume (volinfo); @@ -1613,36 +1701,6 @@ out: return ret; } -int -glusterd_file_copy (int out, int in) -{ - int read_size = 0; - char buffer[16 * 1024]; - int ret = -1; - - if (out <= 0 || in < 0) { - gf_log ("", GF_LOG_ERROR, "Invalid File descriptors"); - goto out; - } - - while (1) { - read_size = read(in, buffer, sizeof(buffer)); - - if (read_size == 0) { - ret = 0; - break; /* end of file */ - } - - if (read_size < 0) { - ret = -1; - break; /*error reading file); */ - } - write (out, buffer, (unsigned int) read_size); - } -out: - return ret; -} - gf_boolean_t glusterd_is_nfs_started () { |