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