bufferlist *pbl)
{
FUNCTRACE();
- Context *onack = new C_aio_Complete(c);
+ Context *oncomplete = new C_aio_Complete(c);
#if defined(WITH_LTTNG) && defined(WITH_EVENTTRACE)
- ((C_aio_Complete *) onack)->oid = oid;
+ ((C_aio_Complete *) oncomplete)->oid = oid;
#endif
c->is_read = true;
c->io = this;
Objecter::Op *objecter_op = objecter->prepare_read_op(oid, oloc,
*o, snap_seq, pbl, flags,
- onack, &c->objver);
+ oncomplete, &c->objver);
objecter->op_submit(objecter_op, &c->tid);
return 0;
}
if (snap_seq != CEPH_NOSNAP)
return -EROFS;
- Context *onack = new C_aio_Complete(c);
+ Context *oncomplete = new C_aio_Complete(c);
#if defined(WITH_LTTNG) && defined(WITH_EVENTTRACE)
- ((C_aio_Complete *) onack)->oid = oid;
+ ((C_aio_Complete *) oncomplete)->oid = oid;
#endif
c->io = this;
Objecter::Op *op = objecter->prepare_mutate_op(
oid, oloc, *o, snap_context, ut, flags,
- onack, &c->objver);
+ oncomplete, &c->objver);
objecter->op_submit(op, &c->tid);
return 0;
return -EDOM;
OID_EVENT_TRACE(oid.name.c_str(), "RADOS_READ_OP_BEGIN");
- Context *onack = new C_aio_Complete(c);
+ Context *oncomplete = new C_aio_Complete(c);
#if defined(WITH_LTTNG) && defined(WITH_EVENTTRACE)
- ((C_aio_Complete *) onack)->oid = oid;
+ ((C_aio_Complete *) oncomplete)->oid = oid;
#endif
c->is_read = true;
c->io = this;
Objecter::Op *o = objecter->prepare_read_op(
oid, oloc,
off, len, snapid, pbl, 0,
- onack, &c->objver);
+ oncomplete, &c->objver);
objecter->op_submit(o, &c->tid);
return 0;
}
return -EDOM;
OID_EVENT_TRACE(oid.name.c_str(), "RADOS_READ_OP_BEGIN");
- Context *onack = new C_aio_Complete(c);
+ Context *oncomplete = new C_aio_Complete(c);
#if defined(WITH_LTTNG) && defined(WITH_EVENTTRACE)
- ((C_aio_Complete *) onack)->oid = oid;
+ ((C_aio_Complete *) oncomplete)->oid = oid;
#endif
c->is_read = true;
c->io = this;
Objecter::Op *o = objecter->prepare_read_op(
oid, oloc,
off, len, snapid, &c->bl, 0,
- onack, &c->objver);
+ oncomplete, &c->objver);
objecter->op_submit(o, &c->tid);
return 0;
}
if (snap_seq != CEPH_NOSNAP)
return -EROFS;
- Context *onack = new C_aio_Complete(c);
+ Context *oncomplete = new C_aio_Complete(c);
#if defined(WITH_LTTNG) && defined(WITH_EVENTTRACE)
- ((C_aio_Complete *) onack)->oid = oid;
+ ((C_aio_Complete *) oncomplete)->oid = oid;
#endif
c->io = this;
queue_aio_write(c);
Objecter::Op *o = objecter->prepare_write_op(
oid, oloc,
off, len, snapc, bl, ut, 0,
- onack, &c->objver);
+ oncomplete, &c->objver);
objecter->op_submit(o, &c->tid);
return 0;
if (snap_seq != CEPH_NOSNAP)
return -EROFS;
- Context *onack = new C_aio_Complete(c);
+ Context *oncomplete = new C_aio_Complete(c);
#if defined(WITH_LTTNG) && defined(WITH_EVENTTRACE)
- ((C_aio_Complete *) onack)->oid = oid;
+ ((C_aio_Complete *) oncomplete)->oid = oid;
#endif
c->io = this;
Objecter::Op *o = objecter->prepare_append_op(
oid, oloc,
len, snapc, bl, ut, 0,
- onack, &c->objver);
+ oncomplete, &c->objver);
objecter->op_submit(o, &c->tid);
return 0;
if (snap_seq != CEPH_NOSNAP)
return -EROFS;
- Context *onack = new C_aio_Complete(c);
+ Context *oncomplete = new C_aio_Complete(c);
#if defined(WITH_LTTNG) && defined(WITH_EVENTTRACE)
- ((C_aio_Complete *) onack)->oid = oid;
+ ((C_aio_Complete *) oncomplete)->oid = oid;
#endif
c->io = this;
Objecter::Op *o = objecter->prepare_write_full_op(
oid, oloc,
snapc, bl, ut, 0,
- onack, &c->objver);
+ oncomplete, &c->objver);
objecter->op_submit(o, &c->tid);
return 0;
if (snap_seq != CEPH_NOSNAP)
return -EROFS;
- Context *onack = new C_aio_Complete(c);
+ Context *oncomplete = new C_aio_Complete(c);
#if defined(WITH_LTTNG) && defined(WITH_EVENTTRACE)
- ((C_aio_Complete *) onack)->oid = oid;
+ ((C_aio_Complete *) oncomplete)->oid = oid;
#endif
c->io = this;
queue_aio_write(c);
oid, oloc,
write_len, off,
snapc, bl, ut, 0,
- onack, &c->objver);
+ oncomplete, &c->objver);
objecter->op_submit(o, &c->tid);
return 0;
if (snap_seq != CEPH_NOSNAP)
return -EROFS;
- Context *onack = new C_aio_Complete(c);
+ Context *oncomplete = new C_aio_Complete(c);
#if defined(WITH_LTTNG) && defined(WITH_EVENTTRACE)
- ((C_aio_Complete *) onack)->oid = oid;
+ ((C_aio_Complete *) oncomplete)->oid = oid;
#endif
c->io = this;
queue_aio_write(c);
Objecter::Op *o = objecter->prepare_remove_op(
oid, oloc,
snapc, ut, flags,
- onack, &c->objver);
+ oncomplete, &c->objver);
objecter->op_submit(o, &c->tid);
return 0;
int librados::IoCtxImpl::hit_set_list(uint32_t hash, AioCompletionImpl *c,
std::list< std::pair<time_t, time_t> > *pls)
{
- Context *onack = new C_aio_Complete(c);
+ Context *oncomplete = new C_aio_Complete(c);
c->is_read = true;
c->io = this;
rd.hit_set_ls(pls, NULL);
object_locator_t oloc(poolid);
Objecter::Op *o = objecter->prepare_pg_read_op(
- hash, oloc, rd, NULL, 0, onack, NULL, NULL);
+ hash, oloc, rd, NULL, 0, oncomplete, NULL, NULL);
objecter->op_submit(o, &c->tid);
return 0;
}
time_t stamp,
bufferlist *pbl)
{
- Context *onack = new C_aio_Complete(c);
+ Context *oncomplete = new C_aio_Complete(c);
c->is_read = true;
c->io = this;
rd.hit_set_get(ceph::real_clock::from_time_t(stamp), pbl, 0);
object_locator_t oloc(poolid);
Objecter::Op *o = objecter->prepare_pg_read_op(
- hash, oloc, rd, NULL, 0, onack, NULL, NULL);
+ hash, oloc, rd, NULL, 0, oncomplete, NULL, NULL);
objecter->op_submit(o, &c->tid);
return 0;
}
std::vector<inconsistent_obj_t>* objects,
uint32_t* interval)
{
- Context *onack = new C_aio_Complete(c);
+ Context *oncomplete = new C_aio_Complete(c);
c->is_read = true;
c->io = this;
op.scrub_ls(start_after, max_to_get, objects, interval, nullptr);
object_locator_t oloc{poolid, pg.ps()};
Objecter::Op *o = objecter->prepare_pg_read_op(
- oloc.hash, oloc, op, nullptr, CEPH_OSD_FLAG_PGOP, onack,
+ oloc.hash, oloc, op, nullptr, CEPH_OSD_FLAG_PGOP, oncomplete,
nullptr, nullptr);
objecter->op_submit(o, &c->tid);
return 0;
std::vector<inconsistent_snapset_t>* snapsets,
uint32_t* interval)
{
- Context *onack = new C_aio_Complete(c);
+ Context *oncomplete = new C_aio_Complete(c);
c->is_read = true;
c->io = this;
op.scrub_ls(start_after, max_to_get, snapsets, interval, nullptr);
object_locator_t oloc{poolid, pg.ps()};
Objecter::Op *o = objecter->prepare_pg_read_op(
- oloc.hash, oloc, op, nullptr, CEPH_OSD_FLAG_PGOP, onack,
+ oloc.hash, oloc, op, nullptr, CEPH_OSD_FLAG_PGOP, oncomplete,
nullptr, nullptr);
objecter->op_submit(o, &c->tid);
return 0;
bufferlist& inbl, bufferlist *outbl)
{
FUNCTRACE();
- Context *onack = new C_aio_Complete(c);
+ Context *oncomplete = new C_aio_Complete(c);
#if defined(WITH_LTTNG) && defined(WITH_EVENTTRACE)
- ((C_aio_Complete *) onack)->oid = oid;
+ ((C_aio_Complete *) oncomplete)->oid = oid;
#endif
c->is_read = true;
c->io = this;
prepare_assert_ops(&rd);
rd.call(cls, method, inbl);
Objecter::Op *o = objecter->prepare_read_op(
- oid, oloc, rd, snap_seq, outbl, 0, onack, &c->objver);
+ oid, oloc, rd, snap_seq, outbl, 0, oncomplete, &c->objver);
objecter->op_submit(o, &c->tid);
return 0;
}
bufferlist& inbl, char *buf, size_t out_len)
{
FUNCTRACE();
- Context *onack = new C_aio_Complete(c);
+ Context *oncomplete = new C_aio_Complete(c);
#if defined(WITH_LTTNG) && defined(WITH_EVENTTRACE)
- ((C_aio_Complete *) onack)->oid = oid;
+ ((C_aio_Complete *) oncomplete)->oid = oid;
#endif
c->is_read = true;
c->io = this;
prepare_assert_ops(&rd);
rd.call(cls, method, inbl);
Objecter::Op *o = objecter->prepare_read_op(
- oid, oloc, rd, snap_seq, &c->bl, 0, onack, &c->objver);
+ oid, oloc, rd, snap_seq, &c->bl, 0, oncomplete, &c->objver);
objecter->op_submit(o, &c->tid);
return 0;
}