<< " initial v " << mds->sessionmap.get_version() << dendl;
- int sessions_inserted = 0;
for (map<client_t,entity_inst_t>::iterator p = cm.begin(); p != cm.end(); ++p) {
- sessions_inserted++;
Session *session = mds->sessionmap.get_session(p->second.name);
assert(session);
dout(20) << __func__ << " r=" << r << dendl;
assert(op->may_write());
const osd_reqid_t &reqid = static_cast<const MOSDOp*>(op->get_req())->get_reqid();
- ObjectContextRef obc;
mempool::osd_pglog::list<pg_log_entry_t> entries;
entries.push_back(pg_log_entry_t(pg_log_entry_t::ERROR, soid,
get_next_version(), eversion_t(), 0,
void check_recovery_sources(const OSDMapRef& osdmap) override;
- /// @see PGBackend::delay_message_until_active
bool can_handle_while_inactive(OpRequestRef op) override;
/// @see PGBackend::handle_message
int main(int argc, char **argv) {
po::options_description desc("Allowed options");
- string store_path, cmd, out_path, oid;
+ string store_path, cmd, oid;
bool debug = false;
desc.add_options()
("help", "produce help message")