osd_client.h revision 2169aea649c08374bec7d220a3b8f64712275356
1f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil#ifndef _FS_CEPH_OSD_CLIENT_H 2f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil#define _FS_CEPH_OSD_CLIENT_H 3f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil 4f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil#include <linux/completion.h> 5415e49a9c4faf1a1480b1497da2037608e5aa2c5Sage Weil#include <linux/kref.h> 6f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil#include <linux/mempool.h> 7f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil#include <linux/rbtree.h> 8f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil 96c4a19158b96ea1fb8acbe0c1d5493d9dcd2f147Alex Elder#include <linux/ceph/types.h> 106c4a19158b96ea1fb8acbe0c1d5493d9dcd2f147Alex Elder#include <linux/ceph/osdmap.h> 116c4a19158b96ea1fb8acbe0c1d5493d9dcd2f147Alex Elder#include <linux/ceph/messenger.h> 126c4a19158b96ea1fb8acbe0c1d5493d9dcd2f147Alex Elder#include <linux/ceph/auth.h> 13c885837f7d4f8c4f5cb2a744cc6929bc078e9dc0Alex Elder#include <linux/ceph/pagelist.h> 14f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil 15224736d9113ab4a7cf3f05c05377492bd99b4b02Stratos Psomadakis/* 16224736d9113ab4a7cf3f05c05377492bd99b4b02Stratos Psomadakis * Maximum object name size 17224736d9113ab4a7cf3f05c05377492bd99b4b02Stratos Psomadakis * (must be at least as big as RBD_MAX_MD_NAME_LEN -- currently 100) 18224736d9113ab4a7cf3f05c05377492bd99b4b02Stratos Psomadakis */ 19224736d9113ab4a7cf3f05c05377492bd99b4b02Stratos Psomadakis#define MAX_OBJ_NAME_SIZE 100 20224736d9113ab4a7cf3f05c05377492bd99b4b02Stratos Psomadakis 21f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weilstruct ceph_msg; 22f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weilstruct ceph_snap_context; 23f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weilstruct ceph_osd_request; 24f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weilstruct ceph_osd_client; 254e7a5dcd1bbab6560fbc8ada29a840e7a20ed7bcSage Weilstruct ceph_authorizer; 26f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil 27f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil/* 28f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil * completion callback for async writepages 29f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil */ 30f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weiltypedef void (*ceph_osdc_callback_t)(struct ceph_osd_request *, 31f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct ceph_msg *); 32f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil 33f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil/* a given osd we're communicating with */ 34f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weilstruct ceph_osd { 35f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil atomic_t o_ref; 36f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct ceph_osd_client *o_osdc; 37f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil int o_osd; 38f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil int o_incarnation; 39f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct rb_node o_node; 40f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct ceph_connection o_con; 41f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct list_head o_requests; 42a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh struct list_head o_linger_requests; 43f5a2041bd96c9f05ff10172b9c814c14f247084eYehuda Sadeh struct list_head o_osd_lru; 446c4a19158b96ea1fb8acbe0c1d5493d9dcd2f147Alex Elder struct ceph_auth_handshake o_auth; 45f5a2041bd96c9f05ff10172b9c814c14f247084eYehuda Sadeh unsigned long lru_ttl; 46422d2cb8f9afadba1ecd3614f658b6daaaa480fbYehuda Sadeh int o_marked_for_keepalive; 47422d2cb8f9afadba1ecd3614f658b6daaaa480fbYehuda Sadeh struct list_head o_keepalive_item; 48f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil}; 49f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil 50f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil/* an in-flight request */ 51f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weilstruct ceph_osd_request { 52f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil u64 r_tid; /* unique for this client */ 53f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct rb_node r_node; 54422d2cb8f9afadba1ecd3614f658b6daaaa480fbYehuda Sadeh struct list_head r_req_lru_item; 55f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct list_head r_osd_item; 56a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh struct list_head r_linger_item; 57a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh struct list_head r_linger_osd; 58f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct ceph_osd *r_osd; 595b191d9914eb68257f47de9d5bfe099b77f0687cSage Weil struct ceph_pg r_pgid; 60d85b705663905b3dae30007f824355bdcfcf3f00Sage Weil int r_pg_osds[CEPH_PG_MAX_SIZE]; 61d85b705663905b3dae30007f824355bdcfcf3f00Sage Weil int r_num_pg_osds; 62f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil 630d59ab81c3d3adf466c3fd37d7fb6d46b05d1fd4Yehuda Sadeh struct ceph_connection *r_con_filling_msg; 64350b1c32ea58d29e25d63fc25e92dd48f9339546Sage Weil 65f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct ceph_msg *r_request, *r_reply; 66f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil int r_result; 67f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil int r_flags; /* any additional flags for the osd */ 68f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil u32 r_sent; /* >0 if r_request is sending/sent */ 69350b1c32ea58d29e25d63fc25e92dd48f9339546Sage Weil int r_got_reply; 70a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh int r_linger; 71f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil 72f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct ceph_osd_client *r_osdc; 73415e49a9c4faf1a1480b1497da2037608e5aa2c5Sage Weil struct kref r_kref; 74f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil bool r_mempool; 75f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct completion r_completion, r_safe_completion; 76f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil ceph_osdc_callback_t r_callback, r_safe_callback; 77f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct ceph_eversion r_reassert_version; 78f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct list_head r_unsafe_item; 79f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil 80f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct inode *r_inode; /* for use by callbacks */ 813d14c5d2b6e15c21d8e5467dc62d33127c23a644Yehuda Sadeh void *r_priv; /* ditto */ 82f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil 83224736d9113ab4a7cf3f05c05377492bd99b4b02Stratos Psomadakis char r_oid[MAX_OBJ_NAME_SIZE]; /* object name */ 84f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil int r_oid_len; 852169aea649c08374bec7d220a3b8f64712275356Sage Weil u64 r_snapid; 863dd72fc0e6dc49c79fa9e7cd7c654deac7ccaa29Sage Weil unsigned long r_stamp; /* send OR check time */ 87f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil 88f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct ceph_file_layout r_file_layout; 89f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct ceph_snap_context *r_snapc; /* snap context for writes */ 90f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil unsigned r_num_pages; /* size of page array (follows) */ 91b7495fc2ff941db6a118a93ab8d61149e3f4cef8Sage Weil unsigned r_page_alignment; /* io offset in first page */ 92f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct page **r_pages; /* pages for data payload */ 93f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil int r_pages_from_pool; 94f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil int r_own_pages; /* if true, i own page list */ 9568b4476b0bc13fef18266b4140309a30e86739d2Yehuda Sadeh#ifdef CONFIG_BLOCK 9668b4476b0bc13fef18266b4140309a30e86739d2Yehuda Sadeh struct bio *r_bio; /* instead of pages */ 9768b4476b0bc13fef18266b4140309a30e86739d2Yehuda Sadeh#endif 9868b4476b0bc13fef18266b4140309a30e86739d2Yehuda Sadeh 99c885837f7d4f8c4f5cb2a744cc6929bc078e9dc0Alex Elder struct ceph_pagelist r_trail; /* trailing part of the data */ 100f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil}; 101f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil 102a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadehstruct ceph_osd_event { 103a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh u64 cookie; 104a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh int one_shot; 105a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh struct ceph_osd_client *osdc; 106a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh void (*cb)(u64, u64, u8, void *); 107a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh void *data; 108a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh struct rb_node node; 109a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh struct list_head osd_node; 110a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh struct kref kref; 111a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh}; 112a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh 113a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadehstruct ceph_osd_event_work { 114a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh struct work_struct work; 115a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh struct ceph_osd_event *event; 116a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh u64 ver; 117a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh u64 notify_id; 118a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh u8 opcode; 119a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh}; 120a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh 121f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weilstruct ceph_osd_client { 122f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct ceph_client *client; 123f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil 124f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct ceph_osdmap *osdmap; /* current map */ 125f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct rw_semaphore map_sem; 126f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct completion map_waiters; 127f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil u64 last_requested_map; 128f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil 129f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct mutex request_mutex; 130f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct rb_root osds; /* osds */ 131f5a2041bd96c9f05ff10172b9c814c14f247084eYehuda Sadeh struct list_head osd_lru; /* idle osds */ 132f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil u64 timeout_tid; /* tid of timeout triggering rq */ 133f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil u64 last_tid; /* tid of last request */ 134f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct rb_root requests; /* pending requests */ 1356f6c7006755b667f9f6c1f3b6f08cd65f75cc471Sage Weil struct list_head req_lru; /* in-flight lru */ 1366f6c7006755b667f9f6c1f3b6f08cd65f75cc471Sage Weil struct list_head req_unsent; /* unsent/need-resend queue */ 1376f6c7006755b667f9f6c1f3b6f08cd65f75cc471Sage Weil struct list_head req_notarget; /* map to no osd */ 138a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh struct list_head req_linger; /* lingering requests */ 139f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil int num_requests; 140f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct delayed_work timeout_work; 141f5a2041bd96c9f05ff10172b9c814c14f247084eYehuda Sadeh struct delayed_work osds_timeout_work; 142039934b895c89c2bb40aa5132efe00e60b70efcaSage Weil#ifdef CONFIG_DEBUG_FS 143f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct dentry *debugfs_file; 144039934b895c89c2bb40aa5132efe00e60b70efcaSage Weil#endif 145f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil 146f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil mempool_t *req_mempool; 147f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil 1480d59ab81c3d3adf466c3fd37d7fb6d46b05d1fd4Yehuda Sadeh struct ceph_msgpool msgpool_op; 149c16e786927b977cb880873214bbd815e8d5ec4baSage Weil struct ceph_msgpool msgpool_op_reply; 150a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh 151a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh spinlock_t event_lock; 152a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh struct rb_root event_tree; 153a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh u64 event_count; 154a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh 155a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh struct workqueue_struct *notify_wq; 156f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil}; 157f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil 15868b4476b0bc13fef18266b4140309a30e86739d2Yehuda Sadehstruct ceph_osd_req_op { 15968b4476b0bc13fef18266b4140309a30e86739d2Yehuda Sadeh u16 op; /* CEPH_OSD_OP_* */ 160e7e319a9c51409c7effe34333ea26facf2fab9e1Alex Elder u32 payload_len; 16168b4476b0bc13fef18266b4140309a30e86739d2Yehuda Sadeh union { 16268b4476b0bc13fef18266b4140309a30e86739d2Yehuda Sadeh struct { 16368b4476b0bc13fef18266b4140309a30e86739d2Yehuda Sadeh u64 offset, length; 16468b4476b0bc13fef18266b4140309a30e86739d2Yehuda Sadeh u64 truncate_size; 16568b4476b0bc13fef18266b4140309a30e86739d2Yehuda Sadeh u32 truncate_seq; 16668b4476b0bc13fef18266b4140309a30e86739d2Yehuda Sadeh } extent; 16768b4476b0bc13fef18266b4140309a30e86739d2Yehuda Sadeh struct { 16868b4476b0bc13fef18266b4140309a30e86739d2Yehuda Sadeh const char *name; 16968b4476b0bc13fef18266b4140309a30e86739d2Yehuda Sadeh const char *val; 170e7e319a9c51409c7effe34333ea26facf2fab9e1Alex Elder u32 name_len; 17168b4476b0bc13fef18266b4140309a30e86739d2Yehuda Sadeh u32 value_len; 17268b4476b0bc13fef18266b4140309a30e86739d2Yehuda Sadeh __u8 cmp_op; /* CEPH_OSD_CMPXATTR_OP_* */ 17368b4476b0bc13fef18266b4140309a30e86739d2Yehuda Sadeh __u8 cmp_mode; /* CEPH_OSD_CMPXATTR_MODE_* */ 17468b4476b0bc13fef18266b4140309a30e86739d2Yehuda Sadeh } xattr; 17568b4476b0bc13fef18266b4140309a30e86739d2Yehuda Sadeh struct { 176ae1533b62b3369e6ae32338f4a77d64d0e88f676Yehuda Sadeh const char *class_name; 177ae1533b62b3369e6ae32338f4a77d64d0e88f676Yehuda Sadeh const char *method_name; 178ae1533b62b3369e6ae32338f4a77d64d0e88f676Yehuda Sadeh const char *indata; 17968b4476b0bc13fef18266b4140309a30e86739d2Yehuda Sadeh u32 indata_len; 180e7e319a9c51409c7effe34333ea26facf2fab9e1Alex Elder __u8 class_len; 181e7e319a9c51409c7effe34333ea26facf2fab9e1Alex Elder __u8 method_len; 182e7e319a9c51409c7effe34333ea26facf2fab9e1Alex Elder __u8 argc; 18368b4476b0bc13fef18266b4140309a30e86739d2Yehuda Sadeh } cls; 18468b4476b0bc13fef18266b4140309a30e86739d2Yehuda Sadeh struct { 185e7e319a9c51409c7effe34333ea26facf2fab9e1Alex Elder u64 cookie; 186e7e319a9c51409c7effe34333ea26facf2fab9e1Alex Elder u64 count; 18768b4476b0bc13fef18266b4140309a30e86739d2Yehuda Sadeh } pgls; 188ae1533b62b3369e6ae32338f4a77d64d0e88f676Yehuda Sadeh struct { 189ae1533b62b3369e6ae32338f4a77d64d0e88f676Yehuda Sadeh u64 snapid; 190ae1533b62b3369e6ae32338f4a77d64d0e88f676Yehuda Sadeh } snap; 191a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh struct { 192a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh u64 cookie; 193a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh u64 ver; 194a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh u32 prot_ver; 195a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh u32 timeout; 196e7e319a9c51409c7effe34333ea26facf2fab9e1Alex Elder __u8 flag; 197a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh } watch; 19868b4476b0bc13fef18266b4140309a30e86739d2Yehuda Sadeh }; 19968b4476b0bc13fef18266b4140309a30e86739d2Yehuda Sadeh}; 20068b4476b0bc13fef18266b4140309a30e86739d2Yehuda Sadeh 201f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weilextern int ceph_osdc_init(struct ceph_osd_client *osdc, 202f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct ceph_client *client); 203f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weilextern void ceph_osdc_stop(struct ceph_osd_client *osdc); 204f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil 205f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weilextern void ceph_osdc_handle_reply(struct ceph_osd_client *osdc, 206f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct ceph_msg *msg); 207f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weilextern void ceph_osdc_handle_map(struct ceph_osd_client *osdc, 208f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct ceph_msg *msg); 209f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil 2103499e8a5d4dbb083324efd942e2c4fb7eb65f27cYehuda Sadehextern struct ceph_osd_request *ceph_osdc_alloc_request(struct ceph_osd_client *osdc, 2113499e8a5d4dbb083324efd942e2c4fb7eb65f27cYehuda Sadeh struct ceph_snap_context *snapc, 212ae7ca4a35b1f5df86e2c32b2cfc01a8d528c7b8cAlex Elder unsigned int num_op, 2133499e8a5d4dbb083324efd942e2c4fb7eb65f27cYehuda Sadeh bool use_mempool, 21454a5400721da7fa5a16cea151aade5bdfee74111Alex Elder gfp_t gfp_flags); 2153499e8a5d4dbb083324efd942e2c4fb7eb65f27cYehuda Sadeh 2163499e8a5d4dbb083324efd942e2c4fb7eb65f27cYehuda Sadehextern void ceph_osdc_build_request(struct ceph_osd_request *req, 2170120be3c60d46d6d55f4bf7a3d654cc705eb0c54Alex Elder u64 off, u64 len, 218ae7ca4a35b1f5df86e2c32b2cfc01a8d528c7b8cAlex Elder unsigned int num_op, 21968b4476b0bc13fef18266b4140309a30e86739d2Yehuda Sadeh struct ceph_osd_req_op *src_ops, 22068b4476b0bc13fef18266b4140309a30e86739d2Yehuda Sadeh struct ceph_snap_context *snapc, 2214d6b250bf18d44571d69a0f4afec4b6a1969729fAlex Elder u64 snap_id, 222af77f26caa35a95af09d1dac5c513b3901de7e37Alex Elder struct timespec *mtime); 2233499e8a5d4dbb083324efd942e2c4fb7eb65f27cYehuda Sadeh 224f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weilextern struct ceph_osd_request *ceph_osdc_new_request(struct ceph_osd_client *, 225f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct ceph_file_layout *layout, 226f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct ceph_vino vino, 227f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil u64 offset, u64 *len, int op, int flags, 228f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct ceph_snap_context *snapc, 229f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil int do_sync, u32 truncate_seq, 230f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil u64 truncate_size, 231f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct timespec *mtime, 232a3bea47e8bdd51d921e5b2045720d60140612c7cAlex Elder bool use_mempool, int page_align); 233f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil 234a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadehextern void ceph_osdc_set_request_linger(struct ceph_osd_client *osdc, 235a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh struct ceph_osd_request *req); 236a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadehextern void ceph_osdc_unregister_linger_request(struct ceph_osd_client *osdc, 237a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh struct ceph_osd_request *req); 238a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh 239f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weilstatic inline void ceph_osdc_get_request(struct ceph_osd_request *req) 240f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil{ 241415e49a9c4faf1a1480b1497da2037608e5aa2c5Sage Weil kref_get(&req->r_kref); 242415e49a9c4faf1a1480b1497da2037608e5aa2c5Sage Weil} 243415e49a9c4faf1a1480b1497da2037608e5aa2c5Sage Weilextern void ceph_osdc_release_request(struct kref *kref); 244415e49a9c4faf1a1480b1497da2037608e5aa2c5Sage Weilstatic inline void ceph_osdc_put_request(struct ceph_osd_request *req) 245415e49a9c4faf1a1480b1497da2037608e5aa2c5Sage Weil{ 246415e49a9c4faf1a1480b1497da2037608e5aa2c5Sage Weil kref_put(&req->r_kref, ceph_osdc_release_request); 247f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil} 248f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil 249f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weilextern int ceph_osdc_start_request(struct ceph_osd_client *osdc, 250f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct ceph_osd_request *req, 251f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil bool nofail); 252f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weilextern int ceph_osdc_wait_request(struct ceph_osd_client *osdc, 253f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct ceph_osd_request *req); 254f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weilextern void ceph_osdc_sync(struct ceph_osd_client *osdc); 255f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil 256f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weilextern int ceph_osdc_readpages(struct ceph_osd_client *osdc, 257f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct ceph_vino vino, 258f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct ceph_file_layout *layout, 259f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil u64 off, u64 *plen, 260f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil u32 truncate_seq, u64 truncate_size, 261b7495fc2ff941db6a118a93ab8d61149e3f4cef8Sage Weil struct page **pages, int nr_pages, 262b7495fc2ff941db6a118a93ab8d61149e3f4cef8Sage Weil int page_align); 263f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil 264f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weilextern int ceph_osdc_writepages(struct ceph_osd_client *osdc, 265f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct ceph_vino vino, 266f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct ceph_file_layout *layout, 267f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct ceph_snap_context *sc, 268f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil u64 off, u64 len, 269f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil u32 truncate_seq, u64 truncate_size, 270f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct timespec *mtime, 2712480882611e3ab844563dd3d0a822227604ab8feAlex Elder struct page **pages, int nr_pages); 272f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil 273a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh/* watch/notify events */ 274a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadehextern int ceph_osdc_create_event(struct ceph_osd_client *osdc, 275a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh void (*event_cb)(u64, u64, u8, void *), 2763c663bbdcdf9296e0fe3362acb9e81f49d7b72c6Alex Elder void *data, struct ceph_osd_event **pevent); 277a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadehextern void ceph_osdc_cancel_event(struct ceph_osd_event *event); 278a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadehextern void ceph_osdc_put_event(struct ceph_osd_event *event); 279f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil#endif 280f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil 281