atomic ops in fs

404afe5b · Nickolai Zeldovich · 8d8cc662 · 404afe5b
--- a/fs.c
+++ b/fs.c
@@ -264,9 +264,7 @@ iget(uint dev, uint inum)
 struct inode*
 idup(struct inode *ip)
 {
-  acquire(&icache.lock);
+  __sync_fetch_and_add(&ip->ref, 1);
-  ip->ref++;
-  release(&icache.lock);
  return ip;
 }
@@ -307,27 +305,28 @@ iunlock(struct inode *ip)
 void
 iput(struct inode *ip)
 {
-  acquire(&icache.lock);
+  if(__sync_sub_and_fetch(&ip->ref, 1) == 0) {
-  if(ip->ref == 1 && ip->nlink == 0){
-    // inode is no longer used: truncate and free inode.
-    if(ip->flags & I_BUSY)
-      panic("iput busy");
-    if((ip->flags & I_VALID) == 0)
-      panic("iput not valid");
-    ip->flags |= I_BUSY;
-    release(&icache.lock);
-    itrunc(ip);
-    ip->type = 0;
-    ip->major = 0;
-    ip->minor = 0;
-    ip->gen += 1;
-    iupdate(ip);
    acquire(&icache.lock);
-    ip->flags &= ~I_BUSY;
+    if (ip->nlink == 0){
-    cv_wakeup(&ip->cv);
+      // inode is no longer used: truncate and free inode.
+      if(ip->flags & I_BUSY)
+	panic("iput busy");
+      if((ip->flags & I_VALID) == 0)
+	panic("iput not valid");
+      ip->flags |= I_BUSY;
+      release(&icache.lock);
+      itrunc(ip);
+      ip->type = 0;
+      ip->major = 0;
+      ip->minor = 0;
+      ip->gen += 1;
+      iupdate(ip);
+      acquire(&icache.lock);
+      ip->flags &= ~I_BUSY;
+      cv_wakeup(&ip->cv);
+    }
+    release(&icache.lock);
  }
-  ip->ref--;
-  release(&icache.lock);
 }
 // Common idiom: unlock, then put.