ceph_osd_request
static void rbd_osd_submit(struct ceph_osd_request *osd_req)
static void rbd_osd_req_callback(struct ceph_osd_request *osd_req)
static void rbd_osd_format_read(struct ceph_osd_request *osd_req)
static void rbd_osd_format_write(struct ceph_osd_request *osd_req)
static struct ceph_osd_request *
struct ceph_osd_request *req;
static struct ceph_osd_request *
struct ceph_osd_request *osd_req;
struct ceph_osd_request, r_private_item);
struct ceph_osd_request *osd_req)
static void rbd_object_map_callback(struct ceph_osd_request *osd_req)
static int rbd_cls_object_map_update(struct ceph_osd_request *req,
struct ceph_osd_request *req;
static void rbd_osd_setup_data(struct ceph_osd_request *osd_req, int which)
static int rbd_osd_setup_stat(struct ceph_osd_request *osd_req, int which)
static int rbd_osd_setup_copyup(struct ceph_osd_request *osd_req, int which,
static void __rbd_osd_setup_write_ops(struct ceph_osd_request *osd_req,
static void __rbd_osd_setup_discard_ops(struct ceph_osd_request *osd_req,
static void __rbd_osd_setup_zeroout_ops(struct ceph_osd_request *osd_req,
static void rbd_osd_setup_write_ops(struct ceph_osd_request *osd_req,
struct ceph_osd_request *osd_req;
struct ceph_osd_request *osd_req;
struct ceph_osd_request *osd_req;
struct ceph_osd_request *osd_req;
struct ceph_osd_request *req;
struct ceph_osd_request *req = NULL;
static void finish_netfs_read(struct ceph_osd_request *req)
struct ceph_osd_request *req = NULL;
struct ceph_osd_request *rd_req = NULL, *wr_req = NULL;
struct ceph_osd_request *req = NULL;
struct ceph_osd_request *req;
static void writepages_finish(struct ceph_osd_request *req)
struct ceph_osd_request *req;
struct ceph_osd_request *req;
static void ceph_aio_complete_req(struct ceph_osd_request *req)
struct ceph_osd_request *orig_req = aio_work->req;
struct ceph_osd_request *req;
struct ceph_osd_request *req;
struct ceph_osd_request,
struct ceph_osd_request *req;
struct ceph_osd_request *req;
static struct ceph_osd_request *
struct ceph_osd_request *req;
struct ceph_osd_request *req;
int ceph_cls_assert_locked(struct ceph_osd_request *req, int which,
struct ceph_osd_request;
typedef void (*ceph_osdc_callback_t)(struct ceph_osd_request *);
struct ceph_osd_request *reg_req;
struct ceph_osd_request *ping_req;
struct ceph_osd_request *__oreq = (oreq); \
struct ceph_osd_req_op *osd_req_op_init(struct ceph_osd_request *osd_req,
extern void osd_req_op_raw_data_in_pages(struct ceph_osd_request *,
extern void osd_req_op_extent_init(struct ceph_osd_request *osd_req,
extern void osd_req_op_extent_update(struct ceph_osd_request *osd_req,
extern void osd_req_op_extent_dup_last(struct ceph_osd_request *osd_req,
struct ceph_osd_request *osd_req,
extern void osd_req_op_extent_osd_data_pages(struct ceph_osd_request *,
void osd_req_op_extent_osd_data_bio(struct ceph_osd_request *osd_req,
void osd_req_op_extent_osd_data_bvecs(struct ceph_osd_request *osd_req,
void osd_req_op_extent_osd_data_bvec_pos(struct ceph_osd_request *osd_req,
void osd_req_op_extent_osd_iter(struct ceph_osd_request *osd_req,
extern void osd_req_op_cls_request_data_pages(struct ceph_osd_request *,
void osd_req_op_cls_request_data_bvecs(struct ceph_osd_request *osd_req,
extern void osd_req_op_cls_response_data_pages(struct ceph_osd_request *,
int osd_req_op_cls_init(struct ceph_osd_request *osd_req, unsigned int which,
extern int osd_req_op_xattr_init(struct ceph_osd_request *osd_req, unsigned int which,
extern void osd_req_op_alloc_hint_init(struct ceph_osd_request *osd_req,
extern int osd_req_op_copy_from_init(struct ceph_osd_request *req,
extern struct ceph_osd_request *ceph_osdc_alloc_request(struct ceph_osd_client *osdc,
int ceph_osdc_alloc_messages(struct ceph_osd_request *req, gfp_t gfp);
extern struct ceph_osd_request *ceph_osdc_new_request(struct ceph_osd_client *,
extern void ceph_osdc_get_request(struct ceph_osd_request *req);
extern void ceph_osdc_put_request(struct ceph_osd_request *req);
struct ceph_osd_request *req);
extern void ceph_osdc_cancel_request(struct ceph_osd_request *req);
struct ceph_osd_request *req);
int ceph_cls_assert_locked(struct ceph_osd_request *req, int which,
static void dump_request(struct seq_file *s, struct ceph_osd_request *req)
struct ceph_osd_request *req =
rb_entry(n, struct ceph_osd_request, r_node);
struct ceph_osd_request *ceph_osdc_new_request(struct ceph_osd_client *osdc,
struct ceph_osd_request *req;
DEFINE_RB_FUNCS(request, struct ceph_osd_request, r_tid, r_node)
DEFINE_RB_FUNCS(request_mc, struct ceph_osd_request, r_tid, r_mc_node)
int (*fn)(struct ceph_osd_request *req, void *arg),
struct ceph_osd_request *req =
rb_entry(p, struct ceph_osd_request, r_node);
struct ceph_osd_request *req =
rb_entry(p, struct ceph_osd_request, r_node);
struct ceph_osd_request *req =
rb_entry(n, struct ceph_osd_request, r_node);
struct ceph_osd_request *req =
rb_entry(n, struct ceph_osd_request, r_node);
static void link_request(struct ceph_osd *osd, struct ceph_osd_request *req)
static void unlink_request(struct ceph_osd *osd, struct ceph_osd_request *req)
osd_req_op_raw_data_in(struct ceph_osd_request *osd_req, unsigned int which)
osd_req_op_extent_osd_data(struct ceph_osd_request *osd_req,
void osd_req_op_raw_data_in_pages(struct ceph_osd_request *osd_req,
static bool should_plug_request(struct ceph_osd_request *req)
static void setup_request_data(struct ceph_osd_request *req)
void osd_req_op_extent_osd_data_pages(struct ceph_osd_request *osd_req,
static void encode_request_partial(struct ceph_osd_request *req,
void osd_req_op_extent_osd_data_bio(struct ceph_osd_request *osd_req,
static void send_request(struct ceph_osd_request *req)
void osd_req_op_extent_osd_data_bvecs(struct ceph_osd_request *osd_req,
static void complete_request(struct ceph_osd_request *req, int err);
static void send_map_check(struct ceph_osd_request *req);
static void __submit_request(struct ceph_osd_request *req, bool wrlocked)
static void account_request(struct ceph_osd_request *req)
static void submit_request(struct ceph_osd_request *req, bool wrlocked)
static void finish_request(struct ceph_osd_request *req)
static void __complete_request(struct ceph_osd_request *req)
void osd_req_op_extent_osd_data_bvec_pos(struct ceph_osd_request *osd_req,
struct ceph_osd_request *req =
container_of(work, struct ceph_osd_request, r_complete_work);
static void complete_request(struct ceph_osd_request *req, int err)
static void cancel_map_check(struct ceph_osd_request *req)
struct ceph_osd_request *lookup_req;
static void cancel_request(struct ceph_osd_request *req)
static void abort_request(struct ceph_osd_request *req, int err)
static int abort_fn(struct ceph_osd_request *req, void *arg)
static int abort_on_full_fn(struct ceph_osd_request *req, void *arg)
static void check_pool_dne(struct ceph_osd_request *req)
void osd_req_op_extent_osd_iter(struct ceph_osd_request *osd_req,
struct ceph_osd_request *req;
static void send_map_check(struct ceph_osd_request *req)
struct ceph_osd_request *lookup_req;
struct ceph_osd_request *osd_req,
void osd_req_op_cls_request_data_pages(struct ceph_osd_request *osd_req,
static void cancel_linger_request(struct ceph_osd_request *req)
void osd_req_op_cls_request_data_bvecs(struct ceph_osd_request *osd_req,
static void linger_commit_cb(struct ceph_osd_request *req)
static void linger_reconnect_cb(struct ceph_osd_request *req)
struct ceph_osd_request *req;
static void linger_ping_cb(struct ceph_osd_request *req)
struct ceph_osd_request *req;
void osd_req_op_cls_response_data_pages(struct ceph_osd_request *osd_req,
struct ceph_osd_request *req =
rb_entry(p, struct ceph_osd_request, r_node);
struct ceph_osd_request *req =
rb_entry(p, struct ceph_osd_request, r_node);
static void osd_req_op_data_release(struct ceph_osd_request *osd_req,
struct ceph_osd_request *req;
struct ceph_osd_request *req =
rb_entry(n, struct ceph_osd_request, r_node);
struct ceph_osd_request *req =
rb_entry(n, struct ceph_osd_request, r_node);
struct ceph_osd_request *req =
rb_entry(n, struct ceph_osd_request, r_node);
struct ceph_osd_request *req =
rb_entry(n, struct ceph_osd_request, r_node);
struct ceph_osd_request *req =
rb_entry(n, struct ceph_osd_request, r_node);
struct ceph_osd_request *req)
void ceph_osdc_cancel_request(struct ceph_osd_request *req)
static int wait_request_timeout(struct ceph_osd_request *req,
struct ceph_osd_request *req)
struct ceph_osd_request *req =
rb_entry(p, struct ceph_osd_request, r_node);
static void request_release_checks(struct ceph_osd_request *req)
struct ceph_osd_request *req;
static int osd_req_op_notify_ack_init(struct ceph_osd_request *req, int which,
struct ceph_osd_request *req = container_of(kref,
struct ceph_osd_request, r_kref);
struct ceph_osd_request *req;
static void link_request(struct ceph_osd *osd, struct ceph_osd_request *req);
static void unlink_request(struct ceph_osd *osd, struct ceph_osd_request *req);
struct ceph_osd_request *req;
void ceph_osdc_get_request(struct ceph_osd_request *req)
struct ceph_osd_request *req;
void ceph_osdc_put_request(struct ceph_osd_request *req)
int osd_req_op_copy_from_init(struct ceph_osd_request *req,
static void request_init(struct ceph_osd_request *req)
size_t size = sizeof(struct ceph_osd_request) +
static u64 sparse_data_requested(struct ceph_osd_request *req)
struct ceph_osd_request *req;
struct ceph_osd_request *ceph_osdc_alloc_request(struct ceph_osd_client *osdc,
struct ceph_osd_request *req;
struct ceph_osd_request *req;
static int __ceph_osdc_alloc_messages(struct ceph_osd_request *req, gfp_t gfp,
static void get_num_data_items(struct ceph_osd_request *req,
int ceph_osdc_alloc_messages(struct ceph_osd_request *req, gfp_t gfp)
osd_req_op_init(struct ceph_osd_request *osd_req, unsigned int which,
void osd_req_op_extent_init(struct ceph_osd_request *osd_req,
void osd_req_op_extent_update(struct ceph_osd_request *osd_req,
void osd_req_op_extent_dup_last(struct ceph_osd_request *osd_req,
int osd_req_op_cls_init(struct ceph_osd_request *osd_req, unsigned int which,
int osd_req_op_xattr_init(struct ceph_osd_request *osd_req, unsigned int which,
static void osd_req_op_watch_init(struct ceph_osd_request *req, int which,
static void osd_req_op_notify_init(struct ceph_osd_request *req, int which,
void osd_req_op_alloc_hint_init(struct ceph_osd_request *osd_req,