// insert readdir results too
// the rest?
- p = reply->get_dir_bl().begin();
+ p = reply->get_extra_bl().begin();
if (!p.end()) {
// only open dir if we're actually adding stuff to it!
Dir *dir = in->open_dir();
int r = reply->get_result();
if (pdirbl)
- pdirbl->claim(reply->get_dir_bl());
+ pdirbl->claim(reply->get_extra_bl());
reply->put();
return r;
}
<< " complete=" << (int)complete
<< dendl;
MClientReply *reply = new MClientReply(req, 0);
- reply->set_dir_bl(dirbl);
+ reply->set_extra_bl(dirbl);
+ dout(10) << "reply to " << *req << " readdir num=" << numfiles << " end=" << (int)end
+ << " complete=" << (int)complete << dendl;
// bump popularity. NOTE: this doesn't quite capture it.
mds->balancer->hit_dir(g_clock.now(), dir, META_POP_IRD, -1, numfiles);
dirbl.claim_append(dnbl);
MClientReply *reply = new MClientReply(req);
- reply->set_dir_bl(dirbl);
+ reply->set_extra_bl(dirbl);
reply_request(mdr, reply, diri);
}
public:
struct ceph_mds_reply_head head;
bufferlist trace_bl;
- bufferlist dir_bl;
+ bufferlist extra_bl;
bufferlist snapbl;
public:
bufferlist::iterator p = payload.begin();
::decode(head, p);
::decode(trace_bl, p);
- ::decode(dir_bl, p);
+ ::decode(extra_bl, p);
::decode(snapbl, p);
assert(p.end());
}
virtual void encode_payload() {
::encode(head, payload);
::encode(trace_bl, payload);
- ::encode(dir_bl, payload);
+ ::encode(extra_bl, payload);
::encode(snapbl, payload);
}
// dir contents
- void set_dir_bl(bufferlist& bl) {
- dir_bl.claim(bl);
+ void set_extra_bl(bufferlist& bl) {
+ extra_bl.claim(bl);
}
- bufferlist &get_dir_bl() {
- return dir_bl;
+ bufferlist &get_extra_bl() {
+ return extra_bl;
}
// trace