diff options
author | Anand V. Avati <avati@blackhole.gluster.com> | 2009-10-18 13:35:13 +0000 |
---|---|---|
committer | Anand V. Avati <avati@dev.gluster.com> | 2009-10-18 12:15:39 -0700 |
commit | b2c0c6c713a00631e658c7faafe51d0c941d65ef (patch) | |
tree | c39533ae5a9f0f1a54ac9c6185bc4edc49b2df04 /libglusterfs/src/inode.c | |
parent | 9d73eb4c8a9bf1e802985abee83ad36439ab681a (diff) |
inode: fix indentation and spacings
Signed-off-by: Anand V. Avati <avati@dev.gluster.com>
BUG: 315 (generation number support)
URL: http://bugs.gluster.com/cgi-bin/bugzilla3/show_bug.cgi?id=315
Diffstat (limited to 'libglusterfs/src/inode.c')
-rw-r--r-- | libglusterfs/src/inode.c | 479 |
1 files changed, 226 insertions, 253 deletions
diff --git a/libglusterfs/src/inode.c b/libglusterfs/src/inode.c index 9a55034d896..825ab4c5c9c 100644 --- a/libglusterfs/src/inode.c +++ b/libglusterfs/src/inode.c @@ -1,20 +1,20 @@ /* - Copyright (c) 2007-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) 2007-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/>. */ #ifndef _CONFIG_H @@ -36,17 +36,17 @@ move latest accessed dentry to list_head of inode */ -#define INODE_DUMP_LIST(head, key_buf, key_prefix, list_type) \ -{ \ - int i = 1;\ - inode_t *inode = NULL;\ - list_for_each_entry (inode, head, list) {\ - gf_proc_dump_build_key(key_buf, key_prefix, "%s.%d",list_type,\ - i++);\ - gf_proc_dump_add_section(key_buf);\ - inode_dump(inode, key);\ - }\ -} +#define INODE_DUMP_LIST(head, key_buf, key_prefix, list_type) \ + { \ + int i = 1; \ + inode_t *inode = NULL; \ + list_for_each_entry (inode, head, list) { \ + gf_proc_dump_build_key(key_buf, key_prefix, "%s.%d",list_type, \ + i++); \ + gf_proc_dump_add_section(key_buf); \ + inode_dump(inode, key); \ + } \ + } static inode_t * __inode_unref (inode_t *inode); @@ -55,9 +55,7 @@ static int inode_table_prune (inode_table_t *table); static int -hash_name (ino_t par, - const char *name, - int mod) +hash_name (ino_t par, const char *name, int mod) { int hash = 0; int ret = 0; @@ -75,8 +73,7 @@ hash_name (ino_t par, static int -hash_inode (ino_t ino, - int mod) +hash_inode (ino_t ino, int mod) { int hash = 0; @@ -167,10 +164,9 @@ __inode_hash (inode_t *inode) static inode_t * -__inode_search (inode_table_t *table, - ino_t ino) +__inode_search (inode_table_t *table, ino_t ino) { - int hash = 0; + int hash = 0; inode_t *inode = NULL; inode_t *tmp = NULL; @@ -188,9 +184,7 @@ __inode_search (inode_table_t *table, static dentry_t * -__dentry_search_for_inode (inode_t *inode, - ino_t par, - const char *name) +__dentry_search_for_inode (inode_t *inode, ino_t par, const char *name) { dentry_t *dentry = NULL; dentry_t *tmp = NULL; @@ -207,9 +201,7 @@ __dentry_search_for_inode (inode_t *inode, dentry_t * -dentry_search_for_inode (inode_t *inode, - ino_t par, - const char *name) +dentry_search_for_inode (inode_t *inode, ino_t par, const char *name) { dentry_t *dentry = NULL; pthread_mutex_lock (&inode->table->lock); @@ -223,9 +215,7 @@ dentry_search_for_inode (inode_t *inode, static dentry_t * -__dentry_search (inode_table_t *table, - ino_t par, - const char *name) +__dentry_search (inode_table_t *table, ino_t par, const char *name) { int hash = 0; dentry_t *dentry = NULL; @@ -247,21 +237,21 @@ __dentry_search (inode_table_t *table, static void __inode_destroy (inode_t *inode) { - int index = 0; + int index = 0; xlator_t *xl = NULL; - if (!inode->_ctx) - goto noctx; + if (!inode->_ctx) + goto noctx; - for (index = 0; index < inode->table->xl->ctx->xl_count; index++) { - if (inode->_ctx[index].key) { - xl = (xlator_t *)(long)inode->_ctx[index].key; - if (xl->cbks->forget) - xl->cbks->forget (xl, inode); - } - } + for (index = 0; index < inode->table->xl->ctx->xl_count; index++) { + if (inode->_ctx[index].key) { + xl = (xlator_t *)(long)inode->_ctx[index].key; + if (xl->cbks->forget) + xl->cbks->forget (xl, inode); + } + } - FREE (inode->_ctx); + FREE (inode->_ctx); noctx: LOCK_DESTROY (&inode->lock); // memset (inode, 0xb, sizeof (*inode)); @@ -390,9 +380,7 @@ inode_ref (inode_t *inode) static dentry_t * -__dentry_create (inode_t *inode, - inode_t *parent, - const char *name) +__dentry_create (inode_t *inode, inode_t *parent, const char *name) { dentry_t *newd = NULL; @@ -436,8 +424,8 @@ __inode_create (inode_table_t *table) list_add (&newi->list, &table->lru); table->lru_size++; - newi->_ctx = CALLOC (1, (sizeof (struct _inode_ctx) * - table->xl->ctx->xl_count)); + newi->_ctx = CALLOC (1, (sizeof (struct _inode_ctx) * + table->xl->ctx->xl_count)); return newi; } @@ -483,11 +471,9 @@ __inode_forget (inode_t *inode, uint64_t nlookup) inode_t * -inode_search (inode_table_t *table, - ino_t ino, - const char *name) +inode_search (inode_table_t *table, ino_t ino, const char *name) { - inode_t *inode = NULL; + inode_t *inode = NULL; dentry_t *dentry = NULL; pthread_mutex_lock (&table->lock); @@ -569,15 +555,13 @@ __inode_replace (inode_t *oldi, inode_t *newi) __inode_unhash (oldi); - if (newi->ino == 1) - newi->table->root = newi; + if (newi->ino == 1) + newi->table->root = newi; } static inode_t * -__inode_link (inode_t *inode, - inode_t *parent, - const char *name, +__inode_link (inode_t *inode, inode_t *parent, const char *name, struct stat *stbuf) { dentry_t *dentry = NULL; @@ -587,8 +571,8 @@ __inode_link (inode_t *inode, table = inode->table; - if (inode->ino) - assert (inode->ino == stbuf->st_ino); + if (inode->ino) + assert (inode->ino == stbuf->st_ino); inode->ino = stbuf->st_ino; inode->st_mode = stbuf->st_mode; @@ -615,18 +599,16 @@ __inode_link (inode_t *inode, __dentry_hash (dentry); } else if (inode->ino != 1) { - gf_log (table->name, GF_LOG_DEBUG, - "child (%"PRId64") without a parent!", inode->ino); - } - + gf_log (table->name, GF_LOG_DEBUG, + "child (%"PRId64") without a parent!", inode->ino); + } + return inode; } int -inode_link (inode_t *inode, - inode_t *parent, - const char *name, +inode_link (inode_t *inode, inode_t *parent, const char *name, struct stat *stbuf) { inode_table_t *table = NULL; @@ -649,18 +631,18 @@ int inode_lookup (inode_t *inode) { inode_table_t *table = NULL; - inode_t *lookup_inode = NULL; + inode_t *lookup_inode = NULL; table = inode->table; - lookup_inode = inode; + lookup_inode = inode; pthread_mutex_lock (&table->lock); { - if (!__is_inode_hashed (inode)) { - lookup_inode = __inode_search (table, inode->ino); + if (!__is_inode_hashed (inode)) { + lookup_inode = __inode_search (table, inode->ino); if (lookup_inode == NULL) lookup_inode = inode; - } + } __inode_lookup (lookup_inode); } @@ -674,20 +656,20 @@ int inode_forget (inode_t *inode, uint64_t nlookup) { inode_table_t *table = NULL; - inode_t *forget_inode = NULL; + inode_t *forget_inode = NULL; table = inode->table; - forget_inode = inode; + forget_inode = inode; pthread_mutex_lock (&table->lock); { - if (!__is_inode_hashed (inode)) { - forget_inode = __inode_search (table, inode->ino); + if (!__is_inode_hashed (inode)) { + forget_inode = __inode_search (table, inode->ino); if (forget_inode == NULL) forget_inode = inode; - } + } - __inode_forget (forget_inode, nlookup); + __inode_forget (forget_inode, nlookup); } pthread_mutex_unlock (&table->lock); @@ -698,38 +680,34 @@ inode_forget (inode_t *inode, uint64_t nlookup) static void -__inode_unlink (inode_t *inode, - inode_t *parent, - const char *name) +__inode_unlink (inode_t *inode, inode_t *parent, const char *name) { dentry_t *dentry = NULL; dentry = __dentry_search_for_inode (inode, parent->ino, name); - /* dentry NULL for corrupted backend */ - if (dentry) - __dentry_unset (dentry); + /* dentry NULL for corrupted backend */ + if (dentry) + __dentry_unset (dentry); } - + void -inode_unlink (inode_t *inode, - inode_t *parent, - const char *name) +inode_unlink (inode_t *inode, inode_t *parent, const char *name) { inode_table_t *table = NULL; - inode_t *unlink_inode = NULL; + inode_t *unlink_inode = NULL; table = inode->table; - unlink_inode = inode; + unlink_inode = inode; pthread_mutex_lock (&table->lock); { - if (!__is_inode_hashed (inode)) { - unlink_inode = __inode_search (table, inode->ino); + if (!__is_inode_hashed (inode)) { + unlink_inode = __inode_search (table, inode->ino); if (unlink_inode == NULL) unlink_inode = inode; - } + } __inode_unlink (unlink_inode, parent, name); } @@ -740,30 +718,26 @@ inode_unlink (inode_t *inode, int -inode_rename (inode_table_t *table, - inode_t *srcdir, - const char *srcname, - inode_t *dstdir, - const char *dstname, - inode_t *inode, +inode_rename (inode_table_t *table, inode_t *srcdir, const char *srcname, + inode_t *dstdir, const char *dstname, inode_t *inode, struct stat *stbuf) { - dentry_t *old_dst = NULL; - inode_t *rename_inode = NULL; + dentry_t *old_dst = NULL; + inode_t *rename_inode = NULL; - rename_inode = inode; + rename_inode = inode; pthread_mutex_lock (&table->lock); { - if (!__is_inode_hashed (inode)) { - rename_inode = __inode_search (table, inode->ino); + if (!__is_inode_hashed (inode)) { + rename_inode = __inode_search (table, inode->ino); if (rename_inode == NULL) rename_inode = inode; - } + } - old_dst = __dentry_search (table, dstdir->ino, dstname); - if (old_dst) - __dentry_unset (old_dst); + old_dst = __dentry_search (table, dstdir->ino, dstname); + if (old_dst) + __dentry_unset (old_dst); __inode_unlink (rename_inode, srcdir, srcname); __inode_link (rename_inode, dstdir, dstname, stbuf); @@ -779,24 +753,24 @@ inode_rename (inode_table_t *table, static dentry_t * __dentry_search_arbit (inode_t *inode) { - dentry_t *dentry = NULL; - dentry_t *trav = NULL; - - list_for_each_entry (trav, &inode->dentry_list, inode_list) { - if (__is_dentry_hashed (trav)) { - dentry = trav; - break; - } - } - - if (!dentry) { - list_for_each_entry (trav, &inode->dentry_list, inode_list) { - dentry = trav; - break; - } - } - - return dentry; + dentry_t *dentry = NULL; + dentry_t *trav = NULL; + + list_for_each_entry (trav, &inode->dentry_list, inode_list) { + if (__is_dentry_hashed (trav)) { + dentry = trav; + break; + } + } + + if (!dentry) { + list_for_each_entry (trav, &inode->dentry_list, inode_list) { + dentry = trav; + break; + } + } + + return dentry; } @@ -826,18 +800,16 @@ inode_parent (inode_t *inode, ino_t par, const char *name) } -int32_t -inode_path (inode_t *inode, - const char *name, - char **bufp) +int +inode_path (inode_t *inode, const char *name, char **bufp) { inode_table_t *table = NULL; dentry_t *trav = NULL; size_t i = 0, size = 0; int64_t ret = 0; int len = 0; - char *buf = NULL; - + char *buf = NULL; + table = inode->table; pthread_mutex_lock (&table->lock); @@ -854,15 +826,15 @@ inode_path (inode_t *inode, goto unlock; } } - - if ((inode->ino != 1) && - (i == 0)) { - gf_log (table->name, GF_LOG_DEBUG, - "no dentry for non-root inode %"PRId64, - inode->ino); - ret = -ENOENT; - goto unlock; - } + + if ((inode->ino != 1) && + (i == 0)) { + gf_log (table->name, GF_LOG_DEBUG, + "no dentry for non-root inode %"PRId64, + inode->ino); + ret = -ENOENT; + goto unlock; + } if (name) { i++; @@ -870,8 +842,8 @@ inode_path (inode_t *inode, } ret = i; - size = i + 1; - buf = CALLOC (size, sizeof (char)); + size = i + 1; + buf = CALLOC (size, sizeof (char)); if (buf) { buf[size - 1] = 0; @@ -890,31 +862,31 @@ inode_path (inode_t *inode, buf[i-len-1] = '/'; i -= (len + 1); } - *bufp = buf; + *bufp = buf; } else { - gf_log (table->name, GF_LOG_ERROR, - "out of memory"); - ret = -ENOMEM; - } + gf_log (table->name, GF_LOG_ERROR, + "out of memory"); + ret = -ENOMEM; + } } unlock: pthread_mutex_unlock (&table->lock); - if (inode->ino == 1 && !name) { - ret = 1; - if (buf) { - FREE (buf); - } - buf = CALLOC (ret + 1, sizeof (char)); - if (buf) { - strcpy (buf, "/"); - *bufp = buf; - } else { - gf_log (table->name, GF_LOG_ERROR, - "out of memory"); - ret = -ENOMEM; - } - } + if (inode->ino == 1 && !name) { + ret = 1; + if (buf) { + FREE (buf); + } + buf = CALLOC (ret + 1, sizeof (char)); + if (buf) { + strcpy (buf, "/"); + *bufp = buf; + } else { + gf_log (table->name, GF_LOG_ERROR, + "out of memory"); + ret = -ENOMEM; + } + } return ret; } @@ -924,9 +896,9 @@ inode_table_prune (inode_table_t *table) { int ret = 0; struct list_head purge = {0, }; - inode_t *del = NULL; - inode_t *tmp = NULL; - inode_t *entry = NULL; + inode_t *del = NULL; + inode_t *tmp = NULL; + inode_t *entry = NULL; INIT_LIST_HEAD (&purge); @@ -945,7 +917,7 @@ inode_table_prune (inode_table_t *table) } list_splice_init (&table->purge, &purge); - table->purge_size = 0; + table->purge_size = 0; } pthread_mutex_unlock (&table->lock); @@ -1028,7 +1000,7 @@ inode_table_new (size_t lru_limit, xlator_t *xl) ; } - __inode_table_init_root (new); + __inode_table_init_root (new); pthread_mutex_init (&new->lock, NULL); @@ -1039,52 +1011,52 @@ inode_table_new (size_t lru_limit, xlator_t *xl) inode_t * inode_from_path (inode_table_t *itable, const char *path) { - inode_t *inode = NULL; - inode_t *parent = NULL; - inode_t *root = NULL; - inode_t *curr = NULL; - char *pathname = NULL; - char *component = NULL, *next_component = NULL; - char *strtokptr = NULL; - - /* top-down approach */ - root = itable->root; - parent = inode_ref (root); - pathname = strdup (path); - component = strtok_r (pathname, "/", &strtokptr); - - if (component == NULL) - /* root inode */ - inode = inode_ref (parent); - - while (component) { - curr = inode_search (itable, parent->ino, component); - - if (curr == NULL) { - component = strtok_r (NULL, "/", &strtokptr); - break; - } - - next_component = strtok_r (NULL, "/", &strtokptr); - - if (next_component) { - inode_unref (parent); - parent = curr; - curr = NULL; - } else { - inode = curr; - } - - component = next_component; - } - - if (parent) - inode_unref (parent); - - if (pathname) - free (pathname); - - return inode; + inode_t *inode = NULL; + inode_t *parent = NULL; + inode_t *root = NULL; + inode_t *curr = NULL; + char *pathname = NULL; + char *component = NULL, *next_component = NULL; + char *strtokptr = NULL; + + /* top-down approach */ + root = itable->root; + parent = inode_ref (root); + pathname = strdup (path); + component = strtok_r (pathname, "/", &strtokptr); + + if (component == NULL) + /* root inode */ + inode = inode_ref (parent); + + while (component) { + curr = inode_search (itable, parent->ino, component); + + if (curr == NULL) { + component = strtok_r (NULL, "/", &strtokptr); + break; + } + + next_component = strtok_r (NULL, "/", &strtokptr); + + if (next_component) { + inode_unref (parent); + parent = curr; + curr = NULL; + } else { + inode = curr; + } + + component = next_component; + } + + if (parent) + inode_unref (parent); + + if (pathname) + free (pathname); + + return inode; } int @@ -1106,7 +1078,7 @@ __inode_ctx_put (inode_t *inode, xlator_t *xlator, uint64_t value) break; } } - + if (put_idx == -1) { ret = -1; goto out;; @@ -1123,8 +1095,8 @@ inode_ctx_put (inode_t *inode, xlator_t *xlator, uint64_t value) { int ret = 0; - if (!inode || !xlator) - return -1; + if (!inode || !xlator) + return -1; LOCK (&inode->lock); { @@ -1132,14 +1104,15 @@ inode_ctx_put (inode_t *inode, xlator_t *xlator, uint64_t value) } UNLOCK (&inode->lock); - return ret; + return ret; } int __inode_ctx_get (inode_t *inode, xlator_t *xlator, uint64_t *value) { - int index = 0; + int index = 0; int ret = 0; + for (index = 0; index < xlator->ctx->xl_count; index++) { if (inode->_ctx[index].key == (uint64_t)(long)xlator) break; @@ -1162,8 +1135,8 @@ inode_ctx_get (inode_t *inode, xlator_t *xlator, uint64_t *value) { int ret = 0; - if (!inode || !xlator) - return -1; + if (!inode || !xlator) + return -1; LOCK (&inode->lock); { @@ -1171,18 +1144,18 @@ inode_ctx_get (inode_t *inode, xlator_t *xlator, uint64_t *value) } UNLOCK (&inode->lock); - return ret; + return ret; } int inode_ctx_del (inode_t *inode, xlator_t *xlator, uint64_t *value) { - int index = 0; + int index = 0; int ret = 0; - if (!inode || !xlator) - return -1; + if (!inode || !xlator) + return -1; LOCK (&inode->lock); { @@ -1197,7 +1170,7 @@ inode_ctx_del (inode_t *inode, xlator_t *xlator, uint64_t *value) } if (value) - *value = inode->_ctx[index].value; + *value = inode->_ctx[index].value; inode->_ctx[index].key = 0; inode->_ctx[index].value = 0; @@ -1205,7 +1178,7 @@ inode_ctx_del (inode_t *inode, xlator_t *xlator, uint64_t *value) unlock: UNLOCK (&inode->lock); - return ret; + return ret; } void @@ -1219,11 +1192,11 @@ inode_dump (inode_t *inode, char *prefix) if (!inode) return; - ret = TRY_LOCK(&inode->lock); + ret = TRY_LOCK(&inode->lock); if (ret != 0) { gf_log("", GF_LOG_WARNING, "Unable to dump inode" - " errno: %d", errno); + " errno: %d", errno); return; } @@ -1237,17 +1210,17 @@ inode_dump (inode_t *inode, char *prefix) gf_proc_dump_write(key, "%ld", inode->ino); gf_proc_dump_build_key(key, prefix, "st_mode"); gf_proc_dump_write(key, "%d", inode->st_mode); - UNLOCK(&inode->lock); - if (!inode->_ctx) - goto out; - - for (i = 0; i < inode->table->xl->ctx->xl_count; i++) { - if (inode->_ctx[i].key) { - xl = (xlator_t *)(long)inode->_ctx[i].key; - if (xl->dumpops && xl->dumpops->inodectx) - xl->dumpops->inodectx (xl, inode); - } - } + UNLOCK(&inode->lock); + if (!inode->_ctx) + goto out; + + for (i = 0; i < inode->table->xl->ctx->xl_count; i++) { + if (inode->_ctx[i].key) { + xl = (xlator_t *)(long)inode->_ctx[i].key; + if (xl->dumpops && xl->dumpops->inodectx) + xl->dumpops->inodectx (xl, inode); + } + } out: return; @@ -1264,11 +1237,11 @@ inode_table_dump (inode_table_t *itable, char *prefix) return; memset(key, 0, sizeof(key)); - ret = pthread_mutex_trylock(&itable->lock); + ret = pthread_mutex_trylock(&itable->lock); if (ret != 0) { gf_log("", GF_LOG_WARNING, "Unable to dump inode table" - " errno: %d", errno); + " errno: %d", errno); return; } |