summaryrefslogtreecommitdiffstats
path: root/src/librados/IoCtxImpl.cc
diff options
context:
space:
mode:
authorPan Liu <pan.liu@istuary.com>2017-03-09 13:58:26 +0100
committerPan Liu <pan.liu@istuary.com>2017-03-09 17:24:32 +0100
commitff8b601ef9984855c80a2648dad6abb67862bdd4 (patch)
tree0361b4a26cdd92262fed496be902b91d41a11873 /src/librados/IoCtxImpl.cc
parentMerge pull request #13896 from optimistyzy/39_1 (diff)
downloadceph-ff8b601ef9984855c80a2648dad6abb67862bdd4.tar.xz
ceph-ff8b601ef9984855c80a2648dad6abb67862bdd4.zip
librados: replace the var name from onact to oncomplete.
Signed-off-by: Pan Liu <pan.liu@istuary.com>
Diffstat (limited to 'src/librados/IoCtxImpl.cc')
-rw-r--r--src/librados/IoCtxImpl.cc82
1 files changed, 41 insertions, 41 deletions
diff --git a/src/librados/IoCtxImpl.cc b/src/librados/IoCtxImpl.cc
index 49cf05faa7f..cfdb4089eee 100644
--- a/src/librados/IoCtxImpl.cc
+++ b/src/librados/IoCtxImpl.cc
@@ -772,17 +772,17 @@ int librados::IoCtxImpl::aio_operate_read(const object_t &oid,
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;
}
@@ -798,9 +798,9 @@ int librados::IoCtxImpl::aio_operate(const object_t& oid,
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;
@@ -808,7 +808,7 @@ int librados::IoCtxImpl::aio_operate(const object_t& oid,
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;
@@ -823,10 +823,10 @@ int librados::IoCtxImpl::aio_read(const object_t oid, AioCompletionImpl *c,
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;
@@ -835,7 +835,7 @@ int librados::IoCtxImpl::aio_read(const object_t oid, AioCompletionImpl *c,
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;
}
@@ -849,10 +849,10 @@ int librados::IoCtxImpl::aio_read(const object_t oid, AioCompletionImpl *c,
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;
@@ -864,7 +864,7 @@ int librados::IoCtxImpl::aio_read(const object_t oid, AioCompletionImpl *c,
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;
}
@@ -924,10 +924,10 @@ int librados::IoCtxImpl::aio_write(const object_t &oid, AioCompletionImpl *c,
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);
@@ -935,7 +935,7 @@ int librados::IoCtxImpl::aio_write(const object_t &oid, AioCompletionImpl *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;
@@ -953,9 +953,9 @@ int librados::IoCtxImpl::aio_append(const object_t &oid, AioCompletionImpl *c,
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;
@@ -964,7 +964,7 @@ int librados::IoCtxImpl::aio_append(const object_t &oid, AioCompletionImpl *c,
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;
@@ -983,9 +983,9 @@ int librados::IoCtxImpl::aio_write_full(const object_t &oid,
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;
@@ -994,7 +994,7 @@ int librados::IoCtxImpl::aio_write_full(const object_t &oid,
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;
@@ -1017,10 +1017,10 @@ int librados::IoCtxImpl::aio_writesame(const object_t &oid,
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);
@@ -1029,7 +1029,7 @@ int librados::IoCtxImpl::aio_writesame(const object_t &oid,
oid, oloc,
write_len, off,
snapc, bl, ut, 0,
- onack, &c->objver);
+ oncomplete, &c->objver);
objecter->op_submit(o, &c->tid);
return 0;
@@ -1044,10 +1044,10 @@ int librados::IoCtxImpl::aio_remove(const object_t &oid, AioCompletionImpl *c, i
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);
@@ -1055,7 +1055,7 @@ int librados::IoCtxImpl::aio_remove(const object_t &oid, AioCompletionImpl *c, i
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;
@@ -1168,7 +1168,7 @@ int librados::IoCtxImpl::aio_cancel(AioCompletionImpl *c)
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;
@@ -1176,7 +1176,7 @@ int librados::IoCtxImpl::hit_set_list(uint32_t hash, AioCompletionImpl *c,
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;
}
@@ -1185,7 +1185,7 @@ int librados::IoCtxImpl::hit_set_get(uint32_t hash, AioCompletionImpl *c,
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;
@@ -1193,7 +1193,7 @@ int librados::IoCtxImpl::hit_set_get(uint32_t hash, AioCompletionImpl *c,
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;
}
@@ -1229,7 +1229,7 @@ int librados::IoCtxImpl::get_inconsistent_objects(const pg_t& pg,
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;
@@ -1237,7 +1237,7 @@ int librados::IoCtxImpl::get_inconsistent_objects(const pg_t& pg,
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;
@@ -1250,7 +1250,7 @@ int librados::IoCtxImpl::get_inconsistent_snapsets(const pg_t& pg,
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;
@@ -1258,7 +1258,7 @@ int librados::IoCtxImpl::get_inconsistent_snapsets(const pg_t& pg,
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;
@@ -1311,10 +1311,10 @@ int librados::IoCtxImpl::aio_exec(const object_t& oid, AioCompletionImpl *c,
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;
@@ -1323,7 +1323,7 @@ int librados::IoCtxImpl::aio_exec(const object_t& oid, AioCompletionImpl *c,
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;
}
@@ -1333,10 +1333,10 @@ int librados::IoCtxImpl::aio_exec(const object_t& oid, AioCompletionImpl *c,
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;
@@ -1349,7 +1349,7 @@ int librados::IoCtxImpl::aio_exec(const object_t& oid, AioCompletionImpl *c,
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;
}