Whamcloud - gitweb
LU-3319 procfs: move llite proc handling over to seq_file
[fs/lustre-release.git] / lustre / llite / vvp_page.c
index 1323b36..2b54a5e 100644 (file)
@@ -139,62 +139,44 @@ static void vvp_page_discard(const struct lu_env *env,
                              const struct cl_page_slice *slice,
                              struct cl_io *unused)
 {
-       struct page           *vmpage  = cl2vm_page(slice);
-       struct address_space *mapping;
-       struct ccc_page      *cpg     = cl2ccc_page(slice);
-
-        LASSERT(vmpage != NULL);
-        LASSERT(PageLocked(vmpage));
-
-       mapping = vmpage->mapping;
-
-        if (cpg->cpg_defer_uptodate && !cpg->cpg_ra_used)
-                ll_ra_stats_inc(mapping, RA_STAT_DISCARDED);
-
-        /*
-         * truncate_complete_page() calls
-         * a_ops->invalidatepage()->cl_page_delete()->vvp_page_delete().
-         */
-        truncate_complete_page(mapping, vmpage);
-}
-
-static int vvp_page_unmap(const struct lu_env *env,
-                         const struct cl_page_slice *slice,
-                         struct cl_io *unused)
-{
-       struct page *vmpage = cl2vm_page(slice);
-       __u64       offset;
+       struct page     *vmpage = cl2vm_page(slice);
+       struct ccc_page *cpg    = cl2ccc_page(slice);
 
        LASSERT(vmpage != NULL);
        LASSERT(PageLocked(vmpage));
 
-       offset = vmpage->index << PAGE_CACHE_SHIFT;
+       if (cpg->cpg_defer_uptodate && !cpg->cpg_ra_used)
+               ll_ra_stats_inc(vmpage->mapping, RA_STAT_DISCARDED);
 
-       /*
-        * XXX is it safe to call this with the page lock held?
-        */
-       ll_teardown_mmaps(vmpage->mapping, offset, offset + PAGE_CACHE_SIZE);
-       return 0;
+       ll_invalidate_page(vmpage);
 }
 
 static void vvp_page_delete(const struct lu_env *env,
                             const struct cl_page_slice *slice)
 {
-       struct page       *vmpage = cl2vm_page(slice);
+       struct page      *vmpage = cl2vm_page(slice);
        struct inode     *inode  = vmpage->mapping->host;
        struct cl_object *obj    = slice->cpl_obj;
+       struct cl_page   *page   = slice->cpl_page;
+       int refc;
 
-        LASSERT(PageLocked(vmpage));
-        LASSERT((struct cl_page *)vmpage->private == slice->cpl_page);
-        LASSERT(inode == ccc_object_inode(obj));
+       LASSERT(PageLocked(vmpage));
+       LASSERT((struct cl_page *)vmpage->private == page);
+       LASSERT(inode == ccc_object_inode(obj));
 
-        vvp_write_complete(cl2ccc(obj), cl2ccc_page(slice));
-        ClearPagePrivate(vmpage);
-        vmpage->private = 0;
-        /*
-         * Reference from vmpage to cl_page is removed, but the reference back
-         * is still here. It is removed later in vvp_page_fini().
-         */
+       vvp_write_complete(cl2ccc(obj), cl2ccc_page(slice));
+
+       /* Drop the reference count held in vvp_page_init */
+       refc = atomic_dec_return(&page->cp_ref);
+       LASSERTF(refc >= 1, "page = %p, refc = %d\n", page, refc);
+
+       ClearPageUptodate(vmpage);
+       ClearPagePrivate(vmpage);
+       vmpage->private = 0;
+       /*
+        * Reference from vmpage to cl_page is removed, but the reference back
+        * is still here. It is removed later in vvp_page_fini().
+        */
 }
 
 static void vvp_page_export(const struct lu_env *env,
@@ -274,8 +256,8 @@ static void vvp_page_completion_read(const struct lu_env *env,
                                      int ioret)
 {
         struct ccc_page *cp     = cl2ccc_page(slice);
-       struct page      *vmpage = cp->cpg_page;
-        struct cl_page  *page   = cl_page_top(slice->cpl_page);
+       struct page     *vmpage = cp->cpg_page;
+       struct cl_page  *page   = slice->cpl_page;
         struct inode    *inode  = ccc_object_inode(page->cp_obj);
         ENTRY;
 
@@ -405,10 +387,8 @@ static const struct cl_page_operations vvp_page_ops = {
         .cpo_assume        = vvp_page_assume,
         .cpo_unassume      = vvp_page_unassume,
         .cpo_disown        = vvp_page_disown,
-        .cpo_vmpage        = ccc_page_vmpage,
         .cpo_discard       = vvp_page_discard,
         .cpo_delete        = vvp_page_delete,
-        .cpo_unmap         = vvp_page_unmap,
         .cpo_export        = vvp_page_export,
         .cpo_is_vmlocked   = vvp_page_is_vmlocked,
         .cpo_fini          = vvp_page_fini,
@@ -516,7 +496,6 @@ static const struct cl_page_operations vvp_transient_page_ops = {
         .cpo_unassume      = vvp_transient_page_unassume,
         .cpo_disown        = vvp_transient_page_disown,
         .cpo_discard       = vvp_transient_page_discard,
-        .cpo_vmpage        = ccc_page_vmpage,
         .cpo_fini          = vvp_transient_page_fini,
         .cpo_is_vmlocked   = vvp_transient_page_is_vmlocked,
         .cpo_print         = vvp_page_print,
@@ -534,17 +513,21 @@ static const struct cl_page_operations vvp_transient_page_ops = {
 };
 
 int vvp_page_init(const struct lu_env *env, struct cl_object *obj,
-               struct cl_page *page, struct page *vmpage)
+               struct cl_page *page, pgoff_t index)
 {
        struct ccc_page *cpg = cl_object_page_slice(obj, page);
+       struct page     *vmpage = page->cp_vmpage;
 
        CLOBINVRNT(env, obj, ccc_object_invariant(obj));
 
+       cpg->cpg_cl.cpl_index = index;
        cpg->cpg_page = vmpage;
        page_cache_get(vmpage);
 
        CFS_INIT_LIST_HEAD(&cpg->cpg_pending_linkage);
        if (page->cp_type == CPT_CACHEABLE) {
+               /* in cache, decref in vvp_page_delete */
+               atomic_inc(&page->cp_ref);
                SetPagePrivate(vmpage);
                vmpage->private = (unsigned long)page;
                cl_page_slice_add(page, &cpg->cpg_cl, obj,