pgbackend->get_is_readable_predicate(),
pgbackend->get_is_recoverable_predicate());
snap_trimmer_machine.initiate();
- repop_map.rehash(g_conf->osd_client_message_cap/_pool.info.get_pg_num() * g_conf->osd_pg_op_threshold_ratio);
}
void ReplicatedPG::get_src_oloc(const object_t& oid, const object_locator_t& oloc, object_locator_t& src_oloc)
repop->start = ceph_clock_now(cct);
repop_queue.push_back(&repop->queue_item);
- repop_map[repop->rep_tid] = repop;
repop->get();
osd->logger->inc(l_osd_op_wip);
dout(20) << " snapset_obc " << *repop->ctx->snapset_obc << dendl;
release_op_ctx_locks(repop->ctx);
repop->ctx->finish(0); // FIXME: return value here is sloppy
- repop_map.erase(repop->rep_tid);
repop->put();
osd->logger->dec(l_osd_op_wip);
remove_repop(repop);
}
- assert(repop_map.empty());
assert(repop_queue.empty());
if (requeue) {
// replica ops
// [primary|tail]
xlist<RepGather*> repop_queue;
- ceph::unordered_map<ceph_tid_t, RepGather*> repop_map;
friend class C_OSD_RepopApplied;
friend class C_OSD_RepopCommit;