pg_map[pgid] = pg;
pg->get("PGMap"); // because it's in pg_map
service.pg_add_epoch(pg->info.pgid, createmap->get_epoch());
+ wake_pg_waiters(pg, pgid);
}
- wake_pg_waiters(pg, pgid);
return pg;
}
if (con->get_peer_type() != CEPH_ENTITY_TYPE_MON) {
Session *s = static_cast<Session*>(con->get_priv());
if (!s) {
- s = new Session;
+ s = new Session(cct);
con->set_priv(s->get());
s->con = con;
- dout(10) << " new session (outgoing)" << s << " con=" << s->con
+ dout(10) << " new session (outgoing) " << s << " con=" << s->con
<< " addr=" << s->con->get_peer_addr() << dendl;
// we don't connect to clients
assert(con->get_peer_type() == CEPH_ENTITY_TYPE_OSD);