UBUNTU: ubuntu: AUFS -- update to 097bf62d6f49619359d34bf17f242df38562489a

author Andy Whitcroft <apw@canonical.com>

Mon, 22 Nov 2010 15:51:22 +0000 (15:51 +0000)

committer Leann Ogasawara <leann.ogasawara@canonical.com>

Mon, 28 Mar 2011 13:51:25 +0000 (06:51 -0700)
author Andy Whitcroft <apw@canonical.com>
Mon, 22 Nov 2010 15:51:22 +0000 (15:51 +0000)
committer Leann Ogasawara <leann.ogasawara@canonical.com>
Mon, 28 Mar 2011 13:51:25 +0000 (06:51 -0700)
diff --git a/ubuntu/aufs/BOM b/ubuntu/aufs/BOM

index a25a63e..efa81f9 100644 (file)
--- a/ubuntu/aufs/BOM
+++ b/ubuntu/aufs/BOM
@@ -1,2 +1,2 @@
  URL: http://git.c3sl.ufpr.br/pub/scm/aufs/aufs2-standalone.git
-COMMIT: c656be344b5080b5a88cfc44977da2072c6b6f80
+COMMIT: 097bf62d6f49619359d34bf17f242df38562489a
diff --git a/ubuntu/aufs/Kconfig b/ubuntu/aufs/Kconfig

index 989f2de..17f8f75 100644 (file)
--- a/ubuntu/aufs/Kconfig
+++ b/ubuntu/aufs/Kconfig
@@ -58,6 +58,7 @@ config AUFS_HNOTIFY
         If you want to modify files on branches directly, eg. bypassing aufs,
         and want aufs to detect the changes of them fully, then enable this
         option and use 'udba=notify' mount option.
+       Currently there is only one available configuration, "fsnotify".
         It will have a negative impact to the performance.
         See detail in aufs.5.
  
@@ -67,9 +68,6 @@ choice
  config AUFS_HFSNOTIFY
         bool "fsnotify"
         select FSNOTIFY
-config AUFS_HINOTIFY
-       bool "inotify (DEPRECATED)"
-       depends on INOTIFY
  endchoice
  
  config AUFS_EXPORT
diff --git a/ubuntu/aufs/Makefile b/ubuntu/aufs/Makefile

index c83dd25..8e9f7c8 100644 (file)
--- a/ubuntu/aufs/Makefile
+++ b/ubuntu/aufs/Makefile
@@ -9,8 +9,8 @@ endif
  # cf. include/linux/kernel.h
  # enable pr_debug
  ccflags-y += -DDEBUG
-ccflags-y += -D'pr_fmt(fmt)="aufs %s:%d:%s[%d]: " fmt, \
-       __func__, __LINE__, current->comm, current->pid'
+# sparse doesn't allow spaces
+ccflags-y += -D'pr_fmt(fmt)=AUFS_NAME"\040%s:%d:%s[%d]:\040"fmt,__func__,__LINE__,current->comm,current->pid'
  
  obj-$(CONFIG_AUFS_FS) += aufs.o
  aufs-y := module.o sbinfo.o super.o branch.o xino.o sysaufs.o opts.o \
@@ -30,7 +30,6 @@ aufs-$(CONFIG_DEBUG_FS) += dbgaufs.o
  aufs-$(CONFIG_AUFS_BDEV_LOOP) += loop.o
  aufs-$(CONFIG_AUFS_HNOTIFY) += hnotify.o
  aufs-$(CONFIG_AUFS_HFSNOTIFY) += hfsnotify.o
-aufs-$(CONFIG_AUFS_HINOTIFY) += hinotify.o
  aufs-$(CONFIG_AUFS_EXPORT) += export.o
  aufs-$(CONFIG_AUFS_POLL) += poll.o
  aufs-$(CONFIG_AUFS_RDU) += rdu.o
diff --git a/ubuntu/aufs/branch.c b/ubuntu/aufs/branch.c

index a890ae1..4687a35 100644 (file)
--- a/ubuntu/aufs/branch.c
+++ b/ubuntu/aufs/branch.c
@@ -321,11 +321,11 @@ static int au_wbr_init(struct au_branch *br, struct super_block *sb,
          * a limit for rmdir/rename a dir
          * cf. AUFS_MAX_NAMELEN in include/linux/aufs_type.h
          */
-       h_dentry = path->dentry;
-       err = statfs_by_dentry(h_dentry, &kst);
+       err = vfs_statfs(path, &kst);
         if (unlikely(err))
                 goto out;
         err = -EINVAL;
+       h_dentry = path->dentry;
         if (kst.f_namelen >= NAME_MAX)
                 err = au_br_init_wh(sb, br, perm, h_dentry);
         else
@@ -354,6 +354,7 @@ static int au_br_init(struct au_branch *br, struct super_block *sb,
         br->br_xino_upper = AUFS_XINO_TRUNC_INIT;
         atomic_set(&br->br_xino_running, 0);
         br->br_id = au_new_br_id(sb);
+       AuDebugOn(br->br_id < 0);
  
         if (au_br_writable(add->perm)) {
                 err = au_wbr_init(br, sb, add->perm, &add->path);
@@ -584,15 +585,23 @@ static int test_inode_busy(struct super_block *sb, aufs_bindex_t bindex,
                            unsigned int sigen, const unsigned int verbose)
  {
         int err;
-       struct inode *i;
+       unsigned long long max, ull;
+       struct inode *i, **array;
         aufs_bindex_t bstart, bend;
  
+       array = au_iarray_alloc(sb, &max);
+       err = PTR_ERR(array);
+       if (IS_ERR(array))
+               goto out;
+
         err = 0;
-       list_for_each_entry(i, &sb->s_inodes, i_sb_list) {
-               AuDebugOn(!atomic_read(&i->i_count));
-               if (!list_empty(&i->i_dentry))
+       AuDbg("b%d\n", bindex);
+       for (ull = 0; !err && ull < max; ull++) {
+               i = array[ull];
+               if (i->i_ino == AUFS_ROOT_INO)
                         continue;
  
+               /* AuDbgInode(i); */
                 if (au_iigen(i) == sigen)
                         ii_read_lock_child(i);
                 else {
@@ -614,12 +623,13 @@ static int test_inode_busy(struct super_block *sb, aufs_bindex_t bindex,
                     && (!S_ISDIR(i->i_mode) || bstart == bend)) {
                         err = -EBUSY;
                         AuVerbose(verbose, "busy i%lu\n", i->i_ino);
-                       ii_read_unlock(i);
-                       break;
+                       AuDbgInode(i);
                 }
                 ii_read_unlock(i);
         }
+       au_iarray_free(array, max);
  
+out:
         return err;
  }
  
@@ -835,41 +845,78 @@ static int need_sigen_inc(int old, int new)
                 || do_need_sigen_inc(new, old);
  }
  
+static unsigned long long au_farray_cb(void *a,
+                                      unsigned long long max __maybe_unused,
+                                      void *arg)
+{
+       unsigned long long n;
+       struct file **p, *f;
+       struct super_block *sb = arg;
+
+       n = 0;
+       p = a;
+       lg_global_lock(files_lglock);
+       do_file_list_for_each_entry(sb, f) {
+               if (au_fi(f)
+                   && !special_file(f->f_dentry->d_inode->i_mode)) {
+                       get_file(f);
+                       *p++ = f;
+                       n++;
+                       AuDebugOn(n > max);
+               }
+       } while_file_list_for_each_entry;
+       lg_global_unlock(files_lglock);
+
+       return n;
+}
+
+static struct file **au_farray_alloc(struct super_block *sb,
+                                    unsigned long long *max)
+{
+       *max = atomic_long_read(&au_sbi(sb)->si_nfiles);
+       return au_array_alloc(max, au_farray_cb, sb);
+}
+
+static void au_farray_free(struct file **a, unsigned long long max)
+{
+       unsigned long long ull;
+
+       for (ull = 0; ull < max; ull++)
+               if (a[ull])
+                       fput(a[ull]);
+       au_array_free(a);
+}
+
  static int au_br_mod_files_ro(struct super_block *sb, aufs_bindex_t bindex)
  {
-       int err;
-       unsigned long n, ul, bytes, files;
+       int err, do_warn;
+       unsigned long long ull, max;
         aufs_bindex_t br_id;
-       struct file *file, *hf, **a;
+       struct file *file, *hf, **array;
         struct dentry *dentry;
         struct inode *inode;
         struct au_hfile *hfile;
-       const int step_bytes = 1024, /* memory allocation unit */
-               step_files = step_bytes / sizeof(*a);
  
-       err = -ENOMEM;
-       n = 0;
-       bytes = step_bytes;
-       files = step_files;
-       a = kmalloc(bytes, GFP_NOFS);
-       if (unlikely(!a))
+       array = au_farray_alloc(sb, &max);
+       err = PTR_ERR(array);
+       if (IS_ERR(array))
                 goto out;
  
-       /* no need file_list_lock() since sbinfo is locked? defered? */
+       do_warn = 0;
         br_id = au_sbr_id(sb, bindex);
-       do_file_list_for_each_entry(sb, file) {
-               if (special_file(file->f_dentry->d_inode->i_mode))
-                       continue;
+       for (ull = 0; ull < max; ull++) {
+               file = array[ull];
                 dentry = file->f_dentry;
                 inode = dentry->d_inode;
  
-               AuDbg("%.*s\n", AuDLNPair(file->f_dentry));
+               /* AuDbg("%.*s\n", AuDLNPair(file->f_dentry)); */
                 fi_read_lock(file);
                 if (unlikely(au_test_mmapped(file))) {
                         err = -EBUSY;
+                       AuDbgFile(file);
                         FiMustNoWaiters(file);
                         fi_read_unlock(file);
-                       goto out_free;
+                       goto out_array;
                 }
  
                 hfile = &au_fi(file)->fi_htop;
@@ -877,39 +924,33 @@ static int au_br_mod_files_ro(struct super_block *sb, aufs_bindex_t bindex)
                 if (!S_ISREG(inode->i_mode)
                     || !(file->f_mode & FMODE_WRITE)
                     || hfile->hf_br->br_id != br_id
-                   || !(hf->f_mode & FMODE_WRITE)) {
-                       FiMustNoWaiters(file);
-                       fi_read_unlock(file);
-                       continue;
+                   || !(hf->f_mode & FMODE_WRITE))
+                       array[ull] = NULL;
+               else {
+                       do_warn = 1;
+                       get_file(file);
                 }
  
                 FiMustNoWaiters(file);
                 fi_read_unlock(file);
-
-               if (n < files)
-                       a[n++] = hf;
-               else {
-                       void *p;
-
-                       err = -ENOMEM;
-                       bytes += step_bytes;
-                       files += step_files;
-                       p = krealloc(a, bytes, GFP_NOFS);
-                       if (p) {
-                               a = p;
-                               a[n++] = hf;
-                       } else
-                               goto out_free;
-               }
-       } while_file_list_for_each_entry;
+               fput(file);
+       }
  
         err = 0;
-       if (n)
+       if (do_warn)
                 au_warn_ima();
-       for (ul = 0; ul < n; ul++) {
+
+       for (ull = 0; ull < max; ull++) {
+               file = array[ull];
+               if (!file)
+                       continue;
+
                 /* todo: already flushed? */
                 /* cf. fs/super.c:mark_files_ro() */
-               hf = a[ul];
+               /* fi_read_lock(file); */
+               hfile = &au_fi(file)->fi_htop;
+               hf = hfile->hf_file;
+               /* fi_read_unlock(file); */
                 hf->f_mode &= ~FMODE_WRITE;
                 if (!file_check_writeable(hf)) {
                         file_release_write(hf);
@@ -917,14 +958,15 @@ static int au_br_mod_files_ro(struct super_block *sb, aufs_bindex_t bindex)
                 }
         }
  
-out_free:
-       kfree(a);
+out_array:
+       au_farray_free(array, max);
  out:
+       AuTraceErr(err);
         return err;
  }
  
  int au_br_mod(struct super_block *sb, struct au_opt_mod *mod, int remount,
-             int *do_update)
+             int *do_refresh)
  {
         int err, rerr;
         aufs_bindex_t bindex;
@@ -999,10 +1041,11 @@ int au_br_mod(struct super_block *sb, struct au_opt_mod *mod, int remount,
         }
  
         if (!err) {
-               *do_update |= need_sigen_inc(br->br_perm, mod->perm);
+               *do_refresh |= need_sigen_inc(br->br_perm, mod->perm);
                 br->br_perm = mod->perm;
         }
  
  out:
+       AuTraceErr(err);
         return err;
  }
diff --git a/ubuntu/aufs/branch.h b/ubuntu/aufs/branch.h

index cf430a5..ddbfbb8 100644 (file)
--- a/ubuntu/aufs/branch.h
+++ b/ubuntu/aufs/branch.h
@@ -144,7 +144,7 @@ struct au_opt_del;
  int au_br_del(struct super_block *sb, struct au_opt_del *del, int remount);
  struct au_opt_mod;
  int au_br_mod(struct super_block *sb, struct au_opt_mod *mod, int remount,
-             int *do_update);
+             int *do_refresh);
  
  /* xino.c */
  static const loff_t au_loff_max = LLONG_MAX;
diff --git a/ubuntu/aufs/conf.mk b/ubuntu/aufs/conf.mk

index 9a57d84..9217b48 100644 (file)
--- a/ubuntu/aufs/conf.mk
+++ b/ubuntu/aufs/conf.mk
@@ -9,7 +9,7 @@ endef
  
  AuConfAll = BRANCH_MAX_127 BRANCH_MAX_511 BRANCH_MAX_1023 BRANCH_MAX_32767 \
         SBILIST \
-       HNOTIFY HFSNOTIFY HINOTIFY \
+       HNOTIFY HFSNOTIFY \
         EXPORT INO_T_64 \
         RDU \
         SP_IATTR \
diff --git a/ubuntu/aufs/cpup.h b/ubuntu/aufs/cpup.h

index 506350d..cd77860 100644 (file)
--- a/ubuntu/aufs/cpup.h
+++ b/ubuntu/aufs/cpup.h
@@ -46,8 +46,10 @@ void au_cpup_attr_all(struct inode *inode, int force);
  #define AuCpup_KEEPLINO        (1 << 1)        /* do not clear the lower xino,
                                            for link(2) */
  #define au_ftest_cpup(flags, name)     ((flags) & AuCpup_##name)
-#define au_fset_cpup(flags, name)      { (flags) |= AuCpup_##name; }
-#define au_fclr_cpup(flags, name)      { (flags) &= ~AuCpup_##name; }
+#define au_fset_cpup(flags, name) \
+       do { (flags) |= AuCpup_##name; } while (0)
+#define au_fclr_cpup(flags, name) \
+       do { (flags) &= ~AuCpup_##name; } while (0)
  
  int au_copy_file(struct file *dst, struct file *src, loff_t len);
  int au_sio_cpup_single(struct dentry *dentry, aufs_bindex_t bdst,
diff --git a/ubuntu/aufs/dcsub.h b/ubuntu/aufs/dcsub.h

index 0c87168..be25a13 100644 (file)
--- a/ubuntu/aufs/dcsub.h
+++ b/ubuntu/aufs/dcsub.h
@@ -25,6 +25,7 @@
  
  #ifdef __KERNEL__
  
+#include <linux/dcache.h>
  #include <linux/types.h>
  
  struct dentry;
@@ -41,6 +42,7 @@ struct au_dcsub_pages {
  
  /* ---------------------------------------------------------------------- */
  
+/* dcsub.c */
  int au_dpages_init(struct au_dcsub_pages *dpages, gfp_t gfp);
  void au_dpages_free(struct au_dcsub_pages *dpages);
  typedef int (*au_dpages_test)(struct dentry *dentry, void *arg);
@@ -50,5 +52,12 @@ int au_dcsub_pages_rev(struct au_dcsub_pages *dpages, struct dentry *dentry,
                        int do_include, au_dpages_test test, void *arg);
  int au_test_subdir(struct dentry *d1, struct dentry *d2);
  
+/* ---------------------------------------------------------------------- */
+
+static inline int au_d_removed(struct dentry *d)
+{
+       return !IS_ROOT(d) && d_unhashed(d);
+}
+
  #endif /* __KERNEL__ */
  #endif /* __AUFS_DCSUB_H__ */
diff --git a/ubuntu/aufs/debug.c b/ubuntu/aufs/debug.c

index 74af9d4..ec8dc07 100644 (file)
--- a/ubuntu/aufs/debug.c
+++ b/ubuntu/aufs/debug.c
@@ -21,6 +21,7 @@
   */
  
  #include <linux/module.h>
+#include <linux/vt_kern.h>
  #include "aufs.h"
  
  int aufs_debug;
@@ -377,26 +378,12 @@ void au_dbg_verify_gen(struct dentry *parent, unsigned int sigen)
  
  void au_dbg_verify_kthread(void)
  {
-       struct task_struct *tsk = current;
-
-       if ((tsk->flags & PF_KTHREAD)
-           && !strncmp(tsk->comm, AUFS_WKQ_NAME "/", sizeof(AUFS_WKQ_NAME))) {
+       if (current->flags & PF_WQ_WORKER) {
                 au_dbg_blocked();
-               BUG();
+               WARN_ON(1);
         }
  }
  
-static void au_dbg_do_verify_wkq(void *args)
-{
-       BUG_ON(current_fsuid());
-       BUG_ON(rlimit(RLIMIT_FSIZE) != RLIM_INFINITY);
-}
-
-void au_dbg_verify_wkq(void)
-{
-       au_wkq_wait(au_dbg_do_verify_wkq, NULL);
-}
-
  /* ---------------------------------------------------------------------- */
  
  void au_debug_sbinfo_init(struct au_sbinfo *sbinfo __maybe_unused)
diff --git a/ubuntu/aufs/debug.h b/ubuntu/aufs/debug.h

index 443f4c5..c6b2626 100644 (file)
--- a/ubuntu/aufs/debug.h
+++ b/ubuntu/aufs/debug.h
@@ -27,10 +27,13 @@
  
  #include <asm/system.h>
  #include <linux/bug.h>
+/* #include <linux/err.h> */
  #include <linux/init.h>
  #include <linux/module.h>
  #include <linux/kallsyms.h>
+/* #include <linux/kernel.h> */
  #include <linux/delay.h>
+/* #include <linux/kd.h> */
  #include <linux/sysrq.h>
  #include <linux/aufs_type.h>
  
@@ -133,7 +136,6 @@ void au_dbg_verify_dir_parent(struct dentry *dentry, unsigned int sigen);
  void au_dbg_verify_nondir_parent(struct dentry *dentry, unsigned int sigen);
  void au_dbg_verify_gen(struct dentry *parent, unsigned int sigen);
  void au_dbg_verify_kthread(void);
-void au_dbg_verify_wkq(void);
  
  int __init au_debug_init(void);
  void au_debug_sbinfo_init(struct au_sbinfo *sbinfo);
@@ -199,7 +201,6 @@ AuStubVoid(au_dbg_verify_nondir_parent, struct dentry *dentry,
            unsigned int sigen)
  AuStubVoid(au_dbg_verify_gen, struct dentry *parent, unsigned int sigen)
  AuStubVoid(au_dbg_verify_kthread, void)
-AuStubVoid(au_dbg_verify_wkq, void)
  AuStubInt0(__init au_debug_init, void)
  AuStubVoid(au_debug_sbinfo_init, struct au_sbinfo *sbinfo)
  
diff --git a/ubuntu/aufs/dentry.c b/ubuntu/aufs/dentry.c

index d669312..2743e26 100644 (file)
--- a/ubuntu/aufs/dentry.c
+++ b/ubuntu/aufs/dentry.c
@@ -82,8 +82,10 @@ static void au_call_lkup_one(void *args)
  
  #define AuLkup_ALLOW_NEG       1
  #define au_ftest_lkup(flags, name)     ((flags) & AuLkup_##name)
-#define au_fset_lkup(flags, name)      { (flags) |= AuLkup_##name; }
-#define au_fclr_lkup(flags, name)      { (flags) &= ~AuLkup_##name; }
+#define au_fset_lkup(flags, name) \
+       do { (flags) |= AuLkup_##name; } while (0)
+#define au_fclr_lkup(flags, name) \
+       do { (flags) &= ~AuLkup_##name; } while (0)
  
  struct au_do_lookup_args {
         unsigned int            flags;
@@ -629,8 +631,9 @@ static int h_d_revalidate(struct dentry *dentry, struct inode *inode,
         name = &dentry->d_name;
  
         /*
-        * Theoretically, REVAL test should be unnecessary in case of INOTIFY.
-        * But inotify doesn't fire some necessary events,
+        * Theoretically, REVAL test should be unnecessary in case of
+        * {FS,I}NOTIFY.
+        * But {fs,i}notify doesn't fire some necessary events,
          *      IN_ATTRIB for atime/nlink/pageio
          *      IN_DELETE for NFS dentry
          * Let's do REVAL test too.
diff --git a/ubuntu/aufs/dinfo.c b/ubuntu/aufs/dinfo.c

index b57ef24..4a638dc 100644 (file)
--- a/ubuntu/aufs/dinfo.c
+++ b/ubuntu/aufs/dinfo.c
@@ -373,7 +373,7 @@ void au_update_dbend(struct dentry *dentry)
         struct dentry *h_dentry;
  
         bstart = au_dbstart(dentry);
-       for (bindex = au_dbend(dentry); bindex <= bstart; bindex--) {
+       for (bindex = au_dbend(dentry); bindex >= bstart; bindex--) {
                 h_dentry = au_h_dptr(dentry, bindex);
                 if (!h_dentry)
                         continue;
diff --git a/ubuntu/aufs/dir.c b/ubuntu/aufs/dir.c

index b7a9302..d97ec02 100644 (file)
--- a/ubuntu/aufs/dir.c
+++ b/ubuntu/aufs/dir.c
@@ -203,10 +203,12 @@ static int aufs_release_dir(struct inode *inode __maybe_unused,
                             struct file *file)
  {
         struct au_vdir *vdir_cache;
+       struct super_block *sb;
         struct au_finfo *finfo;
         struct au_fidir *fidir;
         aufs_bindex_t bindex, bend;
  
+       sb = file->f_dentry->d_sb;
         finfo = au_fi(file);
         fidir = finfo->fi_hdir;
         if (fidir) {
@@ -426,8 +428,10 @@ out:
  #define AuTestEmpty_CALLED     (1 << 1)
  #define AuTestEmpty_SHWH       (1 << 2)
  #define au_ftest_testempty(flags, name)        ((flags) & AuTestEmpty_##name)
-#define au_fset_testempty(flags, name) { (flags) |= AuTestEmpty_##name; }
-#define au_fclr_testempty(flags, name) { (flags) &= ~AuTestEmpty_##name; }
+#define au_fset_testempty(flags, name) \
+       do { (flags) |= AuTestEmpty_##name; } while (0)
+#define au_fclr_testempty(flags, name) \
+       do { (flags) &= ~AuTestEmpty_##name; } while (0)
  
  #ifndef CONFIG_AUFS_SHWH
  #undef AuTestEmpty_SHWH
@@ -625,6 +629,7 @@ int au_test_empty(struct dentry *dentry, struct au_nhash *whlist)
  
  const struct file_operations aufs_dir_fop = {
         .owner          = THIS_MODULE,
+       .llseek         = default_llseek,
         .read           = generic_read_dir,
         .readdir        = aufs_readdir,
         .unlocked_ioctl = aufs_ioctl_dir,
diff --git a/ubuntu/aufs/f_op.c b/ubuntu/aufs/f_op.c

index 67f2a5b..829a67e 100644 (file)
--- a/ubuntu/aufs/f_op.c
+++ b/ubuntu/aufs/f_op.c
@@ -85,6 +85,7 @@ int aufs_release_nondir(struct inode *inode __maybe_unused, struct file *file)
                 file_sb_list_del(file);
                 au_set_h_fptr(file, bindex, NULL);
         }
+
         au_finfo_fin(file);
         return 0;
  }
diff --git a/ubuntu/aufs/file.c b/ubuntu/aufs/file.c

index 33ce3c7..15e38ce 100644 (file)
--- a/ubuntu/aufs/file.c
+++ b/ubuntu/aufs/file.c
@@ -54,8 +54,10 @@ struct file *au_h_open(struct dentry *dentry, aufs_bindex_t bindex, int flags,
         h_inode = h_dentry->d_inode;
         if (au_test_nfsd() && !h_inode)
                 goto out;
-       if (unlikely((!d_unhashed(dentry) && d_unhashed(h_dentry))
-                    || !h_inode))
+       if (unlikely((!d_unhashed(dentry) && au_d_removed(h_dentry))
+                    || !h_inode
+                    /* || !dentry->d_inode->i_nlink */
+                   ))
                 goto out;
  
         sb = dentry->d_sb;
@@ -365,7 +367,8 @@ static int au_file_refresh_by_inode(struct file *file, int *need_reopen)
  
         di_read_lock_parent(parent, AuLock_IR);
         hi_wh = au_hi_wh(inode, bstart);
-       if (au_opt_test(au_mntflags(sb), PLINK)
+       if (!S_ISDIR(inode->i_mode)
+           && au_opt_test(au_mntflags(sb), PLINK)
             && au_plink_test(inode)
             && !d_unhashed(dentry)) {
                 err = au_test_and_cpup_dirs(dentry, bstart);
@@ -434,7 +437,7 @@ static void au_do_refresh_dir(struct file *file)
         }
  
         p = fidir->fd_hfile;
-       if (!au_test_mmapped(file) && !d_unhashed(file->f_dentry)) {
+       if (!au_test_mmapped(file) && !au_d_removed(file->f_dentry)) {
                 bend = au_sbend(sb);
                 for (finfo->fi_btop = 0; finfo->fi_btop <= bend;
                      finfo->fi_btop++, p++)
@@ -498,7 +501,7 @@ static int refresh_file(struct file *file, int (*reopen)(struct file *file))
         need_reopen = 1;
         if (!au_test_mmapped(file))
                 err = au_file_refresh_by_inode(file, &need_reopen);
-       if (!err && need_reopen && !d_unhashed(dentry))
+       if (!err && need_reopen && !au_d_removed(dentry))
                 err = reopen(file);
         if (!err) {
                 au_update_figen(file);
diff --git a/ubuntu/aufs/finfo.c b/ubuntu/aufs/finfo.c

index d618e46..0ffb553 100644 (file)
--- a/ubuntu/aufs/finfo.c
+++ b/ubuntu/aufs/finfo.c
@@ -126,6 +126,8 @@ void au_finfo_fin(struct file *file)
  {
         struct au_finfo *finfo;
  
+       au_nfiles_dec(file->f_dentry->d_sb);
+
         finfo = au_fi(file);
         AuDebugOn(finfo->fi_hdir);
         AuRwDestroy(&finfo->fi_rwsem);
@@ -158,6 +160,7 @@ int au_finfo_init(struct file *file, struct au_fidir *fidir)
                 goto out;
  
         err = 0;
+       au_nfiles_inc(dentry->d_sb);
         au_rw_write_lock(&finfo->fi_rwsem);
         finfo->fi_btop = -1;
         finfo->fi_hdir = fidir;
diff --git a/ubuntu/aufs/hfsnotify.c b/ubuntu/aufs/hfsnotify.c

index 7636a88..621b538 100644 (file)
--- a/ubuntu/aufs/hfsnotify.c
+++ b/ubuntu/aufs/hfsnotify.c
@@ -26,25 +26,32 @@
  static const __u32 AuHfsnMask = (FS_MOVED_TO | FS_MOVED_FROM | FS_DELETE
                                  | FS_CREATE | FS_EVENT_ON_CHILD);
  static struct fsnotify_group *au_hfsn_group;
+static DECLARE_WAIT_QUEUE_HEAD(au_hfsn_wq);
  
  static void au_hfsn_free_mark(struct fsnotify_mark *mark)
  {
-#if 0
         struct au_hnotify *hn = container_of(mark, struct au_hnotify,
                                              hn_mark);
-       au_cache_free_hnotify(hn);
-#endif
         AuDbg("here\n");
+       hn->hn_mark_dead = 1;
+       smp_mb();
+       wake_up_all(&au_hfsn_wq);
  }
  
  static int au_hfsn_alloc(struct au_hnotify *hn, struct inode *h_inode)
  {
         struct fsnotify_mark *mark;
  
+       hn->hn_mark_dead = 0;
         mark = &hn->hn_mark;
         fsnotify_init_mark(mark, au_hfsn_free_mark);
         mark->mask = AuHfsnMask;
-       return fsnotify_add_mark(mark, au_hfsn_group, h_inode, NULL, 1);
+       /*
+        * by udba rename or rmdir, aufs assign a new inode to the known
+        * h_inode, so specify 1 to allow dups.
+        */
+       return fsnotify_add_mark(mark, au_hfsn_group, h_inode, /*mnt*/NULL,
+                                /*allow_dups*/1);
  }
  
  static void au_hfsn_free(struct au_hnotify *hn)
@@ -54,6 +61,9 @@ static void au_hfsn_free(struct au_hnotify *hn)
         mark = &hn->hn_mark;
         fsnotify_destroy_mark(mark);
         fsnotify_put_mark(mark);
+
+       /* TODO: bad approach */
+       wait_event(au_hfsn_wq, hn->hn_mark_dead);
  }
  
  /* ---------------------------------------------------------------------- */
@@ -152,28 +162,21 @@ static int au_hfsn_handle_event(struct fsnotify_group *group,
         AuDebugOn(!inode_mark);
         hnotify = container_of(inode_mark, struct au_hnotify, hn_mark);
         err = au_hnotify(h_dir, hnotify, mask, &h_child_qstr, h_inode);
-       fsnotify_put_mark(inode_mark);
  
  out:
         return err;
  }
  
-/* copied from linux/fs/notify/inotify/inotify_fsnotify.c */
+/* copied from linux/fs/notify/inotify/inotify_fsnotiry.c */
  /* it should be exported to modules */
-static bool au_hfsn_should_send_event(struct fsnotify_group *group, struct inode *inode,
+static bool au_hfsn_should_send_event(struct fsnotify_group *group,
+                                     struct inode *h_inode,
                                       struct fsnotify_mark *inode_mark,
                                       struct fsnotify_mark *vfsmount_mark,
                                       __u32 mask, void *data, int data_type)
  {
-       bool send;
-
         mask = (mask & ~FS_EVENT_ON_CHILD);
-       send = (inode_mark->mask & mask);
-
-       /* find took a reference */
-       fsnotify_put_mark(inode_mark);
-
-       return send;
+       return inode_mark->mask & mask;
  }
  
  static struct fsnotify_ops au_hfsn_ops = {
diff --git a/ubuntu/aufs/hinotify.c b/ubuntu/aufs/hinotify.c

deleted file mode 100644 (file)

index c2d900b..0000000
--- a/ubuntu/aufs/hinotify.c
+++ /dev/null
@@ -1,231 +0,0 @@
-/*
- * Copyright (C) 2005-2010 Junjiro R. Okajima
- *
- * This program, aufs 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 2 of the License, or
- * (at your option) any later version.
- *
- * This program 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, write to the Free Software
- * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA
- */
-
-/*
- * inotify for the lower directories (deprecated)
- */
-
-#include "aufs.h"
-
-static const __u32 AuHinMask = (IN_MOVE | IN_DELETE | IN_CREATE);
-static struct inotify_handle *au_hin_handle;
-
-/* ---------------------------------------------------------------------- */
-
-static int au_hin_alloc(struct au_hnotify *hn, struct inode *h_inode)
-{
-       int err;
-       s32 wd;
-       struct inotify_watch *watch;
-
-       err = -EEXIST;
-       wd = inotify_find_watch(au_hin_handle, h_inode, &watch);
-       if (wd >= 0) {
-               put_inotify_watch(watch);
-               goto out;
-       }
-
-       err = 0;
-       inotify_init_watch(&hn->hn_watch);
-       wd = inotify_add_watch(au_hin_handle, &hn->hn_watch, h_inode,
-                              AuHinMask);
-       if (unlikely(wd < 0)) {
-               err = wd;
-               put_inotify_watch(&hn->hn_watch);
-       }
-
-out:
-       return err;
-}
-
-static void au_hin_free(struct au_hnotify *hn)
-{
-       int err;
-
-       err = 0;
-       if (atomic_read(&hn->hn_watch.count))
-               err = inotify_rm_watch(au_hin_handle, &hn->hn_watch);
-       if (unlikely(err))
-               /* it means the watch is already removed */
-               pr_warning("failed inotify_rm_watch() %d\n", err);
-}
-
-/* ---------------------------------------------------------------------- */
-
-static void au_hin_ctl(struct au_hinode *hinode, int do_set)
-{
-       struct inode *h_inode;
-       struct inotify_watch *watch;
-
-       h_inode = hinode->hi_inode;
-       IMustLock(h_inode);
-
-       /* todo: try inotify_find_update_watch()? */
-       watch = &hinode->hi_notify->hn_watch;
-       mutex_lock(&h_inode->inotify_mutex);
-       /* mutex_lock(&watch->ih->mutex); */
-       if (do_set) {
-               AuDebugOn(watch->mask & AuHinMask);
-               watch->mask |= AuHinMask;
-       } else {
-               AuDebugOn(!(watch->mask & AuHinMask));
-               watch->mask &= ~AuHinMask;
-       }
-       /* mutex_unlock(&watch->ih->mutex); */
-       mutex_unlock(&h_inode->inotify_mutex);
-}
-
-/* ---------------------------------------------------------------------- */
-
-#ifdef AuDbgHnotify
-static char *in_name(u32 mask)
-{
-#ifdef CONFIG_AUFS_DEBUG
-#define test_ret(flag) if (mask & flag) \
-                               return #flag;
-       test_ret(IN_ACCESS);
-       test_ret(IN_MODIFY);
-       test_ret(IN_ATTRIB);
-       test_ret(IN_CLOSE_WRITE);
-       test_ret(IN_CLOSE_NOWRITE);
-       test_ret(IN_OPEN);
-       test_ret(IN_MOVED_FROM);
-       test_ret(IN_MOVED_TO);
-       test_ret(IN_CREATE);
-       test_ret(IN_DELETE);
-       test_ret(IN_DELETE_SELF);
-       test_ret(IN_MOVE_SELF);
-       test_ret(IN_UNMOUNT);
-       test_ret(IN_Q_OVERFLOW);
-       test_ret(IN_IGNORED);
-       return "";
-#undef test_ret
-#else
-       return "??";
-#endif
-}
-#endif
-
-static u32 au_hin_conv_mask(u32 mask)
-{
-       u32 conv;
-
-       conv = 0;
-#define do_conv(flag)  do {                                    \
-               conv |= (mask & IN_ ## flag) ? FS_ ## flag : 0; \
-       } while (0)
-       do_conv(ACCESS);
-       do_conv(MODIFY);
-       do_conv(ATTRIB);
-       do_conv(CLOSE_WRITE);
-       do_conv(CLOSE_NOWRITE);
-       do_conv(OPEN);
-       do_conv(MOVED_FROM);
-       do_conv(MOVED_TO);
-       do_conv(CREATE);
-       do_conv(DELETE);
-       do_conv(DELETE_SELF);
-       do_conv(MOVE_SELF);
-       do_conv(UNMOUNT);
-       do_conv(Q_OVERFLOW);
-#undef do_conv
-#define do_conv(flag)  do {                                            \
-               conv |= (mask & IN_ ## flag) ? FS_IN_ ## flag : 0;      \
-       } while (0)
-       do_conv(IGNORED);
-       /* do_conv(ISDIR); */
-       /* do_conv(ONESHOT); */
-#undef do_conv
-
-       return conv;
-}
-
-static void aufs_inotify(struct inotify_watch *watch, u32 wd __maybe_unused,
-                        u32 mask, u32 cookie __maybe_unused,
-                        const char *h_child_name, struct inode *h_child_inode)
-{
-       struct au_hnotify *hnotify;
-       struct qstr h_child_qstr = {
-               .name = h_child_name
-       };
-
-       /* if IN_UNMOUNT happens, there must be another bug */
-       AuDebugOn(mask & IN_UNMOUNT);
-       if (mask & (IN_IGNORED | IN_UNMOUNT)) {
-               put_inotify_watch(watch);
-               return;
-       }
-
-#ifdef AuDbgHnotify
-       au_debug(1);
-       if (1 || !h_child_name || strcmp(h_child_name, AUFS_XINO_FNAME)) {
-               AuDbg("i%lu, wd %d, mask 0x%x %s, cookie 0x%x, hcname %s,"
-                     " hi%lu\n",
-                     watch->inode->i_ino, wd, mask, in_name(mask), cookie,
-                     h_child_name ? h_child_name : "",
-                     h_child_inode ? h_child_inode->i_ino : 0);
-               WARN_ON(1);
-       }
-       au_debug(0);
-#endif
-
-       if (h_child_name)
-               h_child_qstr.len = strlen(h_child_name);
-       hnotify = container_of(watch, struct au_hnotify, hn_watch);
-       mask = au_hin_conv_mask(mask);
-       au_hnotify(watch->inode, hnotify, mask, &h_child_qstr, h_child_inode);
-}
-
-static void aufs_inotify_destroy(struct inotify_watch *watch __maybe_unused)
-{
-       return;
-}
-
-static struct inotify_operations aufs_inotify_ops = {
-       .handle_event   = aufs_inotify,
-       .destroy_watch  = aufs_inotify_destroy
-};
-
-/* ---------------------------------------------------------------------- */
-
-static int __init au_hin_init(void)
-{
-       int err;
-
-       err = 0;
-       au_hin_handle = inotify_init(&aufs_inotify_ops);
-       if (IS_ERR(au_hin_handle))
-               err = PTR_ERR(au_hin_handle);
-
-       AuTraceErr(err);
-       return err;
-}
-
-static void au_hin_fin(void)
-{
-       inotify_destroy(au_hin_handle);
-}
-
-const struct au_hnotify_op au_hnotify_op = {
-       .ctl            = au_hin_ctl,
-       .alloc          = au_hin_alloc,
-       .free           = au_hin_free,
-
-       .fin            = au_hin_fin,
-       .init           = au_hin_init
-};
diff --git a/ubuntu/aufs/hnotify.c b/ubuntu/aufs/hnotify.c

index 18d1707..535a5ce 100644 (file)
--- a/ubuntu/aufs/hnotify.c
+++ b/ubuntu/aufs/hnotify.c
@@ -281,8 +281,10 @@ static int hn_gen_by_name(struct dentry *dentry, const unsigned int isdir)
  #define AuHnJob_TRYXINO0       (1 << 4)
  #define AuHnJob_MNTPNT         (1 << 5)
  #define au_ftest_hnjob(flags, name)    ((flags) & AuHnJob_##name)
-#define au_fset_hnjob(flags, name)     { (flags) |= AuHnJob_##name; }
-#define au_fclr_hnjob(flags, name)     { (flags) &= ~AuHnJob_##name; }
+#define au_fset_hnjob(flags, name) \
+       do { (flags) |= AuHnJob_##name; } while (0)
+#define au_fclr_hnjob(flags, name) \
+       do { (flags) &= ~AuHnJob_##name; } while (0)
  
  enum {
         AuHn_CHILD,
@@ -451,7 +453,7 @@ static void au_hn_bh(void *_args)
         AuDebugOn(!sb);
         sbinfo = au_sbi(sb);
         AuDebugOn(!sbinfo);
-       si_write_lock(sb, !AuLock_FLUSH | AuLock_NOPLMW);
+       si_write_lock(sb, AuLock_NOPLMW);
  
         ii_read_lock_parent(a->dir);
         bfound = -1;
diff --git a/ubuntu/aufs/i_op.c b/ubuntu/aufs/i_op.c

index d8ad9af..bbda6e4 100644 (file)
--- a/ubuntu/aufs/i_op.c
+++ b/ubuntu/aufs/i_op.c
@@ -62,10 +62,8 @@ static int h_permission(struct inode *h_inode, int mask,
  
         if (!err)
                 err = devcgroup_inode_permission(h_inode, mask);
-       if (!err) {
-               mask &= (MAY_READ | MAY_WRITE | MAY_EXEC | MAY_APPEND);
+       if (!err)
                 err = security_inode_permission(h_inode, mask);
-       }
  
  #if 0
         if (!err) {
@@ -159,14 +157,18 @@ static struct dentry *aufs_lookup(struct inode *dir, struct dentry *dentry,
         IMustLock(dir);
  
         sb = dir->i_sb;
-       si_read_lock(sb, AuLock_FLUSH);
+       err = si_read_lock(sb, AuLock_FLUSH | AuLock_NOPLM);
+       ret = ERR_PTR(err);
+       if (unlikely(err))
+               goto out;
+
         ret = ERR_PTR(-ENAMETOOLONG);
         if (unlikely(dentry->d_name.len > AUFS_MAX_NAMELEN))
-               goto out;
+               goto out_si;
         err = au_di_init(dentry);
         ret = ERR_PTR(err);
         if (unlikely(err))
-               goto out;
+               goto out_si;
  
         parent = dentry->d_parent; /* dir inode is locked */
         di_read_lock_parent(parent, AuLock_IR);
@@ -186,13 +188,16 @@ static struct dentry *aufs_lookup(struct inode *dir, struct dentry *dentry,
                 goto out_unlock;
  
         ret = d_splice_alias(inode, dentry);
-       if (unlikely(IS_ERR(ret) && inode))
+       if (unlikely(IS_ERR(ret) && inode)) {
                 ii_write_unlock(inode);
+               iput(inode);
+       }
  
  out_unlock:
         di_write_unlock(dentry);
-out:
+out_si:
         si_read_unlock(sb);
+out:
         return ret;
  }
  
@@ -475,8 +480,10 @@ static int au_reval_for_attr(struct dentry *dentry, unsigned int sigen)
  
  #define AuIcpup_DID_CPUP       1
  #define au_ftest_icpup(flags, name)    ((flags) & AuIcpup_##name)
-#define au_fset_icpup(flags, name)     { (flags) |= AuIcpup_##name; }
-#define au_fclr_icpup(flags, name)     { (flags) &= ~AuIcpup_##name; }
+#define au_fset_icpup(flags, name) \
+       do { (flags) |= AuIcpup_##name; } while (0)
+#define au_fclr_icpup(flags, name) \
+       do { (flags) &= ~AuIcpup_##name; } while (0)
  
  struct au_icpup_args {
         unsigned char flags;
@@ -539,7 +546,7 @@ static int au_pin_and_icpup(struct dentry *dentry, struct iattr *ia,
  
         h_file = NULL;
         hi_wh = NULL;
-       if (au_ftest_icpup(a->flags, DID_CPUP) && d_unhashed(dentry)) {
+       if (au_ftest_icpup(a->flags, DID_CPUP) && au_d_removed(dentry)) {
                 hi_wh = au_hi_wh(inode, a->btgt);
                 if (!hi_wh) {
                         err = au_sio_cpup_wh(dentry, a->btgt, sz, /*file*/NULL);
@@ -630,6 +637,7 @@ static int aufs_setattr(struct dentry *dentry, struct iattr *ia)
         } else {
                 /* fchmod() doesn't pass ia_file */
                 a->udba = au_opt_udba(sb);
+               /* no au_d_removed(), to set UDBA_NONE for root */
                 if (d_unhashed(dentry))
                         a->udba = AuOpt_UDBA_NONE;
                 di_write_lock_child(dentry);
@@ -734,15 +742,16 @@ static int aufs_getattr(struct vfsmount *mnt __maybe_unused,
         struct vfsmount *h_mnt;
         struct dentry *h_dentry;
  
-       err = 0;
         sb = dentry->d_sb;
         inode = dentry->d_inode;
-       si_read_lock(sb, AuLock_FLUSH | AuLock_NOPLMW);
+       err = si_read_lock(sb, AuLock_FLUSH | AuLock_NOPLM);
+       if (unlikely(err))
+               goto out;
         mnt_flags = au_mntflags(sb);
         udba_none = !!au_opt_test(mnt_flags, UDBA_NONE);
  
         /* support fstat(2) */
-       if (!d_unhashed(dentry) && !udba_none) {
+       if (!au_d_removed(dentry) && !udba_none) {
                 unsigned int sigen = au_sigen(sb);
                 if (au_digen(dentry) == sigen && au_iigen(inode) == sigen)
                         di_read_lock_child(dentry, AuLock_IR);
@@ -752,7 +761,7 @@ static int aufs_getattr(struct vfsmount *mnt __maybe_unused,
                         err = au_reval_for_attr(dentry, sigen);
                         di_downgrade_lock(dentry, AuLock_IR);
                         if (unlikely(err))
-                               goto out;
+                               goto out_unlock;
                 }
         } else
                 di_read_lock_child(dentry, AuLock_IR);
@@ -784,13 +793,16 @@ static int aufs_getattr(struct vfsmount *mnt __maybe_unused,
                         au_refresh_iattr(inode, st, h_dentry->d_inode->i_nlink);
                 goto out_fill; /* success */
         }
-       goto out;
+       AuTraceErr(err);
+       goto out_unlock;
  
  out_fill:
         generic_fillattr(inode, st);
-out:
+out_unlock:
         di_read_unlock(dentry, AuLock_IR);
         si_read_unlock(sb);
+out:
+       AuTraceErr(err);
         return err;
  }
  
diff --git a/ubuntu/aufs/i_op_del.c b/ubuntu/aufs/i_op_del.c

index 1aa09d7..5b31bbd 100644 (file)
--- a/ubuntu/aufs/i_op_del.c
+++ b/ubuntu/aufs/i_op_del.c
@@ -280,17 +280,17 @@ static void epilog(struct inode *dir, struct dentry *dentry,
  /*
   * when an error happened, remove the created whiteout and revert everything.
   */
-static int do_revert(int err, struct inode *dir, aufs_bindex_t bwh,
-                    struct dentry *wh_dentry, struct dentry *dentry,
-                    struct au_dtime *dt)
+static int do_revert(int err, struct inode *dir, aufs_bindex_t bindex,
+                    aufs_bindex_t bwh, struct dentry *wh_dentry,
+                    struct dentry *dentry, struct au_dtime *dt)
  {
         int rerr;
         struct path h_path = {
                 .dentry = wh_dentry,
-               .mnt    = au_sbr_mnt(dir->i_sb, bwh)
+               .mnt    = au_sbr_mnt(dir->i_sb, bindex)
         };
  
-       rerr = au_wh_unlink_dentry(au_h_iptr(dir, bwh), &h_path, dentry);
+       rerr = au_wh_unlink_dentry(au_h_iptr(dir, bindex), &h_path, dentry);
         if (!rerr) {
                 au_set_dbwh(dentry, bwh);
                 au_dtime_revert(dt);
@@ -346,7 +346,7 @@ int aufs_unlink(struct inode *dir, struct dentry *dentry)
         }
  
         if (!err) {
-               drop_nlink(inode);
+               vfsub_drop_nlink(inode);
                 epilog(dir, dentry, bindex);
  
                 /* update target timestamps */
@@ -363,7 +363,7 @@ int aufs_unlink(struct inode *dir, struct dentry *dentry)
         if (wh_dentry) {
                 int rerr;
  
-               rerr = do_revert(err, dir, bwh, wh_dentry, dentry, &dt);
+               rerr = do_revert(err, dir, bindex, bwh, wh_dentry, dentry, &dt);
                 if (rerr)
                         err = rerr;
         }
@@ -451,7 +451,7 @@ int aufs_rmdir(struct inode *dir, struct dentry *dentry)
         if (wh_dentry) {
                 int rerr;
  
-               rerr = do_revert(err, dir, bwh, wh_dentry, dentry, &dt);
+               rerr = do_revert(err, dir, bindex, bwh, wh_dentry, dentry, &dt);
                 if (rerr)
                         err = rerr;
         }
diff --git a/ubuntu/aufs/i_op_ren.c b/ubuntu/aufs/i_op_ren.c

index bbd9eba..89efe67 100644 (file)
--- a/ubuntu/aufs/i_op_ren.c
+++ b/ubuntu/aufs/i_op_ren.c
@@ -35,8 +35,10 @@ enum { AuPARENT, AuCHILD, AuParentChild };
  #define AuRen_DIROPQ   (1 << 6)
  #define AuRen_CPUP     (1 << 7)
  #define au_ftest_ren(flags, name)      ((flags) & AuRen_##name)
-#define au_fset_ren(flags, name)       { (flags) |= AuRen_##name; }
-#define au_fclr_ren(flags, name)       { (flags) &= ~AuRen_##name; }
+#define au_fset_ren(flags, name) \
+       do { (flags) |= AuRen_##name; } while (0)
+#define au_fclr_ren(flags, name) \
+       do { (flags) &= ~AuRen_##name; } while (0)
  
  struct au_ren_args {
         struct {
diff --git a/ubuntu/aufs/iinfo.c b/ubuntu/aufs/iinfo.c

index 1678ba4..6bccfdf 100644 (file)
--- a/ubuntu/aufs/iinfo.c
+++ b/ubuntu/aufs/iinfo.c
@@ -180,6 +180,7 @@ int au_iinfo_init(struct inode *inode)
                 nbr = 1;
         iinfo->ii_hinode = kcalloc(nbr, sizeof(*iinfo->ii_hinode), GFP_NOFS);
         if (iinfo->ii_hinode) {
+               au_ninodes_inc(sb);
                 for (i = 0; i < nbr; i++)
                         iinfo->ii_hinode[i].hi_id = -1;
  
@@ -227,6 +228,7 @@ void au_iinfo_fin(struct inode *inode)
                 return;
  
         sb = inode->i_sb;
+       au_ninodes_dec(sb);
         if (si_pid_test(sb))
                 au_xino_delete_inode(inode, unlinked);
         else {
diff --git a/ubuntu/aufs/include/linux/Kbuild b/ubuntu/aufs/include/linux/Kbuild

new file mode 100644 (file)

index 0000000..e1b2bd3
--- /dev/null
+++ b/ubuntu/aufs/include/linux/Kbuild
@@ -0,0 +1 @@
+header-y = aufs_type.h
diff --git a/ubuntu/aufs/include/linux/aufs_type.h b/ubuntu/aufs/include/linux/aufs_type.h

index b338e44..c9e2845 100644 (file)
--- a/ubuntu/aufs/include/linux/aufs_type.h
+++ b/ubuntu/aufs/include/linux/aufs_type.h
@@ -20,14 +20,11 @@
  #define __AUFS_TYPE_H__
  
  #include <linux/ioctl.h>
-/* for those who didn't "make headers_install" */
-#ifdef __KERNEL__
  #include <linux/kernel.h>
-#endif
  #include <linux/limits.h>
  #include <linux/types.h>
  
-#define AUFS_VERSION   "2.1-standalone.tree-36-UNRELEASED-20101103"
+#define AUFS_VERSION   "2.1-standalone.tree-37-rcN-20101122"
  
  /* todo? move this to linux-2.6.19/include/magic.h */
  #define AUFS_SUPER_MAGIC       ('a' << 24 | 'u' << 16 | 'f' << 8 | 's')
diff --git a/ubuntu/aufs/inode.c b/ubuntu/aufs/inode.c

index 98c4b37..fe4ee9b 100644 (file)
--- a/ubuntu/aufs/inode.c
+++ b/ubuntu/aufs/inode.c
@@ -26,7 +26,7 @@ struct inode *au_igrab(struct inode *inode)
  {
         if (inode) {
                 AuDebugOn(!atomic_read(&inode->i_count));
-               atomic_inc(&inode->i_count);
+               ihold(inode);
         }
         return inode;
  }
diff --git a/ubuntu/aufs/inode.h b/ubuntu/aufs/inode.h

index 8985120..ecb91be 100644 (file)
--- a/ubuntu/aufs/inode.h
+++ b/ubuntu/aufs/inode.h
@@ -35,11 +35,11 @@ struct vfsmount;
  struct au_hnotify {
  #ifdef CONFIG_AUFS_HNOTIFY
  #ifdef CONFIG_AUFS_HFSNOTIFY
+       /* never use fsnotify_add_vfsmount_mark() */
         struct fsnotify_mark            hn_mark;
-#else
-       struct inotify_watch            hn_watch;
+       int                             hn_mark_dead;
  #endif
-       struct inode                            *hn_aufs_inode; /* no get/put */
+       struct inode                    *hn_aufs_inode; /* no get/put */
  #endif
  } ____cacheline_aligned_in_smp;
  
@@ -75,8 +75,10 @@ struct au_icntnr {
  #define AuPin_DI_LOCKED                1
  #define AuPin_MNT_WRITE                (1 << 1)
  #define au_ftest_pin(flags, name)      ((flags) & AuPin_##name)
-#define au_fset_pin(flags, name)       { (flags) |= AuPin_##name; }
-#define au_fclr_pin(flags, name)       { (flags) &= ~AuPin_##name; }
+#define au_fset_pin(flags, name) \
+       do { (flags) |= AuPin_##name; } while (0)
+#define au_fclr_pin(flags, name) \
+       do { (flags) &= ~AuPin_##name; } while (0)
  
  struct au_pin {
         /* input */
@@ -134,8 +136,10 @@ extern struct inode_operations aufs_iop, aufs_symlink_iop, aufs_dir_iop;
  #define AuWrDir_ADD_ENTRY      1
  #define AuWrDir_ISDIR          (1 << 1)
  #define au_ftest_wrdir(flags, name)    ((flags) & AuWrDir_##name)
-#define au_fset_wrdir(flags, name)     { (flags) |= AuWrDir_##name; }
-#define au_fclr_wrdir(flags, name)     { (flags) &= ~AuWrDir_##name; }
+#define au_fset_wrdir(flags, name) \
+       do { (flags) |= AuWrDir_##name; } while (0)
+#define au_fclr_wrdir(flags, name) \
+       do { (flags) &= ~AuWrDir_##name; } while (0)
  
  struct au_wr_dir_args {
         aufs_bindex_t force_btgt;
@@ -187,8 +191,10 @@ unsigned int au_hi_flags(struct inode *inode, int isdir);
  #define AuHi_XINO      1
  #define AuHi_HNOTIFY   (1 << 1)
  #define au_ftest_hi(flags, name)       ((flags) & AuHi_##name)
-#define au_fset_hi(flags, name)                { (flags) |= AuHi_##name; }
-#define au_fclr_hi(flags, name)                { (flags) &= ~AuHi_##name; }
+#define au_fset_hi(flags, name) \
+       do { (flags) |= AuHi_##name; } while (0)
+#define au_fclr_hi(flags, name) \
+       do { (flags) &= ~AuHi_##name; } while (0)
  
  #ifndef CONFIG_AUFS_HNOTIFY
  #undef AuHi_HNOTIFY
@@ -413,12 +419,10 @@ static inline void au_pin_set_parent_lflag(struct au_pin *pin,
                                            unsigned char lflag)
  {
         if (pin) {
-               /* dirty macros require brackets */
-               if (lflag) {
+               if (lflag)
                         au_fset_pin(pin->flags, DI_LOCKED);
-               } else {
+               else
                         au_fclr_pin(pin->flags, DI_LOCKED);
-               }
         }
  }
  
@@ -453,7 +457,7 @@ int au_hnotify(struct inode *h_dir, struct au_hnotify *hnotify, u32 mask,
  int __init au_hnotify_init(void);
  void au_hnotify_fin(void);
  
-/* hinotify.c */
+/* hfsnotify.c */
  extern const struct au_hnotify_op au_hnotify_op;
  
  static inline
diff --git a/ubuntu/aufs/opts.c b/ubuntu/aufs/opts.c

index d0aef5c..bdb2712 100644 (file)
--- a/ubuntu/aufs/opts.c
+++ b/ubuntu/aufs/opts.c
@@ -217,30 +217,16 @@ static match_table_t udbalevel = {
         {AuOpt_UDBA_HNOTIFY, "notify"}, /* abstraction */
  #ifdef CONFIG_AUFS_HFSNOTIFY
         {AuOpt_UDBA_HNOTIFY, "fsnotify"},
-#else
-       {AuOpt_UDBA_HNOTIFY, "inotify"},
  #endif
  #endif
         {-1, NULL}
  };
  
-static void au_warn_inotify(int val, char *str)
-{
-#ifdef CONFIG_AUFS_HINOTIFY
-       if (val == AuOpt_UDBA_HNOTIFY
-           && !strcmp(str, "inotify"))
-               AuWarn1("udba=inotify is deprecated, use udba=notify\n");
-#endif
-}
-
  static int noinline_for_stack udba_val(char *str)
  {
-       int val;
         substring_t args[MAX_OPT_ARGS];
  
-       val = match_token(str, udbalevel, args);
-       au_warn_inotify(val, str);
-       return val;
+       return match_token(str, udbalevel, args);
  }
  
  const char *au_optstr_udba(int udba)
diff --git a/ubuntu/aufs/opts.h b/ubuntu/aufs/opts.h

index dc727ae..03ce335 100644 (file)
--- a/ubuntu/aufs/opts.h
+++ b/ubuntu/aufs/opts.h
@@ -78,7 +78,9 @@ struct super_block;
         (flags) &= ~AuOptMask_UDBA; \
         ((flags) |= AuOpt_##name); \
  } while (0)
-#define au_opt_clr(flags, name)                { ((flags) &= ~AuOpt_##name); }
+#define au_opt_clr(flags, name) do { \
+       ((flags) &= ~AuOpt_##name); \
+} while (0)
  
  static inline unsigned int au_opts_plink(unsigned int mntflags)
  {
@@ -173,8 +175,10 @@ struct au_opt {
  #define AuOpts_TRUNC_XIB       (1 << 3)
  #define AuOpts_REFRESH_DYAOP   (1 << 4)
  #define au_ftest_opts(flags, name)     ((flags) & AuOpts_##name)
-#define au_fset_opts(flags, name)      { (flags) |= AuOpts_##name; }
-#define au_fclr_opts(flags, name)      { (flags) &= ~AuOpts_##name; }
+#define au_fset_opts(flags, name) \
+       do { (flags) |= AuOpts_##name; } while (0)
+#define au_fclr_opts(flags, name) \
+       do { (flags) &= ~AuOpts_##name; } while (0)
  
  struct au_opts {
         struct au_opt   *opt;
diff --git a/ubuntu/aufs/plink.c b/ubuntu/aufs/plink.c

index 5aad81d..dd7eb1e 100644 (file)
--- a/ubuntu/aufs/plink.c
+++ b/ubuntu/aufs/plink.c
@@ -200,12 +200,40 @@ static int plink_name(char *name, int len, struct inode *inode,
         return rlen;
  }
  
+struct au_do_plink_lkup_args {
+       struct dentry **errp;
+       struct qstr *tgtname;
+       struct dentry *h_parent;
+       struct au_branch *br;
+};
+
+static struct dentry *au_do_plink_lkup(struct qstr *tgtname,
+                                      struct dentry *h_parent,
+                                      struct au_branch *br)
+{
+       struct dentry *h_dentry;
+       struct mutex *h_mtx;
+
+       h_mtx = &h_parent->d_inode->i_mutex;
+       mutex_lock_nested(h_mtx, AuLsc_I_CHILD2);
+       h_dentry = au_lkup_one(tgtname, h_parent, br, /*nd*/NULL);
+       mutex_unlock(h_mtx);
+       return h_dentry;
+}
+
+static void au_call_do_plink_lkup(void *args)
+{
+       struct au_do_plink_lkup_args *a = args;
+       *a->errp = au_do_plink_lkup(a->tgtname, a->h_parent, a->br);
+}
+
  /* lookup the plink-ed @inode under the branch at @bindex */
  struct dentry *au_plink_lkup(struct inode *inode, aufs_bindex_t bindex)
  {
         struct dentry *h_dentry, *h_parent;
         struct au_branch *br;
         struct inode *h_dir;
+       int wkq_err;
         char a[PLINK_NAME_LEN];
         struct qstr tgtname = {
                 .name   = a
@@ -218,10 +246,20 @@ struct dentry *au_plink_lkup(struct inode *inode, aufs_bindex_t bindex)
         h_dir = h_parent->d_inode;
         tgtname.len = plink_name(a, sizeof(a), inode, bindex);
  
-       /* always superio. */
-       mutex_lock_nested(&h_dir->i_mutex, AuLsc_I_CHILD2);
-       h_dentry = au_sio_lkup_one(&tgtname, h_parent, br);
-       mutex_unlock(&h_dir->i_mutex);
+       if (current_fsuid()) {
+               struct au_do_plink_lkup_args args = {
+                       .errp           = &h_dentry,
+                       .tgtname        = &tgtname,
+                       .h_parent       = h_parent,
+                       .br             = br
+               };
+
+               wkq_err = au_wkq_wait(au_call_do_plink_lkup, &args);
+               if (unlikely(wkq_err))
+                       h_dentry = ERR_PTR(wkq_err);
+       } else
+               h_dentry = au_do_plink_lkup(&tgtname, h_parent, br);
+
         return h_dentry;
  }
  
@@ -236,6 +274,7 @@ static int do_whplink(struct qstr *tgt, struct dentry *h_parent,
         struct inode *h_dir;
  
         h_dir = h_parent->d_inode;
+       mutex_lock_nested(&h_dir->i_mutex, AuLsc_I_CHILD2);
  again:
         h_path.dentry = au_lkup_one(tgt, h_parent, br, /*nd*/NULL);
         err = PTR_ERR(h_path.dentry);
@@ -244,6 +283,7 @@ again:
  
         err = 0;
         /* wh.plink dir is not monitored */
+       /* todo: is it really safe? */
         if (h_path.dentry->d_inode
             && h_path.dentry->d_inode != h_dentry->d_inode) {
                 err = vfsub_unlink(h_dir, &h_path, /*force*/0);
@@ -257,6 +297,7 @@ again:
         dput(h_path.dentry);
  
  out:
+       mutex_unlock(&h_dir->i_mutex);
         return err;
  }
  
@@ -292,7 +333,6 @@ static int whplink(struct dentry *h_dentry, struct inode *inode,
         tgtname.len = plink_name(a, sizeof(a), inode, bindex);
  
         /* always superio. */
-       mutex_lock_nested(&h_dir->i_mutex, AuLsc_I_CHILD2);
         if (current_fsuid()) {
                 struct do_whplink_args args = {
                         .errp           = &err,
@@ -306,7 +346,6 @@ static int whplink(struct dentry *h_dentry, struct inode *inode,
                         err = wkq_err;
         } else
                 err = do_whplink(&tgtname, h_parent, h_dentry, br);
-       mutex_unlock(&h_dir->i_mutex);
  
         return err;
  }
diff --git a/ubuntu/aufs/rdu.c b/ubuntu/aufs/rdu.c

index 60ee58e..fedbc38 100644 (file)
--- a/ubuntu/aufs/rdu.c
+++ b/ubuntu/aufs/rdu.c
@@ -32,8 +32,10 @@
  #define        AuRdu_CONT      (1 << 1)
  #define        AuRdu_FULL      (1 << 2)
  #define au_ftest_rdu(flags, name)      ((flags) & AuRdu_##name)
-#define au_fset_rdu(flags, name)       { (flags) |= AuRdu_##name; }
-#define au_fclr_rdu(flags, name)       { (flags) &= ~AuRdu_##name; }
+#define au_fset_rdu(flags, name) \
+       do { (flags) |= AuRdu_##name; } while (0)
+#define au_fclr_rdu(flags, name) \
+       do { (flags) &= ~AuRdu_##name; } while (0)
  
  struct au_rdu_arg {
         struct aufs_rdu                 *rdu;
diff --git a/ubuntu/aufs/sbinfo.c b/ubuntu/aufs/sbinfo.c

index 9b46ad2..1eefcb8 100644 (file)
--- a/ubuntu/aufs/sbinfo.c
+++ b/ubuntu/aufs/sbinfo.c
@@ -86,6 +86,10 @@ int au_si_alloc(struct super_block *sb)
         spin_lock_init(&sbinfo->au_si_pid.tree_lock);
         INIT_RADIX_TREE(&sbinfo->au_si_pid.tree, GFP_ATOMIC | __GFP_NOFAIL);
  
+       atomic_long_set(&sbinfo->si_ninodes, 0);
+
+       atomic_long_set(&sbinfo->si_nfiles, 0);
+
         sbinfo->si_bend = -1;
  
         sbinfo->si_wbr_copyup = AuWbrCopyup_Def;
@@ -171,6 +175,7 @@ aufs_bindex_t au_new_br_id(struct super_block *sb)
         sbinfo = au_sbi(sb);
         for (i = 0; i <= AUFS_BRANCH_MAX; i++) {
                 br_id = ++sbinfo->si_last_br_id;
+               AuDebugOn(br_id < 0);
                 if (br_id && au_br_index(sb, br_id) < 0)
                         return br_id;
         }
diff --git a/ubuntu/aufs/super.c b/ubuntu/aufs/super.c

index ed6b8ed..7aba5f2 100644 (file)
--- a/ubuntu/aufs/super.c
+++ b/ubuntu/aufs/super.c
@@ -25,6 +25,8 @@
  #include <linux/module.h>
  #include <linux/seq_file.h>
  #include <linux/statfs.h>
+#include <linux/vmalloc.h>
+#include <linux/writeback.h>
  #include "aufs.h"
  
  /*
@@ -298,7 +300,7 @@ static int au_statfs_sum(struct super_block *sb, struct kstatfs *buf)
         u64 blocks, bfree, bavail, files, ffree;
         aufs_bindex_t bend, bindex, i;
         unsigned char shared;
-       struct vfsmount *h_mnt;
+       struct path h_path;
         struct super_block *h_sb;
  
         blocks = 0;
@@ -310,8 +312,8 @@ static int au_statfs_sum(struct super_block *sb, struct kstatfs *buf)
         err = 0;
         bend = au_sbend(sb);
         for (bindex = bend; bindex >= 0; bindex--) {
-               h_mnt = au_sbr_mnt(sb, bindex);
-               h_sb = h_mnt->mnt_sb;
+               h_path.mnt = au_sbr_mnt(sb, bindex);
+               h_sb = h_path.mnt->mnt_sb;
                 shared = 0;
                 for (i = bindex + 1; !shared && i <= bend; i++)
                         shared = (au_sbr_sb(sb, i) == h_sb);
@@ -319,7 +321,8 @@ static int au_statfs_sum(struct super_block *sb, struct kstatfs *buf)
                         continue;
  
                 /* sb->s_root for NFS is unreliable */
-               err = statfs_by_dentry(h_mnt->mnt_root, buf);
+               h_path.dentry = h_path.mnt->mnt_root;
+               err = vfs_statfs(&h_path, buf);
                 if (unlikely(err))
                         goto out;
  
@@ -343,15 +346,18 @@ out:
  static int aufs_statfs(struct dentry *dentry, struct kstatfs *buf)
  {
         int err;
+       struct path h_path;
         struct super_block *sb;
  
         /* lock free root dinfo */
         sb = dentry->d_sb;
         si_noflush_read_lock(sb);
-       if (!au_opt_test(au_mntflags(sb), SUM))
+       if (!au_opt_test(au_mntflags(sb), SUM)) {
                 /* sb->s_root for NFS is unreliable */
-               err = statfs_by_dentry(au_sbr_mnt(sb, 0)->mnt_root, buf);
-       else
+               h_path.mnt = au_sbr_mnt(sb, 0);
+               h_path.dentry = h_path.mnt->mnt_root;
+               err = vfs_statfs(&h_path, buf);
+       } else
                 err = au_statfs_sum(sb, buf);
         si_read_unlock(sb);
  
@@ -382,6 +388,91 @@ static void aufs_put_super(struct super_block *sb)
  
  /* ---------------------------------------------------------------------- */
  
+void au_array_free(void *array)
+{
+       if (array) {
+               if (!is_vmalloc_addr(array))
+                       kfree(array);
+               else
+                       vfree(array);
+       }
+}
+
+void *au_array_alloc(unsigned long long *hint, au_arraycb_t cb, void *arg)
+{
+       void *array;
+       unsigned long long n;
+
+       array = NULL;
+       n = 0;
+       if (!*hint)
+               goto out;
+
+       if (*hint > ULLONG_MAX / sizeof(array)) {
+               array = ERR_PTR(-EMFILE);
+               pr_err("hint %llu\n", *hint);
+               goto out;
+       }
+
+       array = kmalloc(sizeof(array) * *hint, GFP_NOFS);
+       if (unlikely(!array))
+               array = vmalloc(sizeof(array) * *hint);
+       if (unlikely(!array)) {
+               array = ERR_PTR(-ENOMEM);
+               goto out;
+       }
+
+       n = cb(array, *hint, arg);
+       AuDebugOn(n > *hint);
+
+out:
+       *hint = n;
+       return array;
+}
+
+static unsigned long long au_iarray_cb(void *a,
+                                      unsigned long long max __maybe_unused,
+                                      void *arg)
+{
+       unsigned long long n;
+       struct inode **p, *inode;
+       struct list_head *head;
+
+       n = 0;
+       p = a;
+       head = arg;
+       spin_lock(&inode_lock);
+       list_for_each_entry(inode, head, i_sb_list) {
+               if (!is_bad_inode(inode)
+                   && au_ii(inode)->ii_bstart >= 0) {
+                       au_igrab(inode);
+                       *p++ = inode;
+                       n++;
+                       AuDebugOn(n > max);
+               }
+       }
+       spin_unlock(&inode_lock);
+
+       return n;
+}
+
+struct inode **au_iarray_alloc(struct super_block *sb, unsigned long long *max)
+{
+       *max = atomic_long_read(&au_sbi(sb)->si_ninodes);
+       return au_array_alloc(max, au_iarray_cb, &sb->s_inodes);
+}
+
+void au_iarray_free(struct inode **a, unsigned long long max)
+{
+       unsigned long long ull;
+
+       for (ull = 0; ull < max; ull++)
+               iput(a[ull]);
+       au_array_free(a);
+}
+
+/* ---------------------------------------------------------------------- */
+
  /*
   * refresh dentry and inode at remount time.
   */
@@ -806,24 +897,27 @@ out:
  
  /* ---------------------------------------------------------------------- */
  
-static int aufs_get_sb(struct file_system_type *fs_type, int flags,
-                      const char *dev_name __maybe_unused, void *raw_data,
-                      struct vfsmount *mnt)
+static struct dentry *aufs_mount(struct file_system_type *fs_type, int flags,
+                                const char *dev_name __maybe_unused,
+                                void *raw_data)
  {
-       int err;
+       struct dentry *root;
         struct super_block *sb;
  
         /* all timestamps always follow the ones on the branch */
         /* mnt->mnt_flags |= MNT_NOATIME | MNT_NODIRATIME; */
-       err = get_sb_nodev(fs_type, flags, raw_data, aufs_fill_super, mnt);
-       if (!err) {
-               sb = mnt->mnt_sb;
-               si_write_lock(sb, !AuLock_FLUSH);
-               sysaufs_brs_add(sb, 0);
-               si_write_unlock(sb);
-               au_sbilist_add(sb);
-       }
-       return err;
+       root = mount_nodev(fs_type, flags, raw_data, aufs_fill_super);
+       if (IS_ERR(root))
+               goto out;
+
+       sb = root->d_sb;
+       si_write_lock(sb, !AuLock_FLUSH);
+       sysaufs_brs_add(sb, 0);
+       si_write_unlock(sb);
+       au_sbilist_add(sb);
+
+out:
+       return root;
  }
  
  static void aufs_kill_sb(struct super_block *sb)
@@ -856,7 +950,7 @@ struct file_system_type aufs_fs_type = {
         .fs_flags       =
                 FS_RENAME_DOES_D_MOVE   /* a race between rename and others */
                 | FS_REVAL_DOT,         /* for NFS branch and udba */
-       .get_sb         = aufs_get_sb,
+       .mount          = aufs_mount,
         .kill_sb        = aufs_kill_sb,
         /* no need to __module_get() and module_put(). */
         .owner          = THIS_MODULE,
diff --git a/ubuntu/aufs/super.h b/ubuntu/aufs/super.h

index 2c8d20a..0cc087b 100644 (file)
--- a/ubuntu/aufs/super.h
+++ b/ubuntu/aufs/super.h
@@ -74,6 +74,11 @@ struct au_sbinfo {
                 struct radix_tree_root  tree;
         } au_si_pid;
  
+       /*
+        * dirty approach to protect sb->sb_inodes and ->s_files from remount.
+        */
+       atomic_long_t           si_ninodes, si_nfiles;
+
         /* branch management */
         unsigned int            si_generation;
  
@@ -81,7 +86,10 @@ struct au_sbinfo {
         unsigned char           au_si_status;
  
         aufs_bindex_t           si_bend;
-       aufs_bindex_t           si_last_br_id;
+
+       /* dirty trick to keep br_id plus */
+       unsigned int            si_last_br_id :
+                               sizeof(aufs_bindex_t) * BITS_PER_BYTE - 1;
         struct au_branch        **si_branch;
  
         /* policy to select a writable branch */
@@ -205,14 +213,22 @@ static inline unsigned char au_do_ftest_si(struct au_sbinfo *sbi,
  #define AuLock_NOPLM           (1 << 5)        /* return err in plm mode */
  #define AuLock_NOPLMW          (1 << 6)        /* wait for plm mode ends */
  #define au_ftest_lock(flags, name)     ((flags) & AuLock_##name)
-#define au_fset_lock(flags, name)      { (flags) |= AuLock_##name; }
-#define au_fclr_lock(flags, name)      { (flags) &= ~AuLock_##name; }
+#define au_fset_lock(flags, name) \
+       do { (flags) |= AuLock_##name; } while (0)
+#define au_fclr_lock(flags, name) \
+       do { (flags) &= ~AuLock_##name; } while (0)
  
  /* ---------------------------------------------------------------------- */
  
  /* super.c */
  extern struct file_system_type aufs_fs_type;
  struct inode *au_iget_locked(struct super_block *sb, ino_t ino);
+typedef unsigned long long (*au_arraycb_t)(void *array, unsigned long long max,
+                                          void *arg);
+void au_array_free(void *array);
+void *au_array_alloc(unsigned long long *hint, au_arraycb_t cb, void *arg);
+struct inode **au_iarray_alloc(struct super_block *sb, unsigned long long *max);
+void au_iarray_free(struct inode **a, unsigned long long max);
  
  /* sbinfo.c */
  void au_si_free(struct kobject *kobj);
@@ -465,6 +481,28 @@ static inline unsigned int au_sigen(struct super_block *sb)
         return au_sbi(sb)->si_generation;
  }
  
+static inline void au_ninodes_inc(struct super_block *sb)
+{
+       atomic_long_inc(&au_sbi(sb)->si_ninodes);
+}
+
+static inline void au_ninodes_dec(struct super_block *sb)
+{
+       AuDebugOn(!atomic_long_read(&au_sbi(sb)->si_ninodes));
+       atomic_long_dec(&au_sbi(sb)->si_ninodes);
+}
+
+static inline void au_nfiles_inc(struct super_block *sb)
+{
+       atomic_long_inc(&au_sbi(sb)->si_nfiles);
+}
+
+static inline void au_nfiles_dec(struct super_block *sb)
+{
+       AuDebugOn(!atomic_long_read(&au_sbi(sb)->si_nfiles));
+       atomic_long_dec(&au_sbi(sb)->si_nfiles);
+}
+
  static inline struct au_branch *au_sbr(struct super_block *sb,
                                        aufs_bindex_t bindex)
  {
diff --git a/ubuntu/aufs/vdir.c b/ubuntu/aufs/vdir.c

index 0794106..5777ca4 100644 (file)
--- a/ubuntu/aufs/vdir.c
+++ b/ubuntu/aufs/vdir.c
@@ -434,8 +434,10 @@ static int reinit_vdir(struct au_vdir *vdir)
  #define AuFillVdir_WHABLE      (1 << 1)
  #define AuFillVdir_SHWH                (1 << 2)
  #define au_ftest_fillvdir(flags, name) ((flags) & AuFillVdir_##name)
-#define au_fset_fillvdir(flags, name)  { (flags) |= AuFillVdir_##name; }
-#define au_fclr_fillvdir(flags, name)  { (flags) &= ~AuFillVdir_##name; }
+#define au_fset_fillvdir(flags, name) \
+       do { (flags) |= AuFillVdir_##name; } while (0)
+#define au_fclr_fillvdir(flags, name) \
+       do { (flags) &= ~AuFillVdir_##name; } while (0)
  
  #ifndef CONFIG_AUFS_SHWH
  #undef AuFillVdir_SHWH
diff --git a/ubuntu/aufs/vfsub.c b/ubuntu/aufs/vfsub.c

index cd3fe78..846a124 100644 (file)
--- a/ubuntu/aufs/vfsub.c
+++ b/ubuntu/aufs/vfsub.c
@@ -84,8 +84,8 @@ struct file *vfsub_dentry_open(struct path *path, int flags)
  
         path_get(path);
         file = dentry_open(path->dentry, path->mnt,
-                       flags | vfsub_fmode_to_uint(FMODE_NONOTIFY),
-                       current_cred());
+                          flags /* | vfsub_fmode_to_uint(FMODE_NONOTIFY) */,
+                          current_cred());
         if (IS_ERR(file))
                 goto out;
  
@@ -102,8 +102,9 @@ struct file *vfsub_filp_open(const char *path, int oflags, int mode)
  {
         struct file *file;
  
-       file = filp_open(path, oflags | vfsub_fmode_to_uint(FMODE_NONOTIFY),
-                       mode);
+       file = filp_open(path,
+                        oflags /* | vfsub_fmode_to_uint(FMODE_NONOTIFY) */,
+                        mode);
         if (IS_ERR(file))
                 goto out;
         vfsub_update_h_iattr(&file->f_path, /*did*/NULL); /*ignore*/
@@ -743,7 +744,7 @@ static void call_unlink(void *args)
                 dget(d);
         h_inode = d->d_inode;
         if (h_inode)
-               atomic_inc(&h_inode->i_count);
+               ihold(h_inode);
  
         *a->errp = vfs_unlink(a->dir, d);
         if (!*a->errp) {
diff --git a/ubuntu/aufs/vfsub.h b/ubuntu/aufs/vfsub.h

index e97c1e5..4b44827 100644 (file)
--- a/ubuntu/aufs/vfsub.h
+++ b/ubuntu/aufs/vfsub.h
@@ -27,13 +27,14 @@
  
  #include <linux/fs.h>
  #include <linux/lglock.h>
+#include "debug.h"
  
-/* ---------------------------------------------------------------------- */
+/* copied from linux/fs/internal.h */
  DECLARE_BRLOCK(vfsmount_lock);
-DECLARE_LGLOCK(files_lglock);
  extern void file_sb_list_del(struct file *f);
  
-/* copied from fs/file_table.c */
+/* copied from linux/fs/file_table.c */
+DECLARE_LGLOCK(files_lglock);
  #ifdef CONFIG_SMP
  /*
   * These macros iterate all files on all CPUs for a given superblock.
@@ -61,7 +62,9 @@ extern void file_sb_list_del(struct file *f);
  
  #define while_file_list_for_each_entry                         \
  }
-#endif /* CONFIG_SMP */
+#endif
+
+/* ---------------------------------------------------------------------- */
  
  /* lock subclass for lower inode */
  /* default MAX_LOCKDEP_SUBCLASSES(8) is not enough */
@@ -82,6 +85,14 @@ enum {
  
  /* ---------------------------------------------------------------------- */
  
+static inline void vfsub_drop_nlink(struct inode *inode)
+{
+       AuDebugOn(!inode->i_nlink);
+       drop_nlink(inode);
+}
+
+/* ---------------------------------------------------------------------- */
+
  int vfsub_update_h_iattr(struct path *h_path, int *did);
  struct file *vfsub_dentry_open(struct path *path, int flags);
  struct file *vfsub_filp_open(const char *path, int oflags, int mode);
diff --git a/ubuntu/aufs/wbr_policy.c b/ubuntu/aufs/wbr_policy.c

index f20cf97..bb57ae5 100644 (file)
--- a/ubuntu/aufs/wbr_policy.c
+++ b/ubuntu/aufs/wbr_policy.c
@@ -55,8 +55,10 @@ int au_cpdown_attr(struct path *h_path, struct dentry *h_src)
  #define AuCpdown_MADE_DIR      (1 << 2)
  #define AuCpdown_DIROPQ                (1 << 3)
  #define au_ftest_cpdown(flags, name)   ((flags) & AuCpdown_##name)
-#define au_fset_cpdown(flags, name)    { (flags) |= AuCpdown_##name; }
-#define au_fclr_cpdown(flags, name)    { (flags) &= ~AuCpdown_##name; }
+#define au_fset_cpdown(flags, name) \
+       do { (flags) |= AuCpdown_##name; } while (0)
+#define au_fclr_cpdown(flags, name) \
+       do { (flags) &= ~AuCpdown_##name; } while (0)
  
  struct au_cpdown_dir_args {
         struct dentry *parent;
@@ -407,6 +409,7 @@ static void au_mfs(struct dentry *dentry)
         aufs_bindex_t bindex, bend;
         int err;
         unsigned long long b, bavail;
+       struct path h_path;
         /* reduce the stack usage */
         struct kstatfs *st;
  
@@ -429,7 +432,9 @@ static void au_mfs(struct dentry *dentry)
                         continue;
  
                 /* sb->s_root for NFS is unreliable */
-               err = statfs_by_dentry(br->br_mnt->mnt_root, st);
+               h_path.mnt = br->br_mnt;
+               h_path.dentry = h_path.mnt->mnt_root;
+               err = vfs_statfs(&h_path, st);
                 if (unlikely(err)) {
                         AuWarn1("failed statfs, b%d, %d\n", bindex, err);
                         continue;
diff --git a/ubuntu/aufs/whout.c b/ubuntu/aufs/whout.c

index 31cdec9..284b8cc 100644 (file)
--- a/ubuntu/aufs/whout.c
+++ b/ubuntu/aufs/whout.c
@@ -974,8 +974,9 @@ int au_whtmp_rmdir(struct inode *dir, aufs_bindex_t bindex,
  
         if (!err) {
                 if (au_ibstart(dir) == bindex) {
+                       /* todo: dir->i_mutex is necessary */
                         au_cpup_attr_timesizes(dir);
-                       drop_nlink(dir);
+                       vfsub_drop_nlink(dir);
                 }
                 return 0; /* success */
         }
diff --git a/ubuntu/aufs/whout.h b/ubuntu/aufs/whout.h

index df72838..b262ffd 100644 (file)
--- a/ubuntu/aufs/whout.h
+++ b/ubuntu/aufs/whout.h
@@ -45,8 +45,10 @@ int au_wh_init(struct dentry *h_parent, struct au_branch *br,
  /* diropq flags */
  #define AuDiropq_CREATE        1
  #define au_ftest_diropq(flags, name)   ((flags) & AuDiropq_##name)
-#define au_fset_diropq(flags, name)    { (flags) |= AuDiropq_##name; }
-#define au_fclr_diropq(flags, name)    { (flags) &= ~AuDiropq_##name; }
+#define au_fset_diropq(flags, name) \
+       do { (flags) |= AuDiropq_##name; } while (0)
+#define au_fclr_diropq(flags, name) \
+       do { (flags) &= ~AuDiropq_##name; } while (0)
  
  struct dentry *au_diropq_sio(struct dentry *dentry, aufs_bindex_t bindex,
                              unsigned int flags);
diff --git a/ubuntu/aufs/wkq.c b/ubuntu/aufs/wkq.c

index b1ca42e..9739d3a 100644 (file)
--- a/ubuntu/aufs/wkq.c
+++ b/ubuntu/aufs/wkq.c
@@ -44,7 +44,7 @@ static struct {
  
  struct au_wkinfo {
         struct work_struct wk;
-       struct super_block *sb;
+       struct kobject *kobj;
  
         unsigned int flags; /* see wkq.h */
  
@@ -60,11 +60,14 @@ static void wkq_func(struct work_struct *wk)
  {
         struct au_wkinfo *wkinfo = container_of(wk, struct au_wkinfo, wk);
  
+       AuDebugOn(current_fsuid());
+       AuDebugOn(rlimit(RLIMIT_FSIZE) != RLIM_INFINITY);
+
         wkinfo->func(wkinfo->args);
         if (au_ftest_wkq(wkinfo->flags, WAIT))
                 complete(wkinfo->comp);
         else {
-               kobject_put(&au_sbi(wkinfo->sb)->si_kobj);
+               kobject_put(wkinfo->kobj);
                 module_put(THIS_MODULE);
                 kfree(wkinfo);
         }
@@ -128,6 +131,12 @@ static void au_wkq_run(struct au_wkinfo *wkinfo, unsigned int flags)
         }
  }
  
+/*
+ * Be careful. It is easy to make deadlock happen.
+ * processA: lock, wkq and wait
+ * processB: wkq and wait, lock in wkq
+ * --> deadlock
+ */
  int au_wkq_do_wait(unsigned int flags, au_wkq_func_t func, void *args)
  {
         int err;
@@ -165,12 +174,12 @@ int au_wkq_nowait(au_wkq_func_t func, void *args, struct super_block *sb)
         err = 0;
         wkinfo = kmalloc(sizeof(*wkinfo), GFP_NOFS);
         if (wkinfo) {
-               wkinfo->sb = sb;
+               wkinfo->kobj = &au_sbi(sb)->si_kobj;
                 wkinfo->flags = !AuWkq_WAIT;
                 wkinfo->func = func;
                 wkinfo->args = args;
                 wkinfo->comp = NULL;
-               kobject_get(&au_sbi(sb)->si_kobj);
+               kobject_get(wkinfo->kobj);
                 __module_get(THIS_MODULE);
  
                 au_wkq_run(wkinfo, !AuWkq_WAIT);
@@ -206,7 +215,9 @@ int __init au_wkq_init(void)
  
         err = 0;
         for (i = 0; !err && i < ARRAY_SIZE(au_wkq); i++) {
-               au_wkq[i].wkq = create_workqueue(au_wkq[i].name);
+               BUILD_BUG_ON(!WQ_RESCUER);
+               au_wkq[i].wkq = alloc_workqueue(au_wkq[i].name, !WQ_RESCUER,
+                                               WQ_DFL_ACTIVE);
                 if (IS_ERR(au_wkq[i].wkq))
                         err = PTR_ERR(au_wkq[i].wkq);
                 else if (!au_wkq[i].wkq)
@@ -214,9 +225,7 @@ int __init au_wkq_init(void)
                 if (unlikely(err))
                         au_wkq[i].wkq = NULL;
         }
-       if (!err)
-               au_dbg_verify_wkq();
-       else
+       if (unlikely(err))
                 au_wkq_fin();
  
         return err;
diff --git a/ubuntu/aufs/wkq.h b/ubuntu/aufs/wkq.h

index 7562282..b216f03 100644 (file)
--- a/ubuntu/aufs/wkq.h
+++ b/ubuntu/aufs/wkq.h
@@ -50,8 +50,10 @@ typedef void (*au_wkq_func_t)(void *args);
  #define AuWkq_WAIT     1
  #define AuWkq_PRE      (1 << 1)
  #define au_ftest_wkq(flags, name)      ((flags) & AuWkq_##name)
-#define au_fset_wkq(flags, name)       { (flags) |= AuWkq_##name; }
-#define au_fclr_wkq(flags, name)       { (flags) &= ~AuWkq_##name; }
+#define au_fset_wkq(flags, name) \
+       do { (flags) |= AuWkq_##name; } while (0)
+#define au_fclr_wkq(flags, name) \
+       do { (flags) &= ~AuWkq_##name; } while (0)
  
  /* wkq.c */
  int au_wkq_do_wait(unsigned int flags, au_wkq_func_t func, void *args);
diff --git a/ubuntu/aufs/xino.c b/ubuntu/aufs/xino.c

index 06833a4..84e745a 100644 (file)
--- a/ubuntu/aufs/xino.c
+++ b/ubuntu/aufs/xino.c
@@ -168,7 +168,8 @@ struct file *au_xino_create2(struct file *base_file, struct file *copy_src)
  
         path.mnt = base_file->f_vfsmnt;
         file = vfsub_dentry_open(&path,
-                                O_RDWR | O_CREAT | O_EXCL | O_LARGEFILE);
+                                O_RDWR | O_CREAT | O_EXCL | O_LARGEFILE
+                                /* | FMODE_NONOTIFY */);
         if (IS_ERR(file)) {
                 pr_err("%.*s open err %ld\n", AuLNPair(name), PTR_ERR(file));
                 goto out_dput;
@@ -612,7 +613,7 @@ ino_t au_xino_new_ino(struct super_block *sb)
  
  out:
         set_bit(free_bit, p);
-       sbinfo->si_xib_next_bit++;
+       sbinfo->si_xib_next_bit = free_bit + 1;
         pindex = sbinfo->si_xib_last_pindex;
         mutex_unlock(&sbinfo->si_xib_mtx);
         ino = xib_calc_ino(pindex, free_bit);
@@ -684,7 +685,8 @@ struct file *au_xino_create(struct super_block *sb, char *fname, int silent)
          * hnotify is disabled so we have no notify events to ignore.
          * when a user specified the xino, we cannot get au_hdir to be ignored.
          */
-       file = vfsub_filp_open(fname, O_RDWR | O_CREAT | O_EXCL | O_LARGEFILE,
+       file = vfsub_filp_open(fname, O_RDWR | O_CREAT | O_EXCL | O_LARGEFILE
+                              /* | FMODE_NONOTIFY */,
                                S_IRUGO | S_IWUGO);
         if (IS_ERR(file)) {
                 if (!silent)
author	Andy Whitcroft <apw@canonical.com>
	Mon, 22 Nov 2010 15:51:22 +0000 (15:51 +0000)
committer	Leann Ogasawara <leann.ogasawara@canonical.com>
	Mon, 28 Mar 2011 13:51:25 +0000 (06:51 -0700)
ubuntu/aufs/BOM		patch \| blob \| history
ubuntu/aufs/Kconfig		patch \| blob \| history
ubuntu/aufs/Makefile		patch \| blob \| history
ubuntu/aufs/branch.c		patch \| blob \| history
ubuntu/aufs/branch.h		patch \| blob \| history
ubuntu/aufs/conf.mk		patch \| blob \| history
ubuntu/aufs/cpup.h		patch \| blob \| history
ubuntu/aufs/dcsub.h		patch \| blob \| history
ubuntu/aufs/debug.c		patch \| blob \| history
ubuntu/aufs/debug.h		patch \| blob \| history
ubuntu/aufs/dentry.c		patch \| blob \| history
ubuntu/aufs/dinfo.c		patch \| blob \| history
ubuntu/aufs/dir.c		patch \| blob \| history
ubuntu/aufs/f_op.c		patch \| blob \| history
ubuntu/aufs/file.c		patch \| blob \| history
ubuntu/aufs/finfo.c		patch \| blob \| history
ubuntu/aufs/hfsnotify.c		patch \| blob \| history
ubuntu/aufs/hinotify.c	[deleted file]	patch \| blob \| history
ubuntu/aufs/hnotify.c		patch \| blob \| history
ubuntu/aufs/i_op.c		patch \| blob \| history
ubuntu/aufs/i_op_del.c		patch \| blob \| history
ubuntu/aufs/i_op_ren.c		patch \| blob \| history
ubuntu/aufs/iinfo.c		patch \| blob \| history
ubuntu/aufs/include/linux/Kbuild	[new file with mode: 0644]	patch \| blob
ubuntu/aufs/include/linux/aufs_type.h		patch \| blob \| history
ubuntu/aufs/inode.c		patch \| blob \| history
ubuntu/aufs/inode.h		patch \| blob \| history
ubuntu/aufs/opts.c		patch \| blob \| history
ubuntu/aufs/opts.h		patch \| blob \| history
ubuntu/aufs/plink.c		patch \| blob \| history
ubuntu/aufs/rdu.c		patch \| blob \| history
ubuntu/aufs/sbinfo.c		patch \| blob \| history
ubuntu/aufs/super.c		patch \| blob \| history
ubuntu/aufs/super.h		patch \| blob \| history
ubuntu/aufs/vdir.c		patch \| blob \| history
ubuntu/aufs/vfsub.c		patch \| blob \| history
ubuntu/aufs/vfsub.h		patch \| blob \| history
ubuntu/aufs/wbr_policy.c		patch \| blob \| history
ubuntu/aufs/whout.c		patch \| blob \| history
ubuntu/aufs/whout.h		patch \| blob \| history
ubuntu/aufs/wkq.c		patch \| blob \| history
ubuntu/aufs/wkq.h		patch \| blob \| history
ubuntu/aufs/xino.c		patch \| blob \| history