Lines Matching defs:end
1762 * For decoding ->begin and ->end of MOSDBackoff only -- no MIN/MAX
1767 static int decode_hoid(void **p, void *end, struct ceph_hobject_id *hoid)
1773 ret = ceph_start_decoding(p, end, 4, "hobject_t", &struct_v,
1783 hoid->key = ceph_extract_encoded_string(p, end, &hoid->key_len,
1791 hoid->oid = ceph_extract_encoded_string(p, end, &hoid->oid_len,
1799 ceph_decode_64_safe(p, end, hoid->snapid, e_inval);
1800 ceph_decode_32_safe(p, end, hoid->hash, e_inval);
1801 ceph_decode_8_safe(p, end, hoid->is_max, e_inval);
1803 hoid->nspace = ceph_extract_encoded_string(p, end, &hoid->nspace_len,
1811 ceph_decode_64_safe(p, end, hoid->pool, e_inval);
1826 static void encode_hoid(void **p, void *end, const struct ceph_hobject_id *hoid)
1829 ceph_encode_string(p, end, hoid->key, hoid->key_len);
1830 ceph_encode_string(p, end, hoid->oid, hoid->oid_len);
1834 ceph_encode_string(p, end, hoid->nspace, hoid->nspace_len);
1867 free_hoid(backoff->end);
1891 if (hoid_compare(hoid, cur->end) < 0)
2066 static void encode_oloc(void **p, void *end,
2074 ceph_encode_string(p, end, oloc->pool_ns->str,
2084 void *const end = p + msg->front_alloc_len;
2116 encode_oloc(&p, end, &req->r_t.target_oloc);
2117 ceph_encode_string(&p, end, req->r_t.target_oid.name,
2139 BUG_ON(p > end - 8); /* space for features */
2161 void *const end = p + msg->front_alloc_len;
2239 BUG_ON(p > end);
2440 * twice, it's possible to get a reply and end up here while the
2572 * We can end up releasing caps as a result of abort_request().
3472 static int ceph_oloc_decode(void **p, void *end,
3480 ceph_decode_need(p, end, 1 + 1 + 4, e_inval);
3494 ceph_decode_need(p, end, len, e_inval);
3511 ceph_decode_need(p, end, len, e_inval);
3545 static int ceph_redirect_decode(void **p, void *end,
3553 ceph_decode_need(p, end, 1 + 1 + 4, e_inval);
3562 ceph_decode_need(p, end, len, e_inval);
3565 ret = ceph_oloc_decode(p, end, &redir->oloc);
3602 void *const end = p + msg->front.iov_len;
3610 ceph_decode_32_safe(&p, end, len, e_inval);
3611 ceph_decode_need(&p, end, len, e_inval);
3614 ret = ceph_decode_pgid(&p, end, &m->pgid);
3618 ceph_decode_64_safe(&p, end, m->flags, e_inval);
3619 ceph_decode_32_safe(&p, end, m->result, e_inval);
3620 ceph_decode_need(&p, end, sizeof(bad_replay_version), e_inval);
3623 ceph_decode_32_safe(&p, end, m->epoch, e_inval);
3625 ceph_decode_32_safe(&p, end, m->num_ops, e_inval);
3629 ceph_decode_need(&p, end, m->num_ops * sizeof(struct ceph_osd_op),
3638 ceph_decode_32_safe(&p, end, m->retry_attempt, e_inval);
3640 ceph_decode_32_safe(&p, end, m->rval[i], e_inval);
3643 ceph_decode_need(&p, end, sizeof(m->replay_version), e_inval);
3646 ceph_decode_64_safe(&p, end, m->user_version, e_inval);
3654 ceph_decode_8_safe(&p, end, decode_redir, e_inval);
3662 ret = ceph_redirect_decode(&p, end, &m->redirect);
3936 void *p, void *end, bool incremental,
3949 newmap = osdmap_apply_incremental(&p, end, osdc->osdmap);
3951 newmap = ceph_osdmap_decode(&p, end);
4064 void *const end = p + msg->front.iov_len;
4079 ceph_decode_need(&p, end, sizeof(fsid), bad);
4090 ceph_decode_32_safe(&p, end, nr_maps, bad);
4093 ceph_decode_need(&p, end, 2*sizeof(u32), bad);
4096 ceph_decode_need(&p, end, maplen, bad);
4117 ceph_decode_32_safe(&p, end, nr_maps, bad);
4120 ceph_decode_need(&p, end, 2*sizeof(u32), bad);
4123 ceph_decode_need(&p, end, maplen, bad);
4231 struct ceph_hobject_id *end;
4237 void *const end = p + msg->front.iov_len;
4242 ret = ceph_start_decoding(&p, end, 1, "spg_t", &struct_v, &struct_len);
4246 ret = ceph_decode_pgid(&p, end, &m->spgid.pgid);
4250 ceph_decode_8_safe(&p, end, m->spgid.shard, e_inval);
4251 ceph_decode_32_safe(&p, end, m->map_epoch, e_inval);
4252 ceph_decode_8_safe(&p, end, m->op, e_inval);
4253 ceph_decode_64_safe(&p, end, m->id, e_inval);
4259 ret = decode_hoid(&p, end, m->begin);
4265 m->end = kzalloc(sizeof(*m->end), GFP_NOIO);
4266 if (!m->end) {
4271 ret = decode_hoid(&p, end, m->end);
4274 free_hoid(m->end);
4289 void *p, *end;
4298 hoid_encoding_size(backoff->end);
4305 end = p + msg->front_alloc_len;
4311 encode_hoid(&p, end, backoff->begin);
4312 encode_hoid(&p, end, backoff->end);
4313 BUG_ON(p != end);
4351 backoff->end = m->end;
4352 m->end = NULL; /* ditto */
4371 const struct ceph_hobject_id *end)
4378 return !cmp || (cmp > 0 && hoid_compare(&hoid, end) < 0);
4400 hoid_compare(backoff->end, m->end)) {
4428 if (target_contained_by(&req->r_t, m->begin, m->end)) {
4473 free_hoid(m.end);
4487 void *const end = p + msg->front.iov_len;
4497 ceph_decode_8_safe(&p, end, proto_ver, bad);
4498 ceph_decode_8_safe(&p, end, opcode, bad);
4499 ceph_decode_64_safe(&p, end, cookie, bad);
4501 ceph_decode_64_safe(&p, end, notify_id, bad);
4504 ceph_decode_32_safe(&p, end, payload_len, bad);
4505 ceph_decode_need(&p, end, payload_len, bad);
4511 ceph_decode_32_safe(&p, end, return_code, bad);
4514 ceph_decode_64_safe(&p, end, notifier_id, bad);
4944 static int decode_watcher(void **p, void *end, struct ceph_watch_item *item)
4950 ret = ceph_start_decoding(p, end, 2, "watch_item_t",
4956 ceph_decode_copy_safe(p, end, &item->name, sizeof(item->name), bad);
4957 ceph_decode_64_safe(p, end, item->cookie, bad);
4958 ceph_decode_skip_32(p, end, bad); /* skip timeout seconds */
4961 ret = ceph_decode_entity_addr(p, end, &item->addr);
4975 static int decode_watchers(void **p, void *end,
4984 ret = ceph_start_decoding(p, end, 1, "obj_list_watch_response_t",
4995 ret = decode_watcher(p, end, *watchers + i);
5047 void *const end = p + req->r_ops[0].outdata_len;
5049 ret = decode_watchers(&p, end, watchers, num_watchers);
5266 void *p, *end;
5280 end = p + PAGE_SIZE;
5281 ceph_encode_string(&p, end, src_oid->name, src_oid->name_len);
5282 encode_oloc(&p, end, src_oloc);
5285 op->indata_len = PAGE_SIZE - (end - p);