Sage Weil | 2f2dc05 | 2009-10-06 11:31:09 -0700 | [diff] [blame] | 1 | #ifndef _FS_CEPH_MDS_CLIENT_H |
| 2 | #define _FS_CEPH_MDS_CLIENT_H |
| 3 | |
| 4 | #include <linux/completion.h> |
Sage Weil | 153c8e6 | 2009-12-07 12:31:09 -0800 | [diff] [blame] | 5 | #include <linux/kref.h> |
Sage Weil | 2f2dc05 | 2009-10-06 11:31:09 -0700 | [diff] [blame] | 6 | #include <linux/list.h> |
| 7 | #include <linux/mutex.h> |
Sage Weil | 44ca18f | 2010-02-15 12:08:46 -0800 | [diff] [blame] | 8 | #include <linux/rbtree.h> |
Sage Weil | 2f2dc05 | 2009-10-06 11:31:09 -0700 | [diff] [blame] | 9 | #include <linux/spinlock.h> |
| 10 | |
Yehuda Sadeh | 3d14c5d | 2010-04-06 15:14:15 -0700 | [diff] [blame] | 11 | #include <linux/ceph/types.h> |
| 12 | #include <linux/ceph/messenger.h> |
| 13 | #include <linux/ceph/mdsmap.h> |
Alex Elder | 6c4a191 | 2012-05-16 15:16:38 -0500 | [diff] [blame] | 14 | #include <linux/ceph/auth.h> |
Sage Weil | 2f2dc05 | 2009-10-06 11:31:09 -0700 | [diff] [blame] | 15 | |
| 16 | /* |
| 17 | * Some lock dependencies: |
| 18 | * |
| 19 | * session->s_mutex |
| 20 | * mdsc->mutex |
| 21 | * |
| 22 | * mdsc->snap_rwsem |
| 23 | * |
Sage Weil | be65559 | 2011-11-30 09:47:09 -0800 | [diff] [blame] | 24 | * ci->i_ceph_lock |
Sage Weil | 2f2dc05 | 2009-10-06 11:31:09 -0700 | [diff] [blame] | 25 | * mdsc->snap_flush_lock |
| 26 | * mdsc->cap_delay_lock |
| 27 | * |
| 28 | */ |
| 29 | |
Yehuda Sadeh | 3d14c5d | 2010-04-06 15:14:15 -0700 | [diff] [blame] | 30 | struct ceph_fs_client; |
Sage Weil | 2f2dc05 | 2009-10-06 11:31:09 -0700 | [diff] [blame] | 31 | struct ceph_cap; |
| 32 | |
| 33 | /* |
| 34 | * parsed info about a single inode. pointers are into the encoded |
| 35 | * on-wire structures within the mds reply message payload. |
| 36 | */ |
| 37 | struct ceph_mds_reply_info_in { |
| 38 | struct ceph_mds_reply_inode *in; |
Sage Weil | 14303d2 | 2010-12-14 17:37:52 -0800 | [diff] [blame] | 39 | struct ceph_dir_layout dir_layout; |
Sage Weil | 2f2dc05 | 2009-10-06 11:31:09 -0700 | [diff] [blame] | 40 | u32 symlink_len; |
| 41 | char *symlink; |
| 42 | u32 xattr_len; |
| 43 | char *xattr_data; |
Yan, Zheng | fb01d1f | 2014-11-14 21:29:55 +0800 | [diff] [blame] | 44 | u64 inline_version; |
| 45 | u32 inline_len; |
| 46 | char *inline_data; |
Sage Weil | 2f2dc05 | 2009-10-06 11:31:09 -0700 | [diff] [blame] | 47 | }; |
| 48 | |
| 49 | /* |
Herb Shiu | 25933ab | 2010-12-01 14:14:38 -0800 | [diff] [blame] | 50 | * parsed info about an mds reply, including information about |
| 51 | * either: 1) the target inode and/or its parent directory and dentry, |
| 52 | * and directory contents (for readdir results), or |
| 53 | * 2) the file range lock info (for fcntl F_GETLK results). |
Sage Weil | 2f2dc05 | 2009-10-06 11:31:09 -0700 | [diff] [blame] | 54 | */ |
| 55 | struct ceph_mds_reply_info_parsed { |
| 56 | struct ceph_mds_reply_head *head; |
| 57 | |
Herb Shiu | 25933ab | 2010-12-01 14:14:38 -0800 | [diff] [blame] | 58 | /* trace */ |
Sage Weil | 2f2dc05 | 2009-10-06 11:31:09 -0700 | [diff] [blame] | 59 | struct ceph_mds_reply_info_in diri, targeti; |
| 60 | struct ceph_mds_reply_dirfrag *dirfrag; |
| 61 | char *dname; |
| 62 | u32 dname_len; |
| 63 | struct ceph_mds_reply_lease *dlease; |
| 64 | |
Herb Shiu | 25933ab | 2010-12-01 14:14:38 -0800 | [diff] [blame] | 65 | /* extra */ |
| 66 | union { |
| 67 | /* for fcntl F_GETLK results */ |
| 68 | struct ceph_filelock *filelock_reply; |
| 69 | |
| 70 | /* for readdir results */ |
| 71 | struct { |
| 72 | struct ceph_mds_reply_dirfrag *dir_dir; |
Yan, Zheng | 5400839 | 2014-03-29 13:41:15 +0800 | [diff] [blame] | 73 | size_t dir_buf_size; |
Herb Shiu | 25933ab | 2010-12-01 14:14:38 -0800 | [diff] [blame] | 74 | int dir_nr; |
| 75 | char **dir_dname; |
| 76 | u32 *dir_dname_len; |
| 77 | struct ceph_mds_reply_lease **dir_dlease; |
| 78 | struct ceph_mds_reply_info_in *dir_in; |
| 79 | u8 dir_complete, dir_end; |
| 80 | }; |
Sam Lang | 6e8575f | 2012-12-28 09:56:46 -0800 | [diff] [blame] | 81 | |
| 82 | /* for create results */ |
| 83 | struct { |
| 84 | bool has_create_ino; |
| 85 | u64 ino; |
| 86 | }; |
Herb Shiu | 25933ab | 2010-12-01 14:14:38 -0800 | [diff] [blame] | 87 | }; |
Sage Weil | 2f2dc05 | 2009-10-06 11:31:09 -0700 | [diff] [blame] | 88 | |
| 89 | /* encoded blob describing snapshot contexts for certain |
| 90 | operations (e.g., open) */ |
| 91 | void *snapblob; |
| 92 | int snapblob_len; |
| 93 | }; |
| 94 | |
| 95 | |
| 96 | /* |
| 97 | * cap releases are batched and sent to the MDS en masse. |
| 98 | */ |
| 99 | #define CEPH_CAPS_PER_RELEASE ((PAGE_CACHE_SIZE - \ |
| 100 | sizeof(struct ceph_mds_cap_release)) / \ |
| 101 | sizeof(struct ceph_mds_cap_item)) |
| 102 | |
| 103 | |
| 104 | /* |
| 105 | * state associated with each MDS<->client session |
| 106 | */ |
| 107 | enum { |
| 108 | CEPH_MDS_SESSION_NEW = 1, |
| 109 | CEPH_MDS_SESSION_OPENING = 2, |
| 110 | CEPH_MDS_SESSION_OPEN = 3, |
| 111 | CEPH_MDS_SESSION_HUNG = 4, |
| 112 | CEPH_MDS_SESSION_CLOSING = 5, |
| 113 | CEPH_MDS_SESSION_RESTARTING = 6, |
| 114 | CEPH_MDS_SESSION_RECONNECTING = 7, |
| 115 | }; |
| 116 | |
| 117 | struct ceph_mds_session { |
| 118 | struct ceph_mds_client *s_mdsc; |
| 119 | int s_mds; |
| 120 | int s_state; |
| 121 | unsigned long s_ttl; /* time until mds kills us */ |
| 122 | u64 s_seq; /* incoming msg seq # */ |
| 123 | struct mutex s_mutex; /* serialize session messages */ |
| 124 | |
Sage Weil | 2f2dc05 | 2009-10-06 11:31:09 -0700 | [diff] [blame] | 125 | struct ceph_connection s_con; |
| 126 | |
Alex Elder | 6c4a191 | 2012-05-16 15:16:38 -0500 | [diff] [blame] | 127 | struct ceph_auth_handshake s_auth; |
Sage Weil | 4e7a5dc | 2009-11-18 16:19:57 -0800 | [diff] [blame] | 128 | |
Alex Elder | d8fb02a | 2012-01-12 17:48:10 -0800 | [diff] [blame] | 129 | /* protected by s_gen_ttl_lock */ |
| 130 | spinlock_t s_gen_ttl_lock; |
Sage Weil | 2f2dc05 | 2009-10-06 11:31:09 -0700 | [diff] [blame] | 131 | u32 s_cap_gen; /* inc each time we get mds stale msg */ |
| 132 | unsigned long s_cap_ttl; /* when session caps expire */ |
Alex Elder | d8fb02a | 2012-01-12 17:48:10 -0800 | [diff] [blame] | 133 | |
| 134 | /* protected by s_cap_lock */ |
| 135 | spinlock_t s_cap_lock; |
Sage Weil | 2f2dc05 | 2009-10-06 11:31:09 -0700 | [diff] [blame] | 136 | struct list_head s_caps; /* all caps issued by this session */ |
| 137 | int s_nr_caps, s_trim_caps; |
| 138 | int s_num_cap_releases; |
Yan, Zheng | 99a9c27 | 2013-09-22 11:08:14 +0800 | [diff] [blame] | 139 | int s_cap_reconnect; |
Yan, Zheng | 03f4fcb | 2015-01-05 11:04:04 +0800 | [diff] [blame] | 140 | int s_readonly; |
Sage Weil | 2f2dc05 | 2009-10-06 11:31:09 -0700 | [diff] [blame] | 141 | struct list_head s_cap_releases; /* waiting cap_release messages */ |
| 142 | struct list_head s_cap_releases_done; /* ready to send */ |
Sage Weil | 7c1332b | 2010-02-16 11:39:45 -0800 | [diff] [blame] | 143 | struct ceph_cap *s_cap_iterator; |
Sage Weil | 2f2dc05 | 2009-10-06 11:31:09 -0700 | [diff] [blame] | 144 | |
| 145 | /* protected by mutex */ |
| 146 | struct list_head s_cap_flushing; /* inodes w/ flushing caps */ |
| 147 | struct list_head s_cap_snaps_flushing; |
| 148 | unsigned long s_renew_requested; /* last time we sent a renew req */ |
| 149 | u64 s_renew_seq; |
| 150 | |
| 151 | atomic_t s_ref; |
| 152 | struct list_head s_waiting; /* waiting requests */ |
| 153 | struct list_head s_unsafe; /* unsafe requests */ |
| 154 | }; |
| 155 | |
| 156 | /* |
| 157 | * modes of choosing which MDS to send a request to |
| 158 | */ |
| 159 | enum { |
| 160 | USE_ANY_MDS, |
| 161 | USE_RANDOM_MDS, |
| 162 | USE_AUTH_MDS, /* prefer authoritative mds for this metadata item */ |
| 163 | }; |
| 164 | |
| 165 | struct ceph_mds_request; |
| 166 | struct ceph_mds_client; |
| 167 | |
| 168 | /* |
| 169 | * request completion callback |
| 170 | */ |
| 171 | typedef void (*ceph_mds_request_callback_t) (struct ceph_mds_client *mdsc, |
| 172 | struct ceph_mds_request *req); |
Yan, Zheng | 9280be2 | 2014-10-14 10:33:35 +0800 | [diff] [blame] | 173 | /* |
| 174 | * wait for request completion callback |
| 175 | */ |
| 176 | typedef int (*ceph_mds_request_wait_callback_t) (struct ceph_mds_client *mdsc, |
| 177 | struct ceph_mds_request *req); |
Sage Weil | 2f2dc05 | 2009-10-06 11:31:09 -0700 | [diff] [blame] | 178 | |
| 179 | /* |
| 180 | * an in-flight mds request |
| 181 | */ |
| 182 | struct ceph_mds_request { |
| 183 | u64 r_tid; /* transaction id */ |
Sage Weil | 44ca18f | 2010-02-15 12:08:46 -0800 | [diff] [blame] | 184 | struct rb_node r_node; |
Yehuda Sadeh | 3715166 | 2010-06-17 16:16:12 -0700 | [diff] [blame] | 185 | struct ceph_mds_client *r_mdsc; |
Sage Weil | 2f2dc05 | 2009-10-06 11:31:09 -0700 | [diff] [blame] | 186 | |
| 187 | int r_op; /* mds op code */ |
Sage Weil | 2f2dc05 | 2009-10-06 11:31:09 -0700 | [diff] [blame] | 188 | |
| 189 | /* operation on what? */ |
| 190 | struct inode *r_inode; /* arg1 */ |
| 191 | struct dentry *r_dentry; /* arg1 */ |
| 192 | struct dentry *r_old_dentry; /* arg2: rename from or link from */ |
Sage Weil | 41b02e1 | 2011-07-26 11:31:14 -0700 | [diff] [blame] | 193 | struct inode *r_old_dentry_dir; /* arg2: old dentry's parent dir */ |
Sage Weil | 2f2dc05 | 2009-10-06 11:31:09 -0700 | [diff] [blame] | 194 | char *r_path1, *r_path2; |
| 195 | struct ceph_vino r_ino1, r_ino2; |
| 196 | |
| 197 | struct inode *r_locked_dir; /* dir (if any) i_mutex locked by vfs */ |
| 198 | struct inode *r_target_inode; /* resulting inode */ |
| 199 | |
Sage Weil | b455639 | 2010-05-13 12:01:13 -0700 | [diff] [blame] | 200 | struct mutex r_fill_mutex; |
| 201 | |
Sage Weil | 2f2dc05 | 2009-10-06 11:31:09 -0700 | [diff] [blame] | 202 | union ceph_mds_request_args r_args; |
| 203 | int r_fmode; /* file mode, if expecting cap */ |
Eric W. Biederman | ff3d004 | 2013-01-31 04:01:53 -0800 | [diff] [blame] | 204 | kuid_t r_uid; |
| 205 | kgid_t r_gid; |
Sage Weil | b8e6906 | 2014-05-21 17:41:08 -0700 | [diff] [blame] | 206 | struct timespec r_stamp; |
Sage Weil | 2f2dc05 | 2009-10-06 11:31:09 -0700 | [diff] [blame] | 207 | |
| 208 | /* for choosing which mds to send this request to */ |
| 209 | int r_direct_mode; |
| 210 | u32 r_direct_hash; /* choose dir frag based on this dentry hash */ |
| 211 | bool r_direct_is_hash; /* true if r_direct_hash is valid */ |
| 212 | |
| 213 | /* data payload is used for xattr ops */ |
Yan, Zheng | 25e6bae | 2014-09-16 19:15:28 +0800 | [diff] [blame] | 214 | struct ceph_pagelist *r_pagelist; |
Sage Weil | 2f2dc05 | 2009-10-06 11:31:09 -0700 | [diff] [blame] | 215 | |
| 216 | /* what caps shall we drop? */ |
| 217 | int r_inode_drop, r_inode_unless; |
| 218 | int r_dentry_drop, r_dentry_unless; |
| 219 | int r_old_dentry_drop, r_old_dentry_unless; |
| 220 | struct inode *r_old_inode; |
| 221 | int r_old_inode_drop, r_old_inode_unless; |
| 222 | |
| 223 | struct ceph_msg *r_request; /* original request */ |
Sage Weil | e979cf5 | 2010-07-15 14:58:39 -0700 | [diff] [blame] | 224 | int r_request_release_offset; |
Sage Weil | 2f2dc05 | 2009-10-06 11:31:09 -0700 | [diff] [blame] | 225 | struct ceph_msg *r_reply; |
| 226 | struct ceph_mds_reply_info_parsed r_reply_info; |
Yan, Zheng | 01deead | 2014-11-14 21:56:29 +0800 | [diff] [blame] | 227 | struct page *r_locked_page; |
Sage Weil | 2f2dc05 | 2009-10-06 11:31:09 -0700 | [diff] [blame] | 228 | int r_err; |
Sage Weil | 5b1daec | 2010-01-25 11:33:08 -0800 | [diff] [blame] | 229 | bool r_aborted; |
Sage Weil | 2f2dc05 | 2009-10-06 11:31:09 -0700 | [diff] [blame] | 230 | |
| 231 | unsigned long r_timeout; /* optional. jiffies */ |
| 232 | unsigned long r_started; /* start time to measure timeout against */ |
| 233 | unsigned long r_request_started; /* start time for mds request only, |
| 234 | used to measure lease durations */ |
| 235 | |
| 236 | /* link unsafe requests to parent directory, for fsync */ |
| 237 | struct inode *r_unsafe_dir; |
| 238 | struct list_head r_unsafe_dir_item; |
| 239 | |
| 240 | struct ceph_mds_session *r_session; |
| 241 | |
| 242 | int r_attempts; /* resend attempts */ |
| 243 | int r_num_fwd; /* number of forward attempts */ |
Sage Weil | 2f2dc05 | 2009-10-06 11:31:09 -0700 | [diff] [blame] | 244 | int r_resend_mds; /* mds to resend to next, if any*/ |
Greg Farnum | e55b71f | 2010-06-22 15:58:01 -0700 | [diff] [blame] | 245 | u32 r_sent_on_mseq; /* cap mseq request was sent at*/ |
Sage Weil | 2f2dc05 | 2009-10-06 11:31:09 -0700 | [diff] [blame] | 246 | |
Sage Weil | 153c8e6 | 2009-12-07 12:31:09 -0800 | [diff] [blame] | 247 | struct kref r_kref; |
Sage Weil | 2f2dc05 | 2009-10-06 11:31:09 -0700 | [diff] [blame] | 248 | struct list_head r_wait; |
| 249 | struct completion r_completion; |
| 250 | struct completion r_safe_completion; |
| 251 | ceph_mds_request_callback_t r_callback; |
Yan, Zheng | 9280be2 | 2014-10-14 10:33:35 +0800 | [diff] [blame] | 252 | ceph_mds_request_wait_callback_t r_wait_for_completion; |
Sage Weil | 2f2dc05 | 2009-10-06 11:31:09 -0700 | [diff] [blame] | 253 | struct list_head r_unsafe_item; /* per-session unsafe list item */ |
Sage Weil | e1518c7 | 2010-05-13 11:19:06 -0700 | [diff] [blame] | 254 | bool r_got_unsafe, r_got_safe, r_got_result; |
Sage Weil | 2f2dc05 | 2009-10-06 11:31:09 -0700 | [diff] [blame] | 255 | |
| 256 | bool r_did_prepopulate; |
| 257 | u32 r_readdir_offset; |
| 258 | |
| 259 | struct ceph_cap_reservation r_caps_reservation; |
| 260 | int r_num_caps; |
| 261 | }; |
| 262 | |
Yan, Zheng | 10183a6 | 2015-04-27 15:33:28 +0800 | [diff] [blame^] | 263 | struct ceph_pool_perm { |
| 264 | struct rb_node node; |
| 265 | u32 pool; |
| 266 | int perm; |
| 267 | }; |
| 268 | |
Sage Weil | 2f2dc05 | 2009-10-06 11:31:09 -0700 | [diff] [blame] | 269 | /* |
| 270 | * mds client state |
| 271 | */ |
| 272 | struct ceph_mds_client { |
Yehuda Sadeh | 3d14c5d | 2010-04-06 15:14:15 -0700 | [diff] [blame] | 273 | struct ceph_fs_client *fsc; |
Sage Weil | 2f2dc05 | 2009-10-06 11:31:09 -0700 | [diff] [blame] | 274 | struct mutex mutex; /* all nested structures */ |
| 275 | |
| 276 | struct ceph_mdsmap *mdsmap; |
Sage Weil | f3c60c5 | 2010-08-11 14:51:23 -0700 | [diff] [blame] | 277 | struct completion safe_umount_waiters; |
| 278 | wait_queue_head_t session_close_wq; |
Sage Weil | 2f2dc05 | 2009-10-06 11:31:09 -0700 | [diff] [blame] | 279 | struct list_head waiting_for_map; |
| 280 | |
| 281 | struct ceph_mds_session **sessions; /* NULL for mds if no session */ |
Yan, Zheng | 86d8f67 | 2015-01-09 17:00:42 +0800 | [diff] [blame] | 282 | atomic_t num_sessions; |
Sage Weil | 2f2dc05 | 2009-10-06 11:31:09 -0700 | [diff] [blame] | 283 | int max_sessions; /* len of s_mds_sessions */ |
| 284 | int stopping; /* true if shutting down */ |
| 285 | |
| 286 | /* |
| 287 | * snap_rwsem will cover cap linkage into snaprealms, and |
| 288 | * realm snap contexts. (later, we can do per-realm snap |
| 289 | * contexts locks..) the empty list contains realms with no |
| 290 | * references (implying they contain no inodes with caps) that |
| 291 | * should be destroyed. |
| 292 | */ |
| 293 | struct rw_semaphore snap_rwsem; |
Sage Weil | a105f00 | 2010-02-15 14:37:55 -0800 | [diff] [blame] | 294 | struct rb_root snap_realms; |
Sage Weil | 2f2dc05 | 2009-10-06 11:31:09 -0700 | [diff] [blame] | 295 | struct list_head snap_empty; |
| 296 | spinlock_t snap_empty_lock; /* protect snap_empty */ |
| 297 | |
| 298 | u64 last_tid; /* most recent mds request */ |
Sage Weil | 44ca18f | 2010-02-15 12:08:46 -0800 | [diff] [blame] | 299 | struct rb_root request_tree; /* pending mds requests */ |
Sage Weil | 2f2dc05 | 2009-10-06 11:31:09 -0700 | [diff] [blame] | 300 | struct delayed_work delayed_work; /* delayed work */ |
| 301 | unsigned long last_renew_caps; /* last time we renewed our caps */ |
| 302 | struct list_head cap_delay_list; /* caps with delayed release */ |
| 303 | spinlock_t cap_delay_lock; /* protects cap_delay_list */ |
| 304 | struct list_head snap_flush_list; /* cap_snaps ready to flush */ |
| 305 | spinlock_t snap_flush_lock; |
| 306 | |
| 307 | u64 cap_flush_seq; |
| 308 | struct list_head cap_dirty; /* inodes with dirty caps */ |
Sage Weil | db35405 | 2011-05-24 11:46:31 -0700 | [diff] [blame] | 309 | struct list_head cap_dirty_migrating; /* ...that are migration... */ |
Sage Weil | 2f2dc05 | 2009-10-06 11:31:09 -0700 | [diff] [blame] | 310 | int num_cap_flushing; /* # caps we are flushing */ |
| 311 | spinlock_t cap_dirty_lock; /* protects above items */ |
| 312 | wait_queue_head_t cap_flushing_wq; |
| 313 | |
Yehuda Sadeh | 3715166 | 2010-06-17 16:16:12 -0700 | [diff] [blame] | 314 | /* |
| 315 | * Cap reservations |
| 316 | * |
| 317 | * Maintain a global pool of preallocated struct ceph_caps, referenced |
| 318 | * by struct ceph_caps_reservations. This ensures that we preallocate |
| 319 | * memory needed to successfully process an MDS response. (If an MDS |
| 320 | * sends us cap information and we fail to process it, we will have |
| 321 | * problems due to the client and MDS being out of sync.) |
| 322 | * |
| 323 | * Reservations are 'owned' by a ceph_cap_reservation context. |
| 324 | */ |
| 325 | spinlock_t caps_list_lock; |
| 326 | struct list_head caps_list; /* unused (reserved or |
| 327 | unreserved) */ |
| 328 | int caps_total_count; /* total caps allocated */ |
| 329 | int caps_use_count; /* in use */ |
| 330 | int caps_reserve_count; /* unused, reserved */ |
| 331 | int caps_avail_count; /* unused, unreserved */ |
| 332 | int caps_min_count; /* keep at least this many |
| 333 | (unreserved) */ |
Sage Weil | 2f2dc05 | 2009-10-06 11:31:09 -0700 | [diff] [blame] | 334 | spinlock_t dentry_lru_lock; |
| 335 | struct list_head dentry_lru; |
| 336 | int num_dentry; |
Yan, Zheng | 10183a6 | 2015-04-27 15:33:28 +0800 | [diff] [blame^] | 337 | |
| 338 | struct rw_semaphore pool_perm_rwsem; |
| 339 | struct rb_root pool_perm_tree; |
Sage Weil | 2f2dc05 | 2009-10-06 11:31:09 -0700 | [diff] [blame] | 340 | }; |
| 341 | |
| 342 | extern const char *ceph_mds_op_name(int op); |
| 343 | |
| 344 | extern struct ceph_mds_session * |
| 345 | __ceph_lookup_mds_session(struct ceph_mds_client *, int mds); |
| 346 | |
| 347 | static inline struct ceph_mds_session * |
| 348 | ceph_get_mds_session(struct ceph_mds_session *s) |
| 349 | { |
| 350 | atomic_inc(&s->s_ref); |
| 351 | return s; |
| 352 | } |
| 353 | |
John Spray | a687eca | 2014-09-19 13:51:08 +0100 | [diff] [blame] | 354 | extern const char *ceph_session_state_name(int s); |
| 355 | |
Sage Weil | 2f2dc05 | 2009-10-06 11:31:09 -0700 | [diff] [blame] | 356 | extern void ceph_put_mds_session(struct ceph_mds_session *s); |
| 357 | |
| 358 | extern int ceph_send_msg_mds(struct ceph_mds_client *mdsc, |
| 359 | struct ceph_msg *msg, int mds); |
| 360 | |
Yehuda Sadeh | 3d14c5d | 2010-04-06 15:14:15 -0700 | [diff] [blame] | 361 | extern int ceph_mdsc_init(struct ceph_fs_client *fsc); |
Sage Weil | 2f2dc05 | 2009-10-06 11:31:09 -0700 | [diff] [blame] | 362 | extern void ceph_mdsc_close_sessions(struct ceph_mds_client *mdsc); |
Yehuda Sadeh | 3d14c5d | 2010-04-06 15:14:15 -0700 | [diff] [blame] | 363 | extern void ceph_mdsc_destroy(struct ceph_fs_client *fsc); |
Sage Weil | 2f2dc05 | 2009-10-06 11:31:09 -0700 | [diff] [blame] | 364 | |
| 365 | extern void ceph_mdsc_sync(struct ceph_mds_client *mdsc); |
| 366 | |
| 367 | extern void ceph_mdsc_lease_release(struct ceph_mds_client *mdsc, |
| 368 | struct inode *inode, |
Sage Weil | 2f90b85 | 2011-07-26 11:28:25 -0700 | [diff] [blame] | 369 | struct dentry *dn); |
Sage Weil | 2f2dc05 | 2009-10-06 11:31:09 -0700 | [diff] [blame] | 370 | |
Sage Weil | 167c9e3 | 2010-05-14 10:02:57 -0700 | [diff] [blame] | 371 | extern void ceph_invalidate_dir_request(struct ceph_mds_request *req); |
Yan, Zheng | 5400839 | 2014-03-29 13:41:15 +0800 | [diff] [blame] | 372 | extern int ceph_alloc_readdir_reply_buffer(struct ceph_mds_request *req, |
| 373 | struct inode *dir); |
Sage Weil | 2f2dc05 | 2009-10-06 11:31:09 -0700 | [diff] [blame] | 374 | extern struct ceph_mds_request * |
| 375 | ceph_mdsc_create_request(struct ceph_mds_client *mdsc, int op, int mode); |
| 376 | extern void ceph_mdsc_submit_request(struct ceph_mds_client *mdsc, |
| 377 | struct ceph_mds_request *req); |
| 378 | extern int ceph_mdsc_do_request(struct ceph_mds_client *mdsc, |
| 379 | struct inode *dir, |
| 380 | struct ceph_mds_request *req); |
| 381 | static inline void ceph_mdsc_get_request(struct ceph_mds_request *req) |
| 382 | { |
Sage Weil | 153c8e6 | 2009-12-07 12:31:09 -0800 | [diff] [blame] | 383 | kref_get(&req->r_kref); |
Sage Weil | 2f2dc05 | 2009-10-06 11:31:09 -0700 | [diff] [blame] | 384 | } |
Sage Weil | 153c8e6 | 2009-12-07 12:31:09 -0800 | [diff] [blame] | 385 | extern void ceph_mdsc_release_request(struct kref *kref); |
| 386 | static inline void ceph_mdsc_put_request(struct ceph_mds_request *req) |
| 387 | { |
| 388 | kref_put(&req->r_kref, ceph_mdsc_release_request); |
| 389 | } |
Sage Weil | 2f2dc05 | 2009-10-06 11:31:09 -0700 | [diff] [blame] | 390 | |
Sage Weil | 2b2300d | 2010-06-09 16:52:04 -0700 | [diff] [blame] | 391 | extern int ceph_add_cap_releases(struct ceph_mds_client *mdsc, |
Sage Weil | ee6b272 | 2010-06-10 12:55:52 -0700 | [diff] [blame] | 392 | struct ceph_mds_session *session); |
Sage Weil | 3d7ded4 | 2010-06-09 16:47:10 -0700 | [diff] [blame] | 393 | extern void ceph_send_cap_releases(struct ceph_mds_client *mdsc, |
| 394 | struct ceph_mds_session *session); |
| 395 | |
Sage Weil | 2f2dc05 | 2009-10-06 11:31:09 -0700 | [diff] [blame] | 396 | extern void ceph_mdsc_pre_umount(struct ceph_mds_client *mdsc); |
| 397 | |
| 398 | extern char *ceph_mdsc_build_path(struct dentry *dentry, int *plen, u64 *base, |
| 399 | int stop_on_nosnap); |
| 400 | |
| 401 | extern void __ceph_mdsc_drop_dentry_lease(struct dentry *dentry); |
| 402 | extern void ceph_mdsc_lease_send_msg(struct ceph_mds_session *session, |
| 403 | struct inode *inode, |
| 404 | struct dentry *dentry, char action, |
| 405 | u32 seq); |
| 406 | |
| 407 | extern void ceph_mdsc_handle_map(struct ceph_mds_client *mdsc, |
| 408 | struct ceph_msg *msg); |
| 409 | |
Yan, Zheng | 5d72d13 | 2013-11-24 14:33:01 +0800 | [diff] [blame] | 410 | extern struct ceph_mds_session * |
| 411 | ceph_mdsc_open_export_target_session(struct ceph_mds_client *mdsc, int target); |
Sage Weil | 154f42c | 2010-06-21 13:45:04 -0700 | [diff] [blame] | 412 | extern void ceph_mdsc_open_export_target_sessions(struct ceph_mds_client *mdsc, |
| 413 | struct ceph_mds_session *session); |
| 414 | |
Sage Weil | 2f2dc05 | 2009-10-06 11:31:09 -0700 | [diff] [blame] | 415 | #endif |