Lines Matching full:osd
1105 * osd map
1459 u32 osd; in __decode_primary_temp() local
1461 ceph_decode_32_safe(p, end, osd, e_inval); in __decode_primary_temp()
1462 if (osd == (u32)-1 && incremental) in __decode_primary_temp()
1469 pg->primary_temp.osd = osd; in __decode_primary_temp()
1489 u32 ceph_get_primary_affinity(struct ceph_osdmap *map, int osd) in ceph_get_primary_affinity() argument
1491 BUG_ON(osd >= map->max_osd); in ceph_get_primary_affinity()
1496 return map->osd_primary_affinity[osd]; in ceph_get_primary_affinity()
1499 static int set_primary_affinity(struct ceph_osdmap *map, int osd, u32 aff) in set_primary_affinity() argument
1501 BUG_ON(osd >= map->max_osd); in set_primary_affinity()
1517 map->osd_primary_affinity[osd] = aff; in set_primary_affinity()
1559 u32 osd, aff; in decode_new_primary_affinity() local
1562 ceph_decode_32_safe(p, end, osd, e_inval); in decode_new_primary_affinity()
1565 ret = set_primary_affinity(map, osd, aff); in decode_new_primary_affinity()
1569 pr_info("osd%d primary-affinity 0x%x\n", osd, aff); in decode_new_primary_affinity()
1691 /* (re)alloc osd arrays */ in osdmap_decode()
1731 dout("%s osd%d addr %s\n", __func__, i, ceph_pr_addr(addr)); in osdmap_decode()
1824 * new_up_client: { osd=6, addr=... } # set osd_state and addr
1825 * new_state: { osd=6, xorstate=EXISTS } # clear osd_state
1860 s32 osd; in decode_new_up_state_weight() local
1864 osd = ceph_decode_32(p); in decode_new_up_state_weight()
1866 BUG_ON(osd >= map->max_osd); in decode_new_up_state_weight()
1867 pr_info("osd%d weight 0x%x %s\n", osd, w, in decode_new_up_state_weight()
1870 map->osd_weight[osd] = w; in decode_new_up_state_weight()
1877 map->osd_state[osd] |= CEPH_OSD_EXISTS; in decode_new_up_state_weight()
1878 map->osd_state[osd] &= ~(CEPH_OSD_AUTOOUT | in decode_new_up_state_weight()
1888 s32 osd; in decode_new_up_state_weight() local
1891 osd = ceph_decode_32(p); in decode_new_up_state_weight()
1898 BUG_ON(osd >= map->max_osd); in decode_new_up_state_weight()
1899 if ((map->osd_state[osd] & CEPH_OSD_UP) && in decode_new_up_state_weight()
1901 pr_info("osd%d down\n", osd); in decode_new_up_state_weight()
1902 if ((map->osd_state[osd] & CEPH_OSD_EXISTS) && in decode_new_up_state_weight()
1904 pr_info("osd%d does not exist\n", osd); in decode_new_up_state_weight()
1905 ret = set_primary_affinity(map, osd, in decode_new_up_state_weight()
1909 memset(map->osd_addr + osd, 0, sizeof(*map->osd_addr)); in decode_new_up_state_weight()
1910 map->osd_state[osd] = 0; in decode_new_up_state_weight()
1912 map->osd_state[osd] ^= xorstate; in decode_new_up_state_weight()
1920 s32 osd; in decode_new_up_state_weight() local
1923 osd = ceph_decode_32(p); in decode_new_up_state_weight()
1924 BUG_ON(osd >= map->max_osd); in decode_new_up_state_weight()
1932 dout("%s osd%d addr %s\n", __func__, osd, ceph_pr_addr(&addr)); in decode_new_up_state_weight()
1934 pr_info("osd%d up\n", osd); in decode_new_up_state_weight()
1935 map->osd_state[osd] |= CEPH_OSD_EXISTS | CEPH_OSD_UP; in decode_new_up_state_weight()
1936 map->osd_addr[osd] = addr; in decode_new_up_state_weight()
2327 static int calc_pg_rank(int osd, const struct ceph_osds *acting) in calc_pg_rank() argument
2332 if (acting->osds[i] == osd) in calc_pg_rank()
2587 int osd = pg->pg_upmap.osds[i]; in apply_upmap() local
2589 if (osd != CRUSH_ITEM_NONE && in apply_upmap()
2590 osd < osdmap->max_osd && in apply_upmap()
2591 osdmap->osd_weight[osd] == 0) { in apply_upmap()
2616 int osd = raw->osds[j]; in apply_upmap() local
2618 if (osd == to) { in apply_upmap()
2623 if (osd == from && pos < 0 && in apply_upmap()
2694 int osd = up->osds[i]; in apply_primary_affinity() local
2696 if (osd != CRUSH_ITEM_NONE && in apply_primary_affinity()
2697 osdmap->osd_primary_affinity[osd] != in apply_primary_affinity()
2707 * osd into the hash/rng so that a proportional fraction of an in apply_primary_affinity()
2708 * osd's pgs get rejected as primary. in apply_primary_affinity()
2711 int osd = up->osds[i]; in apply_primary_affinity() local
2714 if (osd == CRUSH_ITEM_NONE) in apply_primary_affinity()
2717 aff = osdmap->osd_primary_affinity[osd]; in apply_primary_affinity()
2720 pps, osd) >> 16) >= aff) { in apply_primary_affinity()
2751 * always a valid OSD set on return: in the "only primary_temp" case,
2790 temp->primary = pg->primary_temp.osd; in get_temp_osds()
3068 * for an OSD is 1 (i.e. a matching host). Locality 0 would be
3069 * the OSD itself.