int use_mds,
bufferlist *pdirbl)
{
- // time the call
- utime_t start = ceph_clock_now(cct);
-
- bool nojournal = false;
- int op = request->get_op();
- if (op == CEPH_MDS_OP_GETATTR ||
- op == CEPH_MDS_OP_READDIR ||
- op == CEPH_MDS_OP_OPEN)
- nojournal = true;
-
// assign a unique tid
tid_t tid = ++last_tid;
request->set_tid(tid);
void Client::handle_mds_map(MMDSMap* m)
{
- int frommds = -1;
- if (m->get_source().is_mds())
- frommds = m->get_source().num();
-
if (m->get_epoch() < mdsmap->get_epoch()) {
ldout(cct, 1) << "handle_mds_map epoch " << m->get_epoch() << " is older than our "
<< mdsmap->get_epoch() << dendl;
m->get_time_warp_seq(), m->get_ctime(), m->get_mtime(), m->get_atime(), issued);
// max_size
- bool kick_writers = false;
if (cap == in->auth_cap &&
m->get_max_size() != in->max_size) {
ldout(cct, 10) << "max_size " << in->max_size << " -> " << m->get_max_size() << dendl;
in->wanted_max_size = 0;
in->requested_max_size = 0;
}
- kick_writers = true;
}
check_cap_issue(in, cap, issued);
<< "Min latency: " << data->min_latency << std::endl;
//write object size/number data for read benchmarks
- int written_objects[2];
- written_objects[0] = data->object_size;
- written_objects[1] = data->finished;
::encode(data->object_size, b_write);
::encode(data->finished, b_write);
::encode(getpid(), b_write);
void LoadGen::run_op(LoadGenOp *op)
{
op->completion = rados->aio_create_completion(op, _load_gen_cb, NULL);
- int ret;
switch (op->type) {
case OP_READ:
- ret = io_ctx.aio_read(op->oid, op->completion, &op->bl, op->len, op->off);
+ io_ctx.aio_read(op->oid, op->completion, &op->bl, op->len, op->off);
break;
case OP_WRITE:
bufferptr p = buffer::create(op->len);
memset(p.c_str(), 0, op->len);
op->bl.push_back(p);
- ret = io_ctx.aio_write(op->oid, op->completion, op->bl, op->len, op->off);
+ io_ctx.aio_write(op->oid, op->completion, op->bl, op->len, op->off);
break;
}