ceph_mds_client
struct ceph_mds_client *mdsc = fsc->mdsc;
void ceph_pool_perm_destroy(struct ceph_mds_client *mdsc)
struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(inode->i_sb);
struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(inode->i_sb);
struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(inode->i_sb);
struct ceph_mds_client *mdsc;
void ceph_remove_cap(struct ceph_mds_client *mdsc, struct ceph_cap *cap,
struct ceph_mds_client *mdsc = arg->session->s_mdsc;
void ceph_caps_init(struct ceph_mds_client *mdsc)
struct ceph_mds_client *mdsc = ceph_inode_to_fs_client(inode)->mdsc;
void ceph_caps_finalize(struct ceph_mds_client *mdsc)
void ceph_adjust_caps_max_min(struct ceph_mds_client *mdsc,
struct ceph_mds_client *mdsc = session->s_mdsc;
static void __ceph_unreserve_caps(struct ceph_mds_client *mdsc, int nr_caps)
struct ceph_mds_client *mdsc = ceph_inode_to_fs_client(inode)->mdsc;
struct ceph_mds_client *mdsc =
static u64 __get_oldest_flush_tid(struct ceph_mds_client *mdsc)
static bool __detach_cap_flush_from_mdsc(struct ceph_mds_client *mdsc,
struct ceph_mds_client *mdsc = ceph_sb_to_fs_client(inode->i_sb)->mdsc;
struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(inode->i_sb);
int ceph_reserve_caps(struct ceph_mds_client *mdsc,
struct ceph_mds_client *mdsc = ceph_sb_to_fs_client(inode->i_sb)->mdsc;
struct ceph_mds_client *mdsc = ceph_sb_to_fs_client(inode->i_sb)->mdsc;
struct ceph_mds_client *mdsc =
static void __kick_flushing_caps(struct ceph_mds_client *mdsc,
void ceph_early_kick_flushing_caps(struct ceph_mds_client *mdsc,
void ceph_kick_flushing_caps(struct ceph_mds_client *mdsc,
struct ceph_mds_client *mdsc = session->s_mdsc;
struct ceph_mds_client *mdsc = ceph_inode_to_fs_client(inode)->mdsc;
struct ceph_mds_client *mdsc = fsc->mdsc;
void ceph_unreserve_caps(struct ceph_mds_client *mdsc,
struct ceph_cap *ceph_get_cap(struct ceph_mds_client *mdsc,
struct ceph_mds_client *mdsc = ceph_sb_to_fs_client(inode->i_sb)->mdsc;
void ceph_put_cap(struct ceph_mds_client *mdsc, struct ceph_cap *cap)
struct ceph_mds_client *mdsc = ceph_sb_to_fs_client(inode->i_sb)->mdsc;
struct ceph_mds_client *mdsc = ceph_sb_to_fs_client(inode->i_sb)->mdsc;
struct ceph_mds_client *mdsc = ceph_inode_to_fs_client(inode)->mdsc;
struct ceph_mds_client *mdsc = fsc->mdsc;
static void handle_cap_import(struct ceph_mds_client *mdsc,
struct ceph_mds_client *mdsc = session->s_mdsc;
unsigned long ceph_check_delayed_caps(struct ceph_mds_client *mdsc)
struct ceph_mds_client *mdsc = s->s_mdsc;
void ceph_flush_dirty_caps(struct ceph_mds_client *mdsc)
struct ceph_mds_client *mdsc = s->s_mdsc;
void ceph_flush_cap_releases(struct ceph_mds_client *mdsc)
struct ceph_mds_client *mdsc, int fmode)
struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(ci->netfs.inode.i_sb);
struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(ci->netfs.inode.i_sb);
struct ceph_mds_client *mdsc =
static u64 __get_oldest_flush_tid(struct ceph_mds_client *mdsc);
static void __cap_set_timeouts(struct ceph_mds_client *mdsc,
static int remove_capsnaps(struct ceph_mds_client *mdsc, struct inode *inode)
static void __kick_flushing_caps(struct ceph_mds_client *mdsc,
struct ceph_mds_client *mdsc = fsc->mdsc;
static void __cap_delay_requeue(struct ceph_mds_client *mdsc,
static void __cap_delay_requeue_front(struct ceph_mds_client *mdsc,
static void __cap_delay_cancel(struct ceph_mds_client *mdsc,
struct ceph_mds_client *mdsc = ceph_inode_to_fs_client(inode)->mdsc;
struct ceph_mds_client *mdsc = fsc->mdsc;
struct ceph_mds_client *mdsc = fsc->mdsc;
struct ceph_mds_client *mdsc = fsc->mdsc;
struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(dir->i_sb);
struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(dir->i_sb);
struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(dir->i_sb);
static void ceph_async_unlink_cb(struct ceph_mds_client *mdsc,
struct ceph_mds_client *mdsc = fsc->mdsc;
struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(old_dir->i_sb);
struct ceph_mds_client *mdsc = ceph_sb_to_fs_client(dn->d_sb)->mdsc;
static void __dentry_dir_lease_touch(struct ceph_mds_client* mdsc,
struct ceph_mds_client *mdsc = ceph_sb_to_fs_client(dn->d_sb)->mdsc;
struct ceph_mds_client *mdsc;
__dentry_leases_walk(struct ceph_mds_client *mdsc,
int ceph_trim_dentries(struct ceph_mds_client *mdsc)
struct ceph_mds_client *mdsc = ceph_sb_to_fs_client(dentry->d_sb)->mdsc;
struct ceph_mds_client *mdsc)
struct ceph_mds_client *mdsc = ceph_sb_to_fs_client(dentry->d_sb)->mdsc;
struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(dentry->d_sb);
struct ceph_mds_client *mdsc = fsc->mdsc;
struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(dentry->d_sb);
struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(dir->i_sb);
struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(dir->i_sb);
struct ceph_mds_client *mdsc = ceph_sb_to_fs_client(sb)->mdsc;
struct ceph_mds_client *mdsc = ceph_sb_to_fs_client(sb)->mdsc;
struct ceph_mds_client *mdsc = ceph_sb_to_fs_client(sb)->mdsc;
struct ceph_mds_client *mdsc;
struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(sb);
static __le32 ceph_flags_sys2wire(struct ceph_mds_client *mdsc, u32 flags)
struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(inode->i_sb);
struct ceph_mds_client *mdsc = fsc->mdsc;
static void ceph_async_create_cb(struct ceph_mds_client *mdsc,
struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(dir->i_sb);
struct ceph_mds_client *mdsc = fsc->mdsc;
struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(sb);
struct ceph_mds_client *mdsc = ceph_sb_to_fs_client(inode->i_sb)->mdsc;
struct ceph_mds_client *mdsc = fsc->mdsc;
struct ceph_mds_client *mdsc = fsc->mdsc;
struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(inode->i_sb);
struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(inode->i_sb);
static int decode_encrypted_symlink(struct ceph_mds_client *mdsc,
static int decode_encrypted_symlink(struct ceph_mds_client *mdsc,
struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(inode->i_sb);
struct ceph_mds_client *mdsc = ceph_sb_to_fs_client(inode->i_sb)->mdsc;
struct ceph_mds_client *mdsc = ceph_inode_to_fs_client(inode)->mdsc;
struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(file_inode(file)->i_sb);
static long __validate_layout(struct ceph_mds_client *mdsc,
struct ceph_mds_client *mdsc = ceph_sb_to_fs_client(inode->i_sb)->mdsc;
static int ceph_lock_wait_for_completion(struct ceph_mds_client *mdsc,
static int ceph_lock_wait_for_completion(struct ceph_mds_client *mdsc,
struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(inode->i_sb);
static void __unregister_session(struct ceph_mds_client *mdsc,
void ceph_mdsc_iterate_sessions(struct ceph_mds_client *mdsc,
lookup_get_request(struct ceph_mds_client *mdsc, u64 tid)
static void __register_request(struct ceph_mds_client *mdsc,
static void __unregister_request(struct ceph_mds_client *mdsc,
static int __choose_mds(struct ceph_mds_client *mdsc,
create_session_full_msg(struct ceph_mds_client *mdsc, int op, u64 seq)
static int __open_session(struct ceph_mds_client *mdsc,
__open_export_target_session(struct ceph_mds_client *mdsc, int target)
ceph_mdsc_open_export_target_session(struct ceph_mds_client *mdsc, int target)
static void __open_export_target_sessions(struct ceph_mds_client *mdsc,
static void dispose_cap_releases(struct ceph_mds_client *mdsc,
static void cleanup_session_requests(struct ceph_mds_client *mdsc,
static int send_renew_caps(struct ceph_mds_client *mdsc,
static int send_flushmsg_ack(struct ceph_mds_client *mdsc,
static void renewed_caps(struct ceph_mds_client *mdsc,
static int __close_session(struct ceph_mds_client *mdsc,
struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(inode->i_sb);
int ceph_trim_caps(struct ceph_mds_client *mdsc,
static int check_caps_flush(struct ceph_mds_client *mdsc,
static void wait_caps_flush(struct ceph_mds_client *mdsc,
static void ceph_send_cap_releases(struct ceph_mds_client *mdsc,
void ceph_flush_session_cap_releases(struct ceph_mds_client *mdsc,
struct ceph_mds_client *mdsc =
container_of(work, struct ceph_mds_client, cap_reclaim_work);
void ceph_queue_cap_reclaim_work(struct ceph_mds_client *mdsc)
void ceph_reclaim_caps_nr(struct ceph_mds_client *mdsc, int nr)
void ceph_queue_cap_unlink_work(struct ceph_mds_client *mdsc)
struct ceph_mds_client *mdsc =
container_of(work, struct ceph_mds_client, cap_unlink_work);
ceph_mdsc_create_request(struct ceph_mds_client *mdsc, int op, int mode)
static struct ceph_mds_request *__get_oldest_req(struct ceph_mds_client *mdsc)
static inline u64 __get_oldest_tid(struct ceph_mds_client *mdsc)
char *ceph_mdsc_build_path(struct ceph_mds_client *mdsc, struct dentry *dentry,
static int build_dentry_path(struct ceph_mds_client *mdsc, struct dentry *dentry,
struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(inode->i_sb);
static int set_request_path_attr(struct ceph_mds_client *mdsc, struct inode *rinode,
struct ceph_mds_client *mdsc = session->s_mdsc;
static void complete_request(struct ceph_mds_client *mdsc,
struct ceph_mds_client *mdsc = session->s_mdsc;
static void __do_request(struct ceph_mds_client *mdsc,
static void __wake_requests(struct ceph_mds_client *mdsc,
static void kick_requests(struct ceph_mds_client *mdsc, int mds)
int ceph_mdsc_submit_request(struct ceph_mds_client *mdsc, struct inode *dir,
int ceph_mdsc_wait_request(struct ceph_mds_client *mdsc,
int ceph_mdsc_do_request(struct ceph_mds_client *mdsc,
struct ceph_mds_client *mdsc = session->s_mdsc;
static void handle_forward(struct ceph_mds_client *mdsc,
struct ceph_mds_client *mdsc = session->s_mdsc;
static void replay_unsafe_requests(struct ceph_mds_client *mdsc,
struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(inode->i_sb);
static int encode_snap_realms(struct ceph_mds_client *mdsc,
static void send_mds_reconnect(struct ceph_mds_client *mdsc,
static void check_new_map(struct ceph_mds_client *mdsc,
static void handle_lease(struct ceph_mds_client *mdsc,
static void maybe_recover_session(struct ceph_mds_client *mdsc)
static void schedule_delayed(struct ceph_mds_client *mdsc, unsigned long delay)
struct ceph_mds_client *mdsc =
container_of(work, struct ceph_mds_client, delayed_work.work);
struct ceph_mds_client *mdsc;
mdsc = kzalloc_obj(struct ceph_mds_client, GFP_NOFS);
static void wait_requests(struct ceph_mds_client *mdsc)
static int ceph_mds_auth_match(struct ceph_mds_client *mdsc,
int ceph_mds_check_access(struct ceph_mds_client *mdsc, char *tpath, int mask)
void ceph_mdsc_pre_umount(struct ceph_mds_client *mdsc)
static void flush_mdlog_and_wait_mdsc_unsafe_requests(struct ceph_mds_client *mdsc,
void ceph_mdsc_sync(struct ceph_mds_client *mdsc)
static bool done_closing_sessions(struct ceph_mds_client *mdsc, int skipped)
void ceph_mdsc_close_sessions(struct ceph_mds_client *mdsc)
void ceph_mdsc_force_umount(struct ceph_mds_client *mdsc)
static void ceph_mdsc_stop(struct ceph_mds_client *mdsc)
struct ceph_mds_client *mdsc = fsc->mdsc;
void ceph_mdsc_handle_fsmap(struct ceph_mds_client *mdsc, struct ceph_msg *msg)
void ceph_mdsc_handle_mdsmap(struct ceph_mds_client *mdsc, struct ceph_msg *msg)
struct ceph_mds_client *mdsc = s->s_mdsc;
struct ceph_mds_client *mdsc = s->s_mdsc;
struct ceph_mds_client *mdsc = s->s_mdsc;
struct ceph_mds_client *mdsc = s->s_mdsc;
struct ceph_mds_client *mdsc = s->s_mdsc;
struct ceph_mds_client *mdsc = s->s_mdsc;
static void __wake_requests(struct ceph_mds_client *mdsc,
struct ceph_mds_session *__ceph_lookup_mds_session(struct ceph_mds_client *mdsc,
static bool __have_session(struct ceph_mds_client *mdsc, int mds)
static int __verify_registered_session(struct ceph_mds_client *mdsc,
static struct ceph_mds_session *register_session(struct ceph_mds_client *mdsc,
struct ceph_mds_client *s_mdsc;
struct ceph_mds_client;
typedef void (*ceph_mds_request_callback_t) (struct ceph_mds_client *mdsc,
typedef int (*ceph_mds_request_wait_callback_t) (struct ceph_mds_client *mdsc,
struct ceph_mds_client *r_mdsc;
__ceph_lookup_mds_session(struct ceph_mds_client *, int mds);
extern void ceph_mdsc_close_sessions(struct ceph_mds_client *mdsc);
extern void ceph_mdsc_force_umount(struct ceph_mds_client *mdsc);
extern void ceph_mdsc_sync(struct ceph_mds_client *mdsc);
ceph_mdsc_create_request(struct ceph_mds_client *mdsc, int op, int mode);
extern int ceph_mdsc_submit_request(struct ceph_mds_client *mdsc,
int ceph_mdsc_wait_request(struct ceph_mds_client *mdsc,
extern int ceph_mdsc_do_request(struct ceph_mds_client *mdsc,
extern void ceph_mdsc_iterate_sessions(struct ceph_mds_client *mdsc,
extern void ceph_flush_session_cap_releases(struct ceph_mds_client *mdsc,
extern void ceph_queue_cap_reclaim_work(struct ceph_mds_client *mdsc);
extern void ceph_reclaim_caps_nr(struct ceph_mds_client *mdsc, int nr);
extern void ceph_queue_cap_unlink_work(struct ceph_mds_client *mdsc);
extern int ceph_mds_check_access(struct ceph_mds_client *mdsc, char *tpath,
extern void ceph_mdsc_pre_umount(struct ceph_mds_client *mdsc);
extern char *ceph_mdsc_build_path(struct ceph_mds_client *mdsc,
extern void ceph_mdsc_handle_mdsmap(struct ceph_mds_client *mdsc,
extern void ceph_mdsc_handle_fsmap(struct ceph_mds_client *mdsc,
ceph_mdsc_open_export_target_session(struct ceph_mds_client *mdsc, int target);
extern int ceph_trim_caps(struct ceph_mds_client *mdsc,
struct ceph_mdsmap *ceph_mdsmap_decode(struct ceph_mds_client *mdsc, void **p,
struct ceph_mdsmap *ceph_mdsmap_decode(struct ceph_mds_client *mdsc, void **p,
struct ceph_mds_client;
static bool ceph_mdsc_send_metrics(struct ceph_mds_client *mdsc,
static void metric_get_session(struct ceph_mds_client *mdsc)
struct ceph_mds_client *mdsc =
container_of(m, struct ceph_mds_client, metric);
static struct inode *lookup_quotarealm_inode(struct ceph_mds_client *mdsc,
struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(inode->i_sb);
void ceph_cleanup_quotarealms_inodes(struct ceph_mds_client *mdsc)
static int get_quota_realm(struct ceph_mds_client *mdsc, struct inode *inode,
struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(sb);
struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(old->i_sb);
struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(inode->i_sb);
void ceph_handle_quota(struct ceph_mds_client *mdsc,
struct ceph_mds_client *mdsc = fsc->mdsc;
find_quotarealm_inode(struct ceph_mds_client *mdsc, u64 ino)
void ceph_handle_snap(struct ceph_mds_client *mdsc,
struct ceph_mds_client *mdsc,
struct ceph_snapid_map* ceph_get_snapid_map(struct ceph_mds_client *mdsc,
void ceph_put_snapid_map(struct ceph_mds_client* mdsc,
void ceph_trim_snapid_map(struct ceph_mds_client *mdsc)
void ceph_cleanup_snapid_map(struct ceph_mds_client *mdsc)
static struct ceph_snap_realm *__lookup_snap_realm(struct ceph_mds_client *mdsc,
struct ceph_snap_realm *ceph_lookup_snap_realm(struct ceph_mds_client *mdsc,
static void __put_snap_realm(struct ceph_mds_client *mdsc,
static void __destroy_snap_realm(struct ceph_mds_client *mdsc,
static void __put_snap_realm(struct ceph_mds_client *mdsc,
void ceph_put_snap_realm(struct ceph_mds_client *mdsc,
static void __cleanup_empty_realms(struct ceph_mds_client *mdsc)
void ceph_cleanup_global_and_empty_realms(struct ceph_mds_client *mdsc)
static int adjust_snap_realm_parent(struct ceph_mds_client *mdsc,
static int build_snap_context(struct ceph_mds_client *mdsc,
static void rebuild_snap_realms(struct ceph_mds_client *mdsc,
void ceph_get_snap_realm(struct ceph_mds_client *mdsc,
struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(inode->i_sb);
static void queue_realm_cap_snaps(struct ceph_mds_client *mdsc,
int ceph_update_snap_trace(struct ceph_mds_client *mdsc,
static void flush_snaps(struct ceph_mds_client *mdsc)
struct ceph_mds_client *mdsc = ceph_inode_to_fs_client(inode)->mdsc;
struct ceph_mds_client *mdsc = fsc->mdsc;
static bool __inc_stopping_blocker(struct ceph_mds_client *mdsc)
static void __dec_stopping_blocker(struct ceph_mds_client *mdsc)
bool ceph_inc_mds_stopping_blocker(struct ceph_mds_client *mdsc,
void ceph_dec_mds_stopping_blocker(struct ceph_mds_client *mdsc)
bool ceph_inc_osd_stopping_blocker(struct ceph_mds_client *mdsc)
void ceph_dec_osd_stopping_blocker(struct ceph_mds_client *mdsc)
struct ceph_mds_client *mdsc = fsc->mdsc;
struct ceph_snap_realm *ceph_lookup_snap_realm(struct ceph_mds_client *mdsc,
extern void ceph_get_snap_realm(struct ceph_mds_client *mdsc,
extern void ceph_put_snap_realm(struct ceph_mds_client *mdsc,
extern int ceph_update_snap_trace(struct ceph_mds_client *m,
extern void ceph_handle_snap(struct ceph_mds_client *mdsc,
extern void ceph_cleanup_global_and_empty_realms(struct ceph_mds_client *mdsc);
extern struct ceph_snapid_map *ceph_get_snapid_map(struct ceph_mds_client *mdsc,
extern void ceph_put_snapid_map(struct ceph_mds_client* mdsc,
extern void ceph_trim_snapid_map(struct ceph_mds_client *mdsc);
extern void ceph_cleanup_snapid_map(struct ceph_mds_client *mdsc);
extern struct ceph_cap *ceph_get_cap(struct ceph_mds_client *mdsc,
extern void ceph_remove_cap(struct ceph_mds_client *mdsc, struct ceph_cap *cap,
extern void ceph_put_cap(struct ceph_mds_client *mdsc,
extern void ceph_early_kick_flushing_caps(struct ceph_mds_client *mdsc,
extern void ceph_kick_flushing_caps(struct ceph_mds_client *mdsc,
extern unsigned long ceph_check_delayed_caps(struct ceph_mds_client *mdsc);
extern void ceph_flush_dirty_caps(struct ceph_mds_client *mdsc);
extern void ceph_flush_cap_releases(struct ceph_mds_client *mdsc);
struct ceph_mds_client *mdsc, int fmode);
extern void ceph_pool_perm_destroy(struct ceph_mds_client* mdsc);
extern int ceph_trim_dentries(struct ceph_mds_client *mdsc);
extern void ceph_handle_quota(struct ceph_mds_client *mdsc,
extern void ceph_cleanup_quotarealms_inodes(struct ceph_mds_client *mdsc);
bool ceph_inc_mds_stopping_blocker(struct ceph_mds_client *mdsc,
void ceph_dec_mds_stopping_blocker(struct ceph_mds_client *mdsc);
bool ceph_inc_osd_stopping_blocker(struct ceph_mds_client *mdsc);
void ceph_dec_osd_stopping_blocker(struct ceph_mds_client *mdsc);
struct ceph_mds_client *mdsc;
static inline struct ceph_mds_client *
return (struct ceph_mds_client *)ceph_sb_to_fs_client(sb)->mdsc;
extern void ceph_caps_init(struct ceph_mds_client *mdsc);
extern void ceph_caps_finalize(struct ceph_mds_client *mdsc);
extern void ceph_adjust_caps_max_min(struct ceph_mds_client *mdsc,
extern int ceph_reserve_caps(struct ceph_mds_client *mdsc,
extern void ceph_unreserve_caps(struct ceph_mds_client *mdsc,
struct ceph_mds_client *mdsc = fsc->mdsc;
struct ceph_mds_client *mdsc = ceph_sb_to_fs_client(inode->i_sb)->mdsc;
struct ceph_mds_client;
TP_PROTO(struct ceph_mds_client *mdsc,
TP_PROTO(struct ceph_mds_client *mdsc,
TP_PROTO(struct ceph_mds_client *mdsc,
TP_PROTO(struct ceph_mds_client *mdsc,
TP_PROTO(struct ceph_mds_client *mdsc,