From: Yan, Zheng Date: Mon, 30 Sep 2019 06:20:18 +0000 (+0800) Subject: mds: cleanup Server::set_trace_dist() X-Git-Tag: v15.1.0~404^2~4 X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=f8929830b500fe7315e890d08dc1c1f614fe1454;p=ceph.git mds: cleanup Server::set_trace_dist() Signed-off-by: "Yan, Zheng" --- diff --git a/src/mds/Server.cc b/src/mds/Server.cc index 71b1672f3016..2a4e4f032312 100644 --- a/src/mds/Server.cc +++ b/src/mds/Server.cc @@ -1981,8 +1981,7 @@ void Server::early_reply(MDRequestRef& mdr, CInode *tracei, CDentry *tracedn) if (tracedn) mdr->cap_releases.erase(tracedn->get_dir()->get_inode()->vino()); - set_trace_dist(mdr->session, reply, tracei, tracedn, mdr->snapid, - req->get_dentry_wanted(), mdr); + set_trace_dist(reply, tracei, tracedn, mdr); } reply->set_extra_bl(mdr->reply_extra_bl); @@ -2039,14 +2038,12 @@ void Server::reply_client_request(MDRequestRef& mdr, const ref_t & apply_allocated_inos(mdr, session); // get tracei/tracedn from mdr? - snapid_t snapid = mdr->snapid; CInode *tracei = mdr->tracei; CDentry *tracedn = mdr->tracedn; bool is_replay = mdr->client_request->is_replay(); bool did_early_reply = mdr->did_early_reply; entity_inst_t client_inst = req->get_source_inst(); - int dentry_wanted = req->get_dentry_wanted(); if (!did_early_reply && !is_replay) { @@ -2078,9 +2075,7 @@ void Server::reply_client_request(MDRequestRef& mdr, const ref_t & mdcache->try_reconnect_cap(tracei, session); } else { // include metadata in reply - set_trace_dist(session, reply, tracei, tracedn, - snapid, dentry_wanted, - mdr); + set_trace_dist(reply, tracei, tracedn, mdr); } } @@ -2119,10 +2114,8 @@ void Server::reply_client_request(MDRequestRef& mdr, const ref_t & * * trace is in reverse order (i.e. root inode comes last) */ -void Server::set_trace_dist(Session *session, const ref_t &reply, +void Server::set_trace_dist(const ref_t &reply, CInode *in, CDentry *dn, - snapid_t snapid, - int dentry_wanted, MDRequestRef& mdr) { // skip doing this for debugging purposes? @@ -2136,13 +2129,13 @@ void Server::set_trace_dist(Session *session, const ref_t &reply, // inode, dentry, dir, ..., inode bufferlist bl; mds_rank_t whoami = mds->get_nodeid(); - client_t client = session->get_client(); + Session *session = mdr->session; + client_t client = mdr->get_client(); + snapid_t snapid = mdr->snapid; utime_t now = ceph_clock_now(); dout(20) << "set_trace_dist snapid " << snapid << dendl; - //assert((bool)dn == (bool)dentry_wanted); // not true for snapshot lookups - // realm if (snapid == CEPH_NOSNAP) { SnapRealm *realm; diff --git a/src/mds/Server.h b/src/mds/Server.h index c1eddd25977b..b8c1eb26af71 100644 --- a/src/mds/Server.h +++ b/src/mds/Server.h @@ -192,9 +192,7 @@ public: void perf_gather_op_latency(const cref_t &req, utime_t lat); void early_reply(MDRequestRef& mdr, CInode *tracei, CDentry *tracedn); void respond_to_request(MDRequestRef& mdr, int r = 0); - void set_trace_dist(Session *session, const ref_t &reply, CInode *in, CDentry *dn, - snapid_t snapid, - int num_dentries_wanted, + void set_trace_dist(const ref_t &reply, CInode *in, CDentry *dn, MDRequestRef& mdr);