From d1d81aa6a3ef75884d67cd5c19aa8becd3fa0be9 Mon Sep 17 00:00:00 2001
From: adilger <adilger>
Date: Mon, 28 Oct 2002 19:25:27 +0000
Subject: [PATCH] Fix space leak after recent change of openunlink code logic
 (fdd was previously released at d_delete time and is now done at d_release
 time, so the mere presence of d_fsdata isn't enough to signal an open file).

---
 lustre/obdfilter/filter.c | 16 ++++++++++++----
 1 file changed, 12 insertions(+), 4 deletions(-)

diff --git a/lustre/obdfilter/filter.c b/lustre/obdfilter/filter.c
index fd523ae..0b4c1bd 100644
--- a/lustre/obdfilter/filter.c
+++ b/lustre/obdfilter/filter.c
@@ -419,6 +419,7 @@ static int filter_destroy_internal(struct obd_device *obd,
         struct obd_run_ctxt saved;
         struct inode *inode = object_dentry->d_inode;
         int rc;
+        ENTRY;
 
         if (inode->i_nlink != 1 || atomic_read(&inode->i_count) != 1) {
                 CERROR("destroying objid %*s nlink = %d, count = %d\n",
@@ -437,7 +438,7 @@ static int filter_destroy_internal(struct obd_device *obd,
                        object_dentry->d_name.len,
                        object_dentry->d_name.name, rc);
 
-        return rc;
+        RETURN(rc);
 }
 
 static int filter_close_internal(struct obd_device *obd,
@@ -877,6 +878,7 @@ static int filter_destroy(struct lustre_handle *conn, struct obdo *oa,
 {
         struct obd_device *obd = class_conn2obd(conn);
         struct dentry *dir_dentry, *object_dentry;
+        struct filter_dentry_data *fdd = object_dentry->d_fsdata;
         int rc;
         ENTRY;
 
@@ -885,7 +887,7 @@ static int filter_destroy(struct lustre_handle *conn, struct obdo *oa,
                 RETURN(-EINVAL);
         }
 
-        CDEBUG(D_INODE, "destroying object "LPD64"\n", oa->o_id);
+        CDEBUG(D_INODE, "destroying objid "LPX64"\n", oa->o_id);
 
         dir_dentry = filter_parent(obd, oa->o_mode);
         down(&dir_dentry->d_inode->i_sem);
@@ -894,13 +896,19 @@ static int filter_destroy(struct lustre_handle *conn, struct obdo *oa,
         if (IS_ERR(object_dentry))
                 GOTO(out, rc = -ENOENT);
 
-        if (object_dentry->d_fsdata) {
+        if (fdd && atomic_read(&fdd->fdd_open_count)) {
                 struct filter_dentry_data *fdd = object_dentry->d_fsdata;
 
                 if (!(fdd->fdd_flags & FILTER_FLAG_DESTROY)) {
                         fdd->fdd_flags |= FILTER_FLAG_DESTROY;
                         /* XXX put into PENDING directory in case of crash */
-                }
+                        CDEBUG(D_INODE,
+                               "defer destroy of %dx open objid "LPX64"\n",
+                               atomic_read(&fdd->fdd_open_count), oa->o_id);
+                } else
+                        CDEBUG(D_INODE,
+                               "repeat destroy of %dx open objid "LPX64"\n",
+                               atomic_read(&fdd->fdd_open_count), oa->o_id);
                 GOTO(out_dput, rc = 0);
         }
 
-- 
1.8.3.1