Lines Matching refs:osd
1105 * osd map
1459 u32 osd;
1461 ceph_decode_32_safe(p, end, osd, e_inval);
1462 if (osd == (u32)-1 && incremental)
1469 pg->primary_temp.osd = osd;
1489 u32 ceph_get_primary_affinity(struct ceph_osdmap *map, int osd)
1491 BUG_ON(osd >= map->max_osd);
1496 return map->osd_primary_affinity[osd];
1499 static int set_primary_affinity(struct ceph_osdmap *map, int osd, u32 aff)
1501 BUG_ON(osd >= map->max_osd);
1517 map->osd_primary_affinity[osd] = aff;
1559 u32 osd, aff;
1562 ceph_decode_32_safe(p, end, osd, e_inval);
1565 ret = set_primary_affinity(map, osd, aff);
1569 pr_info("osd%d primary-affinity 0x%x\n", osd, aff);
1690 /* (re)alloc osd arrays */
1816 * new_up_client: { osd=6, addr=... } # set osd_state and addr
1817 * new_state: { osd=6, xorstate=EXISTS } # clear osd_state
1847 s32 osd;
1851 osd = ceph_decode_32(p);
1853 BUG_ON(osd >= map->max_osd);
1854 pr_info("osd%d weight 0x%x %s\n", osd, w,
1857 map->osd_weight[osd] = w;
1864 map->osd_state[osd] |= CEPH_OSD_EXISTS;
1865 map->osd_state[osd] &= ~(CEPH_OSD_AUTOOUT |
1875 s32 osd;
1879 osd = ceph_decode_32(p);
1886 BUG_ON(osd >= map->max_osd);
1887 if ((map->osd_state[osd] & CEPH_OSD_UP) &&
1889 pr_info("osd%d down\n", osd);
1890 if ((map->osd_state[osd] & CEPH_OSD_EXISTS) &&
1892 pr_info("osd%d does not exist\n", osd);
1893 ret = set_primary_affinity(map, osd,
1897 memset(map->osd_addr + osd, 0, sizeof(*map->osd_addr));
1898 map->osd_state[osd] = 0;
1900 map->osd_state[osd] ^= xorstate;
1908 s32 osd;
1911 osd = ceph_decode_32(p);
1912 BUG_ON(osd >= map->max_osd);
1915 pr_info("osd%d up\n", osd);
1916 map->osd_state[osd] |= CEPH_OSD_EXISTS | CEPH_OSD_UP;
1917 map->osd_addr[osd] = addr;
2308 static int calc_pg_rank(int osd, const struct ceph_osds *acting)
2313 if (acting->osds[i] == osd)
2568 int osd = pg->pg_upmap.osds[i];
2570 if (osd != CRUSH_ITEM_NONE &&
2571 osd < osdmap->max_osd &&
2572 osdmap->osd_weight[osd] == 0) {
2597 int osd = raw->osds[j];
2599 if (osd == to) {
2604 if (osd == from && pos < 0 &&
2675 int osd = up->osds[i];
2677 if (osd != CRUSH_ITEM_NONE &&
2678 osdmap->osd_primary_affinity[osd] !=
2688 * osd into the hash/rng so that a proportional fraction of an
2689 * osd's pgs get rejected as primary.
2692 int osd = up->osds[i];
2695 if (osd == CRUSH_ITEM_NONE)
2698 aff = osdmap->osd_primary_affinity[osd];
2701 pps, osd) >> 16) >= aff) {
2771 temp->primary = pg->primary_temp.osd;