(diskfs_S_dir_unlink): Do fsys_goaway for translated nodes being

unlinked.

1 files changed, 35 insertions, 0 deletions

diff --git a/libdiskfs/dir-unlink.c b/libdiskfs/dir-unlink.c
index bf486f8a..ae5a4310 100644
--- a/libdiskfs/dir-unlink.c
+++ b/libdiskfs/dir-unlink.c
@@ -35,6 +35,8 @@ diskfs_S_dir_unlink (struct protid *dircred,
   if (diskfs_readonly)
     return EROFS;
 
+ retry:
+  
   mutex_lock (&dnp->lock);
 
   error = diskfs_lookup (dnp, name, REMOVE, &np, ds, dircred);
@@ -60,6 +62,39 @@ diskfs_S_dir_unlink (struct protid *dircred,
       return EISDIR;
     }
 
+  mutex_lock (&np->translator.lock);
+  if (np->translator.control != MACH_PORT_NULL)
+    {
+      /* There is a running active translator here.  Give it a push.
+	 If it squeaks, then return an error.  If it consents, then
+	 clear the active translator spec (unless it's been changed
+	 in the interim) and repeat the lookup above.  */
+
+      control = np->translator.control;
+      mach_port_mod_refs (mach_task_self (), control, MACH_PORT_RIGHT_SEND, 1);
+
+      mutex_unlock (&np->translator.lock);
+      diskfs_drop_dirstat (dnp, ds);
+      mutex_unlock (&dnp->lock);
+      mutex_unlock (&np->lock);
+      
+      error = fsys_goaway (control, FSYS_GOAWAY_UNLINK);
+      if (error)
+	return error;
+      
+      mutex_lock (&np->lock);
+      mutex_lock (&np->translator.lock);
+      if (np->translator.control == control)
+	fshelp_translator_drop (&np->translator);
+      mutex_unlock (&np->translator.lock);
+      diskfs_nput (np);
+      
+      mach_port_deallocate (mach_task_self (), control);
+
+      goto retry;
+    }
+  mutex_unlock (&np->translator.lock);
+
   error = diskfs_dirremove (dnp, ds);
   if (diskfs_synchronous)
     diskfs_node_update (dnp, 1);