Lines Matching full:end
71 static int crush_decode_uniform_bucket(void **p, void *end, in crush_decode_uniform_bucket() argument
74 dout("crush_decode_uniform_bucket %p to %p\n", *p, end); in crush_decode_uniform_bucket()
75 ceph_decode_need(p, end, (1+b->h.size) * sizeof(u32), bad); in crush_decode_uniform_bucket()
82 static int crush_decode_list_bucket(void **p, void *end, in crush_decode_list_bucket() argument
86 dout("crush_decode_list_bucket %p to %p\n", *p, end); in crush_decode_list_bucket()
93 ceph_decode_need(p, end, 2 * b->h.size * sizeof(u32), bad); in crush_decode_list_bucket()
103 static int crush_decode_tree_bucket(void **p, void *end, in crush_decode_tree_bucket() argument
107 dout("crush_decode_tree_bucket %p to %p\n", *p, end); in crush_decode_tree_bucket()
108 ceph_decode_8_safe(p, end, b->num_nodes, bad); in crush_decode_tree_bucket()
112 ceph_decode_need(p, end, b->num_nodes * sizeof(u32), bad); in crush_decode_tree_bucket()
120 static int crush_decode_straw_bucket(void **p, void *end, in crush_decode_straw_bucket() argument
124 dout("crush_decode_straw_bucket %p to %p\n", *p, end); in crush_decode_straw_bucket()
131 ceph_decode_need(p, end, 2 * b->h.size * sizeof(u32), bad); in crush_decode_straw_bucket()
141 static int crush_decode_straw2_bucket(void **p, void *end, in crush_decode_straw2_bucket() argument
145 dout("crush_decode_straw2_bucket %p to %p\n", *p, end); in crush_decode_straw2_bucket()
149 ceph_decode_need(p, end, b->h.size * sizeof(u32), bad); in crush_decode_straw2_bucket()
184 static int decode_crush_names(void **p, void *end, struct rb_root *root) in DEFINE_RB_FUNCS()
188 ceph_decode_32_safe(p, end, n, e_inval); in DEFINE_RB_FUNCS()
194 ceph_decode_32_safe(p, end, id, e_inval); in DEFINE_RB_FUNCS()
195 ceph_decode_32_safe(p, end, name_len, e_inval); in DEFINE_RB_FUNCS()
196 ceph_decode_need(p, end, name_len, e_inval); in DEFINE_RB_FUNCS()
281 static u32 *decode_array_32_alloc(void **p, void *end, u32 *plen) in decode_array_32_alloc() argument
287 ceph_decode_32_safe(p, end, len, e_inval); in decode_array_32_alloc()
297 ceph_decode_need(p, end, len * sizeof(u32), e_inval); in decode_array_32_alloc()
315 static int decode_choose_arg(void **p, void *end, struct crush_choose_arg *arg) in decode_choose_arg() argument
319 ceph_decode_32_safe(p, end, arg->weight_set_size, e_inval); in decode_choose_arg()
331 w->weights = decode_array_32_alloc(p, end, &w->size); in decode_choose_arg()
340 arg->ids = decode_array_32_alloc(p, end, &arg->ids_size); in decode_choose_arg()
353 static int decode_choose_args(void **p, void *end, struct crush_map *c) in decode_choose_args() argument
359 ceph_decode_32_safe(p, end, num_choose_arg_maps, e_inval); in decode_choose_args()
367 ceph_decode_64_safe(p, end, arg_map->choose_args_index, in decode_choose_args()
377 ceph_decode_32_safe(p, end, num_buckets, e_inval); in decode_choose_args()
382 ceph_decode_32_safe(p, end, bucket_index, e_inval); in decode_choose_args()
387 ret = decode_choose_arg(p, end, arg); in decode_choose_args()
434 static struct crush_map *crush_decode(void *pbyval, void *end) in crush_decode() argument
443 dout("crush_decode %p to %p len %d\n", *p, end, (int)(end - *p)); in crush_decode()
459 ceph_decode_need(p, end, 4*sizeof(u32), bad); in crush_decode()
483 ceph_decode_32_safe(p, end, alg, bad); in crush_decode()
489 i, (int)(*p-start), *p, end); in crush_decode()
515 ceph_decode_need(p, end, 4*sizeof(u32), bad); in crush_decode()
524 b->size, (int)(*p-start), *p, end); in crush_decode()
530 ceph_decode_need(p, end, b->size*sizeof(u32), bad); in crush_decode()
536 err = crush_decode_uniform_bucket(p, end, in crush_decode()
542 err = crush_decode_list_bucket(p, end, in crush_decode()
548 err = crush_decode_tree_bucket(p, end, in crush_decode()
554 err = crush_decode_straw_bucket(p, end, in crush_decode()
560 err = crush_decode_straw2_bucket(p, end, in crush_decode()
574 ceph_decode_32_safe(p, end, yes, bad); in crush_decode()
577 i, (int)(*p-start), *p, end); in crush_decode()
583 i, (int)(*p-start), *p, end); in crush_decode()
586 ceph_decode_32_safe(p, end, yes, bad); in crush_decode()
598 ceph_decode_copy_safe(p, end, &r->mask, 4, bad); /* 4 u8's */ in crush_decode()
599 ceph_decode_need(p, end, r->len*3*sizeof(u32), bad); in crush_decode()
607 err = decode_crush_names(p, end, &c->type_names); in crush_decode()
611 err = decode_crush_names(p, end, &c->names); in crush_decode()
615 ceph_decode_skip_map(p, end, 32, string, bad); /* rule_name_map */ in crush_decode()
618 ceph_decode_need(p, end, 3*sizeof(u32), done); in crush_decode()
629 ceph_decode_need(p, end, sizeof(u32), done); in crush_decode()
634 ceph_decode_need(p, end, sizeof(u8), done); in crush_decode()
640 ceph_decode_need(p, end, sizeof(u8) + sizeof(u32), done); in crush_decode()
643 ceph_decode_need(p, end, sizeof(u8), done); in crush_decode()
648 if (*p != end) { in crush_decode()
650 ceph_decode_skip_map(p, end, 32, 32, bad); in crush_decode()
652 ceph_decode_skip_map(p, end, 32, string, bad); in crush_decode()
654 ceph_decode_skip_map_of_map(p, end, 32, 32, 32, bad); in crush_decode()
657 if (*p != end) { in crush_decode()
658 err = decode_choose_args(p, end, c); in crush_decode()
791 static int decode_pool(void **p, void *end, struct ceph_pg_pool_info *pi) in decode_pool() argument
797 ceph_decode_need(p, end, 2 + 4, bad); in decode_pool()
809 ceph_decode_need(p, end, len, bad); in decode_pool()
812 ceph_decode_need(p, end, 4 + 4 + 4, bad); in decode_pool()
821 ceph_decode_skip_n(p, end, 8 + 4 + 8 + 4, bad); in decode_pool()
824 ceph_decode_32_safe(p, end, num, bad); in decode_pool()
827 ceph_decode_skip_n(p, end, 8 + 2, bad); in decode_pool()
828 ceph_decode_skip_string(p, end, bad); in decode_pool()
832 ceph_decode_skip_map(p, end, 64, 64, bad); in decode_pool()
834 ceph_decode_need(p, end, 8 + 8 + 4, bad); in decode_pool()
840 ceph_decode_8_safe(p, end, pi->min_size, bad); in decode_pool()
846 ceph_decode_skip_n(p, end, 8 + 8, bad); in decode_pool()
850 ceph_decode_skip_set(p, end, 64, bad); in decode_pool()
852 ceph_decode_need(p, end, 8 + 1 + 8 + 8, bad); in decode_pool()
864 ceph_decode_skip_map(p, end, string, string, bad); in decode_pool()
868 ceph_decode_skip_n(p, end, 2, bad); in decode_pool()
869 ceph_decode_skip_string(p, end, bad); in decode_pool()
872 ceph_decode_skip_n(p, end, 4 + 4, bad); in decode_pool()
877 ceph_decode_skip_32(p, end, bad); in decode_pool()
881 ceph_decode_skip_n(p, end, 16 + 8 + 8, bad); in decode_pool()
885 ceph_decode_skip_string(p, end, bad); in decode_pool()
892 ceph_decode_32_safe(p, end, pi->last_force_request_resend, bad); in decode_pool()
898 ceph_decode_skip_32(p, end, bad); in decode_pool()
902 ceph_decode_skip_64(p, end, bad); in decode_pool()
906 ceph_decode_skip_32(p, end, bad); in decode_pool()
910 ceph_decode_skip_32(p, end, bad); in decode_pool()
914 ceph_decode_skip_8(p, end, bad); in decode_pool()
918 ceph_decode_skip_8(p, end, bad); in decode_pool()
922 ceph_decode_skip_n(p, end, 4 + 4, bad); in decode_pool()
926 ceph_decode_skip_n(p, end, 2, bad); in decode_pool()
927 ceph_decode_skip_string(p, end, bad); in decode_pool()
931 ceph_decode_32_safe(p, end, pi->last_force_request_resend, bad); in decode_pool()
943 static int decode_pool_names(void **p, void *end, struct ceph_osdmap *map) in decode_pool_names() argument
949 ceph_decode_32_safe(p, end, num, bad); in decode_pool_names()
952 ceph_decode_64_safe(p, end, pool, bad); in decode_pool_names()
953 ceph_decode_32_safe(p, end, len, bad); in decode_pool_names()
955 ceph_decode_need(p, end, len, bad); in decode_pool_names()
1281 static int get_osdmap_client_data_v(void **p, void *end, in get_osdmap_client_data_v() argument
1286 ceph_decode_8_safe(p, end, struct_v, e_inval); in get_osdmap_client_data_v()
1290 ceph_decode_8_safe(p, end, struct_compat, e_inval); in get_osdmap_client_data_v()
1299 ceph_decode_8_safe(p, end, struct_v, e_inval); in get_osdmap_client_data_v()
1300 ceph_decode_8_safe(p, end, struct_compat, e_inval); in get_osdmap_client_data_v()
1312 ceph_decode_16_safe(p, end, version, e_inval); in get_osdmap_client_data_v()
1330 static int __decode_pools(void **p, void *end, struct ceph_osdmap *map, in __decode_pools() argument
1335 ceph_decode_32_safe(p, end, n, e_inval); in __decode_pools()
1341 ceph_decode_64_safe(p, end, pool, e_inval); in __decode_pools()
1358 ret = decode_pool(p, end, pi); in __decode_pools()
1369 static int decode_pools(void **p, void *end, struct ceph_osdmap *map) in decode_pools() argument
1371 return __decode_pools(p, end, map, false); in decode_pools()
1374 static int decode_new_pools(void **p, void *end, struct ceph_osdmap *map) in decode_new_pools() argument
1376 return __decode_pools(p, end, map, true); in decode_new_pools()
1381 static int decode_pg_mapping(void **p, void *end, struct rb_root *mapping_root, in decode_pg_mapping() argument
1388 ceph_decode_32_safe(p, end, n, e_inval); in decode_pg_mapping()
1394 ret = ceph_decode_pgid(p, end, &pgid); in decode_pg_mapping()
1406 pg = fn(p, end, incremental); in decode_pg_mapping()
1423 static struct ceph_pg_mapping *__decode_pg_temp(void **p, void *end, in __decode_pg_temp() argument
1429 ceph_decode_32_safe(p, end, len, e_inval); in __decode_pg_temp()
1435 ceph_decode_need(p, end, len * sizeof(u32), e_inval); in __decode_pg_temp()
1450 static int decode_pg_temp(void **p, void *end, struct ceph_osdmap *map) in decode_pg_temp() argument
1452 return decode_pg_mapping(p, end, &map->pg_temp, __decode_pg_temp, in decode_pg_temp()
1456 static int decode_new_pg_temp(void **p, void *end, struct ceph_osdmap *map) in decode_new_pg_temp() argument
1458 return decode_pg_mapping(p, end, &map->pg_temp, __decode_pg_temp, in decode_new_pg_temp()
1462 static struct ceph_pg_mapping *__decode_primary_temp(void **p, void *end, in __decode_primary_temp() argument
1468 ceph_decode_32_safe(p, end, osd, e_inval); in __decode_primary_temp()
1483 static int decode_primary_temp(void **p, void *end, struct ceph_osdmap *map) in decode_primary_temp() argument
1485 return decode_pg_mapping(p, end, &map->primary_temp, in decode_primary_temp()
1489 static int decode_new_primary_temp(void **p, void *end, in decode_new_primary_temp() argument
1492 return decode_pg_mapping(p, end, &map->primary_temp, in decode_new_primary_temp()
1525 static int decode_primary_affinity(void **p, void *end, in decode_primary_affinity() argument
1530 ceph_decode_32_safe(p, end, len, e_inval); in decode_primary_affinity()
1539 ceph_decode_need(p, end, map->max_osd*sizeof(u32), e_inval); in decode_primary_affinity()
1555 static int decode_new_primary_affinity(void **p, void *end, in decode_new_primary_affinity() argument
1560 ceph_decode_32_safe(p, end, n, e_inval); in decode_new_primary_affinity()
1565 ceph_decode_32_safe(p, end, osd, e_inval); in decode_new_primary_affinity()
1566 ceph_decode_32_safe(p, end, aff, e_inval); in decode_new_primary_affinity()
1583 static struct ceph_pg_mapping *__decode_pg_upmap(void **p, void *end, in __decode_pg_upmap() argument
1586 return __decode_pg_temp(p, end, false); in __decode_pg_upmap()
1589 static int decode_pg_upmap(void **p, void *end, struct ceph_osdmap *map) in decode_pg_upmap() argument
1591 return decode_pg_mapping(p, end, &map->pg_upmap, __decode_pg_upmap, in decode_pg_upmap()
1595 static int decode_new_pg_upmap(void **p, void *end, struct ceph_osdmap *map) in decode_new_pg_upmap() argument
1597 return decode_pg_mapping(p, end, &map->pg_upmap, __decode_pg_upmap, in decode_new_pg_upmap()
1601 static int decode_old_pg_upmap(void **p, void *end, struct ceph_osdmap *map) in decode_old_pg_upmap() argument
1603 return decode_pg_mapping(p, end, &map->pg_upmap, NULL, true); in decode_old_pg_upmap()
1606 static struct ceph_pg_mapping *__decode_pg_upmap_items(void **p, void *end, in __decode_pg_upmap_items() argument
1612 ceph_decode_32_safe(p, end, len, e_inval); in __decode_pg_upmap_items()
1616 ceph_decode_need(p, end, 2 * len * sizeof(u32), e_inval); in __decode_pg_upmap_items()
1633 static int decode_pg_upmap_items(void **p, void *end, struct ceph_osdmap *map) in decode_pg_upmap_items() argument
1635 return decode_pg_mapping(p, end, &map->pg_upmap_items, in decode_pg_upmap_items()
1639 static int decode_new_pg_upmap_items(void **p, void *end, in decode_new_pg_upmap_items() argument
1642 return decode_pg_mapping(p, end, &map->pg_upmap_items, in decode_new_pg_upmap_items()
1646 static int decode_old_pg_upmap_items(void **p, void *end, in decode_old_pg_upmap_items() argument
1649 return decode_pg_mapping(p, end, &map->pg_upmap_items, NULL, true); in decode_old_pg_upmap_items()
1655 static int osdmap_decode(void **p, void *end, bool msgr2, in osdmap_decode() argument
1665 dout("%s %p to %p len %d\n", __func__, *p, end, (int)(end - *p)); in osdmap_decode()
1667 err = get_osdmap_client_data_v(p, end, "full", &struct_v); in osdmap_decode()
1672 ceph_decode_need(p, end, sizeof(map->fsid) + sizeof(u32) + in osdmap_decode()
1680 err = decode_pools(p, end, map); in osdmap_decode()
1685 err = decode_pool_names(p, end, map); in osdmap_decode()
1689 ceph_decode_32_safe(p, end, map->pool_max, e_inval); in osdmap_decode()
1691 ceph_decode_32_safe(p, end, map->flags, e_inval); in osdmap_decode()
1694 ceph_decode_32_safe(p, end, max, e_inval); in osdmap_decode()
1702 ceph_decode_need(p, end, 3*sizeof(u32) + in osdmap_decode()
1730 err = ceph_decode_entity_addrvec(p, end, msgr2, addr); in osdmap_decode()
1732 err = ceph_decode_entity_addr(p, end, addr); in osdmap_decode()
1740 err = decode_pg_temp(p, end, map); in osdmap_decode()
1746 err = decode_primary_temp(p, end, map); in osdmap_decode()
1753 err = decode_primary_affinity(p, end, map); in osdmap_decode()
1761 ceph_decode_32_safe(p, end, len, e_inval); in osdmap_decode()
1762 err = osdmap_set_crush(map, crush_decode(*p, min(*p + len, end))); in osdmap_decode()
1769 ceph_decode_skip_map_of_map(p, end, string, string, string, in osdmap_decode()
1774 err = decode_pg_upmap(p, end, map); in osdmap_decode()
1778 err = decode_pg_upmap_items(p, end, map); in osdmap_decode()
1787 *p = end; in osdmap_decode()
1796 err, epoch, (int)(*p - start), *p, start, end); in osdmap_decode()
1799 start, end - start, true); in osdmap_decode()
1806 struct ceph_osdmap *ceph_osdmap_decode(void **p, void *end, bool msgr2) in ceph_osdmap_decode() argument
1815 ret = osdmap_decode(p, end, msgr2, map); in ceph_osdmap_decode()
1832 static int decode_new_up_state_weight(void **p, void *end, u8 struct_v, in decode_new_up_state_weight() argument
1843 ceph_decode_32_safe(p, end, len, e_inval); in decode_new_up_state_weight()
1847 ceph_decode_skip_32(p, end, e_inval); in decode_new_up_state_weight()
1849 ret = ceph_decode_entity_addrvec(p, end, msgr2, &addr); in decode_new_up_state_weight()
1851 ret = ceph_decode_entity_addr(p, end, &addr); in decode_new_up_state_weight()
1857 ceph_decode_32_safe(p, end, len, e_inval); in decode_new_up_state_weight()
1859 ceph_decode_need(p, end, len, e_inval); in decode_new_up_state_weight()
1863 ceph_decode_32_safe(p, end, len, e_inval); in decode_new_up_state_weight()
1868 ceph_decode_need(p, end, 2*sizeof(u32), e_inval); in decode_new_up_state_weight()
1937 ret = ceph_decode_entity_addrvec(p, end, msgr2, &addr); in decode_new_up_state_weight()
1939 ret = ceph_decode_entity_addr(p, end, &addr); in decode_new_up_state_weight()
1960 struct ceph_osdmap *osdmap_apply_incremental(void **p, void *end, bool msgr2, in osdmap_apply_incremental() argument
1974 dout("%s %p to %p len %d\n", __func__, *p, end, (int)(end - *p)); in osdmap_apply_incremental()
1976 err = get_osdmap_client_data_v(p, end, "inc", &struct_v); in osdmap_apply_incremental()
1981 ceph_decode_need(p, end, sizeof(fsid) + sizeof(u32) + sizeof(modified) + in osdmap_apply_incremental()
1993 ceph_decode_32_safe(p, end, len, e_inval); in osdmap_apply_incremental()
1996 len, *p, end); in osdmap_apply_incremental()
1997 return ceph_osdmap_decode(p, min(*p+len, end), msgr2); in osdmap_apply_incremental()
2001 ceph_decode_32_safe(p, end, len, e_inval); in osdmap_apply_incremental()
2004 crush_decode(*p, min(*p + len, end))); in osdmap_apply_incremental()
2017 ceph_decode_32_safe(p, end, max, e_inval); in osdmap_apply_incremental()
2028 err = decode_new_pools(p, end, map); in osdmap_apply_incremental()
2033 err = decode_pool_names(p, end, map); in osdmap_apply_incremental()
2038 ceph_decode_32_safe(p, end, len, e_inval); in osdmap_apply_incremental()
2042 ceph_decode_64_safe(p, end, pool, e_inval); in osdmap_apply_incremental()
2049 err = decode_new_up_state_weight(p, end, struct_v, msgr2, map); in osdmap_apply_incremental()
2054 err = decode_new_pg_temp(p, end, map); in osdmap_apply_incremental()
2060 err = decode_new_primary_temp(p, end, map); in osdmap_apply_incremental()
2067 err = decode_new_primary_affinity(p, end, map); in osdmap_apply_incremental()
2074 ceph_decode_skip_map_of_map(p, end, string, string, string, in osdmap_apply_incremental()
2077 ceph_decode_skip_set(p, end, string, e_inval); in osdmap_apply_incremental()
2081 err = decode_new_pg_upmap(p, end, map); in osdmap_apply_incremental()
2085 err = decode_old_pg_upmap(p, end, map); in osdmap_apply_incremental()
2089 err = decode_new_pg_upmap_items(p, end, map); in osdmap_apply_incremental()
2093 err = decode_old_pg_upmap_items(p, end, map); in osdmap_apply_incremental()
2099 *p = end; in osdmap_apply_incremental()
2108 err, epoch, (int)(*p - start), *p, start, end); in osdmap_apply_incremental()
2111 start, end - start, true); in osdmap_apply_incremental()