| /fs/ceph/ |
| D | mds_client.c | 407 int mds) in __ceph_lookup_mds_session() argument
411 if (mds >= mdsc->max_sessions || !mdsc->sessions[mds]) in __ceph_lookup_mds_session()
413 session = mdsc->sessions[mds]; in __ceph_lookup_mds_session()
420 static bool __have_session(struct ceph_mds_client *mdsc, int mds) in __have_session() argument
422 if (mds >= mdsc->max_sessions) in __have_session()
424 return mdsc->sessions[mds]; in __have_session()
441 int mds) in register_session() argument
445 if (mds >= mdsc->mdsmap->m_num_mds) in register_session()
452 s->s_mds = mds; in register_session()
479 dout("register_session mds%d\n", mds); in register_session()
[all …]
|
| D | mdsmap.c | 150 s32 mds, inc, state; in ceph_mdsmap_decode() local
183 mds = ceph_decode_32(p); in ceph_mdsmap_decode()
208 i+1, n, global_id, mds, inc, in ceph_mdsmap_decode()
212 if (mds < 0 || state <= 0) in ceph_mdsmap_decode()
215 if (mds >= m->m_num_mds) { in ceph_mdsmap_decode()
216 int new_num = max(mds + 1, m->m_num_mds * 2); in ceph_mdsmap_decode()
226 info = &m->m_info[mds]; in ceph_mdsmap_decode()
293 s32 mds = ceph_decode_32(p); in ceph_mdsmap_decode() local
294 if (mds >= 0 && mds < m->m_num_mds) { in ceph_mdsmap_decode()
295 if (m->m_info[mds].laggy) in ceph_mdsmap_decode()
|
| D | caps.c | 316 static struct ceph_cap *__get_cap_for_mds(struct ceph_inode_info *ci, int mds) in __get_cap_for_mds() argument
323 if (mds < cap->mds) in __get_cap_for_mds()
325 else if (mds > cap->mds) in __get_cap_for_mds()
333 struct ceph_cap *ceph_get_cap_for_mds(struct ceph_inode_info *ci, int mds) in ceph_get_cap_for_mds() argument
338 cap = __get_cap_for_mds(ci, mds); in ceph_get_cap_for_mds()
349 int mds = -1; in __ceph_get_cap_mds() local
355 mds = cap->mds; in __ceph_get_cap_mds()
361 return mds; in __ceph_get_cap_mds()
367 int mds; in ceph_get_cap_mds() local
369 mds = __ceph_get_cap_mds(ceph_inode(inode)); in ceph_get_cap_mds()
[all …]
|
| D | debugfs.c | 165 int mds = -1; in mds_sessions_show() local
176 for (mds = 0; mds < mdsc->max_sessions; mds++) { in mds_sessions_show()
178 __ceph_lookup_mds_session(mdsc, mds); in mds_sessions_show()
|
| D | super.h | 146 int mds, mds_wanted; member
232 int mds; /* -1 if same authority as parent */ member
932 int mds);
947 int mds, int drop, int unless, int force);
950 int mds, int drop, int unless);
|
| D | mds_client.h | 380 __ceph_lookup_mds_session(struct ceph_mds_client *, int mds);
394 struct ceph_msg *msg, int mds);
|
| D | inode.c | 142 frag->mds = -1; in __get_or_create_frag()
242 int mds = le32_to_cpu(dirinfo->auth); in ceph_fill_dirfrag() local
250 diri_auth = ci->i_auth_cap->mds; in ceph_fill_dirfrag()
253 if (mds == -1) /* CDIR_AUTH_PARENT */ in ceph_fill_dirfrag()
254 mds = diri_auth; in ceph_fill_dirfrag()
257 if (ndist == 0 && mds == diri_auth) { in ceph_fill_dirfrag()
272 frag->mds = -1; in ceph_fill_dirfrag()
290 frag->mds = mds; in ceph_fill_dirfrag()
|
| D | snap.c | 836 int mds = session->s_mds; in ceph_handle_snap() local
861 dout("handle_snap from mds%d op %s split %llx tracelen %d\n", mds, in ceph_handle_snap()
983 pr_err("corrupt snap message from mds%d\n", mds); in ceph_handle_snap()
|
| /fs/nfs/ |
| D | write.c | 835 list_for_each_entry_safe(freq, t, &cinfo.mds->list, wb_list) { in nfs_page_search_commits_for_head_request_locked()
862 atomic_long_inc(&cinfo->mds->ncommit); in nfs_request_add_commit_list_locked()
883 nfs_request_add_commit_list_locked(req, &cinfo->mds->list, cinfo); in nfs_request_add_commit_list()
908 atomic_long_dec(&cinfo->mds->ncommit); in nfs_request_remove_commit_list()
916 cinfo->mds = &NFS_I(inode)->commit_info; in nfs_init_cinfo_from_inode()
1022 return atomic_long_read(&cinfo->mds->ncommit); in nfs_reqs_to_commit()
1080 if (!atomic_long_read(&cinfo->mds->ncommit)) in nfs_scan_commit()
1083 if (atomic_long_read(&cinfo->mds->ncommit) > 0) { in nfs_scan_commit()
1086 ret = nfs_scan_commit_list(&cinfo->mds->list, dst, in nfs_scan_commit()
1788 atomic_inc(&cinfo->mds->rpcs_out); in nfs_commit_list()
[all …]
|
| D | pnfs_nfs.c | 244 if (atomic_dec_and_test(&cinfo->mds->rpcs_out)) in pnfs_generic_commit_cancel_empty_pagelist()
245 wake_up_atomic_t(&cinfo->mds->rpcs_out); in pnfs_generic_commit_cancel_empty_pagelist()
280 atomic_add(nreq, &cinfo->mds->rpcs_out); in pnfs_generic_commit_pagelist()
|
| D | direct.c | 306 cinfo->mds = &dreq->mds_cinfo; in nfs_init_cinfo_from_dreq()
646 nfs_scan_commit_list(&cinfo->mds->list, list, cinfo, 0); in nfs_direct_write_scan_commit_list()
731 if (atomic_dec_and_test(&cinfo.mds->rpcs_out)) in nfs_direct_commit_complete()
|