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#include <linux/posix_acl.h>
17
18#include <linux/ceph/libceph.h>
19
20#ifdef CONFIG_CEPH_FSCACHE
21#include <linux/fscache.h>
22#endif
23
24
25#define CEPH_SUPER_MAGIC 0x00c36400
26
27
28
29#define CEPH_BLOCK_SHIFT 22
30#define CEPH_BLOCK (1 << CEPH_BLOCK_SHIFT)
31
32#define CEPH_MOUNT_OPT_DIRSTAT (1<<4)
33#define CEPH_MOUNT_OPT_RBYTES (1<<5)
34#define CEPH_MOUNT_OPT_NOASYNCREADDIR (1<<7)
35#define CEPH_MOUNT_OPT_INO32 (1<<8)
36#define CEPH_MOUNT_OPT_DCACHE (1<<9)
37#define CEPH_MOUNT_OPT_FSCACHE (1<<10)
38#define CEPH_MOUNT_OPT_NOPOOLPERM (1<<11)
39
40#define CEPH_MOUNT_OPT_DEFAULT CEPH_MOUNT_OPT_DCACHE
41
42#define ceph_set_mount_opt(fsc, opt) \
43 (fsc)->mount_options->flags |= CEPH_MOUNT_OPT_##opt;
44#define ceph_test_mount_opt(fsc, opt) \
45 (!!((fsc)->mount_options->flags & CEPH_MOUNT_OPT_##opt))
46
47#define CEPH_RSIZE_DEFAULT 0
48#define CEPH_RASIZE_DEFAULT (8192*1024)
49#define CEPH_MAX_READDIR_DEFAULT 1024
50#define CEPH_MAX_READDIR_BYTES_DEFAULT (512*1024)
51#define CEPH_SNAPDIRNAME_DEFAULT ".snap"
52
53struct ceph_mount_options {
54 int flags;
55 int sb_flags;
56
57 int wsize;
58 int rsize;
59 int rasize;
60 int congestion_kb;
61 int caps_wanted_delay_min, caps_wanted_delay_max;
62 int cap_release_safety;
63 int max_readdir;
64 int max_readdir_bytes;
65
66
67
68
69
70
71 char *snapdir_name;
72 char *mds_namespace;
73 char *server_path;
74};
75
76struct ceph_fs_client {
77 struct super_block *sb;
78
79 struct ceph_mount_options *mount_options;
80 struct ceph_client *client;
81
82 unsigned long mount_state;
83 int min_caps;
84
85 struct ceph_mds_client *mdsc;
86
87
88 mempool_t *wb_pagevec_pool;
89 struct workqueue_struct *wb_wq;
90 struct workqueue_struct *pg_inv_wq;
91 struct workqueue_struct *trunc_wq;
92 atomic_long_t writeback_count;
93
94 struct backing_dev_info backing_dev_info;
95
96#ifdef CONFIG_DEBUG_FS
97 struct dentry *debugfs_dentry_lru, *debugfs_caps;
98 struct dentry *debugfs_congestion_kb;
99 struct dentry *debugfs_bdi;
100 struct dentry *debugfs_mdsc, *debugfs_mdsmap;
101 struct dentry *debugfs_mds_sessions;
102#endif
103
104#ifdef CONFIG_CEPH_FSCACHE
105 struct fscache_cookie *fscache;
106#endif
107};
108
109
110
111
112
113
114
115
116
117
118
119
120struct ceph_cap {
121 struct ceph_inode_info *ci;
122 struct rb_node ci_node;
123 struct ceph_mds_session *session;
124 struct list_head session_caps;
125 u64 cap_id;
126 union {
127
128 struct {
129 int issued;
130 int implemented;
131
132 int mds, mds_wanted;
133 };
134
135 struct {
136 u64 cap_ino;
137 int queue_release;
138 };
139 };
140 u32 seq, issue_seq, mseq;
141 u32 cap_gen;
142 unsigned long last_used;
143 struct list_head caps_item;
144};
145
146#define CHECK_CAPS_NODELAY 1
147#define CHECK_CAPS_AUTHONLY 2
148#define CHECK_CAPS_FLUSH 4
149
150struct ceph_cap_flush {
151 u64 tid;
152 int caps;
153 bool wake;
154 struct list_head g_list;
155 struct list_head i_list;
156};
157
158
159
160
161
162
163struct ceph_cap_snap {
164 atomic_t nref;
165 struct list_head ci_item;
166
167 struct ceph_cap_flush cap_flush;
168
169 u64 follows;
170 int issued, dirty;
171 struct ceph_snap_context *context;
172
173 umode_t mode;
174 kuid_t uid;
175 kgid_t gid;
176
177 struct ceph_buffer *xattr_blob;
178 u64 xattr_version;
179
180 u64 size;
181 struct timespec mtime, atime, ctime;
182 u64 time_warp_seq;
183 int writing;
184 int dirty_pages;
185 bool inline_data;
186 bool need_flush;
187};
188
189static inline void ceph_put_cap_snap(struct ceph_cap_snap *capsnap)
190{
191 if (atomic_dec_and_test(&capsnap->nref)) {
192 if (capsnap->xattr_blob)
193 ceph_buffer_put(capsnap->xattr_blob);
194 kfree(capsnap);
195 }
196}
197
198
199
200
201
202
203
204
205
206#define CEPH_MAX_DIRFRAG_REP 4
207
208struct ceph_inode_frag {
209 struct rb_node node;
210
211
212 u32 frag;
213 int split_by;
214
215
216 int mds;
217 int ndist;
218 int dist[CEPH_MAX_DIRFRAG_REP];
219};
220
221
222
223
224
225struct ceph_inode_xattr {
226 struct rb_node node;
227
228 const char *name;
229 int name_len;
230 const char *val;
231 int val_len;
232 int dirty;
233
234 int should_free_name;
235 int should_free_val;
236};
237
238
239
240
241struct ceph_dentry_info {
242 struct ceph_mds_session *lease_session;
243 u32 lease_gen, lease_shared_gen;
244 u32 lease_seq;
245 unsigned long lease_renew_after, lease_renew_from;
246 struct list_head lru;
247 struct dentry *dentry;
248 unsigned long time;
249 u64 offset;
250};
251
252struct ceph_inode_xattrs_info {
253
254
255
256
257
258
259
260 struct ceph_buffer *blob, *prealloc_blob;
261
262 struct rb_root index;
263 bool dirty;
264 int count;
265 int names_size;
266 int vals_size;
267 u64 version, index_version;
268};
269
270
271
272
273struct ceph_inode_info {
274 struct ceph_vino i_vino;
275
276 spinlock_t i_ceph_lock;
277
278 u64 i_version;
279 u64 i_inline_version;
280 u32 i_time_warp_seq;
281
282 unsigned i_ceph_flags;
283 atomic64_t i_release_count;
284 atomic64_t i_ordered_count;
285 atomic64_t i_complete_seq[2];
286
287 struct ceph_dir_layout i_dir_layout;
288 struct ceph_file_layout i_layout;
289 char *i_symlink;
290
291
292 struct timespec i_rctime;
293 u64 i_rbytes, i_rfiles, i_rsubdirs;
294 u64 i_files, i_subdirs;
295
296 struct rb_root i_fragtree;
297 int i_fragtree_nsplits;
298 struct mutex i_fragtree_mutex;
299
300 struct ceph_inode_xattrs_info i_xattrs;
301
302
303
304 struct rb_root i_caps;
305 struct ceph_cap *i_auth_cap;
306 unsigned i_dirty_caps, i_flushing_caps;
307 struct list_head i_dirty_item, i_flushing_item;
308
309
310
311 struct ceph_cap_flush *i_prealloc_cap_flush;
312 struct list_head i_cap_flush_list;
313 wait_queue_head_t i_cap_wq;
314 unsigned long i_hold_caps_min;
315 unsigned long i_hold_caps_max;
316 struct list_head i_cap_delay_list;
317 struct ceph_cap_reservation i_cap_migration_resv;
318 struct list_head i_cap_snaps;
319 struct ceph_snap_context *i_head_snapc;
320
321 unsigned i_snap_caps;
322
323 int i_nr_by_mode[CEPH_FILE_MODE_BITS];
324
325 struct mutex i_truncate_mutex;
326 u32 i_truncate_seq;
327 u64 i_truncate_size;
328 int i_truncate_pending;
329
330 u64 i_max_size;
331 u64 i_reported_size;
332 u64 i_wanted_max_size;
333 u64 i_requested_max_size;
334
335
336 int i_pin_ref;
337 int i_rd_ref, i_rdcache_ref, i_wr_ref, i_wb_ref;
338 int i_wrbuffer_ref, i_wrbuffer_ref_head;
339 u32 i_shared_gen;
340 u32 i_rdcache_gen;
341 u32 i_rdcache_revoking;
342
343 struct list_head i_unsafe_writes;
344 struct list_head i_unsafe_dirops;
345 struct list_head i_unsafe_iops;
346 spinlock_t i_unsafe_lock;
347
348 struct ceph_snap_realm *i_snap_realm;
349 int i_snap_realm_counter;
350 struct list_head i_snap_realm_item;
351 struct list_head i_snap_flush_item;
352
353 struct work_struct i_wb_work;
354 struct work_struct i_pg_inv_work;
355
356 struct work_struct i_vmtruncate_work;
357
358#ifdef CONFIG_CEPH_FSCACHE
359 struct fscache_cookie *fscache;
360 u32 i_fscache_gen;
361#endif
362 struct inode vfs_inode;
363};
364
365static inline struct ceph_inode_info *ceph_inode(struct inode *inode)
366{
367 return container_of(inode, struct ceph_inode_info, vfs_inode);
368}
369
370static inline struct ceph_fs_client *ceph_inode_to_client(struct inode *inode)
371{
372 return (struct ceph_fs_client *)inode->i_sb->s_fs_info;
373}
374
375static inline struct ceph_fs_client *ceph_sb_to_client(struct super_block *sb)
376{
377 return (struct ceph_fs_client *)sb->s_fs_info;
378}
379
380static inline struct ceph_vino ceph_vino(struct inode *inode)
381{
382 return ceph_inode(inode)->i_vino;
383}
384
385
386
387
388
389
390
391
392
393static inline u32 ceph_ino_to_ino32(__u64 vino)
394{
395 u32 ino = vino & 0xffffffff;
396 ino ^= vino >> 32;
397 if (!ino)
398 ino = 2;
399 return ino;
400}
401
402
403
404
405static inline ino_t ceph_vino_to_ino(struct ceph_vino vino)
406{
407#if BITS_PER_LONG == 32
408 return ceph_ino_to_ino32(vino.ino);
409#else
410 return (ino_t)vino.ino;
411#endif
412}
413
414
415
416
417#if BITS_PER_LONG == 32
418static inline ino_t ceph_translate_ino(struct super_block *sb, ino_t ino)
419{
420 return ino;
421}
422#else
423static inline ino_t ceph_translate_ino(struct super_block *sb, ino_t ino)
424{
425 if (ceph_test_mount_opt(ceph_sb_to_client(sb), INO32))
426 ino = ceph_ino_to_ino32(ino);
427 return ino;
428}
429#endif
430
431
432
433#define ceph_vinop(i) ceph_inode(i)->i_vino.ino, ceph_inode(i)->i_vino.snap
434
435static inline u64 ceph_ino(struct inode *inode)
436{
437 return ceph_inode(inode)->i_vino.ino;
438}
439static inline u64 ceph_snap(struct inode *inode)
440{
441 return ceph_inode(inode)->i_vino.snap;
442}
443
444static inline int ceph_ino_compare(struct inode *inode, void *data)
445{
446 struct ceph_vino *pvino = (struct ceph_vino *)data;
447 struct ceph_inode_info *ci = ceph_inode(inode);
448 return ci->i_vino.ino == pvino->ino &&
449 ci->i_vino.snap == pvino->snap;
450}
451
452static inline struct inode *ceph_find_inode(struct super_block *sb,
453 struct ceph_vino vino)
454{
455 ino_t t = ceph_vino_to_ino(vino);
456 return ilookup5(sb, t, ceph_ino_compare, &vino);
457}
458
459
460
461
462
463#define CEPH_I_DIR_ORDERED (1 << 0)
464#define CEPH_I_NODELAY (1 << 1)
465#define CEPH_I_FLUSH (1 << 2)
466#define CEPH_I_NOFLUSH (1 << 3)
467#define CEPH_I_POOL_PERM (1 << 4)
468#define CEPH_I_POOL_RD (1 << 5)
469#define CEPH_I_POOL_WR (1 << 6)
470#define CEPH_I_SEC_INITED (1 << 7)
471#define CEPH_I_CAP_DROPPED (1 << 8)
472#define CEPH_I_KICK_FLUSH (1 << 9)
473#define CEPH_I_FLUSH_SNAPS (1 << 10)
474
475static inline void __ceph_dir_set_complete(struct ceph_inode_info *ci,
476 long long release_count,
477 long long ordered_count)
478{
479 smp_mb__before_atomic();
480 atomic64_set(&ci->i_complete_seq[0], release_count);
481 atomic64_set(&ci->i_complete_seq[1], ordered_count);
482}
483
484static inline void __ceph_dir_clear_complete(struct ceph_inode_info *ci)
485{
486 atomic64_inc(&ci->i_release_count);
487}
488
489static inline void __ceph_dir_clear_ordered(struct ceph_inode_info *ci)
490{
491 atomic64_inc(&ci->i_ordered_count);
492}
493
494static inline bool __ceph_dir_is_complete(struct ceph_inode_info *ci)
495{
496 return atomic64_read(&ci->i_complete_seq[0]) ==
497 atomic64_read(&ci->i_release_count);
498}
499
500static inline bool __ceph_dir_is_complete_ordered(struct ceph_inode_info *ci)
501{
502 return atomic64_read(&ci->i_complete_seq[0]) ==
503 atomic64_read(&ci->i_release_count) &&
504 atomic64_read(&ci->i_complete_seq[1]) ==
505 atomic64_read(&ci->i_ordered_count);
506}
507
508static inline void ceph_dir_clear_complete(struct inode *inode)
509{
510 __ceph_dir_clear_complete(ceph_inode(inode));
511}
512
513static inline void ceph_dir_clear_ordered(struct inode *inode)
514{
515 __ceph_dir_clear_ordered(ceph_inode(inode));
516}
517
518static inline bool ceph_dir_is_complete_ordered(struct inode *inode)
519{
520 bool ret = __ceph_dir_is_complete_ordered(ceph_inode(inode));
521 smp_rmb();
522 return ret;
523}
524
525
526extern struct ceph_inode_frag *__ceph_find_frag(struct ceph_inode_info *ci,
527 u32 f);
528
529
530
531
532
533extern u32 ceph_choose_frag(struct ceph_inode_info *ci, u32 v,
534 struct ceph_inode_frag *pfrag,
535 int *found);
536
537static inline struct ceph_dentry_info *ceph_dentry(struct dentry *dentry)
538{
539 return (struct ceph_dentry_info *)dentry->d_fsdata;
540}
541
542
543
544
545static inline bool __ceph_is_any_real_caps(struct ceph_inode_info *ci)
546{
547 return !RB_EMPTY_ROOT(&ci->i_caps);
548}
549
550extern int __ceph_caps_issued(struct ceph_inode_info *ci, int *implemented);
551extern int __ceph_caps_issued_mask(struct ceph_inode_info *ci, int mask, int t);
552extern int __ceph_caps_issued_other(struct ceph_inode_info *ci,
553 struct ceph_cap *cap);
554
555static inline int ceph_caps_issued(struct ceph_inode_info *ci)
556{
557 int issued;
558 spin_lock(&ci->i_ceph_lock);
559 issued = __ceph_caps_issued(ci, NULL);
560 spin_unlock(&ci->i_ceph_lock);
561 return issued;
562}
563
564static inline int ceph_caps_issued_mask(struct ceph_inode_info *ci, int mask,
565 int touch)
566{
567 int r;
568 spin_lock(&ci->i_ceph_lock);
569 r = __ceph_caps_issued_mask(ci, mask, touch);
570 spin_unlock(&ci->i_ceph_lock);
571 return r;
572}
573
574static inline int __ceph_caps_dirty(struct ceph_inode_info *ci)
575{
576 return ci->i_dirty_caps | ci->i_flushing_caps;
577}
578extern struct ceph_cap_flush *ceph_alloc_cap_flush(void);
579extern void ceph_free_cap_flush(struct ceph_cap_flush *cf);
580extern int __ceph_mark_dirty_caps(struct ceph_inode_info *ci, int mask,
581 struct ceph_cap_flush **pcf);
582
583extern int __ceph_caps_revoking_other(struct ceph_inode_info *ci,
584 struct ceph_cap *ocap, int mask);
585extern int ceph_caps_revoking(struct ceph_inode_info *ci, int mask);
586extern int __ceph_caps_used(struct ceph_inode_info *ci);
587
588extern int __ceph_caps_file_wanted(struct ceph_inode_info *ci);
589
590
591
592
593static inline int __ceph_caps_wanted(struct ceph_inode_info *ci)
594{
595 int w = __ceph_caps_file_wanted(ci) | __ceph_caps_used(ci);
596 if (w & CEPH_CAP_FILE_BUFFER)
597 w |= CEPH_CAP_FILE_EXCL;
598 return w;
599}
600
601
602extern int __ceph_caps_mds_wanted(struct ceph_inode_info *ci);
603
604extern void ceph_caps_init(struct ceph_mds_client *mdsc);
605extern void ceph_caps_finalize(struct ceph_mds_client *mdsc);
606extern void ceph_adjust_min_caps(struct ceph_mds_client *mdsc, int delta);
607extern void ceph_reserve_caps(struct ceph_mds_client *mdsc,
608 struct ceph_cap_reservation *ctx, int need);
609extern int ceph_unreserve_caps(struct ceph_mds_client *mdsc,
610 struct ceph_cap_reservation *ctx);
611extern void ceph_reservation_status(struct ceph_fs_client *client,
612 int *total, int *avail, int *used,
613 int *reserved, int *min);
614
615
616
617
618
619
620#define CEPH_F_SYNC 1
621#define CEPH_F_ATEND 2
622
623struct ceph_file_info {
624 short fmode;
625 short flags;
626
627
628 u32 frag;
629 struct ceph_mds_request *last_readdir;
630
631
632 unsigned next_offset;
633 char *last_name;
634 long long dir_release_count;
635 long long dir_ordered_count;
636 int readdir_cache_idx;
637
638
639 char *dir_info;
640 int dir_info_len;
641};
642
643struct ceph_readdir_cache_control {
644 struct page *page;
645 struct dentry **dentries;
646 int index;
647};
648
649
650
651
652
653
654
655
656
657
658struct ceph_snap_realm {
659 u64 ino;
660 atomic_t nref;
661 struct rb_node node;
662
663 u64 created, seq;
664 u64 parent_ino;
665 u64 parent_since;
666
667 u64 *prior_parent_snaps;
668 u32 num_prior_parent_snaps;
669 u64 *snaps;
670 u32 num_snaps;
671
672 struct ceph_snap_realm *parent;
673 struct list_head children;
674 struct list_head child_item;
675
676 struct list_head empty_item;
677
678 struct list_head dirty_item;
679
680
681 struct ceph_snap_context *cached_context;
682
683 struct list_head inodes_with_caps;
684 spinlock_t inodes_with_caps_lock;
685};
686
687static inline int default_congestion_kb(void)
688{
689 int congestion_kb;
690
691
692
693
694
695
696
697
698
699
700
701
702
703
704
705
706
707
708
709 congestion_kb = (16*int_sqrt(totalram_pages)) << (PAGE_SHIFT-10);
710 if (congestion_kb > 256*1024)
711 congestion_kb = 256*1024;
712
713 return congestion_kb;
714}
715
716
717
718
719struct ceph_snap_realm *ceph_lookup_snap_realm(struct ceph_mds_client *mdsc,
720 u64 ino);
721extern void ceph_get_snap_realm(struct ceph_mds_client *mdsc,
722 struct ceph_snap_realm *realm);
723extern void ceph_put_snap_realm(struct ceph_mds_client *mdsc,
724 struct ceph_snap_realm *realm);
725extern int ceph_update_snap_trace(struct ceph_mds_client *m,
726 void *p, void *e, bool deletion,
727 struct ceph_snap_realm **realm_ret);
728extern void ceph_handle_snap(struct ceph_mds_client *mdsc,
729 struct ceph_mds_session *session,
730 struct ceph_msg *msg);
731extern void ceph_queue_cap_snap(struct ceph_inode_info *ci);
732extern int __ceph_finish_cap_snap(struct ceph_inode_info *ci,
733 struct ceph_cap_snap *capsnap);
734extern void ceph_cleanup_empty_realms(struct ceph_mds_client *mdsc);
735
736
737
738
739
740static inline bool __ceph_have_pending_cap_snap(struct ceph_inode_info *ci)
741{
742 return !list_empty(&ci->i_cap_snaps) &&
743 list_last_entry(&ci->i_cap_snaps, struct ceph_cap_snap,
744 ci_item)->writing;
745}
746
747
748extern const struct inode_operations ceph_file_iops;
749
750extern struct inode *ceph_alloc_inode(struct super_block *sb);
751extern void ceph_destroy_inode(struct inode *inode);
752extern int ceph_drop_inode(struct inode *inode);
753extern void ceph_evict_inode(struct inode *inode);
754
755extern struct inode *ceph_get_inode(struct super_block *sb,
756 struct ceph_vino vino);
757extern struct inode *ceph_get_snapdir(struct inode *parent);
758extern int ceph_fill_file_size(struct inode *inode, int issued,
759 u32 truncate_seq, u64 truncate_size, u64 size);
760extern void ceph_fill_file_time(struct inode *inode, int issued,
761 u64 time_warp_seq, struct timespec *ctime,
762 struct timespec *mtime, struct timespec *atime);
763extern int ceph_fill_trace(struct super_block *sb,
764 struct ceph_mds_request *req,
765 struct ceph_mds_session *session);
766extern int ceph_readdir_prepopulate(struct ceph_mds_request *req,
767 struct ceph_mds_session *session);
768
769extern int ceph_inode_holds_cap(struct inode *inode, int mask);
770
771extern int ceph_inode_set_size(struct inode *inode, loff_t size);
772extern void __ceph_do_pending_vmtruncate(struct inode *inode);
773extern void ceph_queue_vmtruncate(struct inode *inode);
774
775extern void ceph_queue_invalidate(struct inode *inode);
776extern void ceph_queue_writeback(struct inode *inode);
777
778extern int __ceph_do_getattr(struct inode *inode, struct page *locked_page,
779 int mask, bool force);
780static inline int ceph_do_getattr(struct inode *inode, int mask, bool force)
781{
782 return __ceph_do_getattr(inode, NULL, mask, force);
783}
784extern int ceph_permission(struct inode *inode, int mask);
785extern int __ceph_setattr(struct inode *inode, struct iattr *attr);
786extern int ceph_setattr(struct dentry *dentry, struct iattr *attr);
787extern int ceph_getattr(struct vfsmount *mnt, struct dentry *dentry,
788 struct kstat *stat);
789
790
791int __ceph_setxattr(struct inode *, const char *, const void *, size_t, int);
792ssize_t __ceph_getxattr(struct inode *, const char *, void *, size_t);
793extern ssize_t ceph_listxattr(struct dentry *, char *, size_t);
794extern void __ceph_build_xattrs_blob(struct ceph_inode_info *ci);
795extern void __ceph_destroy_xattrs(struct ceph_inode_info *ci);
796extern void __init ceph_xattr_init(void);
797extern void ceph_xattr_exit(void);
798extern const struct xattr_handler *ceph_xattr_handlers[];
799
800#ifdef CONFIG_SECURITY
801extern bool ceph_security_xattr_deadlock(struct inode *in);
802extern bool ceph_security_xattr_wanted(struct inode *in);
803#else
804static inline bool ceph_security_xattr_deadlock(struct inode *in)
805{
806 return false;
807}
808static inline bool ceph_security_xattr_wanted(struct inode *in)
809{
810 return false;
811}
812#endif
813
814
815struct ceph_acls_info {
816 void *default_acl;
817 void *acl;
818 struct ceph_pagelist *pagelist;
819};
820
821#ifdef CONFIG_CEPH_FS_POSIX_ACL
822
823struct posix_acl *ceph_get_acl(struct inode *, int);
824int ceph_set_acl(struct inode *inode, struct posix_acl *acl, int type);
825int ceph_pre_init_acls(struct inode *dir, umode_t *mode,
826 struct ceph_acls_info *info);
827void ceph_init_inode_acls(struct inode *inode, struct ceph_acls_info *info);
828void ceph_release_acls_info(struct ceph_acls_info *info);
829
830static inline void ceph_forget_all_cached_acls(struct inode *inode)
831{
832 forget_all_cached_acls(inode);
833}
834
835#else
836
837#define ceph_get_acl NULL
838#define ceph_set_acl NULL
839
840static inline int ceph_pre_init_acls(struct inode *dir, umode_t *mode,
841 struct ceph_acls_info *info)
842{
843 return 0;
844}
845static inline void ceph_init_inode_acls(struct inode *inode,
846 struct ceph_acls_info *info)
847{
848}
849static inline void ceph_release_acls_info(struct ceph_acls_info *info)
850{
851}
852static inline int ceph_acl_chmod(struct dentry *dentry, struct inode *inode)
853{
854 return 0;
855}
856
857static inline void ceph_forget_all_cached_acls(struct inode *inode)
858{
859}
860
861#endif
862
863
864extern const char *ceph_cap_string(int c);
865extern void ceph_handle_caps(struct ceph_mds_session *session,
866 struct ceph_msg *msg);
867extern struct ceph_cap *ceph_get_cap(struct ceph_mds_client *mdsc,
868 struct ceph_cap_reservation *ctx);
869extern void ceph_add_cap(struct inode *inode,
870 struct ceph_mds_session *session, u64 cap_id,
871 int fmode, unsigned issued, unsigned wanted,
872 unsigned cap, unsigned seq, u64 realmino, int flags,
873 struct ceph_cap **new_cap);
874extern void __ceph_remove_cap(struct ceph_cap *cap, bool queue_release);
875extern void ceph_put_cap(struct ceph_mds_client *mdsc,
876 struct ceph_cap *cap);
877extern int ceph_is_any_caps(struct inode *inode);
878
879extern void ceph_queue_caps_release(struct inode *inode);
880extern int ceph_write_inode(struct inode *inode, struct writeback_control *wbc);
881extern int ceph_fsync(struct file *file, loff_t start, loff_t end,
882 int datasync);
883extern void ceph_early_kick_flushing_caps(struct ceph_mds_client *mdsc,
884 struct ceph_mds_session *session);
885extern void ceph_kick_flushing_caps(struct ceph_mds_client *mdsc,
886 struct ceph_mds_session *session);
887extern struct ceph_cap *ceph_get_cap_for_mds(struct ceph_inode_info *ci,
888 int mds);
889extern int ceph_get_cap_mds(struct inode *inode);
890extern void ceph_get_cap_refs(struct ceph_inode_info *ci, int caps);
891extern void ceph_put_cap_refs(struct ceph_inode_info *ci, int had);
892extern void ceph_put_wrbuffer_cap_refs(struct ceph_inode_info *ci, int nr,
893 struct ceph_snap_context *snapc);
894extern void ceph_flush_snaps(struct ceph_inode_info *ci,
895 struct ceph_mds_session **psession);
896extern void ceph_check_caps(struct ceph_inode_info *ci, int flags,
897 struct ceph_mds_session *session);
898extern void ceph_check_delayed_caps(struct ceph_mds_client *mdsc);
899extern void ceph_flush_dirty_caps(struct ceph_mds_client *mdsc);
900
901extern int ceph_encode_inode_release(void **p, struct inode *inode,
902 int mds, int drop, int unless, int force);
903extern int ceph_encode_dentry_release(void **p, struct dentry *dn,
904 int mds, int drop, int unless);
905
906extern int ceph_get_caps(struct ceph_inode_info *ci, int need, int want,
907 loff_t endoff, int *got, struct page **pinned_page);
908
909
910extern void __ceph_get_fmode(struct ceph_inode_info *ci, int mode);
911extern void ceph_put_fmode(struct ceph_inode_info *ci, int mode);
912
913
914extern const struct address_space_operations ceph_aops;
915extern int ceph_mmap(struct file *file, struct vm_area_struct *vma);
916extern int ceph_uninline_data(struct file *filp, struct page *locked_page);
917extern int ceph_pool_perm_check(struct ceph_inode_info *ci, int need);
918extern void ceph_pool_perm_destroy(struct ceph_mds_client* mdsc);
919
920
921extern const struct file_operations ceph_file_fops;
922
923extern int ceph_renew_caps(struct inode *inode);
924extern int ceph_open(struct inode *inode, struct file *file);
925extern int ceph_atomic_open(struct inode *dir, struct dentry *dentry,
926 struct file *file, unsigned flags, umode_t mode,
927 int *opened);
928extern int ceph_release(struct inode *inode, struct file *filp);
929extern void ceph_fill_inline_data(struct inode *inode, struct page *locked_page,
930 char *data, size_t len);
931extern void ceph_sync_write_wait(struct inode *inode);
932
933extern const struct file_operations ceph_dir_fops;
934extern const struct file_operations ceph_snapdir_fops;
935extern const struct inode_operations ceph_dir_iops;
936extern const struct inode_operations ceph_snapdir_iops;
937extern const struct dentry_operations ceph_dentry_ops, ceph_snap_dentry_ops,
938 ceph_snapdir_dentry_ops;
939
940extern loff_t ceph_make_fpos(unsigned high, unsigned off, bool hash_order);
941extern int ceph_handle_notrace_create(struct inode *dir, struct dentry *dentry);
942extern int ceph_handle_snapdir(struct ceph_mds_request *req,
943 struct dentry *dentry, int err);
944extern struct dentry *ceph_finish_lookup(struct ceph_mds_request *req,
945 struct dentry *dentry, int err);
946
947extern void ceph_dentry_lru_add(struct dentry *dn);
948extern void ceph_dentry_lru_touch(struct dentry *dn);
949extern void ceph_dentry_lru_del(struct dentry *dn);
950extern void ceph_invalidate_dentry_lease(struct dentry *dentry);
951extern unsigned ceph_dentry_hash(struct inode *dir, struct dentry *dn);
952extern void ceph_readdir_cache_release(struct ceph_readdir_cache_control *ctl);
953
954
955
956
957
958int ceph_init_dentry(struct dentry *dentry);
959
960
961
962extern long ceph_ioctl(struct file *file, unsigned int cmd, unsigned long arg);
963
964
965extern const struct export_operations ceph_export_ops;
966
967
968extern __init void ceph_flock_init(void);
969extern int ceph_lock(struct file *file, int cmd, struct file_lock *fl);
970extern int ceph_flock(struct file *file, int cmd, struct file_lock *fl);
971extern void ceph_count_locks(struct inode *inode, int *p_num, int *f_num);
972extern int ceph_encode_locks_to_buffer(struct inode *inode,
973 struct ceph_filelock *flocks,
974 int num_fcntl_locks,
975 int num_flock_locks);
976extern int ceph_locks_to_pagelist(struct ceph_filelock *flocks,
977 struct ceph_pagelist *pagelist,
978 int num_fcntl_locks, int num_flock_locks);
979extern int lock_to_ceph_filelock(struct file_lock *fl, struct ceph_filelock *c);
980
981
982extern int ceph_fs_debugfs_init(struct ceph_fs_client *client);
983extern void ceph_fs_debugfs_cleanup(struct ceph_fs_client *client);
984
985#endif
986