1#ifndef _FS_CEPH_SUPER_H
2#define _FS_CEPH_SUPER_H
3
4#include <linux/ceph/ceph_debug.h>
5
6#include <asm/unaligned.h>
7#include <linux/backing-dev.h>
8#include <linux/completion.h>
9#include <linux/exportfs.h>
10#include <linux/fs.h>
11#include <linux/mempool.h>
12#include <linux/pagemap.h>
13#include <linux/wait.h>
14#include <linux/writeback.h>
15#include <linux/slab.h>
16
17#include <linux/ceph/libceph.h>
18
19
20#define CEPH_SUPER_MAGIC 0x00c36400
21
22
23
24#define CEPH_BLOCK_SHIFT 20
25#define CEPH_BLOCK (1 << CEPH_BLOCK_SHIFT)
26
27#define CEPH_MOUNT_OPT_DIRSTAT (1<<4)
28#define CEPH_MOUNT_OPT_RBYTES (1<<5)
29#define CEPH_MOUNT_OPT_NOASYNCREADDIR (1<<7)
30
31#define CEPH_MOUNT_OPT_DEFAULT (CEPH_MOUNT_OPT_RBYTES)
32
33#define ceph_set_mount_opt(fsc, opt) \
34 (fsc)->mount_options->flags |= CEPH_MOUNT_OPT_##opt;
35#define ceph_test_mount_opt(fsc, opt) \
36 (!!((fsc)->mount_options->flags & CEPH_MOUNT_OPT_##opt))
37
38#define CEPH_MAX_READDIR_DEFAULT 1024
39#define CEPH_MAX_READDIR_BYTES_DEFAULT (512*1024)
40#define CEPH_SNAPDIRNAME_DEFAULT ".snap"
41
42struct ceph_mount_options {
43 int flags;
44 int sb_flags;
45
46 int wsize;
47 int rsize;
48 int congestion_kb;
49 int caps_wanted_delay_min, caps_wanted_delay_max;
50 int cap_release_safety;
51 int max_readdir;
52 int max_readdir_bytes;
53
54
55
56
57
58
59 char *snapdir_name;
60};
61
62struct ceph_fs_client {
63 struct super_block *sb;
64
65 struct ceph_mount_options *mount_options;
66 struct ceph_client *client;
67
68 unsigned long mount_state;
69 int min_caps;
70
71 struct ceph_mds_client *mdsc;
72
73
74 mempool_t *wb_pagevec_pool;
75 struct workqueue_struct *wb_wq;
76 struct workqueue_struct *pg_inv_wq;
77 struct workqueue_struct *trunc_wq;
78 atomic_long_t writeback_count;
79
80 struct backing_dev_info backing_dev_info;
81
82#ifdef CONFIG_DEBUG_FS
83 struct dentry *debugfs_dentry_lru, *debugfs_caps;
84 struct dentry *debugfs_congestion_kb;
85 struct dentry *debugfs_bdi;
86 struct dentry *debugfs_mdsc, *debugfs_mdsmap;
87#endif
88};
89
90
91
92
93
94
95
96
97
98
99
100
101struct ceph_cap {
102 struct ceph_inode_info *ci;
103 struct rb_node ci_node;
104 struct ceph_mds_session *session;
105 struct list_head session_caps;
106 int mds;
107 u64 cap_id;
108 int issued;
109 int implemented;
110 int mds_wanted;
111 u32 seq, issue_seq, mseq;
112 u32 cap_gen;
113 unsigned long last_used;
114 struct list_head caps_item;
115};
116
117#define CHECK_CAPS_NODELAY 1
118#define CHECK_CAPS_AUTHONLY 2
119#define CHECK_CAPS_FLUSH 4
120
121
122
123
124
125
126struct ceph_cap_snap {
127 atomic_t nref;
128 struct ceph_inode_info *ci;
129 struct list_head ci_item, flushing_item;
130
131 u64 follows, flush_tid;
132 int issued, dirty;
133 struct ceph_snap_context *context;
134
135 mode_t mode;
136 uid_t uid;
137 gid_t gid;
138
139 struct ceph_buffer *xattr_blob;
140 u64 xattr_version;
141
142 u64 size;
143 struct timespec mtime, atime, ctime;
144 u64 time_warp_seq;
145 int writing;
146 int dirty_pages;
147};
148
149static inline void ceph_put_cap_snap(struct ceph_cap_snap *capsnap)
150{
151 if (atomic_dec_and_test(&capsnap->nref)) {
152 if (capsnap->xattr_blob)
153 ceph_buffer_put(capsnap->xattr_blob);
154 kfree(capsnap);
155 }
156}
157
158
159
160
161
162
163
164
165
166#define CEPH_MAX_DIRFRAG_REP 4
167
168struct ceph_inode_frag {
169 struct rb_node node;
170
171
172 u32 frag;
173 int split_by;
174
175
176 int mds;
177 int ndist;
178 int dist[CEPH_MAX_DIRFRAG_REP];
179};
180
181
182
183
184
185struct ceph_inode_xattr {
186 struct rb_node node;
187
188 const char *name;
189 int name_len;
190 const char *val;
191 int val_len;
192 int dirty;
193
194 int should_free_name;
195 int should_free_val;
196};
197
198
199
200
201struct ceph_dentry_info {
202 struct ceph_mds_session *lease_session;
203 u32 lease_gen, lease_shared_gen;
204 u32 lease_seq;
205 unsigned long lease_renew_after, lease_renew_from;
206 struct list_head lru;
207 struct dentry *dentry;
208 u64 time;
209 u64 offset;
210};
211
212struct ceph_inode_xattrs_info {
213
214
215
216
217
218
219
220 struct ceph_buffer *blob, *prealloc_blob;
221
222 struct rb_root index;
223 bool dirty;
224 int count;
225 int names_size;
226 int vals_size;
227 u64 version, index_version;
228};
229
230
231
232
233struct ceph_inode_info {
234 struct ceph_vino i_vino;
235
236 u64 i_version;
237 u32 i_time_warp_seq;
238
239 unsigned i_ceph_flags;
240 unsigned long i_release_count;
241
242 struct ceph_dir_layout i_dir_layout;
243 struct ceph_file_layout i_layout;
244 char *i_symlink;
245
246
247 struct timespec i_rctime;
248 u64 i_rbytes, i_rfiles, i_rsubdirs;
249 u64 i_files, i_subdirs;
250 u64 i_max_offset;
251
252 struct rb_root i_fragtree;
253 struct mutex i_fragtree_mutex;
254
255 struct ceph_inode_xattrs_info i_xattrs;
256
257
258
259 struct rb_root i_caps;
260 struct ceph_cap *i_auth_cap;
261 unsigned i_dirty_caps, i_flushing_caps;
262 struct list_head i_dirty_item, i_flushing_item;
263 u64 i_cap_flush_seq;
264
265
266
267 u16 i_cap_flush_last_tid, i_cap_flush_tid[CEPH_CAP_BITS];
268 wait_queue_head_t i_cap_wq;
269 unsigned long i_hold_caps_min;
270 unsigned long i_hold_caps_max;
271 struct list_head i_cap_delay_list;
272 int i_cap_exporting_mds;
273 unsigned i_cap_exporting_mseq;
274 unsigned i_cap_exporting_issued;
275 struct ceph_cap_reservation i_cap_migration_resv;
276 struct list_head i_cap_snaps;
277 struct ceph_snap_context *i_head_snapc;
278
279 unsigned i_snap_caps;
280
281 int i_nr_by_mode[CEPH_FILE_MODE_NUM];
282
283 u32 i_truncate_seq;
284 u64 i_truncate_size;
285 int i_truncate_pending;
286
287 u64 i_max_size;
288 u64 i_reported_size;
289 u64 i_wanted_max_size;
290 u64 i_requested_max_size;
291
292
293 int i_pin_ref;
294 int i_rd_ref, i_rdcache_ref, i_wr_ref;
295 int i_wrbuffer_ref, i_wrbuffer_ref_head;
296 u32 i_shared_gen;
297 u32 i_rdcache_gen;
298 u32 i_rdcache_revoking;
299
300 struct list_head i_unsafe_writes;
301 struct list_head i_unsafe_dirops;
302 spinlock_t i_unsafe_lock;
303
304 struct ceph_snap_realm *i_snap_realm;
305 int i_snap_realm_counter;
306 struct list_head i_snap_realm_item;
307 struct list_head i_snap_flush_item;
308
309 struct work_struct i_wb_work;
310 struct work_struct i_pg_inv_work;
311
312 struct work_struct i_vmtruncate_work;
313
314 struct inode vfs_inode;
315};
316
317static inline struct ceph_inode_info *ceph_inode(struct inode *inode)
318{
319 return container_of(inode, struct ceph_inode_info, vfs_inode);
320}
321
322static inline struct ceph_vino ceph_vino(struct inode *inode)
323{
324 return ceph_inode(inode)->i_vino;
325}
326
327
328
329
330
331
332static inline ino_t ceph_vino_to_ino(struct ceph_vino vino)
333{
334 ino_t ino = (ino_t)vino.ino;
335#if BITS_PER_LONG == 32
336 ino ^= vino.ino >> (sizeof(u64)-sizeof(ino_t)) * 8;
337 if (!ino)
338 ino = 1;
339#endif
340 return ino;
341}
342
343
344#define ceph_vinop(i) ceph_inode(i)->i_vino.ino, ceph_inode(i)->i_vino.snap
345
346static inline u64 ceph_ino(struct inode *inode)
347{
348 return ceph_inode(inode)->i_vino.ino;
349}
350static inline u64 ceph_snap(struct inode *inode)
351{
352 return ceph_inode(inode)->i_vino.snap;
353}
354
355static inline int ceph_ino_compare(struct inode *inode, void *data)
356{
357 struct ceph_vino *pvino = (struct ceph_vino *)data;
358 struct ceph_inode_info *ci = ceph_inode(inode);
359 return ci->i_vino.ino == pvino->ino &&
360 ci->i_vino.snap == pvino->snap;
361}
362
363static inline struct inode *ceph_find_inode(struct super_block *sb,
364 struct ceph_vino vino)
365{
366 ino_t t = ceph_vino_to_ino(vino);
367 return ilookup5(sb, t, ceph_ino_compare, &vino);
368}
369
370
371
372
373
374#define CEPH_I_COMPLETE 1
375#define CEPH_I_NODELAY 4
376#define CEPH_I_FLUSH 8
377#define CEPH_I_NOFLUSH 16
378
379static inline void ceph_i_clear(struct inode *inode, unsigned mask)
380{
381 struct ceph_inode_info *ci = ceph_inode(inode);
382
383 spin_lock(&inode->i_lock);
384 ci->i_ceph_flags &= ~mask;
385 spin_unlock(&inode->i_lock);
386}
387
388static inline void ceph_i_set(struct inode *inode, unsigned mask)
389{
390 struct ceph_inode_info *ci = ceph_inode(inode);
391
392 spin_lock(&inode->i_lock);
393 ci->i_ceph_flags |= mask;
394 spin_unlock(&inode->i_lock);
395}
396
397static inline bool ceph_i_test(struct inode *inode, unsigned mask)
398{
399 struct ceph_inode_info *ci = ceph_inode(inode);
400 bool r;
401
402 spin_lock(&inode->i_lock);
403 r = (ci->i_ceph_flags & mask) == mask;
404 spin_unlock(&inode->i_lock);
405 return r;
406}
407
408
409
410extern struct ceph_inode_frag *__ceph_find_frag(struct ceph_inode_info *ci,
411 u32 f);
412
413
414
415
416
417extern u32 ceph_choose_frag(struct ceph_inode_info *ci, u32 v,
418 struct ceph_inode_frag *pfrag,
419 int *found);
420
421static inline struct ceph_dentry_info *ceph_dentry(struct dentry *dentry)
422{
423 return (struct ceph_dentry_info *)dentry->d_fsdata;
424}
425
426static inline loff_t ceph_make_fpos(unsigned frag, unsigned off)
427{
428 return ((loff_t)frag << 32) | (loff_t)off;
429}
430
431static inline int ceph_set_ino_cb(struct inode *inode, void *data)
432{
433 ceph_inode(inode)->i_vino = *(struct ceph_vino *)data;
434 inode->i_ino = ceph_vino_to_ino(*(struct ceph_vino *)data);
435 return 0;
436}
437
438
439
440
441static inline bool __ceph_is_any_real_caps(struct ceph_inode_info *ci)
442{
443 return !RB_EMPTY_ROOT(&ci->i_caps);
444}
445
446extern int __ceph_caps_issued(struct ceph_inode_info *ci, int *implemented);
447extern int __ceph_caps_issued_mask(struct ceph_inode_info *ci, int mask, int t);
448extern int __ceph_caps_issued_other(struct ceph_inode_info *ci,
449 struct ceph_cap *cap);
450
451static inline int ceph_caps_issued(struct ceph_inode_info *ci)
452{
453 int issued;
454 spin_lock(&ci->vfs_inode.i_lock);
455 issued = __ceph_caps_issued(ci, NULL);
456 spin_unlock(&ci->vfs_inode.i_lock);
457 return issued;
458}
459
460static inline int ceph_caps_issued_mask(struct ceph_inode_info *ci, int mask,
461 int touch)
462{
463 int r;
464 spin_lock(&ci->vfs_inode.i_lock);
465 r = __ceph_caps_issued_mask(ci, mask, touch);
466 spin_unlock(&ci->vfs_inode.i_lock);
467 return r;
468}
469
470static inline int __ceph_caps_dirty(struct ceph_inode_info *ci)
471{
472 return ci->i_dirty_caps | ci->i_flushing_caps;
473}
474extern void __ceph_mark_dirty_caps(struct ceph_inode_info *ci, int mask);
475
476extern int ceph_caps_revoking(struct ceph_inode_info *ci, int mask);
477extern int __ceph_caps_used(struct ceph_inode_info *ci);
478
479extern int __ceph_caps_file_wanted(struct ceph_inode_info *ci);
480
481
482
483
484static inline int __ceph_caps_wanted(struct ceph_inode_info *ci)
485{
486 int w = __ceph_caps_file_wanted(ci) | __ceph_caps_used(ci);
487 if (w & CEPH_CAP_FILE_BUFFER)
488 w |= CEPH_CAP_FILE_EXCL;
489 return w;
490}
491
492
493extern int __ceph_caps_mds_wanted(struct ceph_inode_info *ci);
494
495extern void ceph_caps_init(struct ceph_mds_client *mdsc);
496extern void ceph_caps_finalize(struct ceph_mds_client *mdsc);
497extern void ceph_adjust_min_caps(struct ceph_mds_client *mdsc, int delta);
498extern int ceph_reserve_caps(struct ceph_mds_client *mdsc,
499 struct ceph_cap_reservation *ctx, int need);
500extern int ceph_unreserve_caps(struct ceph_mds_client *mdsc,
501 struct ceph_cap_reservation *ctx);
502extern void ceph_reservation_status(struct ceph_fs_client *client,
503 int *total, int *avail, int *used,
504 int *reserved, int *min);
505
506static inline struct ceph_fs_client *ceph_inode_to_client(struct inode *inode)
507{
508 return (struct ceph_fs_client *)inode->i_sb->s_fs_info;
509}
510
511static inline struct ceph_fs_client *ceph_sb_to_client(struct super_block *sb)
512{
513 return (struct ceph_fs_client *)sb->s_fs_info;
514}
515
516
517
518
519
520struct ceph_file_info {
521 int fmode;
522
523
524 u32 frag;
525 struct ceph_mds_request *last_readdir;
526 int at_end;
527
528
529 unsigned offset;
530 u64 next_offset;
531 char *last_name;
532 struct dentry *dentry;
533 unsigned long dir_release_count;
534
535
536 char *dir_info;
537 int dir_info_len;
538};
539
540
541
542
543
544
545
546
547
548
549
550
551struct ceph_snap_realm {
552 u64 ino;
553 atomic_t nref;
554 struct rb_node node;
555
556 u64 created, seq;
557 u64 parent_ino;
558 u64 parent_since;
559
560 u64 *prior_parent_snaps;
561 int num_prior_parent_snaps;
562 u64 *snaps;
563 int num_snaps;
564
565 struct ceph_snap_realm *parent;
566 struct list_head children;
567 struct list_head child_item;
568
569 struct list_head empty_item;
570
571 struct list_head dirty_item;
572
573
574 struct ceph_snap_context *cached_context;
575
576 struct list_head inodes_with_caps;
577 spinlock_t inodes_with_caps_lock;
578};
579
580static inline int default_congestion_kb(void)
581{
582 int congestion_kb;
583
584
585
586
587
588
589
590
591
592
593
594
595
596
597
598
599
600
601
602 congestion_kb = (16*int_sqrt(totalram_pages)) << (PAGE_SHIFT-10);
603 if (congestion_kb > 256*1024)
604 congestion_kb = 256*1024;
605
606 return congestion_kb;
607}
608
609
610
611
612struct ceph_snap_realm *ceph_lookup_snap_realm(struct ceph_mds_client *mdsc,
613 u64 ino);
614extern void ceph_get_snap_realm(struct ceph_mds_client *mdsc,
615 struct ceph_snap_realm *realm);
616extern void ceph_put_snap_realm(struct ceph_mds_client *mdsc,
617 struct ceph_snap_realm *realm);
618extern int ceph_update_snap_trace(struct ceph_mds_client *m,
619 void *p, void *e, bool deletion);
620extern void ceph_handle_snap(struct ceph_mds_client *mdsc,
621 struct ceph_mds_session *session,
622 struct ceph_msg *msg);
623extern void ceph_queue_cap_snap(struct ceph_inode_info *ci);
624extern int __ceph_finish_cap_snap(struct ceph_inode_info *ci,
625 struct ceph_cap_snap *capsnap);
626extern void ceph_cleanup_empty_realms(struct ceph_mds_client *mdsc);
627
628
629
630
631
632static inline bool __ceph_have_pending_cap_snap(struct ceph_inode_info *ci)
633{
634 return !list_empty(&ci->i_cap_snaps) &&
635 list_entry(ci->i_cap_snaps.prev, struct ceph_cap_snap,
636 ci_item)->writing;
637}
638
639
640extern const struct inode_operations ceph_file_iops;
641
642extern struct inode *ceph_alloc_inode(struct super_block *sb);
643extern void ceph_destroy_inode(struct inode *inode);
644
645extern struct inode *ceph_get_inode(struct super_block *sb,
646 struct ceph_vino vino);
647extern struct inode *ceph_get_snapdir(struct inode *parent);
648extern int ceph_fill_file_size(struct inode *inode, int issued,
649 u32 truncate_seq, u64 truncate_size, u64 size);
650extern void ceph_fill_file_time(struct inode *inode, int issued,
651 u64 time_warp_seq, struct timespec *ctime,
652 struct timespec *mtime, struct timespec *atime);
653extern int ceph_fill_trace(struct super_block *sb,
654 struct ceph_mds_request *req,
655 struct ceph_mds_session *session);
656extern int ceph_readdir_prepopulate(struct ceph_mds_request *req,
657 struct ceph_mds_session *session);
658
659extern int ceph_inode_holds_cap(struct inode *inode, int mask);
660
661extern int ceph_inode_set_size(struct inode *inode, loff_t size);
662extern void __ceph_do_pending_vmtruncate(struct inode *inode);
663extern void ceph_queue_vmtruncate(struct inode *inode);
664
665extern void ceph_queue_invalidate(struct inode *inode);
666extern void ceph_queue_writeback(struct inode *inode);
667
668extern int ceph_do_getattr(struct inode *inode, int mask);
669extern int ceph_permission(struct inode *inode, int mask, unsigned int flags);
670extern int ceph_setattr(struct dentry *dentry, struct iattr *attr);
671extern int ceph_getattr(struct vfsmount *mnt, struct dentry *dentry,
672 struct kstat *stat);
673
674
675extern int ceph_setxattr(struct dentry *, const char *, const void *,
676 size_t, int);
677extern ssize_t ceph_getxattr(struct dentry *, const char *, void *, size_t);
678extern ssize_t ceph_listxattr(struct dentry *, char *, size_t);
679extern int ceph_removexattr(struct dentry *, const char *);
680extern void __ceph_build_xattrs_blob(struct ceph_inode_info *ci);
681extern void __ceph_destroy_xattrs(struct ceph_inode_info *ci);
682
683
684extern const char *ceph_cap_string(int c);
685extern void ceph_handle_caps(struct ceph_mds_session *session,
686 struct ceph_msg *msg);
687extern int ceph_add_cap(struct inode *inode,
688 struct ceph_mds_session *session, u64 cap_id,
689 int fmode, unsigned issued, unsigned wanted,
690 unsigned cap, unsigned seq, u64 realmino, int flags,
691 struct ceph_cap_reservation *caps_reservation);
692extern void __ceph_remove_cap(struct ceph_cap *cap);
693static inline void ceph_remove_cap(struct ceph_cap *cap)
694{
695 struct inode *inode = &cap->ci->vfs_inode;
696 spin_lock(&inode->i_lock);
697 __ceph_remove_cap(cap);
698 spin_unlock(&inode->i_lock);
699}
700extern void ceph_put_cap(struct ceph_mds_client *mdsc,
701 struct ceph_cap *cap);
702
703extern void ceph_queue_caps_release(struct inode *inode);
704extern int ceph_write_inode(struct inode *inode, struct writeback_control *wbc);
705extern int ceph_fsync(struct file *file, int datasync);
706extern void ceph_kick_flushing_caps(struct ceph_mds_client *mdsc,
707 struct ceph_mds_session *session);
708extern struct ceph_cap *ceph_get_cap_for_mds(struct ceph_inode_info *ci,
709 int mds);
710extern int ceph_get_cap_mds(struct inode *inode);
711extern void ceph_get_cap_refs(struct ceph_inode_info *ci, int caps);
712extern void ceph_put_cap_refs(struct ceph_inode_info *ci, int had);
713extern void ceph_put_wrbuffer_cap_refs(struct ceph_inode_info *ci, int nr,
714 struct ceph_snap_context *snapc);
715extern void __ceph_flush_snaps(struct ceph_inode_info *ci,
716 struct ceph_mds_session **psession,
717 int again);
718extern void ceph_check_caps(struct ceph_inode_info *ci, int flags,
719 struct ceph_mds_session *session);
720extern void ceph_check_delayed_caps(struct ceph_mds_client *mdsc);
721extern void ceph_flush_dirty_caps(struct ceph_mds_client *mdsc);
722
723extern int ceph_encode_inode_release(void **p, struct inode *inode,
724 int mds, int drop, int unless, int force);
725extern int ceph_encode_dentry_release(void **p, struct dentry *dn,
726 int mds, int drop, int unless);
727
728extern int ceph_get_caps(struct ceph_inode_info *ci, int need, int want,
729 int *got, loff_t endoff);
730
731
732static inline void __ceph_get_fmode(struct ceph_inode_info *ci, int mode)
733{
734 ci->i_nr_by_mode[mode]++;
735}
736extern void ceph_put_fmode(struct ceph_inode_info *ci, int mode);
737
738
739extern const struct address_space_operations ceph_aops;
740extern int ceph_mmap(struct file *file, struct vm_area_struct *vma);
741
742
743extern const struct file_operations ceph_file_fops;
744extern const struct address_space_operations ceph_aops;
745extern int ceph_copy_to_page_vector(struct page **pages,
746 const char *data,
747 loff_t off, size_t len);
748extern int ceph_copy_from_page_vector(struct page **pages,
749 char *data,
750 loff_t off, size_t len);
751extern struct page **ceph_alloc_page_vector(int num_pages, gfp_t flags);
752extern int ceph_open(struct inode *inode, struct file *file);
753extern struct dentry *ceph_lookup_open(struct inode *dir, struct dentry *dentry,
754 struct nameidata *nd, int mode,
755 int locked_dir);
756extern int ceph_release(struct inode *inode, struct file *filp);
757
758
759extern const struct file_operations ceph_dir_fops;
760extern const struct inode_operations ceph_dir_iops;
761extern const struct dentry_operations ceph_dentry_ops, ceph_snap_dentry_ops,
762 ceph_snapdir_dentry_ops;
763
764extern int ceph_handle_notrace_create(struct inode *dir, struct dentry *dentry);
765extern struct dentry *ceph_finish_lookup(struct ceph_mds_request *req,
766 struct dentry *dentry, int err);
767
768extern void ceph_dentry_lru_add(struct dentry *dn);
769extern void ceph_dentry_lru_touch(struct dentry *dn);
770extern void ceph_dentry_lru_del(struct dentry *dn);
771extern void ceph_invalidate_dentry_lease(struct dentry *dentry);
772extern unsigned ceph_dentry_hash(struct dentry *dn);
773
774
775
776
777
778int ceph_init_dentry(struct dentry *dentry);
779
780
781
782extern long ceph_ioctl(struct file *file, unsigned int cmd, unsigned long arg);
783
784
785extern const struct export_operations ceph_export_ops;
786
787
788extern int ceph_lock(struct file *file, int cmd, struct file_lock *fl);
789extern int ceph_flock(struct file *file, int cmd, struct file_lock *fl);
790extern void ceph_count_locks(struct inode *inode, int *p_num, int *f_num);
791extern int ceph_encode_locks(struct inode *i, struct ceph_pagelist *p,
792 int p_locks, int f_locks);
793extern int lock_to_ceph_filelock(struct file_lock *fl, struct ceph_filelock *c);
794
795static inline struct inode *get_dentry_parent_inode(struct dentry *dentry)
796{
797 if (dentry && dentry->d_parent)
798 return dentry->d_parent->d_inode;
799
800 return NULL;
801}
802
803
804extern int ceph_fs_debugfs_init(struct ceph_fs_client *client);
805extern void ceph_fs_debugfs_cleanup(struct ceph_fs_client *client);
806
807#endif
808