{
dout(0) << "do_pg_op " << *op << dendl;
- //bufferlist& indata = op->get_data();
bufferlist outdata;
int result = 0;
dout(10) << "do_op mode now " << mode << dendl;
const sobject_t& soid = obc->obs.oi.soid;
- OpContext *ctx = new OpContext(op, op->get_reqid(), op->ops, op->get_data(),
+ OpContext *ctx = new OpContext(op, op->get_reqid(), op->ops,
&obc->obs, this);
bool noop = false;
register_object_context(obc);
vector<OSDOp> ops;
- bufferlist data;
tid_t rep_tid = osd->get_tid();
osd_reqid_t reqid(osd->messenger->get_myname(), 0, rep_tid);
- OpContext *ctx = new OpContext(NULL, reqid, ops, data, &obc->obs, this);
+ OpContext *ctx = new OpContext(NULL, reqid, ops, &obc->obs, this);
ctx->mtime = g_clock.now();
ctx->at_version.epoch = osd->osdmap->get_epoch();
rm->tls.push_back(&rm->opt);
rm->tls.push_back(&rm->localt);
+
} else {
// do op
ObjectState obs(op->poid);
obs.oi.size = op->old_size;
obs.exists = op->old_exists;
- rm->ctx = new OpContext(op, op->reqid, op->ops, op->get_data(), &obs, this);
+ rm->ctx = new OpContext(op, op->reqid, op->ops, &obs, this);
rm->ctx->mtime = op->mtime;
rm->ctx->at_version = op->version;
Message *op;
osd_reqid_t reqid;
vector<OSDOp>& ops;
- bufferlist& indata;
bufferlist outdata;
ObjectState *obs;
ReplicatedPG *pg;
- OpContext(Message *_op, osd_reqid_t _reqid, vector<OSDOp>& _ops, bufferlist& _data,
+ OpContext(Message *_op, osd_reqid_t _reqid, vector<OSDOp>& _ops,
ObjectState *_obs, ReplicatedPG *_pg) :
- op(_op), reqid(_reqid), ops(_ops), indata(_data), obs(_obs),
+ op(_op), reqid(_reqid), ops(_ops), obs(_obs),
bytes_written(0),
clone_obc(0), snapset_obc(0), data_off(0), reply(NULL), pg(_pg) {}
~OpContext() {