Searched refs:mdsc (Results 1 - 19 of 19) sorted by relevance

/linux-master/fs/ceph/
H A Dquota.c15 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 Dsnap.c66 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 Dmds_client.c63 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 Dcaps.c47 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 Dioctl.c38 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 Ddebugfs.c31 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 Dmds_client.h61 * 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 Dmetric.c17 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 Ddir.c42 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 Dsuper.c51 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 Dexport.c128 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 Dsuper.h137 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 Dlocks.c14 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 Dmdsmap.h74 struct ceph_mdsmap *ceph_mdsmap_decode(struct ceph_mds_client *mdsc, void **p,
H A Daddr.c234 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 Dinode.c48 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 Dfile.c23 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 Dxattr.c1115 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 Dmdsmap.c118 struct ceph_mdsmap *ceph_mdsmap_decode(struct ceph_mds_client *mdsc, void **p, argument
121 struct ceph_client *cl = mdsc->fsc->client;

Completed in 295 milliseconds