55 static int crush_decode_uniform_bucket(void **p, void *end,  in crush_decode_uniform_bucket()  argument
58 	dout("crush_decode_uniform_bucket %p to %p\n", *p, end);  in crush_decode_uniform_bucket()
59 	ceph_decode_need(p, end, (1+b->h.size) * sizeof(u32), bad);  in crush_decode_uniform_bucket()
66 static int crush_decode_list_bucket(void **p, void *end,  in crush_decode_list_bucket()  argument
70 	dout("crush_decode_list_bucket %p to %p\n", *p, end);  in crush_decode_list_bucket()
77 	ceph_decode_need(p, end, 2 * b->h.size * sizeof(u32), bad);  in crush_decode_list_bucket()
87 static int crush_decode_tree_bucket(void **p, void *end,  in crush_decode_tree_bucket()  argument
91 	dout("crush_decode_tree_bucket %p to %p\n", *p, end);  in crush_decode_tree_bucket()
92 	ceph_decode_8_safe(p, end, b->num_nodes, bad);  in crush_decode_tree_bucket()
96 	ceph_decode_need(p, end, b->num_nodes * sizeof(u32), bad);  in crush_decode_tree_bucket()
104 static int crush_decode_straw_bucket(void **p, void *end,  in crush_decode_straw_bucket()  argument
108 	dout("crush_decode_straw_bucket %p to %p\n", *p, end);  in crush_decode_straw_bucket()
115 	ceph_decode_need(p, end, 2 * b->h.size * sizeof(u32), bad);  in crush_decode_straw_bucket()
125 static int crush_decode_straw2_bucket(void **p, void *end,  in crush_decode_straw2_bucket()  argument
129 	dout("crush_decode_straw2_bucket %p to %p\n", *p, end);  in crush_decode_straw2_bucket()
133 	ceph_decode_need(p, end, b->h.size * sizeof(u32), bad);  in crush_decode_straw2_bucket()
188 static u32 *decode_array_32_alloc(void **p, void *end, u32 *plen)  in decode_array_32_alloc()  argument
194 	ceph_decode_32_safe(p, end, len, e_inval);  in decode_array_32_alloc()
204 		ceph_decode_need(p, end, len * sizeof(u32), e_inval);  in decode_array_32_alloc()
222 static int decode_choose_arg(void **p, void *end, struct crush_choose_arg *arg)  in decode_choose_arg()  argument
226 	ceph_decode_32_safe(p, end, arg->weight_set_size, e_inval);  in decode_choose_arg()
239 			w->weights = decode_array_32_alloc(p, end, &w->size);  in decode_choose_arg()
248 	arg->ids = decode_array_32_alloc(p, end, &arg->ids_size);  in decode_choose_arg()
261 static int decode_choose_args(void **p, void *end, struct crush_map *c)  in decode_choose_args()  argument
267 	ceph_decode_32_safe(p, end, num_choose_arg_maps, e_inval);  in decode_choose_args()
275 		ceph_decode_64_safe(p, end, arg_map->choose_args_index,  in decode_choose_args()
285 		ceph_decode_32_safe(p, end, num_buckets, e_inval);  in decode_choose_args()
290 			ceph_decode_32_safe(p, end, bucket_index, e_inval);  in decode_choose_args()
295 			ret = decode_choose_arg(p, end, arg);  in decode_choose_args()
342 static struct crush_map *crush_decode(void *pbyval, void *end)  in crush_decode()  argument
351 	dout("crush_decode %p to %p len %d\n", *p, end, (int)(end - *p));  in crush_decode()
365 	ceph_decode_need(p, end, 4*sizeof(u32), bad);  in crush_decode()
389 		ceph_decode_32_safe(p, end, alg, bad);  in crush_decode()
395 		     i, (int)(*p-start), *p, end);  in crush_decode()
421 		ceph_decode_need(p, end, 4*sizeof(u32), bad);  in crush_decode()
430 		     b->size, (int)(*p-start), *p, end);  in crush_decode()
436 		ceph_decode_need(p, end, b->size*sizeof(u32), bad);  in crush_decode()
442 			err = crush_decode_uniform_bucket(p, end,  in crush_decode()
448 			err = crush_decode_list_bucket(p, end,  in crush_decode()
454 			err = crush_decode_tree_bucket(p, end,  in crush_decode()
460 			err = crush_decode_straw_bucket(p, end,  in crush_decode()
466 			err = crush_decode_straw2_bucket(p, end,  in crush_decode()
480 		ceph_decode_32_safe(p, end, yes, bad);  in crush_decode()
483 			     i, (int)(*p-start), *p, end);  in crush_decode()
489 		     i, (int)(*p-start), *p, end);  in crush_decode()
492 		ceph_decode_32_safe(p, end, yes, bad);  in crush_decode()
504 		ceph_decode_copy_safe(p, end, &r->mask, 4, bad); /* 4 u8's */  in crush_decode()
505 		ceph_decode_need(p, end, r->len*3*sizeof(u32), bad);  in crush_decode()
513 	ceph_decode_skip_map(p, end, 32, string, bad); /* type_map */  in crush_decode()
514 	ceph_decode_skip_map(p, end, 32, string, bad); /* name_map */  in crush_decode()
515 	ceph_decode_skip_map(p, end, 32, string, bad); /* rule_name_map */  in crush_decode()
518         ceph_decode_need(p, end, 3*sizeof(u32), done);  in crush_decode()
529 	ceph_decode_need(p, end, sizeof(u32), done);  in crush_decode()
534 	ceph_decode_need(p, end, sizeof(u8), done);  in crush_decode()
540 	ceph_decode_need(p, end, sizeof(u8) + sizeof(u32), done);  in crush_decode()
543 	ceph_decode_need(p, end, sizeof(u8), done);  in crush_decode()
548 	if (*p != end) {  in crush_decode()
550 		ceph_decode_skip_map(p, end, 32, 32, bad);  in crush_decode()
552 		ceph_decode_skip_map(p, end, 32, string, bad);  in crush_decode()
554 		ceph_decode_skip_map_of_map(p, end, 32, 32, 32, bad);  in crush_decode()
557 	if (*p != end) {  in crush_decode()
558 		err = decode_choose_args(p, end, c);  in crush_decode()
720 static int decode_pool(void **p, void *end, struct ceph_pg_pool_info *pi)  in decode_pool()  argument
726 	ceph_decode_need(p, end, 2 + 4, bad);  in decode_pool()
738 	ceph_decode_need(p, end, len, bad);  in decode_pool()
884 static int decode_pool_names(void **p, void *end, struct ceph_osdmap *map)  in decode_pool_names()  argument
890 	ceph_decode_32_safe(p, end, num, bad);  in decode_pool_names()
893 		ceph_decode_64_safe(p, end, pool, bad);  in decode_pool_names()
894 		ceph_decode_32_safe(p, end, len, bad);  in decode_pool_names()
896 		ceph_decode_need(p, end, len, bad);  in decode_pool_names()
1086 static int get_osdmap_client_data_v(void **p, void *end,  in get_osdmap_client_data_v()  argument
1091 	ceph_decode_8_safe(p, end, struct_v, e_inval);  in get_osdmap_client_data_v()
1095 		ceph_decode_8_safe(p, end, struct_compat, e_inval);  in get_osdmap_client_data_v()
1104 		ceph_decode_8_safe(p, end, struct_v, e_inval);  in get_osdmap_client_data_v()
1105 		ceph_decode_8_safe(p, end, struct_compat, e_inval);  in get_osdmap_client_data_v()
1117 		ceph_decode_16_safe(p, end, version, e_inval);  in get_osdmap_client_data_v()
1135 static int __decode_pools(void **p, void *end, struct ceph_osdmap *map,  in __decode_pools()  argument
1140 	ceph_decode_32_safe(p, end, n, e_inval);  in __decode_pools()
1146 		ceph_decode_64_safe(p, end, pool, e_inval);  in __decode_pools()
1163 		ret = decode_pool(p, end, pi);  in __decode_pools()
1174 static int decode_pools(void **p, void *end, struct ceph_osdmap *map)  in decode_pools()  argument
1176 	return __decode_pools(p, end, map, false);  in decode_pools()
1179 static int decode_new_pools(void **p, void *end, struct ceph_osdmap *map)  in decode_new_pools()  argument
1181 	return __decode_pools(p, end, map, true);  in decode_new_pools()
1186 static int decode_pg_mapping(void **p, void *end, struct rb_root *mapping_root,
1193 	ceph_decode_32_safe(p, end, n, e_inval);
1199 		ret = ceph_decode_pgid(p, end, &pgid);
1211 			pg = fn(p, end, incremental);
1228 static struct ceph_pg_mapping *__decode_pg_temp(void **p, void *end,  in __decode_pg_temp()  argument
1234 	ceph_decode_32_safe(p, end, len, e_inval);  in __decode_pg_temp()
1240 	ceph_decode_need(p, end, len * sizeof(u32), e_inval);  in __decode_pg_temp()
1255 static int decode_pg_temp(void **p, void *end, struct ceph_osdmap *map)  in decode_pg_temp()  argument
1257 	return decode_pg_mapping(p, end, &map->pg_temp, __decode_pg_temp,  in decode_pg_temp()
1261 static int decode_new_pg_temp(void **p, void *end, struct ceph_osdmap *map)  in decode_new_pg_temp()  argument
1263 	return decode_pg_mapping(p, end, &map->pg_temp, __decode_pg_temp,  in decode_new_pg_temp()
1267 static struct ceph_pg_mapping *__decode_primary_temp(void **p, void *end,  in __decode_primary_temp()  argument
1273 	ceph_decode_32_safe(p, end, osd, e_inval);  in __decode_primary_temp()
1288 static int decode_primary_temp(void **p, void *end, struct ceph_osdmap *map)  in decode_primary_temp()  argument
1290 	return decode_pg_mapping(p, end, &map->primary_temp,  in decode_primary_temp()
1294 static int decode_new_primary_temp(void **p, void *end,  in decode_new_primary_temp()  argument
1297 	return decode_pg_mapping(p, end, &map->primary_temp,  in decode_new_primary_temp()
1334 static int decode_primary_affinity(void **p, void *end,  in decode_primary_affinity()  argument
1339 	ceph_decode_32_safe(p, end, len, e_inval);  in decode_primary_affinity()
1348 	ceph_decode_need(p, end, map->max_osd*sizeof(u32), e_inval);  in decode_primary_affinity()
1364 static int decode_new_primary_affinity(void **p, void *end,  in decode_new_primary_affinity()  argument
1369 	ceph_decode_32_safe(p, end, n, e_inval);  in decode_new_primary_affinity()
1374 		ceph_decode_32_safe(p, end, osd, e_inval);  in decode_new_primary_affinity()
1375 		ceph_decode_32_safe(p, end, aff, e_inval);  in decode_new_primary_affinity()
1390 static struct ceph_pg_mapping *__decode_pg_upmap(void **p, void *end,  in __decode_pg_upmap()  argument
1393 	return __decode_pg_temp(p, end, false);  in __decode_pg_upmap()
1396 static int decode_pg_upmap(void **p, void *end, struct ceph_osdmap *map)  in decode_pg_upmap()  argument
1398 	return decode_pg_mapping(p, end, &map->pg_upmap, __decode_pg_upmap,  in decode_pg_upmap()
1402 static int decode_new_pg_upmap(void **p, void *end, struct ceph_osdmap *map)  in decode_new_pg_upmap()  argument
1404 	return decode_pg_mapping(p, end, &map->pg_upmap, __decode_pg_upmap,  in decode_new_pg_upmap()
1408 static int decode_old_pg_upmap(void **p, void *end, struct ceph_osdmap *map)  in decode_old_pg_upmap()  argument
1410 	return decode_pg_mapping(p, end, &map->pg_upmap, NULL, true);  in decode_old_pg_upmap()
1413 static struct ceph_pg_mapping *__decode_pg_upmap_items(void **p, void *end,  in __decode_pg_upmap_items()  argument
1419 	ceph_decode_32_safe(p, end, len, e_inval);  in __decode_pg_upmap_items()
1423 	ceph_decode_need(p, end, 2 * len * sizeof(u32), e_inval);  in __decode_pg_upmap_items()
1440 static int decode_pg_upmap_items(void **p, void *end, struct ceph_osdmap *map)  in decode_pg_upmap_items()  argument
1442 	return decode_pg_mapping(p, end, &map->pg_upmap_items,  in decode_pg_upmap_items()
1446 static int decode_new_pg_upmap_items(void **p, void *end,  in decode_new_pg_upmap_items()  argument
1449 	return decode_pg_mapping(p, end, &map->pg_upmap_items,  in decode_new_pg_upmap_items()
1453 static int decode_old_pg_upmap_items(void **p, void *end,  in decode_old_pg_upmap_items()  argument
1456 	return decode_pg_mapping(p, end, &map->pg_upmap_items, NULL, true);  in decode_old_pg_upmap_items()
1462 static int osdmap_decode(void **p, void *end, struct ceph_osdmap *map)  in osdmap_decode()  argument
1471 	dout("%s %p to %p len %d\n", __func__, *p, end, (int)(end - *p));  in osdmap_decode()
1473 	err = get_osdmap_client_data_v(p, end, "full", &struct_v);  in osdmap_decode()
1478 	ceph_decode_need(p, end, sizeof(map->fsid) + sizeof(u32) +  in osdmap_decode()
1486 	err = decode_pools(p, end, map);  in osdmap_decode()
1491 	err = decode_pool_names(p, end, map);  in osdmap_decode()
1495 	ceph_decode_32_safe(p, end, map->pool_max, e_inval);  in osdmap_decode()
1497 	ceph_decode_32_safe(p, end, map->flags, e_inval);  in osdmap_decode()
1500 	ceph_decode_32_safe(p, end, max, e_inval);  in osdmap_decode()
1508 	ceph_decode_need(p, end, 3*sizeof(u32) +  in osdmap_decode()
1533 		err = ceph_decode_entity_addr(p, end, &map->osd_addr[i]);  in osdmap_decode()
1539 	err = decode_pg_temp(p, end, map);  in osdmap_decode()
1545 		err = decode_primary_temp(p, end, map);  in osdmap_decode()
1552 		err = decode_primary_affinity(p, end, map);  in osdmap_decode()
1560 	ceph_decode_32_safe(p, end, len, e_inval);  in osdmap_decode()
1561 	err = osdmap_set_crush(map, crush_decode(*p, min(*p + len, end)));  in osdmap_decode()
1568 		ceph_decode_skip_map_of_map(p, end, string, string, string,  in osdmap_decode()
1573 		err = decode_pg_upmap(p, end, map);  in osdmap_decode()
1577 		err = decode_pg_upmap_items(p, end, map);  in osdmap_decode()
1586 	*p = end;  in osdmap_decode()
1595 	       err, epoch, (int)(*p - start), *p, start, end);  in osdmap_decode()
1598 		       start, end - start, true);  in osdmap_decode()
1605 struct ceph_osdmap *ceph_osdmap_decode(void **p, void *end)  in ceph_osdmap_decode()  argument
1614 	ret = osdmap_decode(p, end, map);  in ceph_osdmap_decode()
1631 static int decode_new_up_state_weight(void **p, void *end, u8 struct_v,  in decode_new_up_state_weight()  argument
1641 	ceph_decode_32_safe(p, end, len, e_inval);  in decode_new_up_state_weight()
1645 		ceph_decode_skip_32(p, end, e_inval);  in decode_new_up_state_weight()
1646 		if (ceph_decode_entity_addr(p, end, &addr))  in decode_new_up_state_weight()
1651 	ceph_decode_32_safe(p, end, len, e_inval);  in decode_new_up_state_weight()
1653 	ceph_decode_need(p, end, len, e_inval);  in decode_new_up_state_weight()
1657 	ceph_decode_32_safe(p, end, len, e_inval);  in decode_new_up_state_weight()
1662 		ceph_decode_need(p, end, 2*sizeof(u32), e_inval);  in decode_new_up_state_weight()
1725 		if (ceph_decode_entity_addr(p, end, &addr))  in decode_new_up_state_weight()
1742 struct ceph_osdmap *osdmap_apply_incremental(void **p, void *end,  in osdmap_apply_incremental()  argument
1756 	dout("%s %p to %p len %d\n", __func__, *p, end, (int)(end - *p));  in osdmap_apply_incremental()
1758 	err = get_osdmap_client_data_v(p, end, "inc", &struct_v);  in osdmap_apply_incremental()
1763 	ceph_decode_need(p, end, sizeof(fsid) + sizeof(u32) + sizeof(modified) +  in osdmap_apply_incremental()
1773 	ceph_decode_32_safe(p, end, len, e_inval);  in osdmap_apply_incremental()
1776 		     len, *p, end);  in osdmap_apply_incremental()
1777 		return ceph_osdmap_decode(p, min(*p+len, end));  in osdmap_apply_incremental()
1781 	ceph_decode_32_safe(p, end, len, e_inval);  in osdmap_apply_incremental()
1784 				       crush_decode(*p, min(*p + len, end)));  in osdmap_apply_incremental()
1797 	ceph_decode_32_safe(p, end, max, e_inval);  in osdmap_apply_incremental()
1808 	err = decode_new_pools(p, end, map);  in osdmap_apply_incremental()
1813 	err = decode_pool_names(p, end, map);  in osdmap_apply_incremental()
1818 	ceph_decode_32_safe(p, end, len, e_inval);  in osdmap_apply_incremental()
1822 		ceph_decode_64_safe(p, end, pool, e_inval);  in osdmap_apply_incremental()
1829 	err = decode_new_up_state_weight(p, end, struct_v, map);  in osdmap_apply_incremental()
1834 	err = decode_new_pg_temp(p, end, map);  in osdmap_apply_incremental()
1840 		err = decode_new_primary_temp(p, end, map);  in osdmap_apply_incremental()
1847 		err = decode_new_primary_affinity(p, end, map);  in osdmap_apply_incremental()
1854 		ceph_decode_skip_map_of_map(p, end, string, string, string,  in osdmap_apply_incremental()
1857 		ceph_decode_skip_set(p, end, string, e_inval);  in osdmap_apply_incremental()
1861 		err = decode_new_pg_upmap(p, end, map);  in osdmap_apply_incremental()
1865 		err = decode_old_pg_upmap(p, end, map);  in osdmap_apply_incremental()
1869 		err = decode_new_pg_upmap_items(p, end, map);  in osdmap_apply_incremental()
1873 		err = decode_old_pg_upmap_items(p, end, map);  in osdmap_apply_incremental()
1879 	*p = end;  in osdmap_apply_incremental()
1888 	       err, epoch, (int)(*p - start), *p, start, end);  in osdmap_apply_incremental()
1891 		       start, end - start, true);  in osdmap_apply_incremental()