summaryrefslogtreecommitdiff
path: root/src/mds/Locker.cc
diff options
context:
space:
mode:
authorSage Weil <sage@newdream.net>2011-07-13 13:22:29 -0700
committerSage Weil <sage@newdream.net>2011-07-13 14:57:57 -0700
commit1e3196127767f1f36f0f0149b0ce89060f2b9a8b (patch)
treec5e9707aa458ffb02753d7cc06c46f959fbb0da3 /src/mds/Locker.cc
parent2539d16a19f4752682fb7ec502834fe1293afe4e (diff)
downloadceph-1e3196127767f1f36f0f0149b0ce89060f2b9a8b.tar.gz
mds: drop useless from field from MInodeFileCaps
While we're updating the protocol, clean this up too. Signed-off-by: Sage Weil <sage@newdream.net>
Diffstat (limited to 'src/mds/Locker.cc')
-rw-r--r--src/mds/Locker.cc11
1 files changed, 6 insertions, 5 deletions
diff --git a/src/mds/Locker.cc b/src/mds/Locker.cc
index bfe2fe34244..a39c3c19425 100644
--- a/src/mds/Locker.cc
+++ b/src/mds/Locker.cc
@@ -1771,8 +1771,7 @@ void Locker::request_inode_file_caps(CInode *in)
in->replica_caps_wanted = wanted;
if (mds->mdsmap->get_state(auth) >= MDSMap::STATE_REJOIN)
- mds->send_message_mds(new MInodeFileCaps(in->ino(), mds->get_nodeid(),
- in->replica_caps_wanted),
+ mds->send_message_mds(new MInodeFileCaps(in->ino(), in->replica_caps_wanted),
auth);
} else {
in->replica_caps_wanted_keep_until.sec_ref() = 0;
@@ -1787,6 +1786,8 @@ void Locker::handle_inode_file_caps(MInodeFileCaps *m)
// ok
CInode *in = mdcache->get_inode(m->get_ino());
+ int from = m->get_source().num();
+
assert(in);
assert(in->is_auth());
@@ -1798,12 +1799,12 @@ void Locker::handle_inode_file_caps(MInodeFileCaps *m)
}
- dout(7) << "handle_inode_file_caps replica mds" << m->get_from() << " wants caps " << ccap_string(m->get_caps()) << " on " << *in << dendl;
+ dout(7) << "handle_inode_file_caps replica mds" << from << " wants caps " << ccap_string(m->get_caps()) << " on " << *in << dendl;
if (m->get_caps())
- in->mds_caps_wanted[m->get_from()] = m->get_caps();
+ in->mds_caps_wanted[from] = m->get_caps();
else
- in->mds_caps_wanted.erase(m->get_from());
+ in->mds_caps_wanted.erase(from);
try_eval(in, CEPH_CAP_LOCKS);
m->put();