/* Copyright (c) 2011-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 _CONFIG_H #define _CONFIG_H #include "config.h" #endif #include #include #include #include #include #ifdef GF_LINUX_HOST_OS #include #endif #include "posix-handle.h" #include "posix.h" #include "xlator.h" #include "syscall.h" #include "compat-errno.h" inode_t * posix_resolve (xlator_t *this, inode_table_t *itable, inode_t *parent, char *bname, struct iatt *iabuf) { inode_t *inode = NULL, *linked_inode = NULL; int ret = -1; ret = posix_istat (this, parent->gfid, bname, iabuf); if (ret < 0) goto out; inode = inode_find (itable, iabuf->ia_gfid); if (inode == NULL) { inode = inode_new (itable); } linked_inode = inode_link (inode, parent, bname, iabuf); inode_unref (inode); out: return linked_inode; } int posix_make_ancestral_node (const char *priv_base_path, char *path, int pathsize, gf_dirent_t *head, char *dir_name, struct iatt *iabuf, inode_t *inode, int type, dict_t *xdata) { gf_dirent_t *entry = NULL; char real_path[PATH_MAX + 1] = {0, }, len = 0; loc_t loc = {0, }; int ret = -1; len = strlen (path) + strlen (dir_name) + 1; if (len > pathsize) { goto out; } strcat (path, dir_name); if (type & POSIX_ANCESTRY_DENTRY) { entry = gf_dirent_for_name (dir_name); if (!entry) { gf_log (THIS->name, GF_LOG_ERROR, "could not create gf_dirent for entry %s: (%s)", dir_name, strerror (errno)); goto out; } entry->d_stat = *iabuf; entry->inode = inode_ref (inode); list_add_tail (&entry->list, &head->list); strcpy (real_path, priv_base_path); strcat (real_path, "/"); strcat (real_path, path); loc.inode = inode_ref (inode); gf_uuid_copy (loc.gfid, inode->gfid); entry->dict = posix_xattr_fill (THIS, real_path, &loc, NULL, -1, xdata, iabuf); loc_wipe (&loc); } ret = 0; out: return ret; } int posix_make_ancestryfromgfid (xlator_t *this, char *path, int pathsize, gf_dirent_t *head, int type, uuid_t gfid, const size_t handle_size, const char *priv_base_path, inode_table_t *itable, inode_t **parent, dict_t *xdata) { char *linkname = NULL; /* "../..///" */ char *dir_handle = NULL; char *dir_name = NULL; char *pgfidstr = NULL; char *saveptr = NULL; ssize_t len = 0; inode_t *inode = NULL; struct iatt iabuf = {0, }; int ret = -1; uuid_t tmp_gfid = {0, }; if (!path || !parent || !priv_base_path || gf_uuid_is_null (gfid)) { goto out; } if (__is_root_gfid (gfid)) { if (parent) { if (*parent) { inode_unref (*parent); } *parent = inode_ref (itable->root); } inode = itable->root; memset (&iabuf, 0, sizeof (iabuf)); gf_uuid_copy (iabuf.ia_gfid, inode->gfid); iabuf.ia_type = inode->ia_type; ret = posix_make_ancestral_node (priv_base_path, path, pathsize, head, "/", &iabuf, inode, type, xdata); return ret; } dir_handle = alloca (handle_size); linkname = alloca (PATH_MAX); snprintf (dir_handle, handle_size, "%s/%s/%02x/%02x/%s", priv_base_path, GF_HIDDEN_PATH, gfid[0], gfid[1], uuid_utoa (gfid)); len = readlink (dir_handle, linkname, PATH_MAX); if (len < 0) { gf_log (this->name, GF_LOG_ERROR, "could not read the link " "from the gfid handle %s (%s)", dir_handle, strerror (errno)); goto out; } linkname[len] = '\0'; pgfidstr = strtok_r (linkname + SLEN("../../00/00/"), "/", &saveptr); dir_name = strtok_r (NULL, "/", &saveptr); gf_uuid_parse (pgfidstr, tmp_gfid); ret = posix_make_ancestryfromgfid (this, path, pathsize, head, type, tmp_gfid, handle_size, priv_base_path, itable, parent, xdata); if (ret < 0) { goto out; } memset (&iabuf, 0, sizeof (iabuf)); inode = posix_resolve (this, itable, *parent, dir_name, &iabuf); if (inode == NULL) { ret = -1; goto out; } strcat (dir_name, "/"); ret = posix_make_ancestral_node (priv_base_path, path, pathsize, head, dir_name, &iabuf, inode, type, xdata); if (*parent != NULL) { inode_unref (*parent); } *parent = inode; out: return ret; } int posix_handle_relpath (xlator_t *this, uuid_t gfid, const char *basename, char *buf, size_t buflen) { char *uuid_str = NULL; int len = 0; len = SLEN("../") + SLEN("../") + SLEN("00/") + SLEN("00/") + SLEN(UUID0_STR) + 1 /* '\0' */ ; if (basename) { len += (strlen (basename) + 1); } if (buflen < len || !buf) return len; uuid_str = uuid_utoa (gfid); if (basename) { len = snprintf (buf, buflen, "../../%02x/%02x/%s/%s", gfid[0], gfid[1], uuid_str, basename); } else { len = snprintf (buf, buflen, "../../%02x/%02x/%s", gfid[0], gfid[1], uuid_str); } return len; } /* TODO: explain how this pump fixes ELOOP */ int posix_handle_pump (xlator_t *this, char *buf, int len, int maxlen, char *base_str, int base_len, int pfx_len) { char linkname[512] = {0,}; /* "../..//" */ int ret = 0; int blen = 0; int link_len = 0; /* is a directory's symlink-handle */ ret = readlink (base_str, linkname, 512); if (ret == -1) { gf_log (this->name, GF_LOG_ERROR, "internal readlink failed on %s (%s)", base_str, strerror (errno)); goto err; } if (ret < 512) linkname[ret] = 0; link_len = ret; if ((ret == 8) && memcmp (linkname, "../../..", 8) == 0) { if (strcmp (base_str, buf) == 0) { strcpy (buf + pfx_len, ".."); } goto out; } if (ret < 50 || ret >= 512) { gf_log (this->name, GF_LOG_ERROR, "malformed internal link %s for %s", linkname, base_str); goto err; } if (memcmp (linkname, "../../", 6) != 0) { gf_log (this->name, GF_LOG_ERROR, "malformed internal link %s for %s", linkname, base_str); goto err; } if ((linkname[2] != '/') || (linkname[5] != '/') || (linkname[8] != '/') || (linkname[11] != '/') || (linkname[48] != '/')) { gf_log (this->name, GF_LOG_ERROR, "malformed internal link %s for %s", linkname, base_str); goto err; } if ((linkname[20] != '-') || (linkname[25] != '-') || (linkname[30] != '-') || (linkname[35] != '-')) { gf_log (this->name, GF_LOG_ERROR, "malformed internal link %s for %s", linkname, base_str); goto err; } blen = link_len - 48; if (len + blen >= maxlen) { gf_log (this->name, GF_LOG_ERROR, "Unable to form handle path for %s (maxlen = %d)", buf, maxlen); goto err; } memmove (buf + base_len + blen, buf + base_len, (strlen (buf) - base_len) + 1); strncpy (base_str + pfx_len, linkname + 6, 42); strncpy (buf + pfx_len, linkname + 6, link_len - 6); out: return len + blen; err: return -1; } /* posix_handle_path differs from posix_handle_gfid_path in the way that the path filled in @buf by posix_handle_path will return type IA_IFDIR when an lstat() is performed on it, whereas posix_handle_gfid_path returns path to the handle symlink (typically used for the purpose of unlinking it). posix_handle_path also guarantees immunity to ELOOP on the path returned by it */ int posix_handle_path (xlator_t *this, uuid_t gfid, const char *basename, char *ubuf, size_t size) { struct posix_private *priv = NULL; char *uuid_str = NULL; int len = 0; int ret = -1; struct stat stat; char *base_str = NULL; int base_len = 0; int pfx_len; int maxlen; char *buf; priv = this->private; uuid_str = uuid_utoa (gfid); if (ubuf) { buf = ubuf; maxlen = size; } else { maxlen = PATH_MAX; buf = alloca (maxlen); } base_len = (priv->base_path_length + SLEN(GF_HIDDEN_PATH) + 45); base_str = alloca (base_len + 1); base_len = snprintf (base_str, base_len + 1, "%s/%s/%02x/%02x/%s", priv->base_path, GF_HIDDEN_PATH, gfid[0], gfid[1], uuid_str); pfx_len = priv->base_path_length + 1 + SLEN(GF_HIDDEN_PATH) + 1; if (basename) { len = snprintf (buf, maxlen, "%s/%s", base_str, basename); } else { len = snprintf (buf, maxlen, "%s", base_str); } ret = lstat (base_str, &stat); if (!(ret == 0 && S_ISLNK(stat.st_mode) && stat.st_nlink == 1)) goto out; do { errno = 0; ret = posix_handle_pump (this, buf, len, maxlen, base_str, base_len, pfx_len); len = ret; if (ret == -1) break; ret = lstat (buf, &stat); } while ((ret == -1) && errno == ELOOP); out: return len + 1; } int posix_handle_gfid_path (xlator_t *this, uuid_t gfid, const char *basename, char *buf, size_t buflen) { struct posix_private *priv = NULL; char *uuid_str = NULL; int len = 0; priv = this->private; len = priv->base_path_length /* option directory "/export" */ + SLEN("/") + SLEN(GF_HIDDEN_PATH) + SLEN("/") + SLEN("00/") + SLEN("00/") + SLEN(UUID0_STR) + 1 /* '\0' */ ; if (basename) { len += (strlen (basename) + 1); } else { len += 256; /* worst-case for directory's symlink-handle expansion */ } if ((buflen < len) || !buf) return len; uuid_str = uuid_utoa (gfid); if (__is_root_gfid (gfid)) { if (basename) { len = snprintf (buf, buflen, "%s/%s", priv->base_path, basename); } else { strncpy (buf, priv->base_path, buflen); } goto out; } if (basename) { len = snprintf (buf, buflen, "%s/%s/%02x/%02x/%s/%s", priv->base_path, GF_HIDDEN_PATH, gfid[0], gfid[1], uuid_str, basename); } else { len = snprintf (buf, buflen, "%s/%s/%02x/%02x/%s", priv->base_path, GF_HIDDEN_PATH, gfid[0], gfid[1], uuid_str); } out: return len; } int posix_handle_init (xlator_t *this) { struct posix_private *priv = NULL; char *handle_pfx = NULL; int ret = 0; struct stat stbuf; struct stat rootbuf; struct stat exportbuf; char *rootstr = NULL; uuid_t gfid = {0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,1}; priv = this->private; ret = stat (priv->base_path, &exportbuf); if (ret || !S_ISDIR (exportbuf.st_mode)) { gf_log (this->name, GF_LOG_ERROR, "Not a directory: %s", priv->base_path); return -1; } handle_pfx = alloca (priv->base_path_length + 1 + strlen (GF_HIDDEN_PATH) + 1); sprintf (handle_pfx, "%s/%s", priv->base_path, GF_HIDDEN_PATH); ret = stat (handle_pfx, &stbuf); switch (ret) { case -1: if (errno == ENOENT) { ret = mkdir (handle_pfx, 0600); if (ret != 0) { gf_log (this->name, GF_LOG_ERROR, "Creating directory %s failed: %s", handle_pfx, strerror (errno)); return -1; } } else { gf_log (this->name, GF_LOG_ERROR, "Checking for %s failed: %s", handle_pfx, strerror (errno)); return -1; } break; case 0: if (!S_ISDIR (stbuf.st_mode)) { gf_log (this->name, GF_LOG_ERROR, "Not a directory: %s", handle_pfx); return -1; } break; default: break; } stat (handle_pfx, &priv->handledir); MAKE_HANDLE_ABSPATH(rootstr, this, gfid); ret = stat (rootstr, &rootbuf); switch (ret) { case -1: if (errno != ENOENT) { gf_log (this->name, GF_LOG_ERROR, "%s: %s", priv->base_path, strerror (errno)); return -1; } ret = posix_handle_mkdir_hashes (this, rootstr); if (ret) { gf_log (this->name, GF_LOG_WARNING, "mkdir %s failed (%s)", rootstr, strerror (errno)); return -1; } ret = symlink ("../../..", rootstr); if (ret) { gf_log (this->name, GF_LOG_ERROR, "symlink %s creation failed (%s)", rootstr, strerror (errno)); return -1; } break; case 0: if ((exportbuf.st_ino == rootbuf.st_ino) && (exportbuf.st_dev == rootbuf.st_dev)) return 0; gf_log (this->name, GF_LOG_ERROR, "Different dirs %s (%lld/%lld) != %s (%lld/%lld)", priv->base_path, (long long) exportbuf.st_ino, (long long) exportbuf.st_dev, rootstr, (long long) rootbuf.st_ino, (long long) rootbuf.st_dev); return -1; break; } return 0; } gf_boolean_t posix_does_old_trash_exists (char *old_trash) { uuid_t gfid = {0}; gf_boolean_t exists = _gf_false; struct stat stbuf = {0}; int ret = 0; ret = lstat (old_trash, &stbuf); if ((ret == 0) && S_ISDIR (stbuf.st_mode)) { ret = sys_lgetxattr (old_trash, "trusted.gfid", gfid, 16); if ((ret < 0) && (errno == ENODATA || errno == ENOATTR) ) exists = _gf_true; } return exists; } int posix_handle_new_trash_init (xlator_t *this, char *trash) { int ret = 0; struct stat stbuf = {0}; ret = lstat (trash, &stbuf); switch (ret) { case -1: if (errno == ENOENT) { ret = mkdir (trash, 0755); if (ret != 0) { gf_log (this->name, GF_LOG_ERROR, "Creating directory %s failed: %s", trash, strerror (errno)); } } else { gf_log (this->name, GF_LOG_ERROR, "Checking for %s " "failed: %s", trash, strerror (errno)); } break; case 0: if (!S_ISDIR (stbuf.st_mode)) { gf_log (this->name, GF_LOG_ERROR, "Not a directory: %s", trash); ret = -1; } break; default: break; } return ret; } int posix_mv_old_trash_into_new_trash (xlator_t *this, char *old, char *new) { char dest_old[PATH_MAX] = {0}; int ret = 0; uuid_t dest_name = {0}; if (!posix_does_old_trash_exists (old)) goto out; gf_uuid_generate (dest_name); snprintf (dest_old, sizeof (dest_old), "%s/%s", new, uuid_utoa (dest_name)); ret = rename (old, dest_old); if (ret < 0) { gf_log (this->name, GF_LOG_ERROR, "Not able to move " "%s -> %s (%s)", old, dest_old, strerror (errno)); } out: return ret; } int posix_handle_trash_init (xlator_t *this) { int ret = -1; struct posix_private *priv = NULL; char old_trash[PATH_MAX] = {0}; priv = this->private; priv->trash_path = GF_CALLOC (1, priv->base_path_length + strlen ("/") + strlen (GF_HIDDEN_PATH) + strlen ("/") + strlen (TRASH_DIR) + 1, gf_posix_mt_trash_path); if (!priv->trash_path) goto out; strncpy (priv->trash_path, priv->base_path, priv->base_path_length); strcat (priv->trash_path, "/" GF_HIDDEN_PATH "/" TRASH_DIR); ret = posix_handle_new_trash_init (this, priv->trash_path); if (ret) goto out; snprintf (old_trash, sizeof (old_trash), "%s/.landfill", priv->base_path); ret = posix_mv_old_trash_into_new_trash (this, old_trash, priv->trash_path); out: return ret; } int posix_handle_mkdir_hashes (xlator_t *this, const char *newpath) { char *duppath = NULL; char *parpath = NULL; int ret = 0; duppath = strdupa (newpath); parpath = dirname (duppath); parpath = dirname (duppath); ret = mkdir (parpath, 0700); if (ret == -1 && errno != EEXIST) { gf_log (this->name, GF_LOG_ERROR, "error mkdir hash-1 %s (%s)", parpath, strerror (errno)); return -1; } strcpy (duppath, newpath); parpath = dirname (duppath); ret = mkdir (parpath, 0700); if (ret == -1 && errno != EEXIST) { gf_log (this->name, GF_LOG_ERROR, "error mkdir hash-2 %s (%s)", parpath, strerror (errno)); return -1; } return 0; } int posix_handle_hard (xlator_t *this, const char *oldpath, uuid_t gfid, struct stat *oldbuf) { char *newpath = NULL; struct stat newbuf; int ret = -1; MAKE_HANDLE_ABSPATH (newpath, this, gfid); ret = lstat (newpath, &newbuf); if (ret == -1 && errno != ENOENT) { gf_log (this->name, GF_LOG_WARNING, "%s: %s", newpath, strerror (errno)); return -1; } if (ret == -1 && errno == ENOENT) { ret = posix_handle_mkdir_hashes (this, newpath); if (ret) { gf_log (this->name, GF_LOG_WARNING, "mkdir %s failed (%s)", newpath, strerror (errno)); return -1; } ret = sys_link (oldpath, newpath); if (ret) { gf_log (this->name, GF_LOG_WARNING, "link %s -> %s failed (%s)", oldpath, newpath, strerror (errno)); return -1; } ret = lstat (newpath, &newbuf); if (ret) { gf_log (this->name, GF_LOG_WARNING, "lstat on %s failed (%s)", newpath, strerror (errno)); return -1; } } if (newbuf.st_ino != oldbuf->st_ino || newbuf.st_dev != oldbuf->st_dev) { gf_log (this->name, GF_LOG_WARNING, "mismatching ino/dev between file %s (%lld/%lld) " "and handle %s (%lld/%lld)", oldpath, (long long) oldbuf->st_ino, (long long) oldbuf->st_dev, newpath, (long long) newbuf.st_ino, (long long) newbuf.st_dev); ret = -1; } return ret; } int posix_handle_soft (xlator_t *this, const char *real_path, loc_t *loc, uuid_t gfid, struct stat *oldbuf) { char *oldpath = NULL; char *newpath = NULL; struct stat newbuf; int ret = -1; MAKE_HANDLE_ABSPATH (newpath, this, gfid); MAKE_HANDLE_RELPATH (oldpath, this, loc->pargfid, loc->name); ret = lstat (newpath, &newbuf); if (ret == -1 && errno != ENOENT) { gf_log (this->name, GF_LOG_WARNING, "%s: %s", newpath, strerror (errno)); return -1; } if (ret == -1 && errno == ENOENT) { ret = posix_handle_mkdir_hashes (this, newpath); if (ret) { gf_log (this->name, GF_LOG_WARNING, "mkdir %s failed (%s)", newpath, strerror (errno)); return -1; } ret = symlink (oldpath, newpath); if (ret) { gf_log (this->name, GF_LOG_WARNING, "symlink %s -> %s failed (%s)", oldpath, newpath, strerror (errno)); return -1; } ret = lstat (newpath, &newbuf); if (ret) { gf_log (this->name, GF_LOG_WARNING, "stat on %s failed (%s)", newpath, strerror (errno)); return -1; } } ret = stat (real_path, &newbuf); if (ret) { gf_log (this->name, GF_LOG_WARNING, "stat on %s failed (%s)", newpath, strerror (errno)); return -1; } if (!oldbuf) return ret; if (newbuf.st_ino != oldbuf->st_ino || newbuf.st_dev != oldbuf->st_dev) { gf_log (this->name, GF_LOG_WARNING, "mismatching ino/dev between file %s (%lld/%lld) " "and handle %s (%lld/%lld)", oldpath, (long long) oldbuf->st_ino, (long long) oldbuf->st_dev, newpath, (long long) newbuf.st_ino, (long long) newbuf.st_dev); ret = -1; } return ret; } int posix_handle_unset_gfid (xlator_t *this, uuid_t gfid) { char *path = NULL; int ret = 0; struct stat stat; MAKE_HANDLE_GFID_PATH (path, this, gfid, NULL); ret = lstat (path, &stat); if (ret == -1) { if (errno != ENOENT) { gf_log (this->name, GF_LOG_WARNING, "%s: %s", path, strerror (errno)); } goto out; } ret = unlink (path); if (ret == -1) { gf_log (this->name, GF_LOG_WARNING, "unlink %s failed (%s)", path, strerror (errno)); } out: return ret; } int posix_handle_unset (xlator_t *this, uuid_t gfid, const char *basename) { int ret; struct iatt stat; char *path = NULL; if (!basename) { ret = posix_handle_unset_gfid (this, gfid); return ret; } MAKE_HANDLE_PATH (path, this, gfid, basename); if (!path) { gf_log (this->name, GF_LOG_WARNING, "Failed to create handle path for %s (%s)", basename, uuid_utoa(gfid)); return -1; } ret = posix_istat (this, gfid, basename, &stat); if (ret == -1) { gf_log (this->name, GF_LOG_WARNING, "%s: %s", path, strerror (errno)); return -1; } ret = posix_handle_unset_gfid (this, stat.ia_gfid); return ret; } int posix_create_link_if_gfid_exists (xlator_t *this, uuid_t gfid, char *real_path) { int ret = -1; struct stat stbuf = {0,}; char *newpath = NULL; MAKE_HANDLE_PATH (newpath, this, gfid, NULL); if (!newpath) { gf_log (this->name, GF_LOG_WARNING, "Failed to create handle path (%s)", uuid_utoa(gfid)); return ret; } ret = lstat (newpath, &stbuf); if (!ret) { ret = sys_link (newpath, real_path); } return ret; }