osd_client.h revision acead002b200569273bed331c93c4a91d25e10b8
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 511b83bef24c6746a146d39915a18fb5425f2facb0Sage Weil#define CEPH_OSD_MAX_OP 10 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 82f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil/* an in-flight request */ 83f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weilstruct ceph_osd_request { 84f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil u64 r_tid; /* unique for this client */ 85f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct rb_node r_node; 86422d2cb8f9afadba1ecd3614f658b6daaaa480fbYehuda Sadeh struct list_head r_req_lru_item; 87f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct list_head r_osd_item; 88a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh struct list_head r_linger_item; 89a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh struct list_head r_linger_osd; 90f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct ceph_osd *r_osd; 915b191d9914eb68257f47de9d5bfe099b77f0687cSage Weil struct ceph_pg r_pgid; 92d85b705663905b3dae30007f824355bdcfcf3f00Sage Weil int r_pg_osds[CEPH_PG_MAX_SIZE]; 93d85b705663905b3dae30007f824355bdcfcf3f00Sage Weil int r_num_pg_osds; 94f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil 95f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct ceph_msg *r_request, *r_reply; 96f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil int r_flags; /* any additional flags for the osd */ 97f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil u32 r_sent; /* >0 if r_request is sending/sent */ 981b83bef24c6746a146d39915a18fb5425f2facb0Sage Weil int r_num_ops; 991b83bef24c6746a146d39915a18fb5425f2facb0Sage Weil 1001b83bef24c6746a146d39915a18fb5425f2facb0Sage Weil /* encoded message content */ 1011b83bef24c6746a146d39915a18fb5425f2facb0Sage Weil struct ceph_osd_op *r_request_ops; 1021b83bef24c6746a146d39915a18fb5425f2facb0Sage Weil /* these are updated on each send */ 1031b83bef24c6746a146d39915a18fb5425f2facb0Sage Weil __le32 *r_request_osdmap_epoch; 1041b83bef24c6746a146d39915a18fb5425f2facb0Sage Weil __le32 *r_request_flags; 1051b83bef24c6746a146d39915a18fb5425f2facb0Sage Weil __le64 *r_request_pool; 1061b83bef24c6746a146d39915a18fb5425f2facb0Sage Weil void *r_request_pgid; 1071b83bef24c6746a146d39915a18fb5425f2facb0Sage Weil __le32 *r_request_attempts; 1081b83bef24c6746a146d39915a18fb5425f2facb0Sage Weil struct ceph_eversion *r_request_reassert_version; 1091b83bef24c6746a146d39915a18fb5425f2facb0Sage Weil 1101b83bef24c6746a146d39915a18fb5425f2facb0Sage Weil int r_result; 1111b83bef24c6746a146d39915a18fb5425f2facb0Sage Weil int r_reply_op_len[CEPH_OSD_MAX_OP]; 1121b83bef24c6746a146d39915a18fb5425f2facb0Sage Weil s32 r_reply_op_result[CEPH_OSD_MAX_OP]; 113350b1c32ea58d29e25d63fc25e92dd48f9339546Sage Weil int r_got_reply; 114a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh int r_linger; 1150d5af1643535508f82d6bcc2b9b93b180e8c3f4bAlex Elder int r_completed; 116f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil 117f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct ceph_osd_client *r_osdc; 118415e49a9c4faf1a1480b1497da2037608e5aa2c5Sage Weil struct kref r_kref; 119f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil bool r_mempool; 120f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct completion r_completion, r_safe_completion; 121f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil ceph_osdc_callback_t r_callback, r_safe_callback; 122f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct ceph_eversion r_reassert_version; 123f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct list_head r_unsafe_item; 124f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil 125f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct inode *r_inode; /* for use by callbacks */ 1263d14c5d2b6e15c21d8e5467dc62d33127c23a644Yehuda Sadeh void *r_priv; /* ditto */ 127f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil 128224736d9113ab4a7cf3f05c05377492bd99b4b02Stratos Psomadakis char r_oid[MAX_OBJ_NAME_SIZE]; /* object name */ 129f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil int r_oid_len; 1302169aea649c08374bec7d220a3b8f64712275356Sage Weil u64 r_snapid; 1313dd72fc0e6dc49c79fa9e7cd7c654deac7ccaa29Sage Weil unsigned long r_stamp; /* send OR check time */ 132f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil 133f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct ceph_file_layout r_file_layout; 134f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct ceph_snap_context *r_snapc; /* snap context for writes */ 13568b4476b0bc13fef18266b4140309a30e86739d2Yehuda Sadeh 1360fff87ec798abdb4a99f01cbb0197266bb68c5dcAlex Elder struct ceph_osd_data r_data_in; 1370fff87ec798abdb4a99f01cbb0197266bb68c5dcAlex Elder struct ceph_osd_data r_data_out; 138f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil}; 139f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil 140a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadehstruct ceph_osd_event { 141a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh u64 cookie; 142a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh int one_shot; 143a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh struct ceph_osd_client *osdc; 144a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh void (*cb)(u64, u64, u8, void *); 145a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh void *data; 146a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh struct rb_node node; 147a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh struct list_head osd_node; 148a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh struct kref kref; 149a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh}; 150a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh 151a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadehstruct ceph_osd_event_work { 152a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh struct work_struct work; 153a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh struct ceph_osd_event *event; 154a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh u64 ver; 155a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh u64 notify_id; 156a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh u8 opcode; 157a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh}; 158a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh 159f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weilstruct ceph_osd_client { 160f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct ceph_client *client; 161f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil 162f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct ceph_osdmap *osdmap; /* current map */ 163f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct rw_semaphore map_sem; 164f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct completion map_waiters; 165f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil u64 last_requested_map; 166f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil 167f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct mutex request_mutex; 168f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct rb_root osds; /* osds */ 169f5a2041bd96c9f05ff10172b9c814c14f247084eYehuda Sadeh struct list_head osd_lru; /* idle osds */ 170f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil u64 timeout_tid; /* tid of timeout triggering rq */ 171f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil u64 last_tid; /* tid of last request */ 172f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct rb_root requests; /* pending requests */ 1736f6c7006755b667f9f6c1f3b6f08cd65f75cc471Sage Weil struct list_head req_lru; /* in-flight lru */ 1746f6c7006755b667f9f6c1f3b6f08cd65f75cc471Sage Weil struct list_head req_unsent; /* unsent/need-resend queue */ 1756f6c7006755b667f9f6c1f3b6f08cd65f75cc471Sage Weil struct list_head req_notarget; /* map to no osd */ 176a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh struct list_head req_linger; /* lingering requests */ 177f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil int num_requests; 178f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct delayed_work timeout_work; 179f5a2041bd96c9f05ff10172b9c814c14f247084eYehuda Sadeh struct delayed_work osds_timeout_work; 180039934b895c89c2bb40aa5132efe00e60b70efcaSage Weil#ifdef CONFIG_DEBUG_FS 181f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct dentry *debugfs_file; 182039934b895c89c2bb40aa5132efe00e60b70efcaSage Weil#endif 183f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil 184f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil mempool_t *req_mempool; 185f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil 1860d59ab81c3d3adf466c3fd37d7fb6d46b05d1fd4Yehuda Sadeh struct ceph_msgpool msgpool_op; 187c16e786927b977cb880873214bbd815e8d5ec4baSage Weil struct ceph_msgpool msgpool_op_reply; 188a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh 189a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh spinlock_t event_lock; 190a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh struct rb_root event_tree; 191a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh u64 event_count; 192a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh 193a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh struct workqueue_struct *notify_wq; 194f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil}; 195f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil 19668b4476b0bc13fef18266b4140309a30e86739d2Yehuda Sadehstruct ceph_osd_req_op { 19768b4476b0bc13fef18266b4140309a30e86739d2Yehuda Sadeh u16 op; /* CEPH_OSD_OP_* */ 198e7e319a9c51409c7effe34333ea26facf2fab9e1Alex Elder u32 payload_len; 19968b4476b0bc13fef18266b4140309a30e86739d2Yehuda Sadeh union { 20068b4476b0bc13fef18266b4140309a30e86739d2Yehuda Sadeh struct { 20168b4476b0bc13fef18266b4140309a30e86739d2Yehuda Sadeh u64 offset, length; 20268b4476b0bc13fef18266b4140309a30e86739d2Yehuda Sadeh u64 truncate_size; 20368b4476b0bc13fef18266b4140309a30e86739d2Yehuda Sadeh u32 truncate_seq; 20468b4476b0bc13fef18266b4140309a30e86739d2Yehuda Sadeh } extent; 20568b4476b0bc13fef18266b4140309a30e86739d2Yehuda Sadeh struct { 206ae1533b62b3369e6ae32338f4a77d64d0e88f676Yehuda Sadeh const char *class_name; 207ae1533b62b3369e6ae32338f4a77d64d0e88f676Yehuda Sadeh const char *method_name; 2082a24d1f4bd7995de133c857bfdc77ac82c842300Alex Elder const void *indata; 20968b4476b0bc13fef18266b4140309a30e86739d2Yehuda Sadeh u32 indata_len; 210e7e319a9c51409c7effe34333ea26facf2fab9e1Alex Elder __u8 class_len; 211e7e319a9c51409c7effe34333ea26facf2fab9e1Alex Elder __u8 method_len; 212e7e319a9c51409c7effe34333ea26facf2fab9e1Alex Elder __u8 argc; 21368b4476b0bc13fef18266b4140309a30e86739d2Yehuda Sadeh } cls; 21468b4476b0bc13fef18266b4140309a30e86739d2Yehuda Sadeh struct { 215e7e319a9c51409c7effe34333ea26facf2fab9e1Alex Elder u64 cookie; 216a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh u64 ver; 217a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh u32 prot_ver; 218a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh u32 timeout; 219e7e319a9c51409c7effe34333ea26facf2fab9e1Alex Elder __u8 flag; 220a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh } watch; 22168b4476b0bc13fef18266b4140309a30e86739d2Yehuda Sadeh }; 22268b4476b0bc13fef18266b4140309a30e86739d2Yehuda Sadeh}; 22368b4476b0bc13fef18266b4140309a30e86739d2Yehuda Sadeh 224f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weilextern int ceph_osdc_init(struct ceph_osd_client *osdc, 225f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct ceph_client *client); 226f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weilextern void ceph_osdc_stop(struct ceph_osd_client *osdc); 227f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil 228f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weilextern void ceph_osdc_handle_reply(struct ceph_osd_client *osdc, 229f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct ceph_msg *msg); 230f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weilextern void ceph_osdc_handle_map(struct ceph_osd_client *osdc, 231f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct ceph_msg *msg); 232f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil 23333803f3300265661b5c5d20a9811c6a2a157d545Alex Elderextern void osd_req_op_init(struct ceph_osd_req_op *op, u16 opcode); 23433803f3300265661b5c5d20a9811c6a2a157d545Alex Elderextern void osd_req_op_extent_init(struct ceph_osd_req_op *op, u16 opcode, 23533803f3300265661b5c5d20a9811c6a2a157d545Alex Elder u64 offset, u64 length, 23633803f3300265661b5c5d20a9811c6a2a157d545Alex Elder u64 truncate_size, u32 truncate_seq); 23733803f3300265661b5c5d20a9811c6a2a157d545Alex Elderextern void osd_req_op_cls_init(struct ceph_osd_req_op *op, u16 opcode, 23833803f3300265661b5c5d20a9811c6a2a157d545Alex Elder const char *class, const char *method, 23933803f3300265661b5c5d20a9811c6a2a157d545Alex Elder const void *request_data, 24033803f3300265661b5c5d20a9811c6a2a157d545Alex Elder size_t request_data_size); 24133803f3300265661b5c5d20a9811c6a2a157d545Alex Elderextern void osd_req_op_watch_init(struct ceph_osd_req_op *op, u16 opcode, 24233803f3300265661b5c5d20a9811c6a2a157d545Alex Elder u64 cookie, u64 version, int flag); 24333803f3300265661b5c5d20a9811c6a2a157d545Alex Elder 2443499e8a5d4dbb083324efd942e2c4fb7eb65f27cYehuda Sadehextern struct ceph_osd_request *ceph_osdc_alloc_request(struct ceph_osd_client *osdc, 2453499e8a5d4dbb083324efd942e2c4fb7eb65f27cYehuda Sadeh struct ceph_snap_context *snapc, 246acead002b200569273bed331c93c4a91d25e10b8Alex Elder unsigned int num_ops, 2473499e8a5d4dbb083324efd942e2c4fb7eb65f27cYehuda Sadeh bool use_mempool, 24854a5400721da7fa5a16cea151aade5bdfee74111Alex Elder gfp_t gfp_flags); 2493499e8a5d4dbb083324efd942e2c4fb7eb65f27cYehuda Sadeh 250175face2ba31025b0dcd6da4e711fca7764287faAlex Elderextern void ceph_osdc_build_request(struct ceph_osd_request *req, u64 off, 251acead002b200569273bed331c93c4a91d25e10b8Alex Elder unsigned int num_ops, 25268b4476b0bc13fef18266b4140309a30e86739d2Yehuda Sadeh struct ceph_osd_req_op *src_ops, 25368b4476b0bc13fef18266b4140309a30e86739d2Yehuda Sadeh struct ceph_snap_context *snapc, 2544d6b250bf18d44571d69a0f4afec4b6a1969729fAlex Elder u64 snap_id, 255af77f26caa35a95af09d1dac5c513b3901de7e37Alex Elder struct timespec *mtime); 2563499e8a5d4dbb083324efd942e2c4fb7eb65f27cYehuda Sadeh 257f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weilextern struct ceph_osd_request *ceph_osdc_new_request(struct ceph_osd_client *, 258f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct ceph_file_layout *layout, 259f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct ceph_vino vino, 260acead002b200569273bed331c93c4a91d25e10b8Alex Elder u64 offset, u64 *len, 261acead002b200569273bed331c93c4a91d25e10b8Alex Elder int num_ops, struct ceph_osd_req_op *ops, 262acead002b200569273bed331c93c4a91d25e10b8Alex Elder int opcode, int flags, 263f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct ceph_snap_context *snapc, 264acead002b200569273bed331c93c4a91d25e10b8Alex Elder u32 truncate_seq, u64 truncate_size, 265153e5167e0e237faaefb7adf82db5748c1452d73Alex Elder bool use_mempool); 266f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil 267a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadehextern void ceph_osdc_set_request_linger(struct ceph_osd_client *osdc, 268a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh struct ceph_osd_request *req); 269a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadehextern void ceph_osdc_unregister_linger_request(struct ceph_osd_client *osdc, 270a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh struct ceph_osd_request *req); 271a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh 272f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weilstatic inline void ceph_osdc_get_request(struct ceph_osd_request *req) 273f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil{ 274415e49a9c4faf1a1480b1497da2037608e5aa2c5Sage Weil kref_get(&req->r_kref); 275415e49a9c4faf1a1480b1497da2037608e5aa2c5Sage Weil} 276415e49a9c4faf1a1480b1497da2037608e5aa2c5Sage Weilextern void ceph_osdc_release_request(struct kref *kref); 277415e49a9c4faf1a1480b1497da2037608e5aa2c5Sage Weilstatic inline void ceph_osdc_put_request(struct ceph_osd_request *req) 278415e49a9c4faf1a1480b1497da2037608e5aa2c5Sage Weil{ 279415e49a9c4faf1a1480b1497da2037608e5aa2c5Sage Weil kref_put(&req->r_kref, ceph_osdc_release_request); 280f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil} 281f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil 282f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weilextern int ceph_osdc_start_request(struct ceph_osd_client *osdc, 283f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct ceph_osd_request *req, 284f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil bool nofail); 285f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weilextern int ceph_osdc_wait_request(struct ceph_osd_client *osdc, 286f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct ceph_osd_request *req); 287f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weilextern void ceph_osdc_sync(struct ceph_osd_client *osdc); 288f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil 289f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weilextern int ceph_osdc_readpages(struct ceph_osd_client *osdc, 290f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct ceph_vino vino, 291f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct ceph_file_layout *layout, 292f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil u64 off, u64 *plen, 293f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil u32 truncate_seq, u64 truncate_size, 294b7495fc2ff941db6a118a93ab8d61149e3f4cef8Sage Weil struct page **pages, int nr_pages, 295b7495fc2ff941db6a118a93ab8d61149e3f4cef8Sage Weil int page_align); 296f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil 297f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weilextern int ceph_osdc_writepages(struct ceph_osd_client *osdc, 298f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct ceph_vino vino, 299f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct ceph_file_layout *layout, 300f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct ceph_snap_context *sc, 301f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil u64 off, u64 len, 302f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil u32 truncate_seq, u64 truncate_size, 303f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct timespec *mtime, 3042480882611e3ab844563dd3d0a822227604ab8feAlex Elder struct page **pages, int nr_pages); 305f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil 306a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh/* watch/notify events */ 307a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadehextern int ceph_osdc_create_event(struct ceph_osd_client *osdc, 308a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh void (*event_cb)(u64, u64, u8, void *), 3093c663bbdcdf9296e0fe3362acb9e81f49d7b72c6Alex Elder void *data, struct ceph_osd_event **pevent); 310a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadehextern void ceph_osdc_cancel_event(struct ceph_osd_event *event); 311a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadehextern void ceph_osdc_put_event(struct ceph_osd_event *event); 312f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil#endif 313f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil 314