Lines Matching refs:p
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()
76 b->item_weight = ceph_decode_32(p); 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()
95 b->item_weights[j] = ceph_decode_32(p); in crush_decode_list_bucket()
96 b->sum_weights[j] = ceph_decode_32(p); 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()
114 b->node_weights[j] = ceph_decode_32(p); 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()
133 b->item_weights[j] = ceph_decode_32(p); in crush_decode_straw_bucket()
134 b->straws[j] = ceph_decode_32(p); 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()
151 b->item_weights[j] = ceph_decode_32(p); 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()
203 memcpy(cn->cn_name, *p, name_len); in DEFINE_RB_FUNCS()
205 *p += name_len; in DEFINE_RB_FUNCS()
277 static u32 *decode_array_32_alloc(void **p, void *end, u32 *plen) in decode_array_32_alloc() argument
283 ceph_decode_32_safe(p, end, len, e_inval); in decode_array_32_alloc()
293 ceph_decode_need(p, end, len * sizeof(u32), e_inval); in decode_array_32_alloc()
295 a[i] = ceph_decode_32(p); in decode_array_32_alloc()
311 static int decode_choose_arg(void **p, void *end, struct crush_choose_arg *arg) in decode_choose_arg() argument
315 ceph_decode_32_safe(p, end, arg->weight_set_size, e_inval); in decode_choose_arg()
328 w->weights = decode_array_32_alloc(p, end, &w->size); in decode_choose_arg()
337 arg->ids = decode_array_32_alloc(p, end, &arg->ids_size); in decode_choose_arg()
350 static int decode_choose_args(void **p, void *end, struct crush_map *c) in decode_choose_args() argument
356 ceph_decode_32_safe(p, end, num_choose_arg_maps, e_inval); in decode_choose_args()
364 ceph_decode_64_safe(p, end, arg_map->choose_args_index, in decode_choose_args()
374 ceph_decode_32_safe(p, end, num_buckets, e_inval); in decode_choose_args()
379 ceph_decode_32_safe(p, end, bucket_index, e_inval); in decode_choose_args()
384 ret = decode_choose_arg(p, end, arg); in decode_choose_args()
436 void **p = &pbyval; in crush_decode() local
440 dout("crush_decode %p to %p len %d\n", *p, end, (int)(end - *p)); in crush_decode()
456 ceph_decode_need(p, end, 4*sizeof(u32), bad); in crush_decode()
457 magic = ceph_decode_32(p); in crush_decode()
463 c->max_buckets = ceph_decode_32(p); in crush_decode()
464 c->max_rules = ceph_decode_32(p); in crush_decode()
465 c->max_devices = ceph_decode_32(p); in crush_decode()
480 ceph_decode_32_safe(p, end, alg, bad); in crush_decode()
486 i, (int)(*p-start), *p, end); in crush_decode()
512 ceph_decode_need(p, end, 4*sizeof(u32), bad); in crush_decode()
513 b->id = ceph_decode_32(p); in crush_decode()
514 b->type = ceph_decode_16(p); in crush_decode()
515 b->alg = ceph_decode_8(p); in crush_decode()
516 b->hash = ceph_decode_8(p); in crush_decode()
517 b->weight = ceph_decode_32(p); in crush_decode()
518 b->size = ceph_decode_32(p); in crush_decode()
521 b->size, (int)(*p-start), *p, end); in crush_decode()
527 ceph_decode_need(p, end, b->size*sizeof(u32), bad); in crush_decode()
529 b->items[j] = ceph_decode_32(p); in crush_decode()
533 err = crush_decode_uniform_bucket(p, end, in crush_decode()
539 err = crush_decode_list_bucket(p, end, in crush_decode()
545 err = crush_decode_tree_bucket(p, end, in crush_decode()
551 err = crush_decode_straw_bucket(p, end, in crush_decode()
557 err = crush_decode_straw2_bucket(p, end, in crush_decode()
571 ceph_decode_32_safe(p, end, yes, bad); in crush_decode()
574 i, (int)(*p-start), *p, end); in crush_decode()
580 i, (int)(*p-start), *p, end); in crush_decode()
583 ceph_decode_32_safe(p, end, yes, bad); in crush_decode()
595 ceph_decode_copy_safe(p, end, &r->mask, 4, bad); /* 4 u8's */ in crush_decode()
596 ceph_decode_need(p, end, r->len*3*sizeof(u32), bad); in crush_decode()
598 r->steps[j].op = ceph_decode_32(p); in crush_decode()
599 r->steps[j].arg1 = ceph_decode_32(p); in crush_decode()
600 r->steps[j].arg2 = ceph_decode_32(p); in crush_decode()
604 err = decode_crush_names(p, end, &c->type_names); in crush_decode()
608 err = decode_crush_names(p, end, &c->names); in crush_decode()
612 ceph_decode_skip_map(p, end, 32, string, bad); /* rule_name_map */ in crush_decode()
615 ceph_decode_need(p, end, 3*sizeof(u32), done); in crush_decode()
616 c->choose_local_tries = ceph_decode_32(p); in crush_decode()
617 c->choose_local_fallback_tries = ceph_decode_32(p); in crush_decode()
618 c->choose_total_tries = ceph_decode_32(p); in crush_decode()
626 ceph_decode_need(p, end, sizeof(u32), done); in crush_decode()
627 c->chooseleaf_descend_once = ceph_decode_32(p); in crush_decode()
631 ceph_decode_need(p, end, sizeof(u8), done); in crush_decode()
632 c->chooseleaf_vary_r = ceph_decode_8(p); in crush_decode()
637 ceph_decode_need(p, end, sizeof(u8) + sizeof(u32), done); in crush_decode()
638 *p += sizeof(u8) + sizeof(u32); in crush_decode()
640 ceph_decode_need(p, end, sizeof(u8), done); in crush_decode()
641 c->chooseleaf_stable = ceph_decode_8(p); in crush_decode()
645 if (*p != end) { in crush_decode()
647 ceph_decode_skip_map(p, end, 32, 32, bad); in crush_decode()
649 ceph_decode_skip_map(p, end, 32, string, bad); in crush_decode()
651 ceph_decode_skip_map_of_map(p, end, 32, 32, 32, bad); in crush_decode()
654 if (*p != end) { in crush_decode()
655 err = decode_choose_args(p, end, c); in crush_decode()
788 static int decode_pool(void **p, void *end, struct ceph_pg_pool_info *pi) in decode_pool() argument
794 ceph_decode_need(p, end, 2 + 4, bad); in decode_pool()
795 ev = ceph_decode_8(p); /* encoding version */ in decode_pool()
796 cv = ceph_decode_8(p); /* compat version */ in decode_pool()
805 len = ceph_decode_32(p); in decode_pool()
806 ceph_decode_need(p, end, len, bad); in decode_pool()
807 pool_end = *p + len; in decode_pool()
809 pi->type = ceph_decode_8(p); in decode_pool()
810 pi->size = ceph_decode_8(p); in decode_pool()
811 pi->crush_ruleset = ceph_decode_8(p); in decode_pool()
812 pi->object_hash = ceph_decode_8(p); in decode_pool()
814 pi->pg_num = ceph_decode_32(p); in decode_pool()
815 pi->pgp_num = ceph_decode_32(p); in decode_pool()
817 *p += 4 + 4; /* skip lpg* */ in decode_pool()
818 *p += 4; /* skip last_change */ in decode_pool()
819 *p += 8 + 4; /* skip snap_seq, snap_epoch */ in decode_pool()
822 num = ceph_decode_32(p); in decode_pool()
824 *p += 8; /* snapid key */ in decode_pool()
825 *p += 1 + 1; /* versions */ in decode_pool()
826 len = ceph_decode_32(p); in decode_pool()
827 *p += len; in decode_pool()
831 num = ceph_decode_32(p); in decode_pool()
832 *p += num * (8 + 8); in decode_pool()
834 *p += 8; /* skip auid */ in decode_pool()
835 pi->flags = ceph_decode_64(p); in decode_pool()
836 *p += 4; /* skip crash_replay_interval */ in decode_pool()
839 pi->min_size = ceph_decode_8(p); in decode_pool()
844 *p += 8 + 8; /* skip quota_max_* */ in decode_pool()
848 num = ceph_decode_32(p); in decode_pool()
849 *p += num * 8; in decode_pool()
851 *p += 8; /* skip tier_of */ in decode_pool()
852 *p += 1; /* skip cache_mode */ in decode_pool()
854 pi->read_tier = ceph_decode_64(p); in decode_pool()
855 pi->write_tier = ceph_decode_64(p); in decode_pool()
863 num = ceph_decode_32(p); in decode_pool()
865 len = ceph_decode_32(p); in decode_pool()
866 *p += len; /* key */ in decode_pool()
867 len = ceph_decode_32(p); in decode_pool()
868 *p += len; /* val */ in decode_pool()
874 *p += 1 + 1; /* versions */ in decode_pool()
875 len = ceph_decode_32(p); in decode_pool()
876 *p += len; in decode_pool()
878 *p += 4; /* skip hit_set_period */ in decode_pool()
879 *p += 4; /* skip hit_set_count */ in decode_pool()
883 *p += 4; /* skip stripe_width */ in decode_pool()
886 *p += 8; /* skip target_max_bytes */ in decode_pool()
887 *p += 8; /* skip target_max_objects */ in decode_pool()
888 *p += 4; /* skip cache_target_dirty_ratio_micro */ in decode_pool()
889 *p += 4; /* skip cache_target_full_ratio_micro */ in decode_pool()
890 *p += 4; /* skip cache_min_flush_age */ in decode_pool()
891 *p += 4; /* skip cache_min_evict_age */ in decode_pool()
896 len = ceph_decode_32(p); in decode_pool()
897 *p += len; in decode_pool()
905 pi->last_force_request_resend = ceph_decode_32(p); in decode_pool()
910 *p += 4; /* skip min_read_recency_for_promote */ in decode_pool()
913 *p += 8; /* skip expected_num_objects */ in decode_pool()
916 *p += 4; /* skip cache_target_dirty_high_ratio_micro */ in decode_pool()
919 *p += 4; /* skip min_write_recency_for_promote */ in decode_pool()
922 *p += 1; /* skip use_gmt_hitset */ in decode_pool()
925 *p += 1; /* skip fast_read */ in decode_pool()
928 *p += 4; /* skip hit_set_grade_decay_rate */ in decode_pool()
929 *p += 4; /* skip hit_set_search_last_n */ in decode_pool()
934 *p += 1 + 1; /* versions */ in decode_pool()
935 len = ceph_decode_32(p); in decode_pool()
936 *p += len; in decode_pool()
940 pi->last_force_request_resend = ceph_decode_32(p); in decode_pool()
944 *p = pool_end; in decode_pool()
952 static int decode_pool_names(void **p, void *end, struct ceph_osdmap *map) in decode_pool_names() argument
958 ceph_decode_32_safe(p, end, num, bad); in decode_pool_names()
961 ceph_decode_64_safe(p, end, pool, bad); in decode_pool_names()
962 ceph_decode_32_safe(p, end, len, bad); in decode_pool_names()
964 ceph_decode_need(p, end, len, bad); in decode_pool_names()
967 char *name = kstrndup(*p, len, GFP_NOFS); in decode_pool_names()
975 *p += len; in decode_pool_names()
1290 static int get_osdmap_client_data_v(void **p, void *end, in get_osdmap_client_data_v() argument
1295 ceph_decode_8_safe(p, end, struct_v, e_inval); in get_osdmap_client_data_v()
1299 ceph_decode_8_safe(p, end, struct_compat, e_inval); in get_osdmap_client_data_v()
1306 *p += 4; /* ignore wrapper struct_len */ in get_osdmap_client_data_v()
1308 ceph_decode_8_safe(p, end, struct_v, e_inval); in get_osdmap_client_data_v()
1309 ceph_decode_8_safe(p, end, struct_compat, e_inval); in get_osdmap_client_data_v()
1316 *p += 4; /* ignore client data struct_len */ in get_osdmap_client_data_v()
1320 *p -= 1; in get_osdmap_client_data_v()
1321 ceph_decode_16_safe(p, end, version, e_inval); in get_osdmap_client_data_v()
1339 static int __decode_pools(void **p, void *end, struct ceph_osdmap *map, in __decode_pools() argument
1344 ceph_decode_32_safe(p, end, n, e_inval); in __decode_pools()
1350 ceph_decode_64_safe(p, end, pool, e_inval); in __decode_pools()
1367 ret = decode_pool(p, end, pi); in __decode_pools()
1378 static int decode_pools(void **p, void *end, struct ceph_osdmap *map) in decode_pools() argument
1380 return __decode_pools(p, end, map, false); in decode_pools()
1383 static int decode_new_pools(void **p, void *end, struct ceph_osdmap *map) in decode_new_pools() argument
1385 return __decode_pools(p, end, map, true); in decode_new_pools()
1390 static int decode_pg_mapping(void **p, void *end, struct rb_root *mapping_root,
1397 ceph_decode_32_safe(p, end, n, e_inval);
1403 ret = ceph_decode_pgid(p, end, &pgid);
1415 pg = fn(p, end, incremental);
1432 static struct ceph_pg_mapping *__decode_pg_temp(void **p, void *end, in __decode_pg_temp() argument
1438 ceph_decode_32_safe(p, end, len, e_inval); in __decode_pg_temp()
1444 ceph_decode_need(p, end, len * sizeof(u32), e_inval); in __decode_pg_temp()
1451 pg->pg_temp.osds[i] = ceph_decode_32(p); in __decode_pg_temp()
1459 static int decode_pg_temp(void **p, void *end, struct ceph_osdmap *map) in decode_pg_temp() argument
1461 return decode_pg_mapping(p, end, &map->pg_temp, __decode_pg_temp, in decode_pg_temp()
1465 static int decode_new_pg_temp(void **p, void *end, struct ceph_osdmap *map) in decode_new_pg_temp() argument
1467 return decode_pg_mapping(p, end, &map->pg_temp, __decode_pg_temp, in decode_new_pg_temp()
1471 static struct ceph_pg_mapping *__decode_primary_temp(void **p, void *end, in __decode_primary_temp() argument
1477 ceph_decode_32_safe(p, end, osd, e_inval); in __decode_primary_temp()
1492 static int decode_primary_temp(void **p, void *end, struct ceph_osdmap *map) in decode_primary_temp() argument
1494 return decode_pg_mapping(p, end, &map->primary_temp, in decode_primary_temp()
1498 static int decode_new_primary_temp(void **p, void *end, in decode_new_primary_temp() argument
1501 return decode_pg_mapping(p, end, &map->primary_temp, in decode_new_primary_temp()
1538 static int decode_primary_affinity(void **p, void *end, in decode_primary_affinity() argument
1543 ceph_decode_32_safe(p, end, len, e_inval); in decode_primary_affinity()
1552 ceph_decode_need(p, end, map->max_osd*sizeof(u32), e_inval); in decode_primary_affinity()
1557 ret = set_primary_affinity(map, i, ceph_decode_32(p)); in decode_primary_affinity()
1568 static int decode_new_primary_affinity(void **p, void *end, in decode_new_primary_affinity() argument
1573 ceph_decode_32_safe(p, end, n, e_inval); in decode_new_primary_affinity()
1578 ceph_decode_32_safe(p, end, osd, e_inval); in decode_new_primary_affinity()
1579 ceph_decode_32_safe(p, end, aff, e_inval); in decode_new_primary_affinity()
1594 static struct ceph_pg_mapping *__decode_pg_upmap(void **p, void *end, in __decode_pg_upmap() argument
1597 return __decode_pg_temp(p, end, false); in __decode_pg_upmap()
1600 static int decode_pg_upmap(void **p, void *end, struct ceph_osdmap *map) in decode_pg_upmap() argument
1602 return decode_pg_mapping(p, end, &map->pg_upmap, __decode_pg_upmap, in decode_pg_upmap()
1606 static int decode_new_pg_upmap(void **p, void *end, struct ceph_osdmap *map) in decode_new_pg_upmap() argument
1608 return decode_pg_mapping(p, end, &map->pg_upmap, __decode_pg_upmap, in decode_new_pg_upmap()
1612 static int decode_old_pg_upmap(void **p, void *end, struct ceph_osdmap *map) in decode_old_pg_upmap() argument
1614 return decode_pg_mapping(p, end, &map->pg_upmap, NULL, true); in decode_old_pg_upmap()
1617 static struct ceph_pg_mapping *__decode_pg_upmap_items(void **p, void *end, in __decode_pg_upmap_items() argument
1623 ceph_decode_32_safe(p, end, len, e_inval); in __decode_pg_upmap_items()
1627 ceph_decode_need(p, end, 2 * len * sizeof(u32), e_inval); in __decode_pg_upmap_items()
1634 pg->pg_upmap_items.from_to[i][0] = ceph_decode_32(p); in __decode_pg_upmap_items()
1635 pg->pg_upmap_items.from_to[i][1] = ceph_decode_32(p); in __decode_pg_upmap_items()
1644 static int decode_pg_upmap_items(void **p, void *end, struct ceph_osdmap *map) in decode_pg_upmap_items() argument
1646 return decode_pg_mapping(p, end, &map->pg_upmap_items, in decode_pg_upmap_items()
1650 static int decode_new_pg_upmap_items(void **p, void *end, in decode_new_pg_upmap_items() argument
1653 return decode_pg_mapping(p, end, &map->pg_upmap_items, in decode_new_pg_upmap_items()
1657 static int decode_old_pg_upmap_items(void **p, void *end, in decode_old_pg_upmap_items() argument
1660 return decode_pg_mapping(p, end, &map->pg_upmap_items, NULL, true); in decode_old_pg_upmap_items()
1666 static int osdmap_decode(void **p, void *end, bool msgr2, in osdmap_decode() argument
1671 void *start = *p; in osdmap_decode()
1676 dout("%s %p to %p len %d\n", __func__, *p, end, (int)(end - *p)); in osdmap_decode()
1678 err = get_osdmap_client_data_v(p, end, "full", &struct_v); in osdmap_decode()
1683 ceph_decode_need(p, end, sizeof(map->fsid) + sizeof(u32) + in osdmap_decode()
1685 ceph_decode_copy(p, &map->fsid, sizeof(map->fsid)); in osdmap_decode()
1686 epoch = map->epoch = ceph_decode_32(p); in osdmap_decode()
1687 ceph_decode_copy(p, &map->created, sizeof(map->created)); in osdmap_decode()
1688 ceph_decode_copy(p, &map->modified, sizeof(map->modified)); in osdmap_decode()
1691 err = decode_pools(p, end, map); in osdmap_decode()
1696 err = decode_pool_names(p, end, map); in osdmap_decode()
1700 ceph_decode_32_safe(p, end, map->pool_max, e_inval); in osdmap_decode()
1702 ceph_decode_32_safe(p, end, map->flags, e_inval); in osdmap_decode()
1705 ceph_decode_32_safe(p, end, max, e_inval); in osdmap_decode()
1713 ceph_decode_need(p, end, 3*sizeof(u32) + in osdmap_decode()
1717 if (ceph_decode_32(p) != map->max_osd) in osdmap_decode()
1722 map->osd_state[i] = ceph_decode_32(p); in osdmap_decode()
1725 map->osd_state[i] = ceph_decode_8(p); in osdmap_decode()
1728 if (ceph_decode_32(p) != map->max_osd) in osdmap_decode()
1732 map->osd_weight[i] = ceph_decode_32(p); in osdmap_decode()
1734 if (ceph_decode_32(p) != map->max_osd) in osdmap_decode()
1741 err = ceph_decode_entity_addrvec(p, end, msgr2, addr); in osdmap_decode()
1743 err = ceph_decode_entity_addr(p, end, addr); in osdmap_decode()
1751 err = decode_pg_temp(p, end, map); in osdmap_decode()
1757 err = decode_primary_temp(p, end, map); in osdmap_decode()
1764 err = decode_primary_affinity(p, end, map); in osdmap_decode()
1772 ceph_decode_32_safe(p, end, len, e_inval); in osdmap_decode()
1773 err = osdmap_set_crush(map, crush_decode(*p, min(*p + len, end))); in osdmap_decode()
1777 *p += len; in osdmap_decode()
1780 ceph_decode_skip_map_of_map(p, end, string, string, string, in osdmap_decode()
1785 err = decode_pg_upmap(p, end, map); in osdmap_decode()
1789 err = decode_pg_upmap_items(p, end, map); in osdmap_decode()
1798 *p = end; in osdmap_decode()
1807 err, epoch, (int)(*p - start), *p, start, end); in osdmap_decode()
1817 struct ceph_osdmap *ceph_osdmap_decode(void **p, void *end, bool msgr2) in ceph_osdmap_decode() argument
1826 ret = osdmap_decode(p, end, msgr2, map); in ceph_osdmap_decode()
1843 static int decode_new_up_state_weight(void **p, void *end, u8 struct_v, in decode_new_up_state_weight() argument
1853 new_up_client = *p; in decode_new_up_state_weight()
1854 ceph_decode_32_safe(p, end, len, e_inval); in decode_new_up_state_weight()
1858 ceph_decode_skip_32(p, end, e_inval); in decode_new_up_state_weight()
1860 ret = ceph_decode_entity_addrvec(p, end, msgr2, &addr); in decode_new_up_state_weight()
1862 ret = ceph_decode_entity_addr(p, end, &addr); in decode_new_up_state_weight()
1867 new_state = *p; in decode_new_up_state_weight()
1868 ceph_decode_32_safe(p, end, len, e_inval); in decode_new_up_state_weight()
1870 ceph_decode_need(p, end, len, e_inval); in decode_new_up_state_weight()
1871 *p += len; in decode_new_up_state_weight()
1874 ceph_decode_32_safe(p, end, len, e_inval); in decode_new_up_state_weight()
1879 ceph_decode_need(p, end, 2*sizeof(u32), e_inval); in decode_new_up_state_weight()
1880 osd = ceph_decode_32(p); in decode_new_up_state_weight()
1881 w = ceph_decode_32(p); in decode_new_up_state_weight()
1898 new_weight_end = *p; in decode_new_up_state_weight()
1901 *p = new_state; in decode_new_up_state_weight()
1902 len = ceph_decode_32(p); in decode_new_up_state_weight()
1907 osd = ceph_decode_32(p); in decode_new_up_state_weight()
1909 xorstate = ceph_decode_32(p); in decode_new_up_state_weight()
1911 xorstate = ceph_decode_8(p); in decode_new_up_state_weight()
1933 *p = new_up_client; in decode_new_up_state_weight()
1934 len = ceph_decode_32(p); in decode_new_up_state_weight()
1939 osd = ceph_decode_32(p); in decode_new_up_state_weight()
1942 ret = ceph_decode_entity_addrvec(p, end, msgr2, &addr); in decode_new_up_state_weight()
1944 ret = ceph_decode_entity_addr(p, end, &addr); in decode_new_up_state_weight()
1955 *p = new_weight_end; in decode_new_up_state_weight()
1965 struct ceph_osdmap *osdmap_apply_incremental(void **p, void *end, bool msgr2, in osdmap_apply_incremental() argument
1975 void *start = *p; in osdmap_apply_incremental()
1979 dout("%s %p to %p len %d\n", __func__, *p, end, (int)(end - *p)); in osdmap_apply_incremental()
1981 err = get_osdmap_client_data_v(p, end, "inc", &struct_v); in osdmap_apply_incremental()
1986 ceph_decode_need(p, end, sizeof(fsid) + sizeof(u32) + sizeof(modified) + in osdmap_apply_incremental()
1988 ceph_decode_copy(p, &fsid, sizeof(fsid)); in osdmap_apply_incremental()
1989 epoch = ceph_decode_32(p); in osdmap_apply_incremental()
1991 ceph_decode_copy(p, &modified, sizeof(modified)); in osdmap_apply_incremental()
1992 new_pool_max = ceph_decode_64(p); in osdmap_apply_incremental()
1993 new_flags = ceph_decode_32(p); in osdmap_apply_incremental()
1996 ceph_decode_32_safe(p, end, len, e_inval); in osdmap_apply_incremental()
1999 len, *p, end); in osdmap_apply_incremental()
2000 return ceph_osdmap_decode(p, min(*p+len, end), msgr2); in osdmap_apply_incremental()
2004 ceph_decode_32_safe(p, end, len, e_inval); in osdmap_apply_incremental()
2007 crush_decode(*p, min(*p + len, end))); in osdmap_apply_incremental()
2010 *p += len; in osdmap_apply_incremental()
2020 ceph_decode_32_safe(p, end, max, e_inval); in osdmap_apply_incremental()
2031 err = decode_new_pools(p, end, map); in osdmap_apply_incremental()
2036 err = decode_pool_names(p, end, map); in osdmap_apply_incremental()
2041 ceph_decode_32_safe(p, end, len, e_inval); in osdmap_apply_incremental()
2045 ceph_decode_64_safe(p, end, pool, e_inval); in osdmap_apply_incremental()
2052 err = decode_new_up_state_weight(p, end, struct_v, msgr2, map); in osdmap_apply_incremental()
2057 err = decode_new_pg_temp(p, end, map); in osdmap_apply_incremental()
2063 err = decode_new_primary_temp(p, end, map); in osdmap_apply_incremental()
2070 err = decode_new_primary_affinity(p, end, map); in osdmap_apply_incremental()
2077 ceph_decode_skip_map_of_map(p, end, string, string, string, in osdmap_apply_incremental()
2080 ceph_decode_skip_set(p, end, string, e_inval); in osdmap_apply_incremental()
2084 err = decode_new_pg_upmap(p, end, map); in osdmap_apply_incremental()
2088 err = decode_old_pg_upmap(p, end, map); in osdmap_apply_incremental()
2092 err = decode_new_pg_upmap_items(p, end, map); in osdmap_apply_incremental()
2096 err = decode_old_pg_upmap_items(p, end, map); in osdmap_apply_incremental()
2102 *p = end; in osdmap_apply_incremental()
2111 err, epoch, (int)(*p - start), *p, start, end); in osdmap_apply_incremental()