pair<TestOp*, TestOp::CallbackInfo*> *cb_arg =
new pair<TestOp*, TestOp::CallbackInfo*>(this,
new TestOp::CallbackInfo(0));
- comp = context->rados.aio_create_completion((void*) cb_arg, NULL,
+ comp = context->rados.aio_create_completion((void*) cb_arg,
&write_callback);
context->io_ctx.aio_operate(context->prefix+oid, comp, &op);
}
pair<TestOp*, TestOp::CallbackInfo*> *cb_arg =
new pair<TestOp*, TestOp::CallbackInfo*>(this,
new TestOp::CallbackInfo(0));
- comp = context->rados.aio_create_completion((void*) cb_arg, NULL,
- &write_callback);
+ comp = context->rados.aio_create_completion((void*) cb_arg, &write_callback);
context->io_ctx.aio_operate(context->prefix+oid, comp, &op);
}
new pair<TestOp*, TestOp::CallbackInfo*>(this,
new TestOp::CallbackInfo(tid));
librados::AioCompletion *completion =
- context->rados.aio_create_completion((void*) cb_arg, NULL,
- &write_callback);
+ context->rados.aio_create_completion((void*) cb_arg, &write_callback);
waiting.insert(completion);
librados::ObjectWriteOperation op;
if (do_append) {
this,
new TestOp::CallbackInfo(++tid));
librados::AioCompletion *completion = context->rados.aio_create_completion(
- (void*) cb_arg, NULL, &write_callback);
+ (void*) cb_arg, &write_callback);
waiting.insert(completion);
waiting_on++;
write_op.setxattr("_header", contbl);
this,
new TestOp::CallbackInfo(++tid));
rcompletion = context->rados.aio_create_completion(
- (void*) cb_arg, NULL, &write_callback);
+ (void*) cb_arg, &write_callback);
waiting_on++;
read_op.read(0, 1, &rbuffer, 0);
context->io_ctx.aio_operate(
new pair<TestOp*, TestOp::CallbackInfo*>(this,
new TestOp::CallbackInfo(tid));
librados::AioCompletion *completion =
- context->rados.aio_create_completion((void*) cb_arg, NULL,
+ context->rados.aio_create_completion((void*) cb_arg,
&write_callback);
waiting.insert(completion);
librados::ObjectWriteOperation op;
this,
new TestOp::CallbackInfo(++tid));
librados::AioCompletion *completion = context->rados.aio_create_completion(
- (void*) cb_arg, NULL, &write_callback);
+ (void*) cb_arg, &write_callback);
waiting.insert(completion);
waiting_on++;
write_op.setxattr("_header", contbl);
this,
new TestOp::CallbackInfo(++tid));
rcompletion = context->rados.aio_create_completion(
- (void*) cb_arg, NULL, &write_callback);
+ (void*) cb_arg, &write_callback);
waiting_on++;
read_op.read(0, 1, &rbuffer, 0);
context->io_ctx.aio_operate(
std::cout << num << ": read oid " << oid << " snap " << snap << std::endl;
done = 0;
for (uint32_t i = 0; i < 3; i++) {
- completions[i] = context->rados.aio_create_completion((void *) this, &read_callback, 0);
+ completions[i] = context->rados.aio_create_completion((void *) this, &read_callback);
}
context->oid_in_use.insert(oid);
new pair<TestOp*, TestOp::CallbackInfo*>(this,
new TestOp::CallbackInfo(0));
comps[0] =
- context->rados.aio_create_completion((void*) cb_arg, NULL,
+ context->rados.aio_create_completion((void*) cb_arg,
&write_callback);
context->io_ctx.aio_operate(
context->prefix+oid, comps[0], &zero_write_op1);
new pair<TestOp*, TestOp::CallbackInfo*>(this,
new TestOp::CallbackInfo(1));
comps[1] =
- context->rados.aio_create_completion((void*) cb_arg, NULL,
+ context->rados.aio_create_completion((void*) cb_arg,
&write_callback);
context->io_ctx.aio_operate(
context->prefix+oid, comps[1], &op);
new pair<TestOp*, TestOp::CallbackInfo*>(this,
new TestOp::CallbackInfo(2));
comps[2] =
- context->rados.aio_create_completion((void*) cb_arg, NULL,
+ context->rados.aio_create_completion((void*) cb_arg,
&write_callback);
context->io_ctx.aio_operate(
context->prefix+oid, comps[2], &zero_write_op2);
pair<TestOp*, TestOp::CallbackInfo*> *cb_arg =
new pair<TestOp*, TestOp::CallbackInfo*>(this,
new TestOp::CallbackInfo(0));
- comp = context->rados.aio_create_completion((void*) cb_arg, NULL,
+ comp = context->rados.aio_create_completion((void*) cb_arg,
&write_callback);
context->io_ctx.aio_operate(context->prefix+oid, comp, &op);
pair<TestOp*, TestOp::CallbackInfo*> *read_cb_arg =
new pair<TestOp*, TestOp::CallbackInfo*>(this,
new TestOp::CallbackInfo(1));
- comp_racing_read = context->rados.aio_create_completion((void*) read_cb_arg, NULL, &write_callback);
+ comp_racing_read = context->rados.aio_create_completion((void*) read_cb_arg, &write_callback);
rd_op.stat(NULL, NULL, NULL);
context->io_ctx.aio_operate(context->prefix+oid, comp_racing_read, &rd_op,
librados::OPERATION_ORDER_READS_WRITES, // order wrt previous write/update
std::cout << num << ": chunk read oid " << oid << " snap " << snap << std::endl;
done = 0;
for (uint32_t i = 0; i < 2; i++) {
- completions[i] = context->rados.aio_create_completion((void *) this, &read_callback, 0);
+ completions[i] = context->rados.aio_create_completion((void *) this, &read_callback);
}
context->find_object(oid, &old_value);
pair<TestOp*, TestOp::CallbackInfo*> *cb_arg =
new pair<TestOp*, TestOp::CallbackInfo*>(this,
new TestOp::CallbackInfo(0));
- comp = context->rados.aio_create_completion((void*) cb_arg, NULL,
- &write_callback);
+ comp = context->rados.aio_create_completion((void*) cb_arg, &write_callback);
if (tgt_pool_name == context->low_tier_pool_name) {
context->low_tier_io_ctx.aio_operate(context->prefix+oid, comp, &op);
} else {
pair<TestOp*, TestOp::CallbackInfo*> *cb_arg =
new pair<TestOp*, TestOp::CallbackInfo*>(this,
new TestOp::CallbackInfo(0));
- comp = context->rados.aio_create_completion((void*) cb_arg, NULL,
+ comp = context->rados.aio_create_completion((void*) cb_arg,
&write_callback);
context->io_ctx.aio_operate(context->prefix+oid, comp, &op,
librados::OPERATION_ORDER_READS_WRITES);
pair<TestOp*, TestOp::CallbackInfo*> *cb_arg =
new pair<TestOp*, TestOp::CallbackInfo*>(this,
new TestOp::CallbackInfo(0));
- comp = context->rados.aio_create_completion((void*) cb_arg, NULL,
- &write_callback);
+ comp = context->rados.aio_create_completion((void*) cb_arg, &write_callback);
context->io_ctx.aio_operate(context->prefix+oid, comp, &op,
librados::OPERATION_ORDER_READS_WRITES);
}
pair<TestOp*, TestOp::CallbackInfo*> *cb_arg =
new pair<TestOp*, TestOp::CallbackInfo*>(this,
new TestOp::CallbackInfo(0));
- completion = context->rados.aio_create_completion((void *) cb_arg, NULL,
+ completion = context->rados.aio_create_completion((void *) cb_arg,
&write_callback);
context->state_lock.unlock();
pair<TestOp*, TestOp::CallbackInfo*> *cb_arg =
new pair<TestOp*, TestOp::CallbackInfo*>(this,
new TestOp::CallbackInfo(0));
- completion = context->rados.aio_create_completion((void *) cb_arg, NULL,
+ completion = context->rados.aio_create_completion((void *) cb_arg,
&write_callback);
context->state_lock.unlock();
pair<TestOp*, TestOp::CallbackInfo*> *cb_arg =
new pair<TestOp*, TestOp::CallbackInfo*>(this,
new TestOp::CallbackInfo(0));
- comp1 = context->rados.aio_create_completion((void*) cb_arg, NULL,
+ comp1 = context->rados.aio_create_completion((void*) cb_arg,
&write_callback);
int r = context->io_ctx.hit_set_list(hash, comp1, &ls);
ceph_assert(r == 0);
pair<TestOp*, TestOp::CallbackInfo*> *cb_arg =
new pair<TestOp*, TestOp::CallbackInfo*>(this,
new TestOp::CallbackInfo(0));
- comp2 = context->rados.aio_create_completion((void*) cb_arg, NULL,
- &write_callback);
+ comp2 = context->rados.aio_create_completion((void*) cb_arg, &write_callback);
r = context->io_ctx.hit_set_get(hash, comp2, p->second, &bl);
ceph_assert(r == 0);
}
pair<TestOp*, TestOp::CallbackInfo*> *cb_arg =
new pair<TestOp*, TestOp::CallbackInfo*>(this,
new TestOp::CallbackInfo(0));
- completion = context->rados.aio_create_completion((void *) cb_arg, NULL,
+ completion = context->rados.aio_create_completion((void *) cb_arg,
&write_callback);
context->oid_in_use.insert(oid);
pair<TestOp*, TestOp::CallbackInfo*> *cb_arg =
new pair<TestOp*, TestOp::CallbackInfo*>(this,
new TestOp::CallbackInfo(0));
- completion = context->rados.aio_create_completion((void *) cb_arg, NULL,
+ completion = context->rados.aio_create_completion((void *) cb_arg,
&write_callback);
context->oid_in_use.insert(oid);
pair<TestOp*, TestOp::CallbackInfo*> *cb_arg =
new pair<TestOp*, TestOp::CallbackInfo*>(this,
new TestOp::CallbackInfo(0));
- completion = context->rados.aio_create_completion((void *) cb_arg, NULL,
+ completion = context->rados.aio_create_completion((void *) cb_arg,
&write_callback);
context->oid_flushing.insert(oid);
context->oid_not_flushing.erase(oid);
pair<TestOp*, TestOp::CallbackInfo*> *cb_arg =
new pair<TestOp*, TestOp::CallbackInfo*>(this,
new TestOp::CallbackInfo(0));
- completion = context->rados.aio_create_completion((void *) cb_arg, NULL,
+ completion = context->rados.aio_create_completion((void *) cb_arg,
&write_callback);
context->state_lock.unlock();