Lines Matching refs:osdmap
1415 peer_addr = &osd->o_osdc->osdmap->osd_addr[osd->o_osd];
1460 &osdc->osdmap->osd_addr[osd->o_osd]);
1519 for (n = rb_first(&osdc->osdmap->pg_pools); n; n = rb_next(n)) {
1534 pi = ceph_pg_pool_by_id(osdc->osdmap, pool_id);
1543 * based on the current osdmap and osd_client settings.
1557 (osdc->osdmap->epoch < osdc->epoch_barrier);
1582 locality = ceph_get_crush_locality(osdc->osdmap,
1623 t->epoch = osdc->osdmap->epoch;
1624 pi = ceph_pg_pool_by_id(osdc->osdmap, t->base_oloc.pool);
1631 if (osdc->osdmap->epoch == pi->last_force_request_resend) {
1649 pi = ceph_pg_pool_by_id(osdc->osdmap, t->target_oloc.pool);
1661 ceph_pg_to_up_acting_osds(osdc->osdmap, pi, &pgid, &up, &acting);
1692 ceph_pg_to_primary_shard(osdc->osdmap, pi, &pgid, &t->spgid);
2181 ceph_encode_32(&p, req->r_osdc->osdmap->epoch);
2379 WARN_ON(!osdc->osdmap->epoch);
2391 osdc->osdmap->epoch + 1, continuous))
2424 } else if (osdc->osdmap->epoch < osdc->epoch_barrier) {
2425 dout("req %p epoch %u barrier %u\n", req, osdc->osdmap->epoch,
2449 pr_warn_ratelimited("cluster is full (osdmap FULL)\n");
2639 if (eb > osdc->osdmap->epoch)
2673 update_epoch_barrier(osdc, osdc->osdmap->epoch);
2700 struct ceph_osdmap *map = osdc->osdmap;
2774 ret = ceph_monc_get_version_async(&osdc->client->monc, "osdmap",
3337 struct ceph_osdmap *map = osdc->osdmap;
3410 ret = ceph_monc_get_version_async(&osdc->client->monc, "osdmap",
3902 for (n = rb_first(&osdc->osdmap->pg_pools); n; n = rb_next(n)) {
3914 pi = ceph_pg_pool_by_id(osdc->osdmap, pool_id);
4039 osdc->osdmap);
4045 if (newmap != osdc->osdmap) {
4056 old_pi = ceph_pg_pool_by_id(osdc->osdmap, pi->id);
4063 if (osdc->osdmap->epoch &&
4064 osdc->osdmap->epoch + 1 < newmap->epoch) {
4069 ceph_osdmap_destroy(osdc->osdmap);
4070 osdc->osdmap = newmap;
4084 if (!ceph_osd_is_up(osdc->osdmap, osd->o_osd) ||
4086 ceph_osd_addr(osdc->osdmap, osd->o_osd),
4109 if (req->r_t.epoch < osdc->osdmap->epoch) {
4165 dout("%s have %u\n", __func__, osdc->osdmap->epoch);
4187 if (osdc->osdmap->epoch &&
4188 osdc->osdmap->epoch + 1 == epoch) {
4217 } else if (osdc->osdmap->epoch >= epoch) {
4220 osdc->osdmap->epoch);
4234 * subscribe to subsequent osdmap updates if full to ensure
4243 osdc->osdmap->epoch < osdc->epoch_barrier)
4250 osdc->osdmap->epoch);
5268 osdc->osdmap = ceph_osdmap_alloc();
5269 if (!osdc->osdmap)
5312 ceph_osdmap_destroy(osdc->osdmap);
5341 ceph_osdmap_destroy(osdc->osdmap);