/linux-master/fs/ceph/ |
H A D | quota.c | 15 struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(inode->i_sb); local 17 atomic64_inc(&mdsc->quotarealms_count); 19 atomic64_dec(&mdsc->quotarealms_count); 25 struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(sb); local 28 if (atomic64_read(&mdsc->quotarealms_count) > 0) 40 void ceph_handle_quota(struct ceph_mds_client *mdsc, argument 44 struct super_block *sb = mdsc->fsc->sb; 46 struct ceph_client *cl = mdsc->fsc->client; 51 if (!ceph_inc_mds_stopping_blocker(mdsc, session)) 81 ceph_dec_mds_stopping_blocker(mdsc); 85 find_quotarealm_inode(struct ceph_mds_client *mdsc, u64 ino) argument 130 lookup_quotarealm_inode(struct ceph_mds_client *mdsc, struct super_block *sb, struct ceph_snap_realm *realm) argument 179 ceph_cleanup_quotarealms_inodes(struct ceph_mds_client *mdsc) argument 214 get_quota_realm(struct ceph_mds_client *mdsc, struct inode *inode, enum quota_get_realm which_quota, struct ceph_snap_realm **realmp, bool retry) argument 281 struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(old->i_sb); local 329 struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(inode->i_sb); local 492 struct ceph_mds_client *mdsc = fsc->mdsc; local [all...] |
H A D | snap.c | 66 void ceph_get_snap_realm(struct ceph_mds_client *mdsc, argument 69 lockdep_assert_held(&mdsc->snap_rwsem); 80 spin_lock(&mdsc->snap_empty_lock); 83 spin_unlock(&mdsc->snap_empty_lock); 114 struct ceph_mds_client *mdsc, 119 lockdep_assert_held_write(&mdsc->snap_rwsem); 138 __insert_snap_realm(&mdsc->snap_realms, realm); 139 mdsc->num_snap_realms++; 141 doutc(mdsc->fsc->client, "%llx %p\n", realm->ino, realm); 150 static struct ceph_snap_realm *__lookup_snap_realm(struct ceph_mds_client *mdsc, argument 113 ceph_create_snap_realm( struct ceph_mds_client *mdsc, u64 ino) argument 173 ceph_lookup_snap_realm(struct ceph_mds_client *mdsc, u64 ino) argument 189 __destroy_snap_realm(struct ceph_mds_client *mdsc, struct ceph_snap_realm *realm) argument 214 __put_snap_realm(struct ceph_mds_client *mdsc, struct ceph_snap_realm *realm) argument 230 ceph_put_snap_realm(struct ceph_mds_client *mdsc, struct ceph_snap_realm *realm) argument 253 __cleanup_empty_realms(struct ceph_mds_client *mdsc) argument 271 ceph_cleanup_global_and_empty_realms(struct ceph_mds_client *mdsc) argument 291 adjust_snap_realm_parent(struct ceph_mds_client *mdsc, struct ceph_snap_realm *realm, u64 parentino) argument 335 build_snap_context(struct ceph_mds_client *mdsc, struct ceph_snap_realm *realm, struct list_head *realm_queue, struct list_head *dirty_realms) argument 433 rebuild_snap_realms(struct ceph_mds_client *mdsc, struct ceph_snap_realm *realm, struct list_head *dirty_realms) argument 666 struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(inode->i_sb); local 722 queue_realm_cap_snaps(struct ceph_mds_client *mdsc, struct ceph_snap_realm *realm) argument 779 ceph_update_snap_trace(struct ceph_mds_client *mdsc, void *p, void *e, bool deletion, struct ceph_snap_realm **realm_ret) argument 942 flush_snaps(struct ceph_mds_client *mdsc) argument 980 struct ceph_mds_client *mdsc = ceph_inode_to_fs_client(inode)->mdsc; local 1016 ceph_handle_snap(struct ceph_mds_client *mdsc, struct ceph_mds_session *session, struct ceph_msg *msg) argument 1188 ceph_get_snapid_map(struct ceph_mds_client *mdsc, u64 snap) argument 1268 ceph_put_snapid_map(struct ceph_mds_client* mdsc, struct ceph_snapid_map *sm) argument 1287 ceph_trim_snapid_map(struct ceph_mds_client *mdsc) argument 1317 ceph_cleanup_snapid_map(struct ceph_mds_client *mdsc) argument [all...] |
H A D | mds_client.c | 63 static void __wake_requests(struct ceph_mds_client *mdsc, 932 * called under mdsc->mutex 934 struct ceph_mds_session *__ceph_lookup_mds_session(struct ceph_mds_client *mdsc, argument 937 if (mds >= mdsc->max_sessions || !mdsc->sessions[mds]) 939 return ceph_get_mds_session(mdsc->sessions[mds]); 942 static bool __have_session(struct ceph_mds_client *mdsc, int mds) argument 944 if (mds >= mdsc->max_sessions || !mdsc->sessions[mds]) 950 static int __verify_registered_session(struct ceph_mds_client *mdsc, argument 963 register_session(struct ceph_mds_client *mdsc, int mds) argument 1036 __unregister_session(struct ceph_mds_client *mdsc, struct ceph_mds_session *s) argument 1060 ceph_mdsc_iterate_sessions(struct ceph_mds_client *mdsc, void (*cb)(struct ceph_mds_session *), bool check_state) argument 1146 lookup_get_request(struct ceph_mds_client *mdsc, u64 tid) argument 1163 __register_request(struct ceph_mds_client *mdsc, struct ceph_mds_request *req, struct inode *dir) argument 1204 __unregister_request(struct ceph_mds_client *mdsc, struct ceph_mds_request *req) argument 1282 __choose_mds(struct ceph_mds_client *mdsc, struct ceph_mds_request *req, bool *random) argument 1538 create_session_full_msg(struct ceph_mds_client *mdsc, int op, u64 seq) argument 1661 __open_session(struct ceph_mds_client *mdsc, struct ceph_mds_session *session) argument 1693 __open_export_target_session(struct ceph_mds_client *mdsc, int target) argument 1715 ceph_mdsc_open_export_target_session(struct ceph_mds_client *mdsc, int target) argument 1729 __open_export_target_sessions(struct ceph_mds_client *mdsc, struct ceph_mds_session *session) argument 1750 ceph_mdsc_open_export_target_sessions(struct ceph_mds_client *mdsc, struct ceph_mds_session *session) argument 1774 dispose_cap_releases(struct ceph_mds_client *mdsc, struct list_head *dispose) argument 1786 cleanup_session_requests(struct ceph_mds_client *mdsc, struct ceph_mds_session *session) argument 2022 send_renew_caps(struct ceph_mds_client *mdsc, struct ceph_mds_session *session) argument 2053 send_flushmsg_ack(struct ceph_mds_client *mdsc, struct ceph_mds_session *session, u64 seq) argument 2074 renewed_caps(struct ceph_mds_client *mdsc, struct ceph_mds_session *session, int is_renew) argument 2127 __close_session(struct ceph_mds_client *mdsc, struct ceph_mds_session *session) argument 2171 struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(inode->i_sb); local 2251 ceph_trim_caps(struct ceph_mds_client *mdsc, struct ceph_mds_session *session, int max_caps) argument 2273 check_caps_flush(struct ceph_mds_client *mdsc, u64 want_flush_tid) argument 2299 wait_caps_flush(struct ceph_mds_client *mdsc, u64 want_flush_tid) argument 2315 ceph_send_cap_releases(struct ceph_mds_client *mdsc, struct ceph_mds_session *session) argument 2423 ceph_flush_cap_releases(struct ceph_mds_client *mdsc, struct ceph_mds_session *session) argument 2455 struct ceph_mds_client *mdsc = local 2462 ceph_queue_cap_reclaim_work(struct ceph_mds_client *mdsc) argument 2475 ceph_reclaim_caps_nr(struct ceph_mds_client *mdsc, int nr) argument 2487 ceph_queue_cap_unlink_work(struct ceph_mds_client *mdsc) argument 2502 struct ceph_mds_client *mdsc = local 2578 ceph_mdsc_create_request(struct ceph_mds_client *mdsc, int op, int mode) argument 2614 __get_oldest_req(struct ceph_mds_client *mdsc) argument 2622 __get_oldest_tid(struct ceph_mds_client *mdsc) argument 2707 ceph_mdsc_build_path(struct ceph_mds_client *mdsc, struct dentry *dentry, int *plen, u64 *pbase, int for_wire) argument 2826 build_dentry_path(struct ceph_mds_client *mdsc, struct dentry *dentry, struct inode *dir, const char **ppath, int *ppathlen, u64 *pino, bool *pfreepath, bool parent_locked) argument 2856 struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(inode->i_sb); local 2879 set_request_path_attr(struct ceph_mds_client *mdsc, struct inode *rinode, struct dentry *rdentry, struct inode *rdiri, const char *rpath, u64 rino, const char **ppath, int *pathlen, u64 *ino, bool *freepath, bool parent_locked) argument 2973 struct ceph_mds_client *mdsc = session->s_mdsc; local 3244 complete_request(struct ceph_mds_client *mdsc, struct ceph_mds_request *req) argument 3262 struct ceph_mds_client *mdsc = session->s_mdsc; local 3392 __do_request(struct ceph_mds_client *mdsc, struct ceph_mds_request *req) argument 3598 __wake_requests(struct ceph_mds_client *mdsc, struct list_head *head) argument 3621 kick_requests(struct ceph_mds_client *mdsc, int mds) argument 3644 ceph_mdsc_submit_request(struct ceph_mds_client *mdsc, struct inode *dir, struct ceph_mds_request *req) argument 3691 ceph_mdsc_wait_request(struct ceph_mds_client *mdsc, struct ceph_mds_request *req, ceph_mds_request_wait_callback_t wait_func) argument 3747 ceph_mdsc_do_request(struct ceph_mds_client *mdsc, struct inode *dir, struct ceph_mds_request *req) argument 3795 struct ceph_mds_client *mdsc = session->s_mdsc; local 4005 handle_forward(struct ceph_mds_client *mdsc, struct ceph_mds_session *session, struct ceph_msg *msg) argument 4108 struct ceph_mds_client *mdsc = session->s_mdsc; local 4323 replay_unsafe_requests(struct ceph_mds_client *mdsc, struct ceph_mds_session *session) argument 4473 struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(inode->i_sb); local 4662 encode_snap_realms(struct ceph_mds_client *mdsc, struct ceph_reconnect_state *recon_state) argument 4733 send_mds_reconnect(struct ceph_mds_client *mdsc, struct ceph_mds_session *session) argument 4908 check_new_map(struct ceph_mds_client *mdsc, struct ceph_mdsmap *newmap, struct ceph_mdsmap *oldmap) argument 5082 handle_lease(struct ceph_mds_client *mdsc, struct ceph_mds_session *session, struct ceph_msg *msg) argument 5234 maybe_recover_session(struct ceph_mds_client *mdsc) argument 5302 schedule_delayed(struct ceph_mds_client *mdsc, unsigned long delay) argument 5315 struct ceph_mds_client *mdsc = local 5374 struct ceph_mds_client *mdsc; local 5451 wait_requests(struct ceph_mds_client *mdsc) argument 5506 ceph_mdsc_pre_umount(struct ceph_mds_client *mdsc) argument 5529 flush_mdlog_and_wait_mdsc_unsafe_requests(struct ceph_mds_client *mdsc, u64 want_tid) argument 5594 ceph_mdsc_sync(struct ceph_mds_client *mdsc) argument 5627 done_closing_sessions(struct ceph_mds_client *mdsc, int skipped) argument 5637 ceph_mdsc_close_sessions(struct ceph_mds_client *mdsc) argument 5695 ceph_mdsc_force_umount(struct ceph_mds_client *mdsc) argument 5729 ceph_mdsc_stop(struct ceph_mds_client *mdsc) argument 5751 struct ceph_mds_client *mdsc = fsc->mdsc; local 5769 ceph_mdsc_handle_fsmap(struct ceph_mds_client *mdsc, struct ceph_msg *msg) argument 5843 ceph_mdsc_handle_mdsmap(struct ceph_mds_client *mdsc, struct ceph_msg *msg) argument 5929 struct ceph_mds_client *mdsc = s->s_mdsc; local 5941 struct ceph_mds_client *mdsc = s->s_mdsc; local 6001 struct ceph_mds_client *mdsc = s->s_mdsc; local 6018 struct ceph_mds_client *mdsc = s->s_mdsc; local 6028 struct ceph_mds_client *mdsc = s->s_mdsc; local 6040 struct ceph_mds_client *mdsc = s->s_mdsc; local [all...] |
H A D | caps.c | 47 static u64 __get_oldest_flush_tid(struct ceph_mds_client *mdsc); 48 static void __kick_flushing_caps(struct ceph_mds_client *mdsc, 129 void ceph_caps_init(struct ceph_mds_client *mdsc) argument 131 INIT_LIST_HEAD(&mdsc->caps_list); 132 spin_lock_init(&mdsc->caps_list_lock); 135 void ceph_caps_finalize(struct ceph_mds_client *mdsc) argument 139 spin_lock(&mdsc->caps_list_lock); 140 while (!list_empty(&mdsc->caps_list)) { 141 cap = list_first_entry(&mdsc->caps_list, 146 mdsc 154 ceph_adjust_caps_max_min(struct ceph_mds_client *mdsc, struct ceph_mount_options *fsopt) argument 168 __ceph_unreserve_caps(struct ceph_mds_client *mdsc, int nr_caps) argument 202 ceph_reserve_caps(struct ceph_mds_client *mdsc, struct ceph_cap_reservation *ctx, int need) argument 308 ceph_unreserve_caps(struct ceph_mds_client *mdsc, struct ceph_cap_reservation *ctx) argument 330 ceph_get_cap(struct ceph_mds_client *mdsc, struct ceph_cap_reservation *ctx) argument 386 ceph_put_cap(struct ceph_mds_client *mdsc, struct ceph_cap *cap) argument 417 struct ceph_mds_client *mdsc = fsc->mdsc; local 496 __cap_set_timeouts(struct ceph_mds_client *mdsc, struct ceph_inode_info *ci) argument 516 __cap_delay_requeue(struct ceph_mds_client *mdsc, struct ceph_inode_info *ci) argument 543 __cap_delay_requeue_front(struct ceph_mds_client *mdsc, struct ceph_inode_info *ci) argument 562 __cap_delay_cancel(struct ceph_mds_client *mdsc, struct ceph_inode_info *ci) argument 655 struct ceph_mds_client *mdsc = ceph_inode_to_fs_client(inode)->mdsc; local 1140 struct ceph_mds_client *mdsc; local 1210 ceph_remove_cap(struct ceph_mds_client *mdsc, struct ceph_cap *cap, bool queue_release) argument 1260 struct ceph_mds_client *mdsc = arg->session->s_mdsc; local 1380 struct ceph_mds_client *mdsc = ceph_inode_to_fs_client(inode)->mdsc; local 1635 struct ceph_mds_client *mdsc = session->s_mdsc; variable in typeref:struct:ceph_mds_client 1733 struct ceph_mds_client *mdsc = ceph_inode_to_fs_client(inode)->mdsc; local 1798 struct ceph_mds_client *mdsc = local 1870 __get_oldest_flush_tid(struct ceph_mds_client *mdsc) argument 1885 __detach_cap_flush_from_mdsc(struct ceph_mds_client *mdsc, struct ceph_cap_flush *cf) argument 1925 struct ceph_mds_client *mdsc = ceph_sb_to_fs_client(inode->i_sb)->mdsc; local 2023 struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(inode->i_sb); local 2288 struct ceph_mds_client *mdsc = ceph_sb_to_fs_client(inode->i_sb)->mdsc; local 2366 struct ceph_mds_client *mdsc = ceph_sb_to_fs_client(inode->i_sb)->mdsc; local 2554 struct ceph_mds_client *mdsc = local 2648 ceph_early_kick_flushing_caps(struct ceph_mds_client *mdsc, struct ceph_mds_session *session) argument 2700 ceph_kick_flushing_caps(struct ceph_mds_client *mdsc, struct ceph_mds_session *session) argument 2739 struct ceph_mds_client *mdsc = session->s_mdsc; local 2822 struct ceph_mds_client *mdsc = ceph_inode_to_fs_client(inode)->mdsc; local 3070 struct ceph_mds_client *mdsc = fsc->mdsc; local 3811 struct ceph_mds_client *mdsc = ceph_sb_to_fs_client(inode->i_sb)->mdsc; variable in typeref:struct:ceph_mds_client 3921 struct ceph_mds_client *mdsc = ceph_sb_to_fs_client(inode->i_sb)->mdsc; local 3967 struct ceph_mds_client *mdsc = ceph_sb_to_fs_client(inode->i_sb)->mdsc; local 4062 struct ceph_mds_client *mdsc = ceph_inode_to_fs_client(inode)->mdsc; local 4193 handle_cap_import(struct ceph_mds_client *mdsc, struct inode *inode, struct ceph_mds_caps *im, struct ceph_mds_cap_peer *ph, struct ceph_mds_session *session, struct ceph_cap **target_cap, int *old_issued) argument 4323 struct ceph_mds_client *mdsc = session->s_mdsc; local 4602 ceph_check_delayed_caps(struct ceph_mds_client *mdsc) argument 4657 struct ceph_mds_client *mdsc = s->s_mdsc; local 4680 ceph_flush_dirty_caps(struct ceph_mds_client *mdsc) argument 4685 __ceph_touch_fmode(struct ceph_inode_info *ci, struct ceph_mds_client *mdsc, int fmode) argument 4702 struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(ci->netfs.inode.i_sb); local 4736 struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(ci->netfs.inode.i_sb); local 4781 struct ceph_mds_client *mdsc = local 4957 remove_capsnaps(struct ceph_mds_client *mdsc, struct inode *inode) argument 4985 struct ceph_mds_client *mdsc = fsc->mdsc; local [all...] |
H A D | ioctl.c | 38 static long __validate_layout(struct ceph_mds_client *mdsc, argument 51 mutex_lock(&mdsc->mutex); 53 for (i = 0; i < mdsc->mdsmap->m_num_data_pg_pools; i++) 54 if (mdsc->mdsmap->m_data_pg_pools[i] == l->data_pool) { 58 mutex_unlock(&mdsc->mutex); 68 struct ceph_mds_client *mdsc = ceph_sb_to_fs_client(inode->i_sb)->mdsc; local 104 err = __validate_layout(mdsc, &nl); 108 req = ceph_mdsc_create_request(mdsc, CEPH_MDS_OP_SETLAYOUT, 126 err = ceph_mdsc_do_request(mdsc, NUL 143 struct ceph_mds_client *mdsc = ceph_sb_to_fs_client(inode->i_sb)->mdsc; local 247 struct ceph_mds_client *mdsc = ceph_inode_to_fs_client(inode)->mdsc; local 278 struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(file_inode(file)->i_sb); local [all...] |
H A D | debugfs.c | 31 if (!fsc->mdsc || !fsc->mdsc->mdsmap) 33 mdsmap = fsc->mdsc->mdsmap; 50 * mdsc debugfs 55 struct ceph_mds_client *mdsc = fsc->mdsc; local 62 mutex_lock(&mdsc->mutex); 63 for (rp = rb_first(&mdsc->request_tree); rp; rp = rb_next(rp)) { 84 path = ceph_mdsc_build_path(mdsc, req->r_dentry, &pathlen, 103 path = ceph_mdsc_build_path(mdsc, re 271 struct ceph_mds_client *mdsc = fsc->mdsc; local 319 struct ceph_mds_client *mdsc = fsc->mdsc; local 366 DEFINE_SHOW_ATTRIBUTE(mdsc); variable [all...] |
H A D | mds_client.h | 61 * mdsc->mutex 63 * mdsc->snap_rwsem 66 * mdsc->snap_flush_lock 67 * mdsc->cap_delay_lock 251 typedef void (*ceph_mds_request_callback_t) (struct ceph_mds_client *mdsc, 256 typedef int (*ceph_mds_request_wait_callback_t) (struct ceph_mds_client *mdsc, 533 extern int ceph_send_msg_mds(struct ceph_mds_client *mdsc, 537 extern void ceph_mdsc_close_sessions(struct ceph_mds_client *mdsc); 538 extern void ceph_mdsc_force_umount(struct ceph_mds_client *mdsc); 541 extern void ceph_mdsc_sync(struct ceph_mds_client *mdsc); [all...] |
H A D | metric.c | 17 static bool ceph_mdsc_send_metrics(struct ceph_mds_client *mdsc, argument 31 struct ceph_client_metric *m = &mdsc->metric; 34 struct ceph_client *cl = mdsc->fsc->client; 41 mutex_lock(&mdsc->mutex); 42 if (ceph_mdsmap_get_state(mdsc->mdsmap, s->s_mds) != CEPH_MDS_STATE_ACTIVE) { 43 mutex_unlock(&mdsc->mutex); 46 mutex_unlock(&mdsc->mutex); 186 static void metric_get_session(struct ceph_mds_client *mdsc) argument 191 mutex_lock(&mdsc->mutex); 192 for (i = 0; i < mdsc 217 struct ceph_mds_client *mdsc = local [all...] |
H A D | dir.c | 42 struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(dentry->d_sb); local 54 atomic64_inc(&mdsc->metric.total_dentries); 322 struct ceph_mds_client *mdsc = fsc->mdsc; local 365 __ceph_touch_fmode(ci, mdsc, CEPH_FILE_MODE_WR); 408 req = ceph_mdsc_create_request(mdsc, op, USE_AUTH_MDS); 456 err = ceph_mdsc_do_request(mdsc, NULL, req); 800 struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(dir->i_sb); local 840 __ceph_touch_fmode(ci, mdsc, CEPH_FILE_MODE_RD); 853 req = ceph_mdsc_create_request(mdsc, o 915 struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(dir->i_sb); local 1025 struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(dir->i_sb); local 1099 struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(dir->i_sb); local 1183 struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(dir->i_sb); local 1236 ceph_async_unlink_cb(struct ceph_mds_client *mdsc, struct ceph_mds_request *req) argument 1335 struct ceph_mds_client *mdsc = fsc->mdsc; local 1428 struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(old_dir->i_sb); local 1506 struct ceph_mds_client *mdsc = ceph_sb_to_fs_client(dn->d_sb)->mdsc; local 1522 __dentry_dir_lease_touch(struct ceph_mds_client* mdsc, struct ceph_dentry_info *di) argument 1540 struct ceph_mds_client *mdsc = ceph_sb_to_fs_client(dn->d_sb)->mdsc; local 1570 struct ceph_mds_client *mdsc; local 1600 __dentry_leases_walk(struct ceph_mds_client *mdsc, struct ceph_lease_walk_control *lwc) argument 1729 ceph_trim_dentries(struct ceph_mds_client *mdsc) argument 1808 struct ceph_mds_client *mdsc = ceph_sb_to_fs_client(dentry->d_sb)->mdsc; local 1881 dir_lease_is_valid(struct inode *dir, struct dentry *dentry, struct ceph_mds_client *mdsc) argument 1918 struct ceph_mds_client *mdsc = ceph_sb_to_fs_client(dentry->d_sb)->mdsc; local 2074 struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(dentry->d_sb); local [all...] |
H A D | super.c | 51 ceph_mdsc_close_sessions(fsc->mdsc); 64 if (fsc->mdsc->mdsmap->m_num_data_pg_pools == 1) { 65 data_pool = fsc->mdsc->mdsmap->m_data_pg_pools[0]; 128 ceph_flush_dirty_caps(fsc->mdsc); 135 ceph_mdsc_sync(fsc->mdsc); 791 ceph_mdsc_handle_mdsmap(fsc->mdsc, msg); 794 ceph_mdsc_handle_fsmap(fsc->mdsc, msg); 1011 ceph_mdsc_force_umount(fsc->mdsc); 1052 struct ceph_mds_client *mdsc = fsc->mdsc; local 1478 __inc_stopping_blocker(struct ceph_mds_client *mdsc) argument 1490 __dec_stopping_blocker(struct ceph_mds_client *mdsc) argument 1500 ceph_inc_mds_stopping_blocker(struct ceph_mds_client *mdsc, struct ceph_mds_session *session) argument 1510 ceph_dec_mds_stopping_blocker(struct ceph_mds_client *mdsc) argument 1516 ceph_inc_osd_stopping_blocker(struct ceph_mds_client *mdsc) argument 1521 ceph_dec_osd_stopping_blocker(struct ceph_mds_client *mdsc) argument 1530 struct ceph_mds_client *mdsc = fsc->mdsc; local [all...] |
H A D | export.c | 128 struct ceph_mds_client *mdsc = ceph_sb_to_fs_client(sb)->mdsc; local 144 req = ceph_mdsc_create_request(mdsc, CEPH_MDS_OP_LOOKUPINO, 156 err = ceph_mdsc_do_request(mdsc, NULL, req); 210 struct ceph_mds_client *mdsc = ceph_sb_to_fs_client(sb)->mdsc; local 211 struct ceph_client *cl = mdsc->fsc->client; 244 req = ceph_mdsc_create_request(mdsc, CEPH_MDS_OP_LOOKUPINO, 265 err = ceph_mdsc_do_request(mdsc, NULL, req); 321 struct ceph_mds_client *mdsc local 540 struct ceph_mds_client *mdsc; local [all...] |
H A D | super.h | 137 struct ceph_mds_client *mdsc; member in struct:ceph_fs_client 390 * is protected by the mdsc->cap_dirty_lock, but each individual item 392 * requires the mdsc->cap_dirty_lock. List presence for an item can 506 return (struct ceph_mds_client *)ceph_sb_to_fs_client(sb)->mdsc; 811 extern void ceph_caps_init(struct ceph_mds_client *mdsc); 812 extern void ceph_caps_finalize(struct ceph_mds_client *mdsc); 813 extern void ceph_adjust_caps_max_min(struct ceph_mds_client *mdsc, 815 extern int ceph_reserve_caps(struct ceph_mds_client *mdsc, 817 extern void ceph_unreserve_caps(struct ceph_mds_client *mdsc, 985 struct ceph_snap_realm *ceph_lookup_snap_realm(struct ceph_mds_client *mdsc, [all...] |
H A D | locks.c | 14 static int ceph_lock_wait_for_completion(struct ceph_mds_client *mdsc, 79 struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(inode->i_sb); local 80 struct ceph_client *cl = mdsc->fsc->client; 100 req = ceph_mdsc_create_request(mdsc, operation, USE_AUTH_MDS); 129 err = ceph_mdsc_submit_request(mdsc, inode, req); 131 err = ceph_mdsc_wait_request(mdsc, req, wait ? 159 static int ceph_lock_wait_for_completion(struct ceph_mds_client *mdsc, argument 162 struct ceph_client *cl = mdsc->fsc->client; 182 mutex_lock(&mdsc->mutex); 201 mutex_unlock(&mdsc [all...] |
H A D | mdsmap.h | 74 struct ceph_mdsmap *ceph_mdsmap_decode(struct ceph_mds_client *mdsc, void **p,
|
H A D | addr.c | 234 ceph_update_read_metrics(&fsc->mdsc->metric, req->r_start_latency, 268 ceph_dec_osd_stopping_blocker(fsc->mdsc); 278 struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(inode->i_sb); local 293 req = ceph_mdsc_create_request(mdsc, CEPH_MDS_OP_GETATTR, mode); 302 err = ceph_mdsc_do_request(mdsc, NULL, req); 402 if (!ceph_inc_osd_stopping_blocker(fsc->mdsc)) { 747 ceph_update_write_metrics(&fsc->mdsc->metric, req->r_start_latency, 905 ceph_update_write_metrics(&fsc->mdsc->metric, req->r_start_latency, 916 ceph_dec_osd_stopping_blocker(fsc->mdsc); 1227 if (!ceph_inc_osd_stopping_blocker(fsc->mdsc)) { 1991 struct ceph_mds_client *mdsc = fsc->mdsc; local 2228 ceph_pool_perm_destroy(struct ceph_mds_client *mdsc) argument [all...] |
H A D | inode.c | 48 struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(inode->i_sb); local 53 percpu_counter_inc(&mdsc->metric.total_inodes); 134 struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(sb); local 135 struct ceph_client *cl = mdsc->fsc->client; 689 struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(inode->i_sb); local 696 percpu_counter_dec(&mdsc->metric.total_inodes); 721 ceph_put_snapid_map(mdsc, ci->i_snapid_map); 901 static int decode_encrypted_symlink(struct ceph_mds_client *mdsc, argument 905 struct ceph_client *cl = mdsc->fsc->client; 926 static int decode_encrypted_symlink(struct ceph_mds_client *mdsc, argument 944 struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(inode->i_sb); local 2471 struct ceph_mds_client *mdsc = ceph_sb_to_fs_client(inode->i_sb)->mdsc; local 2873 struct ceph_mds_client *mdsc = fsc->mdsc; local 2921 struct ceph_mds_client *mdsc = fsc->mdsc; local [all...] |
H A D | file.c | 23 static __le32 ceph_flags_sys2wire(struct ceph_mds_client *mdsc, u32 flags) argument 25 struct ceph_client *cl = mdsc->fsc->client; 182 struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(sb); local 190 req = ceph_mdsc_create_request(mdsc, op, want_auth); 194 req->r_args.open.flags = ceph_flags_sys2wire(mdsc, flags); 302 struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(inode->i_sb); local 303 struct ceph_client *cl = mdsc->fsc->client; 309 __ceph_touch_fmode(ci, mdsc, fmode); 345 err = ceph_mdsc_do_request(mdsc, NULL, req); 364 struct ceph_mds_client *mdsc local 567 ceph_async_create_cb(struct ceph_mds_client *mdsc, struct ceph_mds_request *req) argument 640 struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(dir->i_sb); local 754 struct ceph_mds_client *mdsc = fsc->mdsc; local [all...] |
H A D | xattr.c | 1115 struct ceph_mds_client *mdsc = fsc->mdsc; local 1140 req = ceph_mdsc_create_request(mdsc, op, USE_AUTH_MDS); 1167 err = ceph_mdsc_do_request(mdsc, NULL, req); 1183 struct ceph_mds_client *mdsc = ceph_sb_to_fs_client(inode->i_sb)->mdsc; local 1238 (required_blob_size > mdsc->mdsmap->m_max_xattr_size)) { 1241 mdsc->mdsmap->m_max_xattr_size); 1247 if (!down_read_trylock(&mdsc->snap_rwsem)) { 1249 down_read(&mdsc [all...] |
H A D | mdsmap.c | 118 struct ceph_mdsmap *ceph_mdsmap_decode(struct ceph_mds_client *mdsc, void **p, argument 121 struct ceph_client *cl = mdsc->fsc->client;
|