Lines Matching refs:op
372 struct ceph_osd_req_op *op; in osd_req_op_data_release() local
375 op = &osd_req->r_ops[which]; in osd_req_op_data_release()
377 switch (op->op) { in osd_req_op_data_release()
381 ceph_osd_data_release(&op->extent.osd_data); in osd_req_op_data_release()
384 ceph_osd_data_release(&op->cls.request_info); in osd_req_op_data_release()
385 ceph_osd_data_release(&op->cls.request_data); in osd_req_op_data_release()
386 ceph_osd_data_release(&op->cls.response_data); in osd_req_op_data_release()
390 ceph_osd_data_release(&op->xattr.osd_data); in osd_req_op_data_release()
393 ceph_osd_data_release(&op->raw_data_in); in osd_req_op_data_release()
396 ceph_osd_data_release(&op->notify_ack.request_data); in osd_req_op_data_release()
399 ceph_osd_data_release(&op->notify.request_data); in osd_req_op_data_release()
400 ceph_osd_data_release(&op->notify.response_data); in osd_req_op_data_release()
403 ceph_osd_data_release(&op->list_watchers.response_data); in osd_req_op_data_release()
406 ceph_osd_data_release(&op->copy_from.osd_data); in osd_req_op_data_release()
640 #define GENERATE_CASE(op, opcode, str) case CEPH_OSD_OP_##op: return true; in osd_req_opcode_valid() argument
652 struct ceph_osd_req_op *op; in get_num_data_items() local
657 for (op = req->r_ops; op != &req->r_ops[req->r_num_ops]; op++) { in get_num_data_items()
658 switch (op->op) { in get_num_data_items()
687 WARN_ON(!osd_req_opcode_valid(op->op)); in get_num_data_items()
716 struct ceph_osd_req_op *op; in osd_req_op_init() local
721 op = &osd_req->r_ops[which]; in osd_req_op_init()
722 memset(op, 0, sizeof (*op)); in osd_req_op_init()
723 op->op = opcode; in osd_req_op_init()
724 op->flags = flags; in osd_req_op_init()
726 return op; in osd_req_op_init()
735 struct ceph_osd_req_op *op = osd_req_op_init(osd_req, which, in osd_req_op_extent_init() local
743 op->extent.offset = offset; in osd_req_op_extent_init()
744 op->extent.length = length; in osd_req_op_extent_init()
745 op->extent.truncate_size = truncate_size; in osd_req_op_extent_init()
746 op->extent.truncate_seq = truncate_seq; in osd_req_op_extent_init()
750 op->indata_len = payload_len; in osd_req_op_extent_init()
757 struct ceph_osd_req_op *op; in osd_req_op_extent_update() local
761 op = &osd_req->r_ops[which]; in osd_req_op_extent_update()
762 previous = op->extent.length; in osd_req_op_extent_update()
768 op->extent.length = length; in osd_req_op_extent_update()
769 if (op->op == CEPH_OSD_OP_WRITE || op->op == CEPH_OSD_OP_WRITEFULL) in osd_req_op_extent_update()
770 op->indata_len -= previous - length; in osd_req_op_extent_update()
777 struct ceph_osd_req_op *op, *prev_op; in osd_req_op_extent_dup_last() local
782 op = osd_req_op_init(osd_req, which + 1, prev_op->op, prev_op->flags); in osd_req_op_extent_dup_last()
784 op->indata_len = prev_op->indata_len; in osd_req_op_extent_dup_last()
785 op->outdata_len = prev_op->outdata_len; in osd_req_op_extent_dup_last()
786 op->extent = prev_op->extent; in osd_req_op_extent_dup_last()
788 op->extent.offset += offset_inc; in osd_req_op_extent_dup_last()
789 op->extent.length -= offset_inc; in osd_req_op_extent_dup_last()
791 if (op->op == CEPH_OSD_OP_WRITE || op->op == CEPH_OSD_OP_WRITEFULL) in osd_req_op_extent_dup_last()
792 op->indata_len -= offset_inc; in osd_req_op_extent_dup_last()
799 struct ceph_osd_req_op *op; in osd_req_op_cls_init() local
805 op = osd_req_op_init(osd_req, which, CEPH_OSD_OP_CALL, 0); in osd_req_op_cls_init()
811 op->cls.class_name = class; in osd_req_op_cls_init()
814 op->cls.class_len = size; in osd_req_op_cls_init()
820 op->cls.method_name = method; in osd_req_op_cls_init()
823 op->cls.method_len = size; in osd_req_op_cls_init()
830 op->indata_len = payload_len; in osd_req_op_cls_init()
843 struct ceph_osd_req_op *op = osd_req_op_init(osd_req, which, in osd_req_op_xattr_init() local
856 op->xattr.name_len = payload_len; in osd_req_op_xattr_init()
861 op->xattr.value_len = size; in osd_req_op_xattr_init()
867 op->xattr.cmp_op = cmp_op; in osd_req_op_xattr_init()
868 op->xattr.cmp_mode = cmp_mode; in osd_req_op_xattr_init()
870 ceph_osd_data_pagelist_init(&op->xattr.osd_data, pagelist); in osd_req_op_xattr_init()
871 op->indata_len = payload_len; in osd_req_op_xattr_init()
886 struct ceph_osd_req_op *op; in osd_req_op_watch_init() local
888 op = osd_req_op_init(req, which, CEPH_OSD_OP_WATCH, 0); in osd_req_op_watch_init()
889 op->watch.cookie = cookie; in osd_req_op_watch_init()
890 op->watch.op = watch_opcode; in osd_req_op_watch_init()
891 op->watch.gen = gen; in osd_req_op_watch_init()
901 struct ceph_osd_req_op *op; in osd_req_op_notify_init() local
903 op = osd_req_op_init(req, which, CEPH_OSD_OP_NOTIFY, 0); in osd_req_op_notify_init()
904 op->notify.cookie = cookie; in osd_req_op_notify_init()
906 ceph_osd_data_pagelist_init(&op->notify.request_data, request_pl); in osd_req_op_notify_init()
907 op->indata_len = request_pl->length; in osd_req_op_notify_init()
919 struct ceph_osd_req_op *op; in osd_req_op_alloc_hint_init() local
921 op = osd_req_op_init(osd_req, which, CEPH_OSD_OP_SETALLOCHINT, 0); in osd_req_op_alloc_hint_init()
922 op->alloc_hint.expected_object_size = expected_object_size; in osd_req_op_alloc_hint_init()
923 op->alloc_hint.expected_write_size = expected_write_size; in osd_req_op_alloc_hint_init()
924 op->alloc_hint.flags = flags; in osd_req_op_alloc_hint_init()
931 op->flags |= CEPH_OSD_OP_FLAG_FAILOK; in osd_req_op_alloc_hint_init()
962 switch (src->op) { in osd_req_encode_op()
985 dst->watch.op = src->watch.op; in osd_req_encode_op()
1022 ceph_osd_op_name(src->op)); in osd_req_encode_op()
1028 dst->op = cpu_to_le16(src->op); in osd_req_encode_op()
1982 struct ceph_osd_req_op *op; in setup_request_data() local
1988 for (op = req->r_ops; op != &req->r_ops[req->r_num_ops]; op++) { in setup_request_data()
1989 switch (op->op) { in setup_request_data()
1993 WARN_ON(op->indata_len != op->extent.length); in setup_request_data()
1995 &op->extent.osd_data); in setup_request_data()
1999 WARN_ON(op->indata_len != op->xattr.name_len + in setup_request_data()
2000 op->xattr.value_len); in setup_request_data()
2002 &op->xattr.osd_data); in setup_request_data()
2006 &op->notify_ack.request_data); in setup_request_data()
2010 &op->copy_from.osd_data); in setup_request_data()
2016 &op->raw_data_in); in setup_request_data()
2020 &op->extent.osd_data); in setup_request_data()
2024 &op->list_watchers.response_data); in setup_request_data()
2029 WARN_ON(op->indata_len != op->cls.class_len + in setup_request_data()
2030 op->cls.method_len + in setup_request_data()
2031 op->cls.indata_len); in setup_request_data()
2033 &op->cls.request_info); in setup_request_data()
2036 &op->cls.request_data); in setup_request_data()
2039 &op->cls.response_data); in setup_request_data()
2043 &op->notify.request_data); in setup_request_data()
2045 &op->notify.response_data); in setup_request_data()
3000 WARN_ON(req->r_ops[0].op != CEPH_OSD_OP_NOTIFY || in linger_commit_cb()
3632 struct ceph_osd_op *op = p; in decode_MOSDOpReply() local
3634 m->outdata_len[i] = le32_to_cpu(op->payload_len); in decode_MOSDOpReply()
3635 p += sizeof(*op); in decode_MOSDOpReply()
4228 u8 op; member
4252 ceph_decode_8_safe(&p, end, m->op, e_inval); in decode_MOSDBackoff()
4461 switch (m.op) { in handle_backoff()
4469 pr_err("%s osd%d unknown op %d\n", __func__, osd->o_osd, m.op); in handle_backoff()
4770 struct ceph_osd_req_op *op; in osd_req_op_notify_ack_init() local
4774 op = osd_req_op_init(req, which, CEPH_OSD_OP_NOTIFY_ACK, 0); in osd_req_op_notify_ack_init()
4793 ceph_osd_data_pagelist_init(&op->notify_ack.request_data, pl); in osd_req_op_notify_ack_init()
4794 op->indata_len = pl->length; in osd_req_op_notify_ack_init()
5264 struct ceph_osd_req_op *op; in osd_req_op_copy_from_init() local
5272 op = osd_req_op_init(req, 0, CEPH_OSD_OP_COPY_FROM2, in osd_req_op_copy_from_init()
5274 op->copy_from.snapid = src_snapid; in osd_req_op_copy_from_init()
5275 op->copy_from.src_version = src_version; in osd_req_op_copy_from_init()
5276 op->copy_from.flags = copy_from_flags; in osd_req_op_copy_from_init()
5277 op->copy_from.src_fadvise_flags = src_fadvise_flags; in osd_req_op_copy_from_init()
5285 op->indata_len = PAGE_SIZE - (end - p); in osd_req_op_copy_from_init()
5287 ceph_osd_data_pages_init(&op->copy_from.osd_data, pages, in osd_req_op_copy_from_init()
5288 op->indata_len, 0, false, true); in osd_req_op_copy_from_init()