osd_client.h revision a4ce40a9a7c1053ac2a41cf64255e44e356e5522
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 501b83bef24c6746a146d39915a18fb5425f2facb0Sage Weil 5179528734f3ae4699a2886f62f55e18fb34fb3651Alex Elder#define CEPH_OSD_MAX_OP 2 521b83bef24c6746a146d39915a18fb5425f2facb0Sage Weil 532ac2b7a6d4976bd6b5dc0751aa77d12d48d3ac4cAlex Elderenum ceph_osd_data_type { 542ac2b7a6d4976bd6b5dc0751aa77d12d48d3ac4cAlex Elder CEPH_OSD_DATA_TYPE_NONE, 552ac2b7a6d4976bd6b5dc0751aa77d12d48d3ac4cAlex Elder CEPH_OSD_DATA_TYPE_PAGES, 569a5e6d09ddd0cd68ce64c3aa54095e4a0e85b089Alex Elder CEPH_OSD_DATA_TYPE_PAGELIST, 572ac2b7a6d4976bd6b5dc0751aa77d12d48d3ac4cAlex Elder#ifdef CONFIG_BLOCK 582ac2b7a6d4976bd6b5dc0751aa77d12d48d3ac4cAlex Elder CEPH_OSD_DATA_TYPE_BIO, 592ac2b7a6d4976bd6b5dc0751aa77d12d48d3ac4cAlex Elder#endif /* CONFIG_BLOCK */ 602ac2b7a6d4976bd6b5dc0751aa77d12d48d3ac4cAlex Elder}; 612ac2b7a6d4976bd6b5dc0751aa77d12d48d3ac4cAlex Elder 622794a82a11cfeae0890741b18b0049ddb55ce646Alex Elderstruct ceph_osd_data { 632ac2b7a6d4976bd6b5dc0751aa77d12d48d3ac4cAlex Elder enum ceph_osd_data_type type; 642ac2b7a6d4976bd6b5dc0751aa77d12d48d3ac4cAlex Elder union { 652794a82a11cfeae0890741b18b0049ddb55ce646Alex Elder struct { 662794a82a11cfeae0890741b18b0049ddb55ce646Alex Elder struct page **pages; 67e0c594878e3211b09208c779df5f996f0b831d9eAlex Elder u64 length; 682794a82a11cfeae0890741b18b0049ddb55ce646Alex Elder u32 alignment; 692794a82a11cfeae0890741b18b0049ddb55ce646Alex Elder bool pages_from_pool; 702794a82a11cfeae0890741b18b0049ddb55ce646Alex Elder bool own_pages; 712794a82a11cfeae0890741b18b0049ddb55ce646Alex Elder }; 729a5e6d09ddd0cd68ce64c3aa54095e4a0e85b089Alex Elder struct ceph_pagelist *pagelist; 732794a82a11cfeae0890741b18b0049ddb55ce646Alex Elder#ifdef CONFIG_BLOCK 74fdce58ccb5df621695b079378c619046acabc778Alex Elder struct { 75fdce58ccb5df621695b079378c619046acabc778Alex Elder struct bio *bio; /* list of bios */ 76fdce58ccb5df621695b079378c619046acabc778Alex Elder size_t bio_length; /* total in list */ 77fdce58ccb5df621695b079378c619046acabc778Alex Elder }; 782794a82a11cfeae0890741b18b0049ddb55ce646Alex Elder#endif /* CONFIG_BLOCK */ 792794a82a11cfeae0890741b18b0049ddb55ce646Alex Elder }; 802794a82a11cfeae0890741b18b0049ddb55ce646Alex Elder}; 812794a82a11cfeae0890741b18b0049ddb55ce646Alex Elder 8279528734f3ae4699a2886f62f55e18fb34fb3651Alex Elderstruct ceph_osd_req_op { 8379528734f3ae4699a2886f62f55e18fb34fb3651Alex Elder u16 op; /* CEPH_OSD_OP_* */ 8479528734f3ae4699a2886f62f55e18fb34fb3651Alex Elder u32 payload_len; 8579528734f3ae4699a2886f62f55e18fb34fb3651Alex Elder union { 8679528734f3ae4699a2886f62f55e18fb34fb3651Alex Elder struct { 8779528734f3ae4699a2886f62f55e18fb34fb3651Alex Elder u64 offset, length; 8879528734f3ae4699a2886f62f55e18fb34fb3651Alex Elder u64 truncate_size; 8979528734f3ae4699a2886f62f55e18fb34fb3651Alex Elder u32 truncate_seq; 908c042b0df99cd06ef8473ef6e204b87b3dc80158Alex Elder struct ceph_osd_data *osd_data; 9179528734f3ae4699a2886f62f55e18fb34fb3651Alex Elder } extent; 9279528734f3ae4699a2886f62f55e18fb34fb3651Alex Elder struct { 9379528734f3ae4699a2886f62f55e18fb34fb3651Alex Elder const char *class_name; 9479528734f3ae4699a2886f62f55e18fb34fb3651Alex Elder const char *method_name; 9554d5064912649e296552f298e6472ffd37cd8f90Alex Elder const void *request_data; 965f562df5f59340eae4272501b974903f48d2ad92Alex Elder struct ceph_osd_data *request_info; 978c042b0df99cd06ef8473ef6e204b87b3dc80158Alex Elder struct ceph_osd_data *response_data; 985f562df5f59340eae4272501b974903f48d2ad92Alex Elder u32 request_data_len; 9979528734f3ae4699a2886f62f55e18fb34fb3651Alex Elder __u8 class_len; 10079528734f3ae4699a2886f62f55e18fb34fb3651Alex Elder __u8 method_len; 10179528734f3ae4699a2886f62f55e18fb34fb3651Alex Elder __u8 argc; 10279528734f3ae4699a2886f62f55e18fb34fb3651Alex Elder } cls; 10379528734f3ae4699a2886f62f55e18fb34fb3651Alex Elder struct { 10479528734f3ae4699a2886f62f55e18fb34fb3651Alex Elder u64 cookie; 10579528734f3ae4699a2886f62f55e18fb34fb3651Alex Elder u64 ver; 10679528734f3ae4699a2886f62f55e18fb34fb3651Alex Elder u32 prot_ver; 10779528734f3ae4699a2886f62f55e18fb34fb3651Alex Elder u32 timeout; 10879528734f3ae4699a2886f62f55e18fb34fb3651Alex Elder __u8 flag; 10979528734f3ae4699a2886f62f55e18fb34fb3651Alex Elder } watch; 11079528734f3ae4699a2886f62f55e18fb34fb3651Alex Elder }; 11179528734f3ae4699a2886f62f55e18fb34fb3651Alex Elder}; 11279528734f3ae4699a2886f62f55e18fb34fb3651Alex Elder 113f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil/* an in-flight request */ 114f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weilstruct ceph_osd_request { 115f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil u64 r_tid; /* unique for this client */ 116f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct rb_node r_node; 117422d2cb8f9afadba1ecd3614f658b6daaaa480fbYehuda Sadeh struct list_head r_req_lru_item; 118f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct list_head r_osd_item; 119a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh struct list_head r_linger_item; 120a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh struct list_head r_linger_osd; 121f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct ceph_osd *r_osd; 1225b191d9914eb68257f47de9d5bfe099b77f0687cSage Weil struct ceph_pg r_pgid; 123d85b705663905b3dae30007f824355bdcfcf3f00Sage Weil int r_pg_osds[CEPH_PG_MAX_SIZE]; 124d85b705663905b3dae30007f824355bdcfcf3f00Sage Weil int r_num_pg_osds; 125f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil 126f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct ceph_msg *r_request, *r_reply; 127f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil int r_flags; /* any additional flags for the osd */ 128f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil u32 r_sent; /* >0 if r_request is sending/sent */ 1291b83bef24c6746a146d39915a18fb5425f2facb0Sage Weil 13079528734f3ae4699a2886f62f55e18fb34fb3651Alex Elder /* request osd ops array */ 13179528734f3ae4699a2886f62f55e18fb34fb3651Alex Elder unsigned int r_num_ops; 13279528734f3ae4699a2886f62f55e18fb34fb3651Alex Elder struct ceph_osd_req_op r_ops[CEPH_OSD_MAX_OP]; 13379528734f3ae4699a2886f62f55e18fb34fb3651Alex Elder 1341b83bef24c6746a146d39915a18fb5425f2facb0Sage Weil /* these are updated on each send */ 1351b83bef24c6746a146d39915a18fb5425f2facb0Sage Weil __le32 *r_request_osdmap_epoch; 1361b83bef24c6746a146d39915a18fb5425f2facb0Sage Weil __le32 *r_request_flags; 1371b83bef24c6746a146d39915a18fb5425f2facb0Sage Weil __le64 *r_request_pool; 1381b83bef24c6746a146d39915a18fb5425f2facb0Sage Weil void *r_request_pgid; 1391b83bef24c6746a146d39915a18fb5425f2facb0Sage Weil __le32 *r_request_attempts; 1401b83bef24c6746a146d39915a18fb5425f2facb0Sage Weil struct ceph_eversion *r_request_reassert_version; 1411b83bef24c6746a146d39915a18fb5425f2facb0Sage Weil 1421b83bef24c6746a146d39915a18fb5425f2facb0Sage Weil int r_result; 1431b83bef24c6746a146d39915a18fb5425f2facb0Sage Weil int r_reply_op_len[CEPH_OSD_MAX_OP]; 1441b83bef24c6746a146d39915a18fb5425f2facb0Sage Weil s32 r_reply_op_result[CEPH_OSD_MAX_OP]; 145350b1c32ea58d29e25d63fc25e92dd48f9339546Sage Weil int r_got_reply; 146a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh int r_linger; 1470d5af1643535508f82d6bcc2b9b93b180e8c3f4bAlex Elder int r_completed; 148f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil 149f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct ceph_osd_client *r_osdc; 150415e49a9c4faf1a1480b1497da2037608e5aa2c5Sage Weil struct kref r_kref; 151f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil bool r_mempool; 152f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct completion r_completion, r_safe_completion; 153f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil ceph_osdc_callback_t r_callback, r_safe_callback; 154f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct ceph_eversion r_reassert_version; 155f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct list_head r_unsafe_item; 156f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil 157f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct inode *r_inode; /* for use by callbacks */ 1583d14c5d2b6e15c21d8e5467dc62d33127c23a644Yehuda Sadeh void *r_priv; /* ditto */ 159f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil 160224736d9113ab4a7cf3f05c05377492bd99b4b02Stratos Psomadakis char r_oid[MAX_OBJ_NAME_SIZE]; /* object name */ 161f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil int r_oid_len; 1622169aea649c08374bec7d220a3b8f64712275356Sage Weil u64 r_snapid; 1633dd72fc0e6dc49c79fa9e7cd7c654deac7ccaa29Sage Weil unsigned long r_stamp; /* send OR check time */ 164f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil 165f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct ceph_file_layout r_file_layout; 166f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct ceph_snap_context *r_snapc; /* snap context for writes */ 16768b4476b0bc13fef18266b4140309a30e86739d2Yehuda Sadeh 1680fff87ec798abdb4a99f01cbb0197266bb68c5dcAlex Elder struct ceph_osd_data r_data_in; 1690fff87ec798abdb4a99f01cbb0197266bb68c5dcAlex Elder struct ceph_osd_data r_data_out; 170f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil}; 171f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil 172a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadehstruct ceph_osd_event { 173a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh u64 cookie; 174a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh int one_shot; 175a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh struct ceph_osd_client *osdc; 176a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh void (*cb)(u64, u64, u8, void *); 177a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh void *data; 178a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh struct rb_node node; 179a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh struct list_head osd_node; 180a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh struct kref kref; 181a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh}; 182a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh 183a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadehstruct ceph_osd_event_work { 184a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh struct work_struct work; 185a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh struct ceph_osd_event *event; 186a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh u64 ver; 187a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh u64 notify_id; 188a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh u8 opcode; 189a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh}; 190a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh 191f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weilstruct ceph_osd_client { 192f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct ceph_client *client; 193f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil 194f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct ceph_osdmap *osdmap; /* current map */ 195f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct rw_semaphore map_sem; 196f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct completion map_waiters; 197f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil u64 last_requested_map; 198f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil 199f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct mutex request_mutex; 200f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct rb_root osds; /* osds */ 201f5a2041bd96c9f05ff10172b9c814c14f247084eYehuda Sadeh struct list_head osd_lru; /* idle osds */ 202f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil u64 timeout_tid; /* tid of timeout triggering rq */ 203f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil u64 last_tid; /* tid of last request */ 204f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct rb_root requests; /* pending requests */ 2056f6c7006755b667f9f6c1f3b6f08cd65f75cc471Sage Weil struct list_head req_lru; /* in-flight lru */ 2066f6c7006755b667f9f6c1f3b6f08cd65f75cc471Sage Weil struct list_head req_unsent; /* unsent/need-resend queue */ 2076f6c7006755b667f9f6c1f3b6f08cd65f75cc471Sage Weil struct list_head req_notarget; /* map to no osd */ 208a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh struct list_head req_linger; /* lingering requests */ 209f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil int num_requests; 210f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct delayed_work timeout_work; 211f5a2041bd96c9f05ff10172b9c814c14f247084eYehuda Sadeh struct delayed_work osds_timeout_work; 212039934b895c89c2bb40aa5132efe00e60b70efcaSage Weil#ifdef CONFIG_DEBUG_FS 213f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct dentry *debugfs_file; 214039934b895c89c2bb40aa5132efe00e60b70efcaSage Weil#endif 215f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil 216f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil mempool_t *req_mempool; 217f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil 2180d59ab81c3d3adf466c3fd37d7fb6d46b05d1fd4Yehuda Sadeh struct ceph_msgpool msgpool_op; 219c16e786927b977cb880873214bbd815e8d5ec4baSage Weil struct ceph_msgpool msgpool_op_reply; 220a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh 221a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh spinlock_t event_lock; 222a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh struct rb_root event_tree; 223a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh u64 event_count; 224a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh 225a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh struct workqueue_struct *notify_wq; 226f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil}; 227f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil 228f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weilextern int ceph_osdc_init(struct ceph_osd_client *osdc, 229f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct ceph_client *client); 230f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weilextern void ceph_osdc_stop(struct ceph_osd_client *osdc); 231f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil 232f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weilextern void ceph_osdc_handle_reply(struct ceph_osd_client *osdc, 233f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct ceph_msg *msg); 234f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weilextern void ceph_osdc_handle_map(struct ceph_osd_client *osdc, 235f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct ceph_msg *msg); 236f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil 237c99d2d4abb6c405ef52e9bc1da87b382b8f41739Alex Elderextern void osd_req_op_extent_init(struct ceph_osd_request *osd_req, 238c99d2d4abb6c405ef52e9bc1da87b382b8f41739Alex Elder unsigned int which, u16 opcode, 23933803f3300265661b5c5d20a9811c6a2a157d545Alex Elder u64 offset, u64 length, 24033803f3300265661b5c5d20a9811c6a2a157d545Alex Elder u64 truncate_size, u32 truncate_seq); 241c99d2d4abb6c405ef52e9bc1da87b382b8f41739Alex Elderextern void osd_req_op_extent_update(struct ceph_osd_request *osd_req, 242c99d2d4abb6c405ef52e9bc1da87b382b8f41739Alex Elder unsigned int which, u64 length); 243a4ce40a9a7c1053ac2a41cf64255e44e356e5522Alex Elder 244a4ce40a9a7c1053ac2a41cf64255e44e356e5522Alex Elderextern struct ceph_osd_data *osd_req_op_extent_osd_data( 245a4ce40a9a7c1053ac2a41cf64255e44e356e5522Alex Elder struct ceph_osd_request *osd_req, 246a4ce40a9a7c1053ac2a41cf64255e44e356e5522Alex Elder unsigned int which, bool write_request); 247a4ce40a9a7c1053ac2a41cf64255e44e356e5522Alex Elderextern struct ceph_osd_data *osd_req_op_cls_response_data( 248a4ce40a9a7c1053ac2a41cf64255e44e356e5522Alex Elder struct ceph_osd_request *osd_req, 249a4ce40a9a7c1053ac2a41cf64255e44e356e5522Alex Elder unsigned int which); 250a4ce40a9a7c1053ac2a41cf64255e44e356e5522Alex Elder 251a4ce40a9a7c1053ac2a41cf64255e44e356e5522Alex Elderextern void osd_req_op_extent_osd_data_pages(struct ceph_osd_request *, 252a4ce40a9a7c1053ac2a41cf64255e44e356e5522Alex Elder unsigned int which, bool write_request, 253a4ce40a9a7c1053ac2a41cf64255e44e356e5522Alex Elder struct page **pages, u64 length, 254a4ce40a9a7c1053ac2a41cf64255e44e356e5522Alex Elder u32 alignment, bool pages_from_pool, 255a4ce40a9a7c1053ac2a41cf64255e44e356e5522Alex Elder bool own_pages); 256a4ce40a9a7c1053ac2a41cf64255e44e356e5522Alex Elderextern void osd_req_op_extent_osd_data_pagelist(struct ceph_osd_request *, 257a4ce40a9a7c1053ac2a41cf64255e44e356e5522Alex Elder unsigned int which, bool write_request, 258a4ce40a9a7c1053ac2a41cf64255e44e356e5522Alex Elder struct ceph_pagelist *pagelist); 259a4ce40a9a7c1053ac2a41cf64255e44e356e5522Alex Elder#ifdef CONFIG_BLOCK 260a4ce40a9a7c1053ac2a41cf64255e44e356e5522Alex Elderextern void osd_req_op_extent_osd_data_bio(struct ceph_osd_request *, 261a4ce40a9a7c1053ac2a41cf64255e44e356e5522Alex Elder unsigned int which, bool write_request, 262a4ce40a9a7c1053ac2a41cf64255e44e356e5522Alex Elder struct bio *bio, size_t bio_length); 263a4ce40a9a7c1053ac2a41cf64255e44e356e5522Alex Elder#endif /* CONFIG_BLOCK */ 264a4ce40a9a7c1053ac2a41cf64255e44e356e5522Alex Elder 265a4ce40a9a7c1053ac2a41cf64255e44e356e5522Alex Elderextern void osd_req_op_cls_response_data_pages(struct ceph_osd_request *, 266c99d2d4abb6c405ef52e9bc1da87b382b8f41739Alex Elder unsigned int which, 267a4ce40a9a7c1053ac2a41cf64255e44e356e5522Alex Elder struct page **pages, u64 length, 268a4ce40a9a7c1053ac2a41cf64255e44e356e5522Alex Elder u32 alignment, bool pages_from_pool, 269a4ce40a9a7c1053ac2a41cf64255e44e356e5522Alex Elder bool own_pages); 270a4ce40a9a7c1053ac2a41cf64255e44e356e5522Alex Elder 271c99d2d4abb6c405ef52e9bc1da87b382b8f41739Alex Elderextern void osd_req_op_cls_init(struct ceph_osd_request *osd_req, 272c99d2d4abb6c405ef52e9bc1da87b382b8f41739Alex Elder unsigned int which, u16 opcode, 27333803f3300265661b5c5d20a9811c6a2a157d545Alex Elder const char *class, const char *method, 27433803f3300265661b5c5d20a9811c6a2a157d545Alex Elder const void *request_data, 27533803f3300265661b5c5d20a9811c6a2a157d545Alex Elder size_t request_data_size); 276c99d2d4abb6c405ef52e9bc1da87b382b8f41739Alex Elderextern void osd_req_op_watch_init(struct ceph_osd_request *osd_req, 277c99d2d4abb6c405ef52e9bc1da87b382b8f41739Alex Elder unsigned int which, u16 opcode, 27833803f3300265661b5c5d20a9811c6a2a157d545Alex Elder u64 cookie, u64 version, int flag); 27933803f3300265661b5c5d20a9811c6a2a157d545Alex Elder 2803499e8a5d4dbb083324efd942e2c4fb7eb65f27cYehuda Sadehextern struct ceph_osd_request *ceph_osdc_alloc_request(struct ceph_osd_client *osdc, 2813499e8a5d4dbb083324efd942e2c4fb7eb65f27cYehuda Sadeh struct ceph_snap_context *snapc, 282acead002b200569273bed331c93c4a91d25e10b8Alex Elder unsigned int num_ops, 2833499e8a5d4dbb083324efd942e2c4fb7eb65f27cYehuda Sadeh bool use_mempool, 28454a5400721da7fa5a16cea151aade5bdfee74111Alex Elder gfp_t gfp_flags); 2853499e8a5d4dbb083324efd942e2c4fb7eb65f27cYehuda Sadeh 286175face2ba31025b0dcd6da4e711fca7764287faAlex Elderextern void ceph_osdc_build_request(struct ceph_osd_request *req, u64 off, 28768b4476b0bc13fef18266b4140309a30e86739d2Yehuda Sadeh struct ceph_snap_context *snapc, 2884d6b250bf18d44571d69a0f4afec4b6a1969729fAlex Elder u64 snap_id, 289af77f26caa35a95af09d1dac5c513b3901de7e37Alex Elder struct timespec *mtime); 2903499e8a5d4dbb083324efd942e2c4fb7eb65f27cYehuda Sadeh 291f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weilextern struct ceph_osd_request *ceph_osdc_new_request(struct ceph_osd_client *, 292f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct ceph_file_layout *layout, 293f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct ceph_vino vino, 294acead002b200569273bed331c93c4a91d25e10b8Alex Elder u64 offset, u64 *len, 29579528734f3ae4699a2886f62f55e18fb34fb3651Alex Elder int num_ops, int opcode, int flags, 296f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct ceph_snap_context *snapc, 297acead002b200569273bed331c93c4a91d25e10b8Alex Elder u32 truncate_seq, u64 truncate_size, 298153e5167e0e237faaefb7adf82db5748c1452d73Alex Elder bool use_mempool); 299f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil 300a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadehextern void ceph_osdc_set_request_linger(struct ceph_osd_client *osdc, 301a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh struct ceph_osd_request *req); 302a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadehextern void ceph_osdc_unregister_linger_request(struct ceph_osd_client *osdc, 303a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh struct ceph_osd_request *req); 304a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh 305f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weilstatic inline void ceph_osdc_get_request(struct ceph_osd_request *req) 306f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil{ 307415e49a9c4faf1a1480b1497da2037608e5aa2c5Sage Weil kref_get(&req->r_kref); 308415e49a9c4faf1a1480b1497da2037608e5aa2c5Sage Weil} 309415e49a9c4faf1a1480b1497da2037608e5aa2c5Sage Weilextern void ceph_osdc_release_request(struct kref *kref); 310415e49a9c4faf1a1480b1497da2037608e5aa2c5Sage Weilstatic inline void ceph_osdc_put_request(struct ceph_osd_request *req) 311415e49a9c4faf1a1480b1497da2037608e5aa2c5Sage Weil{ 312415e49a9c4faf1a1480b1497da2037608e5aa2c5Sage Weil kref_put(&req->r_kref, ceph_osdc_release_request); 313f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil} 314f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil 315f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weilextern int ceph_osdc_start_request(struct ceph_osd_client *osdc, 316f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct ceph_osd_request *req, 317f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil bool nofail); 318f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weilextern int ceph_osdc_wait_request(struct ceph_osd_client *osdc, 319f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct ceph_osd_request *req); 320f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weilextern void ceph_osdc_sync(struct ceph_osd_client *osdc); 321f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil 322f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weilextern int ceph_osdc_readpages(struct ceph_osd_client *osdc, 323f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct ceph_vino vino, 324f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct ceph_file_layout *layout, 325f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil u64 off, u64 *plen, 326f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil u32 truncate_seq, u64 truncate_size, 327b7495fc2ff941db6a118a93ab8d61149e3f4cef8Sage Weil struct page **pages, int nr_pages, 328b7495fc2ff941db6a118a93ab8d61149e3f4cef8Sage Weil int page_align); 329f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil 330f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weilextern int ceph_osdc_writepages(struct ceph_osd_client *osdc, 331f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct ceph_vino vino, 332f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct ceph_file_layout *layout, 333f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct ceph_snap_context *sc, 334f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil u64 off, u64 len, 335f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil u32 truncate_seq, u64 truncate_size, 336f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct timespec *mtime, 3372480882611e3ab844563dd3d0a822227604ab8feAlex Elder struct page **pages, int nr_pages); 338f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil 339a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh/* watch/notify events */ 340a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadehextern int ceph_osdc_create_event(struct ceph_osd_client *osdc, 341a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh void (*event_cb)(u64, u64, u8, void *), 3423c663bbdcdf9296e0fe3362acb9e81f49d7b72c6Alex Elder void *data, struct ceph_osd_event **pevent); 343a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadehextern void ceph_osdc_cancel_event(struct ceph_osd_event *event); 344a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadehextern void ceph_osdc_put_event(struct ceph_osd_event *event); 345f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil#endif 346f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil 347