object_number);
ldout(m_cct, 20) << "removing journal object " << oid << dendl;
- librados::AioCompletion *comp =
- librados::Rados::aio_create_completion(ctx, NULL,
- utils::rados_ctx_callback);
+ auto comp =
+ librados::Rados::aio_create_completion(ctx, utils::rados_ctx_callback);
int r = m_ioctx.aio_remove(oid, comp,
CEPH_OSD_FLAG_FULL_FORCE | CEPH_OSD_FLAG_FULL_TRY);
ceph_assert(r == 0);
op.read(m_read_off, m_max_fetch_bytes, &context->read_bl, NULL);
op.set_op_flags2(CEPH_OSD_OP_FLAG_FADVISE_DONTNEED);
- librados::AioCompletion *rados_completion =
- librados::Rados::aio_create_completion(context, utils::rados_ctx_callback,
- NULL);
+ auto rados_completion =
+ librados::Rados::aio_create_completion(context, utils::rados_ctx_callback);
int r = m_ioctx.aio_operate(m_oid, rados_completion, &op, 0, NULL);
ceph_assert(r == 0);
rados_completion->release();
}
auto rados_completion = librados::Rados::aio_create_completion(
- new C_AppendFlush(this, append_tid), nullptr, utils::rados_ctx_callback);
+ new C_AppendFlush(this, append_tid), utils::rados_ctx_callback);
int r = m_ioctx.aio_operate(m_oid, rados_completion, &op);
ceph_assert(r == 0);
rados_completion->release();