Commit | Line | Data |
---|---|---|
f24e9980 SW |
1 | #ifndef _FS_CEPH_OSD_CLIENT_H |
2 | #define _FS_CEPH_OSD_CLIENT_H | |
3 | ||
4 | #include <linux/completion.h> | |
415e49a9 | 5 | #include <linux/kref.h> |
f24e9980 SW |
6 | #include <linux/mempool.h> |
7 | #include <linux/rbtree.h> | |
8 | ||
9 | #include "types.h" | |
10 | #include "osdmap.h" | |
11 | #include "messenger.h" | |
12 | ||
13 | struct ceph_msg; | |
14 | struct ceph_snap_context; | |
15 | struct ceph_osd_request; | |
16 | struct ceph_osd_client; | |
4e7a5dcd | 17 | struct ceph_authorizer; |
f24e9980 SW |
18 | |
19 | /* | |
20 | * completion callback for async writepages | |
21 | */ | |
22 | typedef void (*ceph_osdc_callback_t)(struct ceph_osd_request *, | |
23 | struct ceph_msg *); | |
24 | ||
25 | /* a given osd we're communicating with */ | |
26 | struct ceph_osd { | |
27 | atomic_t o_ref; | |
28 | struct ceph_osd_client *o_osdc; | |
29 | int o_osd; | |
30 | int o_incarnation; | |
31 | struct rb_node o_node; | |
32 | struct ceph_connection o_con; | |
33 | struct list_head o_requests; | |
4e7a5dcd SW |
34 | struct ceph_authorizer *o_authorizer; |
35 | void *o_authorizer_buf, *o_authorizer_reply_buf; | |
36 | size_t o_authorizer_buf_len, o_authorizer_reply_buf_len; | |
f24e9980 SW |
37 | }; |
38 | ||
39 | /* an in-flight request */ | |
40 | struct ceph_osd_request { | |
41 | u64 r_tid; /* unique for this client */ | |
42 | struct rb_node r_node; | |
43 | struct list_head r_osd_item; | |
44 | struct ceph_osd *r_osd; | |
45 | ||
350b1c32 SW |
46 | struct ceph_connection *r_con_filling_pages; |
47 | ||
f24e9980 SW |
48 | struct ceph_msg *r_request, *r_reply; |
49 | int r_result; | |
50 | int r_flags; /* any additional flags for the osd */ | |
51 | u32 r_sent; /* >0 if r_request is sending/sent */ | |
350b1c32 | 52 | int r_got_reply; |
93c20d98 | 53 | int r_num_prealloc_reply; |
f24e9980 SW |
54 | |
55 | struct ceph_osd_client *r_osdc; | |
415e49a9 | 56 | struct kref r_kref; |
f24e9980 SW |
57 | bool r_mempool; |
58 | struct completion r_completion, r_safe_completion; | |
59 | ceph_osdc_callback_t r_callback, r_safe_callback; | |
60 | struct ceph_eversion r_reassert_version; | |
61 | struct list_head r_unsafe_item; | |
62 | ||
63 | struct inode *r_inode; /* for use by callbacks */ | |
64 | struct writeback_control *r_wbc; /* ditto */ | |
65 | ||
66 | char r_oid[40]; /* object name */ | |
67 | int r_oid_len; | |
68 | unsigned long r_timeout_stamp; | |
69 | bool r_resend; /* msg send failed, needs retry */ | |
70 | ||
71 | struct ceph_file_layout r_file_layout; | |
72 | struct ceph_snap_context *r_snapc; /* snap context for writes */ | |
73 | unsigned r_num_pages; /* size of page array (follows) */ | |
74 | struct page **r_pages; /* pages for data payload */ | |
75 | int r_pages_from_pool; | |
76 | int r_own_pages; /* if true, i own page list */ | |
77 | }; | |
78 | ||
79 | struct ceph_osd_client { | |
80 | struct ceph_client *client; | |
81 | ||
82 | struct ceph_osdmap *osdmap; /* current map */ | |
83 | struct rw_semaphore map_sem; | |
84 | struct completion map_waiters; | |
85 | u64 last_requested_map; | |
86 | ||
87 | struct mutex request_mutex; | |
88 | struct rb_root osds; /* osds */ | |
89 | u64 timeout_tid; /* tid of timeout triggering rq */ | |
90 | u64 last_tid; /* tid of last request */ | |
91 | struct rb_root requests; /* pending requests */ | |
92 | int num_requests; | |
93 | struct delayed_work timeout_work; | |
039934b8 | 94 | #ifdef CONFIG_DEBUG_FS |
f24e9980 | 95 | struct dentry *debugfs_file; |
039934b8 | 96 | #endif |
f24e9980 SW |
97 | |
98 | mempool_t *req_mempool; | |
99 | ||
100 | struct ceph_msgpool msgpool_op; | |
101 | struct ceph_msgpool msgpool_op_reply; | |
102 | }; | |
103 | ||
104 | extern int ceph_osdc_init(struct ceph_osd_client *osdc, | |
105 | struct ceph_client *client); | |
106 | extern void ceph_osdc_stop(struct ceph_osd_client *osdc); | |
107 | ||
108 | extern void ceph_osdc_handle_reply(struct ceph_osd_client *osdc, | |
109 | struct ceph_msg *msg); | |
110 | extern void ceph_osdc_handle_map(struct ceph_osd_client *osdc, | |
111 | struct ceph_msg *msg); | |
112 | ||
113 | extern struct ceph_osd_request *ceph_osdc_new_request(struct ceph_osd_client *, | |
114 | struct ceph_file_layout *layout, | |
115 | struct ceph_vino vino, | |
116 | u64 offset, u64 *len, int op, int flags, | |
117 | struct ceph_snap_context *snapc, | |
118 | int do_sync, u32 truncate_seq, | |
119 | u64 truncate_size, | |
120 | struct timespec *mtime, | |
121 | bool use_mempool, int num_reply); | |
122 | ||
123 | static inline void ceph_osdc_get_request(struct ceph_osd_request *req) | |
124 | { | |
415e49a9 SW |
125 | kref_get(&req->r_kref); |
126 | } | |
127 | extern void ceph_osdc_release_request(struct kref *kref); | |
128 | static inline void ceph_osdc_put_request(struct ceph_osd_request *req) | |
129 | { | |
130 | kref_put(&req->r_kref, ceph_osdc_release_request); | |
f24e9980 | 131 | } |
f24e9980 SW |
132 | |
133 | extern int ceph_osdc_start_request(struct ceph_osd_client *osdc, | |
134 | struct ceph_osd_request *req, | |
135 | bool nofail); | |
136 | extern int ceph_osdc_wait_request(struct ceph_osd_client *osdc, | |
137 | struct ceph_osd_request *req); | |
138 | extern void ceph_osdc_sync(struct ceph_osd_client *osdc); | |
139 | ||
140 | extern int ceph_osdc_readpages(struct ceph_osd_client *osdc, | |
141 | struct ceph_vino vino, | |
142 | struct ceph_file_layout *layout, | |
143 | u64 off, u64 *plen, | |
144 | u32 truncate_seq, u64 truncate_size, | |
145 | struct page **pages, int nr_pages); | |
146 | ||
147 | extern int ceph_osdc_writepages(struct ceph_osd_client *osdc, | |
148 | struct ceph_vino vino, | |
149 | struct ceph_file_layout *layout, | |
150 | struct ceph_snap_context *sc, | |
151 | u64 off, u64 len, | |
152 | u32 truncate_seq, u64 truncate_size, | |
153 | struct timespec *mtime, | |
154 | struct page **pages, int nr_pages, | |
155 | int flags, int do_sync, bool nofail); | |
156 | ||
157 | #endif | |
158 |