ceph: use fscache as a local presisent cache

Adding support for fscache to the Ceph filesystem. This would bring it to on
par with some of the other network filesystems in Linux (like NFS, AFS, etc...)

In order to mount the filesystem with fscache the 'fsc' mount option must be
passed.

Signed-off-by: Milosz Tanski <milosz@adfin.com>
Signed-off-by: Sage Weil <sage@inktank.com>

1 files changed, 11 insertions, 3 deletions

diff --git a/fs/ceph/inode.c b/fs/ceph/inode.c
index 602ccd8e06b7..eae41cd73276 100644
--- a/fs/ceph/inode.c
+++ b/fs/ceph/inode.c
@@ -12,6 +12,7 @@
 
 #include "super.h"
 #include "mds_client.h"
+#include "cache.h"
 #include <linux/ceph/decode.h>
 
 /*
@@ -386,6 +387,8 @@ struct inode *ceph_alloc_inode(struct super_block *sb)
 
         INIT_WORK(&ci->i_vmtruncate_work, ceph_vmtruncate_work);
 
+        ceph_fscache_inode_init(ci);
+
         return &ci->vfs_inode;
 }
 
@@ -405,6 +408,8 @@ void ceph_destroy_inode(struct inode *inode)
 
         dout("destroy_inode %p ino %llx.%llx\n", inode, ceph_vinop(inode));
 
+        ceph_fscache_unregister_inode_cookie(ci);
+
         ceph_queue_caps_release(inode);
 
         /*
@@ -439,7 +444,6 @@ void ceph_destroy_inode(struct inode *inode)
         call_rcu(&inode->i_rcu, ceph_i_callback);
 }
 
-
 /*
  * Helpers to fill in size, ctime, mtime, and atime.  We have to be
  * careful because either the client or MDS may have more up to date
@@ -491,6 +495,10 @@ int ceph_fill_file_size(struct inode *inode, int issued,
                      truncate_size);
                 ci->i_truncate_size = truncate_size;
         }
+
+        if (queue_trunc)
+                ceph_fscache_invalidate(inode);
+
         return queue_trunc;
 }
 
@@ -1079,7 +1087,7 @@ int ceph_fill_trace(struct super_block *sb, struct ceph_mds_request *req,
                          * complete.
                          */
                         ceph_set_dentry_offset(req->r_old_dentry);
-                        dout("dn %p gets new offset %lld\n", req->r_old_dentry, 
+                        dout("dn %p gets new offset %lld\n", req->r_old_dentry,
                              ceph_dentry(req->r_old_dentry)->offset);
 
                         dn = req->r_old_dentry;  /* use old_dentry */
@@ -1494,6 +1502,7 @@ void ceph_queue_vmtruncate(struct inode *inode)
         struct ceph_inode_info *ci = ceph_inode(inode);
 
         ihold(inode);
+
         if (queue_work(ceph_sb_to_client(inode->i_sb)->trunc_wq,
                        &ci->i_vmtruncate_work)) {
                 dout("ceph_queue_vmtruncate %p\n", inode);
@@ -1565,7 +1574,6 @@ retry:
         wake_up_all(&ci->i_cap_wq);
 }
 
-
 /*
  * symlinks
  */