Lines Matching refs:m
2324 struct rb_node *m; in ceph_osdc_abort_on_full() local
2326 m = rb_first(&osd->o_requests); in ceph_osdc_abort_on_full()
2327 while (m) { in ceph_osdc_abort_on_full()
2328 struct ceph_osd_request *req = rb_entry(m, in ceph_osdc_abort_on_full()
2330 m = rb_next(m); in ceph_osdc_abort_on_full()
2352 struct rb_node *m; in ceph_osdc_abort_on_full() local
2354 m = rb_first(&osd->o_requests); in ceph_osdc_abort_on_full()
2355 while (m) { in ceph_osdc_abort_on_full()
2356 struct ceph_osd_request *req = rb_entry(m, in ceph_osdc_abort_on_full()
2358 m = rb_next(m); in ceph_osdc_abort_on_full()
3305 static int decode_MOSDOpReply(const struct ceph_msg *msg, struct MOSDOpReply *m) in decode_MOSDOpReply() argument
3320 ret = ceph_decode_pgid(&p, end, &m->pgid); in decode_MOSDOpReply()
3324 ceph_decode_64_safe(&p, end, m->flags, e_inval); in decode_MOSDOpReply()
3325 ceph_decode_32_safe(&p, end, m->result, e_inval); in decode_MOSDOpReply()
3329 ceph_decode_32_safe(&p, end, m->epoch, e_inval); in decode_MOSDOpReply()
3331 ceph_decode_32_safe(&p, end, m->num_ops, e_inval); in decode_MOSDOpReply()
3332 if (m->num_ops > ARRAY_SIZE(m->outdata_len)) in decode_MOSDOpReply()
3335 ceph_decode_need(&p, end, m->num_ops * sizeof(struct ceph_osd_op), in decode_MOSDOpReply()
3337 for (i = 0; i < m->num_ops; i++) { in decode_MOSDOpReply()
3340 m->outdata_len[i] = le32_to_cpu(op->payload_len); in decode_MOSDOpReply()
3344 ceph_decode_32_safe(&p, end, m->retry_attempt, e_inval); in decode_MOSDOpReply()
3345 for (i = 0; i < m->num_ops; i++) in decode_MOSDOpReply()
3346 ceph_decode_32_safe(&p, end, m->rval[i], e_inval); in decode_MOSDOpReply()
3349 ceph_decode_need(&p, end, sizeof(m->replay_version), e_inval); in decode_MOSDOpReply()
3350 memcpy(&m->replay_version, p, sizeof(m->replay_version)); in decode_MOSDOpReply()
3351 p += sizeof(m->replay_version); in decode_MOSDOpReply()
3352 ceph_decode_64_safe(&p, end, m->user_version, e_inval); in decode_MOSDOpReply()
3354 m->replay_version = bad_replay_version; /* struct */ in decode_MOSDOpReply()
3355 m->user_version = le64_to_cpu(m->replay_version.version); in decode_MOSDOpReply()
3368 ret = ceph_redirect_decode(&p, end, &m->redirect); in decode_MOSDOpReply()
3372 ceph_oloc_init(&m->redirect.oloc); in decode_MOSDOpReply()
3389 struct MOSDOpReply m; in handle_reply() local
3411 m.redirect.oloc.pool_ns = req->r_t.target_oloc.pool_ns; in handle_reply()
3412 ret = decode_MOSDOpReply(msg, &m); in handle_reply()
3413 m.redirect.oloc.pool_ns = NULL; in handle_reply()
3421 __func__, req, req->r_tid, m.flags, m.pgid.pool, m.pgid.seed, in handle_reply()
3422 m.epoch, m.retry_attempt, le32_to_cpu(m.replay_version.epoch), in handle_reply()
3423 le64_to_cpu(m.replay_version.version), m.user_version); in handle_reply()
3425 if (m.retry_attempt >= 0) { in handle_reply()
3426 if (m.retry_attempt != req->r_attempts - 1) { in handle_reply()
3428 req, req->r_tid, m.retry_attempt, in handle_reply()
3436 if (!ceph_oloc_empty(&m.redirect.oloc)) { in handle_reply()
3438 m.redirect.oloc.pool); in handle_reply()
3446 req->r_t.target_oloc.pool = m.redirect.oloc.pool; in handle_reply()
3453 if (m.num_ops != req->r_num_ops) { in handle_reply()
3454 pr_err("num_ops %d != %d for tid %llu\n", m.num_ops, in handle_reply()
3460 req->r_tid, i, m.rval[i], m.outdata_len[i]); in handle_reply()
3461 req->r_ops[i].rval = m.rval[i]; in handle_reply()
3462 req->r_ops[i].outdata_len = m.outdata_len[i]; in handle_reply()
3463 data_len += m.outdata_len[i]; in handle_reply()
3471 req, req->r_tid, m.result, data_len); in handle_reply()
3477 WARN_ON(!(m.flags & CEPH_OSD_FLAG_ONDISK)); in handle_reply()
3478 req->r_result = m.result ?: data_len; in handle_reply()
3921 static int decode_MOSDBackoff(const struct ceph_msg *msg, struct MOSDBackoff *m) in decode_MOSDBackoff() argument
3933 ret = ceph_decode_pgid(&p, end, &m->spgid.pgid); in decode_MOSDBackoff()
3937 ceph_decode_8_safe(&p, end, m->spgid.shard, e_inval); in decode_MOSDBackoff()
3938 ceph_decode_32_safe(&p, end, m->map_epoch, e_inval); in decode_MOSDBackoff()
3939 ceph_decode_8_safe(&p, end, m->op, e_inval); in decode_MOSDBackoff()
3940 ceph_decode_64_safe(&p, end, m->id, e_inval); in decode_MOSDBackoff()
3942 m->begin = kzalloc(sizeof(*m->begin), GFP_NOIO); in decode_MOSDBackoff()
3943 if (!m->begin) in decode_MOSDBackoff()
3946 ret = decode_hoid(&p, end, m->begin); in decode_MOSDBackoff()
3948 free_hoid(m->begin); in decode_MOSDBackoff()
3952 m->end = kzalloc(sizeof(*m->end), GFP_NOIO); in decode_MOSDBackoff()
3953 if (!m->end) { in decode_MOSDBackoff()
3954 free_hoid(m->begin); in decode_MOSDBackoff()
3958 ret = decode_hoid(&p, end, m->end); in decode_MOSDBackoff()
3960 free_hoid(m->begin); in decode_MOSDBackoff()
3961 free_hoid(m->end); in decode_MOSDBackoff()
4009 static void handle_backoff_block(struct ceph_osd *osd, struct MOSDBackoff *m) in handle_backoff_block() argument
4016 m->spgid.pgid.pool, m->spgid.pgid.seed, m->spgid.shard, m->id); in handle_backoff_block()
4018 spg = lookup_spg_mapping(&osd->o_backoff_mappings, &m->spgid); in handle_backoff_block()
4025 spg->spgid = m->spgid; /* struct */ in handle_backoff_block()
4034 backoff->spgid = m->spgid; /* struct */ in handle_backoff_block()
4035 backoff->id = m->id; in handle_backoff_block()
4036 backoff->begin = m->begin; in handle_backoff_block()
4037 m->begin = NULL; /* backoff now owns this */ in handle_backoff_block()
4038 backoff->end = m->end; in handle_backoff_block()
4039 m->end = NULL; /* ditto */ in handle_backoff_block()
4048 msg = create_backoff_message(backoff, m->map_epoch); in handle_backoff_block()
4069 const struct MOSDBackoff *m) in handle_backoff_unblock() argument
4076 m->spgid.pgid.pool, m->spgid.pgid.seed, m->spgid.shard, m->id); in handle_backoff_unblock()
4078 backoff = lookup_backoff_by_id(&osd->o_backoffs_by_id, m->id); in handle_backoff_unblock()
4081 __func__, osd->o_osd, m->spgid.pgid.pool, in handle_backoff_unblock()
4082 m->spgid.pgid.seed, m->spgid.shard, m->id); in handle_backoff_unblock()
4086 if (hoid_compare(backoff->begin, m->begin) && in handle_backoff_unblock()
4087 hoid_compare(backoff->end, m->end)) { in handle_backoff_unblock()
4089 __func__, osd->o_osd, m->spgid.pgid.pool, in handle_backoff_unblock()
4090 m->spgid.pgid.seed, m->spgid.shard, m->id); in handle_backoff_unblock()
4110 if (!ceph_spg_compare(&req->r_t.spgid, &m->spgid)) { in handle_backoff_unblock()
4115 if (target_contained_by(&req->r_t, m->begin, m->end)) { in handle_backoff_unblock()
4129 struct MOSDBackoff m; in handle_backoff() local
4141 ret = decode_MOSDBackoff(msg, &m); in handle_backoff()
4148 switch (m.op) { in handle_backoff()
4150 handle_backoff_block(osd, &m); in handle_backoff()
4153 handle_backoff_unblock(osd, &m); in handle_backoff()
4156 pr_err("%s osd%d unknown op %d\n", __func__, osd->o_osd, m.op); in handle_backoff()
4159 free_hoid(m.begin); in handle_backoff()
4160 free_hoid(m.end); in handle_backoff()
5130 struct ceph_msg *m = NULL; in get_reply() local
5159 m = ceph_msg_new(CEPH_MSG_OSD_OPREPLY, front_len, GFP_NOFS, in get_reply()
5161 if (!m) in get_reply()
5164 req->r_reply = m; in get_reply()
5171 m = NULL; in get_reply()
5176 m = ceph_msg_get(req->r_reply); in get_reply()
5177 dout("get_reply tid %lld %p\n", tid, m); in get_reply()
5183 return m; in get_reply()
5191 struct ceph_msg *m; in alloc_msg_with_page_vector() local
5196 m = ceph_msg_new(type, front_len, GFP_NOIO, false); in alloc_msg_with_page_vector()
5197 if (!m) in alloc_msg_with_page_vector()
5207 ceph_msg_put(m); in alloc_msg_with_page_vector()
5213 ceph_osdc_msg_data_add(m, &osd_data); in alloc_msg_with_page_vector()
5216 return m; in alloc_msg_with_page_vector()