Lines Matching refs:opcode
435 static bool osd_req_opcode_valid(u16 opcode) in osd_req_opcode_valid() argument
437 switch (opcode) { in osd_req_opcode_valid()
438 #define GENERATE_CASE(op, opcode, str) case CEPH_OSD_OP_##op: return true; in osd_req_opcode_valid() argument
453 u16 opcode) in _osd_req_op_init() argument
458 BUG_ON(!osd_req_opcode_valid(opcode)); in _osd_req_op_init()
462 op->op = opcode; in _osd_req_op_init()
468 unsigned int which, u16 opcode) in osd_req_op_init() argument
470 (void)_osd_req_op_init(osd_req, which, opcode); in osd_req_op_init()
475 unsigned int which, u16 opcode, in osd_req_op_extent_init() argument
479 struct ceph_osd_req_op *op = _osd_req_op_init(osd_req, which, opcode); in osd_req_op_extent_init()
482 BUG_ON(opcode != CEPH_OSD_OP_READ && opcode != CEPH_OSD_OP_WRITE && in osd_req_op_extent_init()
483 opcode != CEPH_OSD_OP_ZERO && opcode != CEPH_OSD_OP_TRUNCATE); in osd_req_op_extent_init()
489 if (opcode == CEPH_OSD_OP_WRITE) in osd_req_op_extent_init()
516 u16 opcode, const char *class, const char *method) in osd_req_op_cls_init() argument
518 struct ceph_osd_req_op *op = _osd_req_op_init(osd_req, which, opcode); in osd_req_op_cls_init()
523 BUG_ON(opcode != CEPH_OSD_OP_CALL); in osd_req_op_cls_init()
552 u16 opcode, const char *name, const void *value, in osd_req_op_xattr_init() argument
555 struct ceph_osd_req_op *op = _osd_req_op_init(osd_req, which, opcode); in osd_req_op_xattr_init()
559 BUG_ON(opcode != CEPH_OSD_OP_SETXATTR && opcode != CEPH_OSD_OP_CMPXATTR); in osd_req_op_xattr_init()
585 unsigned int which, u16 opcode, in osd_req_op_watch_init() argument
588 struct ceph_osd_req_op *op = _osd_req_op_init(osd_req, which, opcode); in osd_req_op_watch_init()
590 BUG_ON(opcode != CEPH_OSD_OP_NOTIFY_ACK && opcode != CEPH_OSD_OP_WATCH); in osd_req_op_watch_init()
594 if (opcode == CEPH_OSD_OP_WATCH && flag) in osd_req_op_watch_init()
758 int opcode, int flags, in ceph_osdc_new_request() argument
770 BUG_ON(opcode != CEPH_OSD_OP_READ && opcode != CEPH_OSD_OP_WRITE && in ceph_osdc_new_request()
771 opcode != CEPH_OSD_OP_ZERO && opcode != CEPH_OSD_OP_TRUNCATE && in ceph_osdc_new_request()
772 opcode != CEPH_OSD_OP_CREATE && opcode != CEPH_OSD_OP_DELETE); in ceph_osdc_new_request()
788 if (opcode == CEPH_OSD_OP_CREATE || opcode == CEPH_OSD_OP_DELETE) { in ceph_osdc_new_request()
789 osd_req_op_init(req, which, opcode); in ceph_osdc_new_request()
802 osd_req_op_extent_init(req, which, opcode, objoff, objlen, in ceph_osdc_new_request()
2321 u8 opcode = event_work->opcode; in do_event_work() local
2324 event->cb(ver, notify_id, opcode, event->data); in do_event_work()
2340 u8 opcode; in handle_watch_notify() local
2348 ceph_decode_8_safe(&p, end, opcode, bad); in handle_watch_notify()
2373 event_work->opcode = opcode; in handle_watch_notify()