Lines Matching refs:end
39 static int decode_mon_info(void **p, void *end, bool msgr2, in decode_mon_info() argument
47 ret = ceph_start_decoding(p, end, 1, "mon_info_t", &struct_v, in decode_mon_info()
53 ceph_decode_skip_string(p, end, e_inval); /* skip mon name */ in decode_mon_info()
54 ret = ceph_decode_entity_addrvec(p, end, msgr2, addr); in decode_mon_info()
70 static struct ceph_monmap *ceph_monmap_decode(void **p, void *end, bool msgr2) in ceph_monmap_decode() argument
82 ceph_decode_32_safe(p, end, blob_len, e_inval); in ceph_monmap_decode()
83 ceph_decode_need(p, end, blob_len, e_inval); in ceph_monmap_decode()
85 ret = ceph_start_decoding(p, end, 6, "monmap", &struct_v, &struct_len); in ceph_monmap_decode()
90 ceph_decode_copy_safe(p, end, &fsid, sizeof(fsid), e_inval); in ceph_monmap_decode()
91 ceph_decode_32_safe(p, end, epoch, e_inval); in ceph_monmap_decode()
99 ret = ceph_start_decoding(p, end, 1, "mon_feature_t", in ceph_monmap_decode()
106 ret = ceph_start_decoding(p, end, 1, "mon_feature_t", in ceph_monmap_decode()
113 ceph_decode_32_safe(p, end, num_mon, e_inval); in ceph_monmap_decode()
133 ceph_decode_skip_string(p, end, e_inval); /* skip mon name */ in ceph_monmap_decode()
138 ret = decode_mon_info(p, end, msgr2, &inst->addr); in ceph_monmap_decode()
140 ret = ceph_decode_entity_addr(p, end, &inst->addr); in ceph_monmap_decode()
336 void *const end = p + msg->front_alloc_len; in __send_subscribe() local
370 ceph_encode_string(&p, end, buf, len); in __send_subscribe()
375 BUG_ON(p > end); in __send_subscribe()
544 void *p, *end; in ceph_monc_handle_map() local
550 end = p + msg->front.iov_len; in ceph_monc_handle_map()
552 monmap = ceph_monmap_decode(&p, end, ceph_msgr2(client)); in ceph_monc_handle_map()
822 void *end = p + msg->front_alloc_len; in handle_get_version_reply() local
827 ceph_decode_need(&p, end, 2*sizeof(u64), bad); in handle_get_version_reply()
880 void *const end = p + req->request->front_alloc_len; in __ceph_monc_get_version() local
883 ceph_encode_string(&p, end, what, strlen(what)); in __ceph_monc_get_version()
884 WARN_ON(p != end); in __ceph_monc_get_version()
944 void *const end = p + msg->front_alloc_len; in handle_command_ack() local
949 ceph_decode_need(&p, end, sizeof(struct ceph_mon_request_header) + in handle_command_ack()