Whamcloud - gitweb
- remove non-needed CERROR
[fs/lustre-release.git] / lustre / smfs / inode.c
index 0243f2c..1e6a729 100644 (file)
 #include <linux/lustre_smfs.h>
 #include "smfs_internal.h"
 
+#define SMFS_IOPEN_INO  1
+
 static void smfs_init_inode_info(struct inode *inode, void *opaque)
 {
-        if (!I2SMI(inode)) {
-                struct inode *cache_inode = NULL;
-                struct smfs_iget_args *sargs = opaque;
-                unsigned long ino;
-
-                /* getting backing fs inode. */
-                ino = sargs ? sargs->s_ino : inode->i_ino;
-                cache_inode = iget(S2CSB(inode->i_sb), ino); 
-                
-                OBD_ALLOC(inode->u.generic_ip,
-                          sizeof(struct smfs_inode_info));
         
-                LASSERT(inode->u.generic_ip);
-                I2CI(inode) = cache_inode;
+        struct inode *cache_inode = NULL;
+        struct smfs_iget_args *sargs = opaque;
+        unsigned long ino;
+
+        LASSERTF((!I2SMI(inode)), "Inode %lu already has smfs_inode_info %p \n",
+                 inode->i_ino, I2SMI(inode));
         
-                CDEBUG(D_INODE, "cache_inode %lu i_count %d\n",
-                       cache_inode->i_ino, atomic_read(&cache_inode->i_count));
+        /* getting backing fs inode. */
+        LASSERT(sargs);
+        ino = inode->i_ino;
+        cache_inode = iget(S2CSB(inode->i_sb), ino); 
         
-                post_smfs_inode(inode, cache_inode);
-                sm_set_inode_ops(cache_inode, inode);
+        OBD_ALLOC(inode->u.generic_ip, sizeof(struct smfs_inode_info));
+
+        LASSERT(inode->u.generic_ip);
+              
+        I2CI(inode) = cache_inode;
+        CDEBUG(D_INODE,"Init inode info #%lu (%p) icount %u\n", inode->i_ino, inode, 
+                        atomic_read(&cache_inode->i_count));
         
-                if (sargs) { 
-                        struct inode *dir = sargs->s_inode; 
-                        if (dir)
-                                I2SMI(inode)->smi_flags = I2SMI(dir)->smi_flags;
-                }
+        post_smfs_inode(inode, cache_inode);
+        sm_set_inode_ops(cache_inode, inode);
+        //iopen stuff
+        if (ino == SMFS_IOPEN_INO) {
+                inode->i_op = &smfs_iopen_iops;
+                inode->i_fop = &smfs_iopen_fops;
         }
+        //inherit parent inode flags
+        if (sargs->s_inode) { 
+                I2SMI(inode)->smi_flags = I2SMI(sargs->s_inode)->smi_flags;
+                CDEBUG(D_INODE, "set inode %lu flags 0x%.8x\n", inode->i_ino,
+                      I2SMI(inode)->smi_flags);
+        } 
 }
 
 static void smfs_clear_inode_info(struct inode *inode)
 {
-        if (I2SMI(inode)) {
-                struct inode *cache_inode = I2CI(inode);
-
-                //CDEBUG(D_INODE, "Clear_info: cache_inode %lu\n", cache_inode->i_ino);
+        struct inode *cache_inode = I2CI(inode);
+        struct smfs_inode_info * info = I2SMI(inode);
+        
+        CDEBUG(D_INODE, "Clear_info: inode %lu (%p)\n", inode->i_ino, inode);
 
-                LASSERTF(((atomic_read(&cache_inode->i_count) == 1) || 
-                          cache_inode == cache_inode->i_sb->s_root->d_inode),
-                         "inode %p cache inode %p #%lu i_count %d != 1 \n", 
-                         inode, cache_inode, cache_inode->i_ino, 
-                         atomic_read(&cache_inode->i_count));
-                
-                //if (cache_inode != cache_inode->i_sb->s_root->d_inode)
-                iput(cache_inode);
-                
-                OBD_FREE(inode->u.generic_ip,
-                         sizeof(struct smfs_inode_info));
-                inode->u.generic_ip = NULL;
-        }
+        inode->u.generic_ip = NULL;      
+        iput(cache_inode);
+        OBD_FREE(info, sizeof(*info));
 }
 
 #if (LINUX_VERSION_CODE < KERNEL_VERSION(2,5,0))
@@ -100,7 +99,6 @@ static void smfs_read_inode2(struct inode *inode, void *opaque)
                 return;
         }
         
-        CDEBUG(D_INODE, "read_inode ino %lu\n", inode->i_ino);
         smfs_init_inode_info(inode, opaque);
         CDEBUG(D_INODE, "read_inode ino %lu icount %d \n",
                inode->i_ino, atomic_read(&inode->i_count));
@@ -123,13 +121,17 @@ static int smfs_test_inode(struct inode *inode, void *opaque)
             !smfs_snap_test_inode(inode, opaque))
                 return 0;  
 #endif
-        
+                
         return 1;
 }
 
 #if (LINUX_VERSION_CODE >= KERNEL_VERSION(2,5,0))
 int smfs_set_inode(struct inode *inode, void *opaque)
 {
+        struct smfs_iget_args *sargs = opaque;
+        
+        inode->i_ino = sargs->s_ino;
+        
         return 0;
 }
 
@@ -146,12 +148,12 @@ static struct inode *smfs_iget(struct super_block *sb, ino_t hash,
                         smfs_init_inode_info(inode, (void*)sargs);
                         unlock_new_inode(inode);
                 }
-                inode->i_ino = hash;
-                CDEBUG(D_VFSTRACE, "inode: %lu/%u(%p) index %d "
+                
+                CDEBUG(D_INODE, "inode: %lu/%u(%p) index %d "
                        "ino %d\n", inode->i_ino, inode->i_generation,
                        inode, sargs->s_index, sargs->s_ino);
+                
         }
-        
         return inode;
 }
 #else
@@ -165,7 +167,7 @@ struct inode *smfs_iget(struct super_block *sb, ino_t hash,
         if (inode) {
                 struct inode *cache_inode = I2CI(inode);
                 
-                CDEBUG(D_VFSTRACE, "new inode: %lu/%u(%p)\n", inode->i_ino,
+                CDEBUG(D_INODE, "new inode: %lu/%u(%p)\n", inode->i_ino,
                        inode->i_generation, inode);
         }
         return inode;
@@ -182,31 +184,41 @@ struct inode *smfs_get_inode(struct super_block *sb, ino_t hash,
         sargs.s_ino = hash; 
         sargs.s_inode = dir; 
         sargs.s_index = index;
-        CDEBUG(D_VFSTRACE, "get_inode: %lu\n", hash);
-
+        
         inode = smfs_iget(sb, hash, &sargs);
 
         RETURN(inode);
 }
+#ifdef FC3_KERNEL 
+static int smfs_write_inode(struct inode *inode, int wait)
+#else
 static void smfs_write_inode(struct inode *inode, int wait)
+#endif
 {
-        struct inode *cache_inode;
-        
+        struct inode *cache_inode = I2CI(inode);
+#ifdef FC3_KERNEL
+        int rc = 0;
+#endif        
         ENTRY;
 
-        cache_inode = I2CI(inode);
         LASSERT(cache_inode);
         
         CDEBUG(D_INODE,"Write inode %lu\n",inode->i_ino);
 
         pre_smfs_inode(inode, cache_inode);
         
+#ifdef FC3_KERNEL
+        rc = cache_inode->i_sb->s_op->write_inode(cache_inode, wait);
+#else
         cache_inode->i_sb->s_op->write_inode(cache_inode, wait);
-        
+#endif
         post_smfs_inode(inode, cache_inode);
         
+#ifdef FC3_KERNEL
+        RETURN(rc);
+#else
         EXIT;
+#endif
 }
 
 static void smfs_dirty_inode(struct inode *inode)
@@ -218,6 +230,7 @@ static void smfs_dirty_inode(struct inode *inode)
         LASSERT(cache_inode);
         
         pre_smfs_inode(inode, cache_inode);
+    
         S2CSB(inode->i_sb)->s_op->dirty_inode(cache_inode);
 
         post_smfs_inode(inode, cache_inode);
@@ -226,16 +239,15 @@ static void smfs_dirty_inode(struct inode *inode)
 
 static void smfs_delete_inode(struct inode *inode)
 {
-        ENTRY;
+        struct inode * cache_inode = I2CI(inode);
+
+        //smfs_clear_inode_info(inode);
         clear_inode(inode);
-        EXIT;
 }
 
 static void smfs_clear_inode(struct inode *inode)
 {
-        ENTRY;
         smfs_clear_inode_info(inode);
-        EXIT;
 }
 
 static void smfs_write_super(struct super_block *sb)