From 4377dba3191d37b3817516c4fa26b99eb2abad07 Mon Sep 17 00:00:00 2001
From: Sage Weil <sage@newdream.net>
Date: Wed, 31 Dec 2008 09:15:34 -0800
Subject: [PATCH] mds: fix xattr projection

We do not want the new xattr to appear in the inode until the journal
entry commits.
---
 src/TODO          |  1 -
 src/mds/Server.cc | 43 ++++++++++++++++++++++++++++++++++++++++---
 2 files changed, 40 insertions(+), 4 deletions(-)

diff --git a/src/TODO b/src/TODO
index 771d720535417..63ae1c6e1d7a3 100644
--- a/src/TODO
+++ b/src/TODO
@@ -105,7 +105,6 @@ userspace client
 
 mds
 - xlock vs wrlock.. need more lock states?
-- xattrs need to be properly projected.  should we just expand inode_t?  or make some smarter thing?
 - dftlock is missing from rejoin phase
 - file size recovery gives (wrong) 4MB-increment results?
 - hard link backpointers
diff --git a/src/mds/Server.cc b/src/mds/Server.cc
index 010a1900472f4..f27e89270b04d 100644
--- a/src/mds/Server.cc
+++ b/src/mds/Server.cc
@@ -1979,6 +1979,31 @@ void Server::handle_client_setlayout(MDRequest *mdr)
 
 // XATTRS
 
+class C_MDS_inode_xattr_update_finish : public Context {
+  MDS *mds;
+  MDRequest *mdr;
+  CInode *in;
+public:
+  map<string, bufferptr> xattrs;
+
+  C_MDS_inode_xattr_update_finish(MDS *m, MDRequest *r, CInode *i) :
+    mds(m), mdr(r), in(i) { }
+  void finish(int r) {
+    assert(r == 0);
+
+    // apply
+    in->pop_and_dirty_projected_inode(mdr->ls);
+    
+    in->xattrs.swap(xattrs);
+
+    mdr->apply();
+
+    mds->balancer->hit_inode(mdr->now, in, META_POP_IWR);   
+
+    mds->server->reply_request(mdr, 0);
+  }
+};
+
 void Server::handle_client_setxattr(MDRequest *mdr)
 {
   MClientRequest *req = mdr->client_request;
@@ -2029,15 +2054,21 @@ void Server::handle_client_setxattr(MDRequest *mdr)
   mdcache->predirty_journal_parents(mdr, &le->metablob, cur, 0, PREDIRTY_PRIMARY, false);
 
   mdcache->journal_cow_inode(mdr, &le->metablob, cur);
+
+  C_MDS_inode_xattr_update_finish *fin = new C_MDS_inode_xattr_update_finish(mds, mdr, cur);
+  fin->xattrs = cur->xattrs;
+
   cur->xattrs.erase(name);
   cur->xattrs[name] = buffer::create(len);
   if (len)
     req->get_data().copy(0, len, cur->xattrs[name].c_str());
   le->metablob.add_primary_dentry(cur->get_projected_parent_dn(), true, cur, pi);
-  
+
   early_reply(mdr, cur, 0);
 
-  mdlog->submit_entry(le, new C_MDS_inode_update_finish(mds, mdr, cur));
+  fin->xattrs.swap(cur->xattrs);
+
+  mdlog->submit_entry(le, fin);
 }
 
 void Server::handle_client_removexattr(MDRequest *mdr)
@@ -2082,12 +2113,18 @@ void Server::handle_client_removexattr(MDRequest *mdr)
   mdcache->predirty_journal_parents(mdr, &le->metablob, cur, 0, PREDIRTY_PRIMARY, false);
 
   mdcache->journal_cow_inode(mdr, &le->metablob, cur);
+
+  C_MDS_inode_xattr_update_finish *fin = new C_MDS_inode_xattr_update_finish(mds, mdr, cur);
+  fin->xattrs = cur->xattrs;
+
   cur->xattrs.erase(name);
   le->metablob.add_primary_dentry(cur->get_projected_parent_dn(), true, cur, pi);
 
   early_reply(mdr, cur, 0);
 
-  mdlog->submit_entry(le, new C_MDS_inode_update_finish(mds, mdr, cur));
+  fin->xattrs.swap(cur->xattrs);
+
+  mdlog->submit_entry(le, fin);
 }
 
 
-- 
2.39.5