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 15f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weilstruct ceph_msg; 16f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weilstruct ceph_snap_context; 17f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weilstruct ceph_osd_request; 18f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weilstruct ceph_osd_client; 194e7a5dcd1bbab6560fbc8ada29a840e7a20ed7bcSage Weilstruct ceph_authorizer; 20f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil 21f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil/* 22f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil * completion callback for async writepages 23f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil */ 24f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weiltypedef void (*ceph_osdc_callback_t)(struct ceph_osd_request *, 25f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct ceph_msg *); 2626be88087ae8a04a5b576aa2f490597b649fc132Alex Eldertypedef void (*ceph_osdc_unsafe_callback_t)(struct ceph_osd_request *, bool); 27f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil 28f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil/* a given osd we're communicating with */ 29f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weilstruct ceph_osd { 30f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil atomic_t o_ref; 31f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct ceph_osd_client *o_osdc; 32f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil int o_osd; 33f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil int o_incarnation; 34f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct rb_node o_node; 35f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct ceph_connection o_con; 36f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct list_head o_requests; 37a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh struct list_head o_linger_requests; 38f5a2041bd96c9f05ff10172b9c814c14f247084eYehuda Sadeh struct list_head o_osd_lru; 396c4a19158b96ea1fb8acbe0c1d5493d9dcd2f147Alex Elder struct ceph_auth_handshake o_auth; 40f5a2041bd96c9f05ff10172b9c814c14f247084eYehuda Sadeh unsigned long lru_ttl; 41422d2cb8f9afadba1ecd3614f658b6daaaa480fbYehuda Sadeh int o_marked_for_keepalive; 42422d2cb8f9afadba1ecd3614f658b6daaaa480fbYehuda Sadeh struct list_head o_keepalive_item; 43f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil}; 44f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil 451b83bef24c6746a146d39915a18fb5425f2facb0Sage Weil 467cc69d42e6950404587bef9489a5ed6f9f6bab4eIlya Dryomov#define CEPH_OSD_MAX_OP 3 471b83bef24c6746a146d39915a18fb5425f2facb0Sage Weil 482ac2b7a6d4976bd6b5dc0751aa77d12d48d3ac4cAlex Elderenum ceph_osd_data_type { 49ec9123c56787fa7fb2608f05b19d21c5e1912d87Alex Elder CEPH_OSD_DATA_TYPE_NONE = 0, 502ac2b7a6d4976bd6b5dc0751aa77d12d48d3ac4cAlex Elder CEPH_OSD_DATA_TYPE_PAGES, 519a5e6d09ddd0cd68ce64c3aa54095e4a0e85b089Alex Elder CEPH_OSD_DATA_TYPE_PAGELIST, 522ac2b7a6d4976bd6b5dc0751aa77d12d48d3ac4cAlex Elder#ifdef CONFIG_BLOCK 532ac2b7a6d4976bd6b5dc0751aa77d12d48d3ac4cAlex Elder CEPH_OSD_DATA_TYPE_BIO, 542ac2b7a6d4976bd6b5dc0751aa77d12d48d3ac4cAlex Elder#endif /* CONFIG_BLOCK */ 552ac2b7a6d4976bd6b5dc0751aa77d12d48d3ac4cAlex Elder}; 562ac2b7a6d4976bd6b5dc0751aa77d12d48d3ac4cAlex Elder 572794a82a11cfeae0890741b18b0049ddb55ce646Alex Elderstruct ceph_osd_data { 582ac2b7a6d4976bd6b5dc0751aa77d12d48d3ac4cAlex Elder enum ceph_osd_data_type type; 592ac2b7a6d4976bd6b5dc0751aa77d12d48d3ac4cAlex Elder union { 602794a82a11cfeae0890741b18b0049ddb55ce646Alex Elder struct { 612794a82a11cfeae0890741b18b0049ddb55ce646Alex Elder struct page **pages; 62e0c594878e3211b09208c779df5f996f0b831d9eAlex Elder u64 length; 632794a82a11cfeae0890741b18b0049ddb55ce646Alex Elder u32 alignment; 642794a82a11cfeae0890741b18b0049ddb55ce646Alex Elder bool pages_from_pool; 652794a82a11cfeae0890741b18b0049ddb55ce646Alex Elder bool own_pages; 662794a82a11cfeae0890741b18b0049ddb55ce646Alex Elder }; 679a5e6d09ddd0cd68ce64c3aa54095e4a0e85b089Alex Elder struct ceph_pagelist *pagelist; 682794a82a11cfeae0890741b18b0049ddb55ce646Alex Elder#ifdef CONFIG_BLOCK 69fdce58ccb5df621695b079378c619046acabc778Alex Elder struct { 70fdce58ccb5df621695b079378c619046acabc778Alex Elder struct bio *bio; /* list of bios */ 71fdce58ccb5df621695b079378c619046acabc778Alex Elder size_t bio_length; /* total in list */ 72fdce58ccb5df621695b079378c619046acabc778Alex Elder }; 732794a82a11cfeae0890741b18b0049ddb55ce646Alex Elder#endif /* CONFIG_BLOCK */ 742794a82a11cfeae0890741b18b0049ddb55ce646Alex Elder }; 752794a82a11cfeae0890741b18b0049ddb55ce646Alex Elder}; 762794a82a11cfeae0890741b18b0049ddb55ce646Alex Elder 7779528734f3ae4699a2886f62f55e18fb34fb3651Alex Elderstruct ceph_osd_req_op { 7879528734f3ae4699a2886f62f55e18fb34fb3651Alex Elder u16 op; /* CEPH_OSD_OP_* */ 797b25bf5f02c5c80adf96120e031dc3a1756ce54dIlya Dryomov u32 flags; /* CEPH_OSD_OP_FLAG_* */ 8079528734f3ae4699a2886f62f55e18fb34fb3651Alex Elder u32 payload_len; 8179528734f3ae4699a2886f62f55e18fb34fb3651Alex Elder union { 8249719778bfa5371ec9b5a7d989bb29000e3ac5dfAlex Elder struct ceph_osd_data raw_data_in; 8379528734f3ae4699a2886f62f55e18fb34fb3651Alex Elder struct { 8479528734f3ae4699a2886f62f55e18fb34fb3651Alex Elder u64 offset, length; 8579528734f3ae4699a2886f62f55e18fb34fb3651Alex Elder u64 truncate_size; 8679528734f3ae4699a2886f62f55e18fb34fb3651Alex Elder u32 truncate_seq; 875476492fba9fd0b4118aacf5b924dd29b8cca56cAlex Elder struct ceph_osd_data osd_data; 8879528734f3ae4699a2886f62f55e18fb34fb3651Alex Elder } extent; 8979528734f3ae4699a2886f62f55e18fb34fb3651Alex Elder struct { 9079528734f3ae4699a2886f62f55e18fb34fb3651Alex Elder const char *class_name; 9179528734f3ae4699a2886f62f55e18fb34fb3651Alex Elder const char *method_name; 925476492fba9fd0b4118aacf5b924dd29b8cca56cAlex Elder struct ceph_osd_data request_info; 9304017e29bbcf0673d8a6af616c56e395d05f5971Alex Elder struct ceph_osd_data request_data; 945476492fba9fd0b4118aacf5b924dd29b8cca56cAlex Elder struct ceph_osd_data response_data; 9579528734f3ae4699a2886f62f55e18fb34fb3651Alex Elder __u8 class_len; 9679528734f3ae4699a2886f62f55e18fb34fb3651Alex Elder __u8 method_len; 9779528734f3ae4699a2886f62f55e18fb34fb3651Alex Elder __u8 argc; 9879528734f3ae4699a2886f62f55e18fb34fb3651Alex Elder } cls; 9979528734f3ae4699a2886f62f55e18fb34fb3651Alex Elder struct { 10079528734f3ae4699a2886f62f55e18fb34fb3651Alex Elder u64 cookie; 10179528734f3ae4699a2886f62f55e18fb34fb3651Alex Elder u64 ver; 10279528734f3ae4699a2886f62f55e18fb34fb3651Alex Elder u32 prot_ver; 10379528734f3ae4699a2886f62f55e18fb34fb3651Alex Elder u32 timeout; 10479528734f3ae4699a2886f62f55e18fb34fb3651Alex Elder __u8 flag; 10579528734f3ae4699a2886f62f55e18fb34fb3651Alex Elder } watch; 106c647b8a8c6366f849c2a237bfe525cb1d316d5f4Ilya Dryomov struct { 107c647b8a8c6366f849c2a237bfe525cb1d316d5f4Ilya Dryomov u64 expected_object_size; 108c647b8a8c6366f849c2a237bfe525cb1d316d5f4Ilya Dryomov u64 expected_write_size; 109c647b8a8c6366f849c2a237bfe525cb1d316d5f4Ilya Dryomov } alloc_hint; 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; 1201d0326b13bc9ecab5c784415165e6f78fb06ae5bIlya Dryomov struct list_head r_linger_osd_item; 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; 140d29adb34a94715174c88ca93e8aba955850c9bdeJosh Durgin bool r_paused; 1411b83bef24c6746a146d39915a18fb5425f2facb0Sage Weil struct ceph_eversion *r_request_reassert_version; 1421b83bef24c6746a146d39915a18fb5425f2facb0Sage Weil 1431b83bef24c6746a146d39915a18fb5425f2facb0Sage Weil int r_result; 1441b83bef24c6746a146d39915a18fb5425f2facb0Sage Weil int r_reply_op_len[CEPH_OSD_MAX_OP]; 1451b83bef24c6746a146d39915a18fb5425f2facb0Sage Weil s32 r_reply_op_result[CEPH_OSD_MAX_OP]; 146350b1c32ea58d29e25d63fc25e92dd48f9339546Sage Weil int r_got_reply; 147a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh int r_linger; 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; 15326be88087ae8a04a5b576aa2f490597b649fc132Alex Elder ceph_osdc_callback_t r_callback; 15426be88087ae8a04a5b576aa2f490597b649fc132Alex Elder ceph_osdc_unsafe_callback_t r_unsafe_callback; 155f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct ceph_eversion r_reassert_version; 156f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct list_head r_unsafe_item; 157f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil 158f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct inode *r_inode; /* for use by callbacks */ 1593d14c5d2b6e15c21d8e5467dc62d33127c23a644Yehuda Sadeh void *r_priv; /* ditto */ 160f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil 1613c972c95c68f455d80ff185aa440857be046bbe0Ilya Dryomov struct ceph_object_locator r_base_oloc; 1623c972c95c68f455d80ff185aa440857be046bbe0Ilya Dryomov struct ceph_object_id r_base_oid; 163205ee1187a671c3b067d7f1e974903b44036f270Ilya Dryomov struct ceph_object_locator r_target_oloc; 164205ee1187a671c3b067d7f1e974903b44036f270Ilya Dryomov struct ceph_object_id r_target_oid; 16522116525baec1d63f4878eaa92f0b57946a78819Ilya Dryomov 1662169aea649c08374bec7d220a3b8f64712275356Sage Weil u64 r_snapid; 1673dd72fc0e6dc49c79fa9e7cd7c654deac7ccaa29Sage Weil unsigned long r_stamp; /* send OR check time */ 168f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil 169f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct ceph_snap_context *r_snapc; /* snap context for writes */ 170f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil}; 171f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil 172205ee1187a671c3b067d7f1e974903b44036f270Ilya Dryomovstruct ceph_request_redirect { 173205ee1187a671c3b067d7f1e974903b44036f270Ilya Dryomov struct ceph_object_locator oloc; 174205ee1187a671c3b067d7f1e974903b44036f270Ilya Dryomov}; 175205ee1187a671c3b067d7f1e974903b44036f270Ilya Dryomov 176a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadehstruct ceph_osd_event { 177a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh u64 cookie; 178a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh int one_shot; 179a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh struct ceph_osd_client *osdc; 180a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh void (*cb)(u64, u64, u8, void *); 181a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh void *data; 182a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh struct rb_node node; 183a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh struct list_head osd_node; 184a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh struct kref kref; 185a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh}; 186a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh 187a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadehstruct ceph_osd_event_work { 188a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh struct work_struct work; 189a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh struct ceph_osd_event *event; 190a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh u64 ver; 191a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh u64 notify_id; 192a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh u8 opcode; 193a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh}; 194a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh 195f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weilstruct ceph_osd_client { 196f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct ceph_client *client; 197f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil 198f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct ceph_osdmap *osdmap; /* current map */ 199f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct rw_semaphore map_sem; 200f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct completion map_waiters; 201f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil u64 last_requested_map; 202f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil 203f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct mutex request_mutex; 204f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct rb_root osds; /* osds */ 205f5a2041bd96c9f05ff10172b9c814c14f247084eYehuda Sadeh struct list_head osd_lru; /* idle osds */ 206f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil u64 timeout_tid; /* tid of timeout triggering rq */ 207f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil u64 last_tid; /* tid of last request */ 208f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct rb_root requests; /* pending requests */ 2096f6c7006755b667f9f6c1f3b6f08cd65f75cc471Sage Weil struct list_head req_lru; /* in-flight lru */ 2106f6c7006755b667f9f6c1f3b6f08cd65f75cc471Sage Weil struct list_head req_unsent; /* unsent/need-resend queue */ 2116f6c7006755b667f9f6c1f3b6f08cd65f75cc471Sage Weil struct list_head req_notarget; /* map to no osd */ 212a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh struct list_head req_linger; /* lingering requests */ 213f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil int num_requests; 214f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct delayed_work timeout_work; 215f5a2041bd96c9f05ff10172b9c814c14f247084eYehuda Sadeh struct delayed_work osds_timeout_work; 216039934b895c89c2bb40aa5132efe00e60b70efcaSage Weil#ifdef CONFIG_DEBUG_FS 217f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct dentry *debugfs_file; 218039934b895c89c2bb40aa5132efe00e60b70efcaSage Weil#endif 219f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil 220f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil mempool_t *req_mempool; 221f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil 2220d59ab81c3d3adf466c3fd37d7fb6d46b05d1fd4Yehuda Sadeh struct ceph_msgpool msgpool_op; 223c16e786927b977cb880873214bbd815e8d5ec4baSage Weil struct ceph_msgpool msgpool_op_reply; 224a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh 225a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh spinlock_t event_lock; 226a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh struct rb_root event_tree; 227a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh u64 event_count; 228a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh 229a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh struct workqueue_struct *notify_wq; 230f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil}; 231f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil 2325522ae0b68421e2645303ff010e27afc5292e0abAlex Elderextern int ceph_osdc_setup(void); 2335522ae0b68421e2645303ff010e27afc5292e0abAlex Elderextern void ceph_osdc_cleanup(void); 2345522ae0b68421e2645303ff010e27afc5292e0abAlex Elder 235f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weilextern int ceph_osdc_init(struct ceph_osd_client *osdc, 236f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct ceph_client *client); 237f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weilextern void ceph_osdc_stop(struct ceph_osd_client *osdc); 238f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil 239f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weilextern void ceph_osdc_handle_reply(struct ceph_osd_client *osdc, 240f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct ceph_msg *msg); 241f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weilextern void ceph_osdc_handle_map(struct ceph_osd_client *osdc, 242f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct ceph_msg *msg); 243f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil 24449719778bfa5371ec9b5a7d989bb29000e3ac5dfAlex Elderextern void osd_req_op_init(struct ceph_osd_request *osd_req, 24549719778bfa5371ec9b5a7d989bb29000e3ac5dfAlex Elder unsigned int which, u16 opcode); 24649719778bfa5371ec9b5a7d989bb29000e3ac5dfAlex Elder 24749719778bfa5371ec9b5a7d989bb29000e3ac5dfAlex Elderextern void osd_req_op_raw_data_in_pages(struct ceph_osd_request *, 24849719778bfa5371ec9b5a7d989bb29000e3ac5dfAlex Elder unsigned int which, 24949719778bfa5371ec9b5a7d989bb29000e3ac5dfAlex Elder struct page **pages, u64 length, 25049719778bfa5371ec9b5a7d989bb29000e3ac5dfAlex Elder u32 alignment, bool pages_from_pool, 25149719778bfa5371ec9b5a7d989bb29000e3ac5dfAlex Elder bool own_pages); 25249719778bfa5371ec9b5a7d989bb29000e3ac5dfAlex Elder 253c99d2d4abb6c405ef52e9bc1da87b382b8f41739Alex Elderextern void osd_req_op_extent_init(struct ceph_osd_request *osd_req, 254c99d2d4abb6c405ef52e9bc1da87b382b8f41739Alex Elder unsigned int which, u16 opcode, 25533803f3300265661b5c5d20a9811c6a2a157d545Alex Elder u64 offset, u64 length, 25633803f3300265661b5c5d20a9811c6a2a157d545Alex Elder u64 truncate_size, u32 truncate_seq); 257c99d2d4abb6c405ef52e9bc1da87b382b8f41739Alex Elderextern void osd_req_op_extent_update(struct ceph_osd_request *osd_req, 258c99d2d4abb6c405ef52e9bc1da87b382b8f41739Alex Elder unsigned int which, u64 length); 259a4ce40a9a7c1053ac2a41cf64255e44e356e5522Alex Elder 260a4ce40a9a7c1053ac2a41cf64255e44e356e5522Alex Elderextern struct ceph_osd_data *osd_req_op_extent_osd_data( 261a4ce40a9a7c1053ac2a41cf64255e44e356e5522Alex Elder struct ceph_osd_request *osd_req, 262406e2c9f9286fc93ae2191a7abf477dea05aadc9Alex Elder unsigned int which); 263a4ce40a9a7c1053ac2a41cf64255e44e356e5522Alex Elderextern struct ceph_osd_data *osd_req_op_cls_response_data( 264a4ce40a9a7c1053ac2a41cf64255e44e356e5522Alex Elder struct ceph_osd_request *osd_req, 265a4ce40a9a7c1053ac2a41cf64255e44e356e5522Alex Elder unsigned int which); 266a4ce40a9a7c1053ac2a41cf64255e44e356e5522Alex Elder 267a4ce40a9a7c1053ac2a41cf64255e44e356e5522Alex Elderextern void osd_req_op_extent_osd_data_pages(struct ceph_osd_request *, 268406e2c9f9286fc93ae2191a7abf477dea05aadc9Alex Elder unsigned int which, 269a4ce40a9a7c1053ac2a41cf64255e44e356e5522Alex Elder struct page **pages, u64 length, 270a4ce40a9a7c1053ac2a41cf64255e44e356e5522Alex Elder u32 alignment, bool pages_from_pool, 271a4ce40a9a7c1053ac2a41cf64255e44e356e5522Alex Elder bool own_pages); 272a4ce40a9a7c1053ac2a41cf64255e44e356e5522Alex Elderextern void osd_req_op_extent_osd_data_pagelist(struct ceph_osd_request *, 273406e2c9f9286fc93ae2191a7abf477dea05aadc9Alex Elder unsigned int which, 274a4ce40a9a7c1053ac2a41cf64255e44e356e5522Alex Elder struct ceph_pagelist *pagelist); 275a4ce40a9a7c1053ac2a41cf64255e44e356e5522Alex Elder#ifdef CONFIG_BLOCK 276a4ce40a9a7c1053ac2a41cf64255e44e356e5522Alex Elderextern void osd_req_op_extent_osd_data_bio(struct ceph_osd_request *, 277406e2c9f9286fc93ae2191a7abf477dea05aadc9Alex Elder unsigned int which, 278a4ce40a9a7c1053ac2a41cf64255e44e356e5522Alex Elder struct bio *bio, size_t bio_length); 279a4ce40a9a7c1053ac2a41cf64255e44e356e5522Alex Elder#endif /* CONFIG_BLOCK */ 280a4ce40a9a7c1053ac2a41cf64255e44e356e5522Alex Elder 28104017e29bbcf0673d8a6af616c56e395d05f5971Alex Elderextern void osd_req_op_cls_request_data_pagelist(struct ceph_osd_request *, 28204017e29bbcf0673d8a6af616c56e395d05f5971Alex Elder unsigned int which, 28304017e29bbcf0673d8a6af616c56e395d05f5971Alex Elder struct ceph_pagelist *pagelist); 2846c57b5545d46e276381a15a59283c984cf3f94e3Alex Elderextern void osd_req_op_cls_request_data_pages(struct ceph_osd_request *, 2856c57b5545d46e276381a15a59283c984cf3f94e3Alex Elder unsigned int which, 2866c57b5545d46e276381a15a59283c984cf3f94e3Alex Elder struct page **pages, u64 length, 2876c57b5545d46e276381a15a59283c984cf3f94e3Alex Elder u32 alignment, bool pages_from_pool, 2886c57b5545d46e276381a15a59283c984cf3f94e3Alex Elder bool own_pages); 289a4ce40a9a7c1053ac2a41cf64255e44e356e5522Alex Elderextern void osd_req_op_cls_response_data_pages(struct ceph_osd_request *, 290c99d2d4abb6c405ef52e9bc1da87b382b8f41739Alex Elder unsigned int which, 291a4ce40a9a7c1053ac2a41cf64255e44e356e5522Alex Elder struct page **pages, u64 length, 292a4ce40a9a7c1053ac2a41cf64255e44e356e5522Alex Elder u32 alignment, bool pages_from_pool, 293a4ce40a9a7c1053ac2a41cf64255e44e356e5522Alex Elder bool own_pages); 294a4ce40a9a7c1053ac2a41cf64255e44e356e5522Alex Elder 295c99d2d4abb6c405ef52e9bc1da87b382b8f41739Alex Elderextern void osd_req_op_cls_init(struct ceph_osd_request *osd_req, 296c99d2d4abb6c405ef52e9bc1da87b382b8f41739Alex Elder unsigned int which, u16 opcode, 29704017e29bbcf0673d8a6af616c56e395d05f5971Alex Elder const char *class, const char *method); 298c99d2d4abb6c405ef52e9bc1da87b382b8f41739Alex Elderextern void osd_req_op_watch_init(struct ceph_osd_request *osd_req, 299c99d2d4abb6c405ef52e9bc1da87b382b8f41739Alex Elder unsigned int which, u16 opcode, 30033803f3300265661b5c5d20a9811c6a2a157d545Alex Elder u64 cookie, u64 version, int flag); 301c647b8a8c6366f849c2a237bfe525cb1d316d5f4Ilya Dryomovextern void osd_req_op_alloc_hint_init(struct ceph_osd_request *osd_req, 302c647b8a8c6366f849c2a237bfe525cb1d316d5f4Ilya Dryomov unsigned int which, 303c647b8a8c6366f849c2a237bfe525cb1d316d5f4Ilya Dryomov u64 expected_object_size, 304c647b8a8c6366f849c2a237bfe525cb1d316d5f4Ilya Dryomov u64 expected_write_size); 30533803f3300265661b5c5d20a9811c6a2a157d545Alex Elder 3063499e8a5d4dbb083324efd942e2c4fb7eb65f27cYehuda Sadehextern struct ceph_osd_request *ceph_osdc_alloc_request(struct ceph_osd_client *osdc, 3073499e8a5d4dbb083324efd942e2c4fb7eb65f27cYehuda Sadeh struct ceph_snap_context *snapc, 308acead002b200569273bed331c93c4a91d25e10b8Alex Elder unsigned int num_ops, 3093499e8a5d4dbb083324efd942e2c4fb7eb65f27cYehuda Sadeh bool use_mempool, 31054a5400721da7fa5a16cea151aade5bdfee74111Alex Elder gfp_t gfp_flags); 3113499e8a5d4dbb083324efd942e2c4fb7eb65f27cYehuda Sadeh 312175face2ba31025b0dcd6da4e711fca7764287faAlex Elderextern void ceph_osdc_build_request(struct ceph_osd_request *req, u64 off, 31368b4476b0bc13fef18266b4140309a30e86739d2Yehuda Sadeh struct ceph_snap_context *snapc, 3144d6b250bf18d44571d69a0f4afec4b6a1969729fAlex Elder u64 snap_id, 315af77f26caa35a95af09d1dac5c513b3901de7e37Alex Elder struct timespec *mtime); 3163499e8a5d4dbb083324efd942e2c4fb7eb65f27cYehuda Sadeh 317f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weilextern struct ceph_osd_request *ceph_osdc_new_request(struct ceph_osd_client *, 318f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct ceph_file_layout *layout, 319f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct ceph_vino vino, 320acead002b200569273bed331c93c4a91d25e10b8Alex Elder u64 offset, u64 *len, 32179528734f3ae4699a2886f62f55e18fb34fb3651Alex Elder int num_ops, int opcode, int flags, 322f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct ceph_snap_context *snapc, 323acead002b200569273bed331c93c4a91d25e10b8Alex Elder u32 truncate_seq, u64 truncate_size, 324153e5167e0e237faaefb7adf82db5748c1452d73Alex Elder bool use_mempool); 325f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil 326a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadehextern void ceph_osdc_set_request_linger(struct ceph_osd_client *osdc, 327a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh struct ceph_osd_request *req); 328a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh 3299e94af202afd961da39f82b55ba83edd4ad30e98Ilya Dryomovextern void ceph_osdc_get_request(struct ceph_osd_request *req); 3309e94af202afd961da39f82b55ba83edd4ad30e98Ilya Dryomovextern void ceph_osdc_put_request(struct ceph_osd_request *req); 331f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil 332f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weilextern int ceph_osdc_start_request(struct ceph_osd_client *osdc, 333f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct ceph_osd_request *req, 334f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil bool nofail); 335c9f9b93ddfd76498fe36d9f550bd26533a4ee6bfIlya Dryomovextern void ceph_osdc_cancel_request(struct ceph_osd_request *req); 336f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weilextern int ceph_osdc_wait_request(struct ceph_osd_client *osdc, 337f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct ceph_osd_request *req); 338f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weilextern void ceph_osdc_sync(struct ceph_osd_client *osdc); 339f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil 340dd935f44a40f8fb02aff2cc0df2269c92422df1cJosh Durginextern void ceph_osdc_flush_notifies(struct ceph_osd_client *osdc); 341dd935f44a40f8fb02aff2cc0df2269c92422df1cJosh Durgin 342f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weilextern int ceph_osdc_readpages(struct ceph_osd_client *osdc, 343f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct ceph_vino vino, 344f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct ceph_file_layout *layout, 345f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil u64 off, u64 *plen, 346f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil u32 truncate_seq, u64 truncate_size, 347b7495fc2ff941db6a118a93ab8d61149e3f4cef8Sage Weil struct page **pages, int nr_pages, 348b7495fc2ff941db6a118a93ab8d61149e3f4cef8Sage Weil int page_align); 349f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil 350f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weilextern int ceph_osdc_writepages(struct ceph_osd_client *osdc, 351f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct ceph_vino vino, 352f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct ceph_file_layout *layout, 353f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct ceph_snap_context *sc, 354f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil u64 off, u64 len, 355f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil u32 truncate_seq, u64 truncate_size, 356f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil struct timespec *mtime, 3572480882611e3ab844563dd3d0a822227604ab8feAlex Elder struct page **pages, int nr_pages); 358f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil 359a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh/* watch/notify events */ 360a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadehextern int ceph_osdc_create_event(struct ceph_osd_client *osdc, 361a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadeh void (*event_cb)(u64, u64, u8, void *), 3623c663bbdcdf9296e0fe3362acb9e81f49d7b72c6Alex Elder void *data, struct ceph_osd_event **pevent); 363a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadehextern void ceph_osdc_cancel_event(struct ceph_osd_event *event); 364a40c4f10e3fb96030358e49abd010c1f08446fa3Yehuda Sadehextern void ceph_osdc_put_event(struct ceph_osd_event *event); 365f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil#endif 366f24e9980eb860d8600cbe5ef3d2fd9295320d229Sage Weil 367