1 #ifndef _FS_CEPH_OSD_CLIENT_H
2 #define _FS_CEPH_OSD_CLIENT_H
4 #include <linux/completion.h>
5 #include <linux/kref.h>
6 #include <linux/mempool.h>
7 #include <linux/rbtree.h>
11 #include "messenger.h"
14 struct ceph_snap_context
;
15 struct ceph_osd_request
;
16 struct ceph_osd_client
;
17 struct ceph_authorizer
;
21 * completion callback for async writepages
23 typedef void (*ceph_osdc_callback_t
)(struct ceph_osd_request
*,
26 /* a given osd we're communicating with */
29 struct ceph_osd_client
*o_osdc
;
32 struct rb_node o_node
;
33 struct ceph_connection o_con
;
34 struct list_head o_requests
;
35 struct list_head o_osd_lru
;
36 struct ceph_authorizer
*o_authorizer
;
37 void *o_authorizer_buf
, *o_authorizer_reply_buf
;
38 size_t o_authorizer_buf_len
, o_authorizer_reply_buf_len
;
39 unsigned long lru_ttl
;
40 int o_marked_for_keepalive
;
41 struct list_head o_keepalive_item
;
44 /* an in-flight request */
45 struct ceph_osd_request
{
46 u64 r_tid
; /* unique for this client */
47 struct rb_node r_node
;
48 struct list_head r_req_lru_item
;
49 struct list_head r_osd_item
;
50 struct ceph_osd
*r_osd
;
51 struct ceph_pg r_pgid
;
52 int r_pg_osds
[CEPH_PG_MAX_SIZE
];
55 struct ceph_connection
*r_con_filling_msg
;
57 struct ceph_msg
*r_request
, *r_reply
;
59 int r_flags
; /* any additional flags for the osd */
60 u32 r_sent
; /* >0 if r_request is sending/sent */
63 struct ceph_osd_client
*r_osdc
;
66 struct completion r_completion
, r_safe_completion
;
67 ceph_osdc_callback_t r_callback
, r_safe_callback
;
68 struct ceph_eversion r_reassert_version
;
69 struct list_head r_unsafe_item
;
71 struct inode
*r_inode
; /* for use by callbacks */
73 char r_oid
[40]; /* object name */
75 unsigned long r_stamp
; /* send OR check time */
76 bool r_resend
; /* msg send failed, needs retry */
78 struct ceph_file_layout r_file_layout
;
79 struct ceph_snap_context
*r_snapc
; /* snap context for writes */
80 unsigned r_num_pages
; /* size of page array (follows) */
81 struct page
**r_pages
; /* pages for data payload */
82 int r_pages_from_pool
;
83 int r_own_pages
; /* if true, i own page list */
85 struct bio
*r_bio
; /* instead of pages */
88 struct ceph_pagelist
*r_trail
; /* trailing part of the data */
91 struct ceph_osd_client
{
92 struct ceph_client
*client
;
94 struct ceph_osdmap
*osdmap
; /* current map */
95 struct rw_semaphore map_sem
;
96 struct completion map_waiters
;
97 u64 last_requested_map
;
99 struct mutex request_mutex
;
100 struct rb_root osds
; /* osds */
101 struct list_head osd_lru
; /* idle osds */
102 u64 timeout_tid
; /* tid of timeout triggering rq */
103 u64 last_tid
; /* tid of last request */
104 struct rb_root requests
; /* pending requests */
105 struct list_head req_lru
; /* pending requests lru */
107 struct delayed_work timeout_work
;
108 struct delayed_work osds_timeout_work
;
109 #ifdef CONFIG_DEBUG_FS
110 struct dentry
*debugfs_file
;
113 mempool_t
*req_mempool
;
115 struct ceph_msgpool msgpool_op
;
116 struct ceph_msgpool msgpool_op_reply
;
119 struct ceph_osd_req_op
{
120 u16 op
; /* CEPH_OSD_OP_* */
121 u32 flags
; /* CEPH_OSD_FLAG_* */
133 __u8 cmp_op
; /* CEPH_OSD_CMPXATTR_OP_* */
134 __u8 cmp_mode
; /* CEPH_OSD_CMPXATTR_MODE_* */
137 const char *class_name
;
139 const char *method_name
;
155 extern int ceph_osdc_init(struct ceph_osd_client
*osdc
,
156 struct ceph_client
*client
);
157 extern void ceph_osdc_stop(struct ceph_osd_client
*osdc
);
159 extern void ceph_osdc_handle_reply(struct ceph_osd_client
*osdc
,
160 struct ceph_msg
*msg
);
161 extern void ceph_osdc_handle_map(struct ceph_osd_client
*osdc
,
162 struct ceph_msg
*msg
);
164 extern void ceph_calc_raw_layout(struct ceph_osd_client
*osdc
,
165 struct ceph_file_layout
*layout
,
167 u64 off
, u64
*plen
, u64
*bno
,
168 struct ceph_osd_request
*req
,
169 struct ceph_osd_req_op
*op
);
171 extern struct ceph_osd_request
*ceph_osdc_alloc_request(struct ceph_osd_client
*osdc
,
173 struct ceph_snap_context
*snapc
,
174 struct ceph_osd_req_op
*ops
,
180 extern void ceph_osdc_build_request(struct ceph_osd_request
*req
,
182 struct ceph_osd_req_op
*src_ops
,
183 struct ceph_snap_context
*snapc
,
184 struct timespec
*mtime
,
188 extern struct ceph_osd_request
*ceph_osdc_new_request(struct ceph_osd_client
*,
189 struct ceph_file_layout
*layout
,
190 struct ceph_vino vino
,
191 u64 offset
, u64
*len
, int op
, int flags
,
192 struct ceph_snap_context
*snapc
,
193 int do_sync
, u32 truncate_seq
,
195 struct timespec
*mtime
,
196 bool use_mempool
, int num_reply
);
198 static inline void ceph_osdc_get_request(struct ceph_osd_request
*req
)
200 kref_get(&req
->r_kref
);
202 extern void ceph_osdc_release_request(struct kref
*kref
);
203 static inline void ceph_osdc_put_request(struct ceph_osd_request
*req
)
205 kref_put(&req
->r_kref
, ceph_osdc_release_request
);
208 extern int ceph_osdc_start_request(struct ceph_osd_client
*osdc
,
209 struct ceph_osd_request
*req
,
211 extern int ceph_osdc_wait_request(struct ceph_osd_client
*osdc
,
212 struct ceph_osd_request
*req
);
213 extern void ceph_osdc_sync(struct ceph_osd_client
*osdc
);
215 extern int ceph_osdc_readpages(struct ceph_osd_client
*osdc
,
216 struct ceph_vino vino
,
217 struct ceph_file_layout
*layout
,
219 u32 truncate_seq
, u64 truncate_size
,
220 struct page
**pages
, int nr_pages
);
222 extern int ceph_osdc_writepages(struct ceph_osd_client
*osdc
,
223 struct ceph_vino vino
,
224 struct ceph_file_layout
*layout
,
225 struct ceph_snap_context
*sc
,
227 u32 truncate_seq
, u64 truncate_size
,
228 struct timespec
*mtime
,
229 struct page
**pages
, int nr_pages
,
230 int flags
, int do_sync
, bool nofail
);