Lines Matching refs:osdmap

1339 	peer_addr = &osd->o_osdc->osdmap->osd_addr[osd->o_osd];  in reopen_osd()
1384 &osdc->osdmap->osd_addr[osd->o_osd]); in lookup_create_osd()
1439 for (n = rb_first(&osdc->osdmap->pg_pools); n; n = rb_next(n)) { in have_pool_full()
1454 pi = ceph_pg_pool_by_id(osdc->osdmap, pool_id); in pool_full()
1477 (osdc->osdmap->epoch < osdc->epoch_barrier); in target_should_be_paused()
1502 locality = ceph_get_crush_locality(osdc->osdmap, in pick_closest_replica()
1543 t->epoch = osdc->osdmap->epoch; in calc_target()
1544 pi = ceph_pg_pool_by_id(osdc->osdmap, t->base_oloc.pool); in calc_target()
1551 if (osdc->osdmap->epoch == pi->last_force_request_resend) { in calc_target()
1569 pi = ceph_pg_pool_by_id(osdc->osdmap, t->target_oloc.pool); in calc_target()
1581 ceph_pg_to_up_acting_osds(osdc->osdmap, pi, &pgid, &up, &acting); in calc_target()
1612 ceph_pg_to_primary_shard(osdc->osdmap, pi, &pgid, &t->spgid); in calc_target()
2100 ceph_encode_32(&p, req->r_osdc->osdmap->epoch); in encode_request_partial()
2298 WARN_ON(!osdc->osdmap->epoch); in maybe_request_map()
2310 osdc->osdmap->epoch + 1, continuous)) in maybe_request_map()
2343 } else if (osdc->osdmap->epoch < osdc->epoch_barrier) { in __submit_request()
2344 dout("req %p epoch %u barrier %u\n", req, osdc->osdmap->epoch, in __submit_request()
2552 if (eb > osdc->osdmap->epoch) in update_epoch_barrier()
2586 update_epoch_barrier(osdc, osdc->osdmap->epoch); in abort_on_full_fn()
2613 struct ceph_osdmap *map = osdc->osdmap; in check_pool_dne()
3250 struct ceph_osdmap *map = osdc->osdmap; in check_linger_pool_dne()
3807 for (n = rb_first(&osdc->osdmap->pg_pools); n; n = rb_next(n)) { in set_pool_was_full()
3819 pi = ceph_pg_pool_by_id(osdc->osdmap, pool_id); in pool_cleared_full()
3942 newmap = osdmap_apply_incremental(&p, end, osdc->osdmap); in handle_one_map()
3948 if (newmap != osdc->osdmap) { in handle_one_map()
3959 old_pi = ceph_pg_pool_by_id(osdc->osdmap, pi->id); in handle_one_map()
3966 if (osdc->osdmap->epoch && in handle_one_map()
3967 osdc->osdmap->epoch + 1 < newmap->epoch) { in handle_one_map()
3972 ceph_osdmap_destroy(osdc->osdmap); in handle_one_map()
3973 osdc->osdmap = newmap; in handle_one_map()
3987 if (!ceph_osd_is_up(osdc->osdmap, osd->o_osd) || in handle_one_map()
3989 ceph_osd_addr(osdc->osdmap, osd->o_osd), in handle_one_map()
4012 if (req->r_t.epoch < osdc->osdmap->epoch) { in kick_requests()
4068 dout("%s have %u\n", __func__, osdc->osdmap->epoch); in ceph_osdc_handle_map()
4090 if (osdc->osdmap->epoch && in ceph_osdc_handle_map()
4091 osdc->osdmap->epoch + 1 == epoch) { in ceph_osdc_handle_map()
4120 } else if (osdc->osdmap->epoch >= epoch) { in ceph_osdc_handle_map()
4123 osdc->osdmap->epoch); in ceph_osdc_handle_map()
4146 osdc->osdmap->epoch < osdc->epoch_barrier) in ceph_osdc_handle_map()
4153 osdc->osdmap->epoch); in ceph_osdc_handle_map()
5168 osdc->osdmap = ceph_osdmap_alloc(); in ceph_osdc_init()
5169 if (!osdc->osdmap) in ceph_osdc_init()
5212 ceph_osdmap_destroy(osdc->osdmap); in ceph_osdc_init()
5241 ceph_osdmap_destroy(osdc->osdmap); in ceph_osdc_stop()