709 	struct ceph_pg_mapping *pg;  in alloc_pg_mapping()  local
711 	pg = kmalloc(sizeof(*pg) + payload_len, GFP_NOIO);  in alloc_pg_mapping()
712 	if (!pg)  in alloc_pg_mapping()
715 	RB_CLEAR_NODE(&pg->node);  in alloc_pg_mapping()
716 	return pg;  in alloc_pg_mapping()
719 static void free_pg_mapping(struct ceph_pg_mapping *pg)  in free_pg_mapping()  argument
721 	WARN_ON(!RB_EMPTY_NODE(&pg->node));  in free_pg_mapping()
723 	kfree(pg);  in free_pg_mapping()
1140 		struct ceph_pg_mapping *pg =  in ceph_osdmap_destroy()  local
1143 		erase_pg_mapping(&map->pg_temp, pg);  in ceph_osdmap_destroy()
1144 		free_pg_mapping(pg);  in ceph_osdmap_destroy()
1147 		struct ceph_pg_mapping *pg =  in ceph_osdmap_destroy()  local
1150 		erase_pg_mapping(&map->primary_temp, pg);  in ceph_osdmap_destroy()
1151 		free_pg_mapping(pg);  in ceph_osdmap_destroy()
1154 		struct ceph_pg_mapping *pg =  in ceph_osdmap_destroy()  local
1157 		rb_erase(&pg->node, &map->pg_upmap);  in ceph_osdmap_destroy()
1158 		kfree(pg);  in ceph_osdmap_destroy()
1161 		struct ceph_pg_mapping *pg =  in ceph_osdmap_destroy()  local
1164 		rb_erase(&pg->node, &map->pg_upmap_items);  in ceph_osdmap_destroy()
1165 		kfree(pg);  in ceph_osdmap_destroy()
1387 		struct ceph_pg_mapping *pg;  in decode_pg_mapping()  local
1395 		pg = lookup_pg_mapping(mapping_root, &pgid);  in decode_pg_mapping()
1396 		if (pg) {  in decode_pg_mapping()
1398 			erase_pg_mapping(mapping_root, pg);  in decode_pg_mapping()
1399 			free_pg_mapping(pg);  in decode_pg_mapping()
1403 			pg = fn(p, end, incremental);  in decode_pg_mapping()
1404 			if (IS_ERR(pg))  in decode_pg_mapping()
1405 				return PTR_ERR(pg);  in decode_pg_mapping()
1407 			if (pg) {  in decode_pg_mapping()
1408 				pg->pgid = pgid; /* struct */  in decode_pg_mapping()
1409 				insert_pg_mapping(mapping_root, pg);  in decode_pg_mapping()
1423 	struct ceph_pg_mapping *pg;  in __decode_pg_temp()  local
1429 	if ((size_t)len > (SIZE_MAX - sizeof(*pg)) / sizeof(u32))  in __decode_pg_temp()
1433 	pg = alloc_pg_mapping(len * sizeof(u32));  in __decode_pg_temp()
1434 	if (!pg)  in __decode_pg_temp()
1437 	pg->pg_temp.len = len;  in __decode_pg_temp()
1439 		pg->pg_temp.osds[i] = ceph_decode_32(p);  in __decode_pg_temp()
1441 	return pg;  in __decode_pg_temp()
1462 	struct ceph_pg_mapping *pg;  in __decode_primary_temp()  local
1469 	pg = alloc_pg_mapping(0);  in __decode_primary_temp()
1470 	if (!pg)  in __decode_primary_temp()
1473 	pg->primary_temp.osd = osd;  in __decode_primary_temp()
1474 	return pg;  in __decode_primary_temp()
1606 	struct ceph_pg_mapping *pg;  in __decode_pg_upmap_items()  local
1610 	if ((size_t)len > (SIZE_MAX - sizeof(*pg)) / (2 * sizeof(u32)))  in __decode_pg_upmap_items()
1614 	pg = alloc_pg_mapping(2 * len * sizeof(u32));  in __decode_pg_upmap_items()
1615 	if (!pg)  in __decode_pg_upmap_items()
1618 	pg->pg_upmap_items.len = len;  in __decode_pg_upmap_items()
1620 		pg->pg_upmap_items.from_to[i][0] = ceph_decode_32(p);  in __decode_pg_upmap_items()
1621 		pg->pg_upmap_items.from_to[i][1] = ceph_decode_32(p);  in __decode_pg_upmap_items()
1624 	return pg;  in __decode_pg_upmap_items()
2588 	struct ceph_pg_mapping *pg;  in apply_upmap()  local
2591 	pg = lookup_pg_mapping(&osdmap->pg_upmap, pgid);  in apply_upmap()
2592 	if (pg) {  in apply_upmap()
2594 		for (i = 0; i < pg->pg_upmap.len; i++) {  in apply_upmap()
2595 			int osd = pg->pg_upmap.osds[i];  in apply_upmap()
2604 		for (i = 0; i < pg->pg_upmap.len; i++)  in apply_upmap()
2605 			raw->osds[i] = pg->pg_upmap.osds[i];  in apply_upmap()
2606 		raw->size = pg->pg_upmap.len;  in apply_upmap()
2610 	pg = lookup_pg_mapping(&osdmap->pg_upmap_items, pgid);  in apply_upmap()
2611 	if (pg) {  in apply_upmap()
2616 		for (i = 0; i < pg->pg_upmap_items.len; i++) {  in apply_upmap()
2617 			int from = pg->pg_upmap_items.from_to[i][0];  in apply_upmap()
2618 			int to = pg->pg_upmap_items.from_to[i][1];  in apply_upmap()
2767 	struct ceph_pg_mapping *pg;  in get_temp_osds()  local
2773 	pg = lookup_pg_mapping(&osdmap->pg_temp, pgid);  in get_temp_osds()
2774 	if (pg) {  in get_temp_osds()
2775 		for (i = 0; i < pg->pg_temp.len; i++) {  in get_temp_osds()
2776 			if (ceph_osd_is_down(osdmap, pg->pg_temp.osds[i])) {  in get_temp_osds()
2782 				temp->osds[temp->size++] = pg->pg_temp.osds[i];  in get_temp_osds()
2796 	pg = lookup_pg_mapping(&osdmap->primary_temp, pgid);  in get_temp_osds()
2797 	if (pg)  in get_temp_osds()
2798 		temp->primary = pg->primary_temp.osd;  in get_temp_osds()