Home
last modified time | relevance | path

Searched refs:mds (Results 1 – 10 of 10) sorted by relevance

/fs/ceph/
Dmdsmap.c48 int mds; in ceph_mdsmap_get_random_mds() local
50 mds = __mdsmap_get_random_mds(m, false); in ceph_mdsmap_get_random_mds()
51 if (mds == m->possible_max_rank || mds == -1) in ceph_mdsmap_get_random_mds()
52 mds = __mdsmap_get_random_mds(m, true); in ceph_mdsmap_get_random_mds()
54 return mds == m->possible_max_rank ? -1 : mds; in ceph_mdsmap_get_random_mds()
176 s32 mds, inc, state; in ceph_mdsmap_decode() local
208 mds = ceph_decode_32(p); in ceph_mdsmap_decode()
235 i+1, n, global_id, mds, inc, in ceph_mdsmap_decode()
240 if (mds < 0 || mds >= m->possible_max_rank) { in ceph_mdsmap_decode()
241 pr_warn("mdsmap_decode got incorrect mds(%d)\n", mds); in ceph_mdsmap_decode()
[all …]
Dmds_client.c682 int mds) in __ceph_lookup_mds_session() argument
684 if (mds >= mdsc->max_sessions || !mdsc->sessions[mds]) in __ceph_lookup_mds_session()
686 return ceph_get_mds_session(mdsc->sessions[mds]); in __ceph_lookup_mds_session()
689 static bool __have_session(struct ceph_mds_client *mdsc, int mds) in __have_session() argument
691 if (mds >= mdsc->max_sessions || !mdsc->sessions[mds]) in __have_session()
711 int mds) in register_session() argument
715 if (mds >= mdsc->mdsmap->possible_max_rank) in register_session()
722 if (mds >= mdsc->max_sessions) { in register_session()
723 int newmax = 1 << get_count_order(mds + 1); in register_session()
739 dout("%s: mds%d\n", __func__, mds); in register_session()
[all …]
Dcaps.c433 static struct ceph_cap *__get_cap_for_mds(struct ceph_inode_info *ci, int mds) in __get_cap_for_mds() argument
440 if (mds < cap->mds) in __get_cap_for_mds()
442 else if (mds > cap->mds) in __get_cap_for_mds()
450 struct ceph_cap *ceph_get_cap_for_mds(struct ceph_inode_info *ci, int mds) in ceph_get_cap_for_mds() argument
455 cap = __get_cap_for_mds(ci, mds); in ceph_get_cap_for_mds()
473 if (new->mds < cap->mds) in __insert_cap_node()
475 else if (new->mds > cap->mds) in __insert_cap_node()
639 int mds = session->s_mds; in ceph_add_cap() local
652 cap = __get_cap_for_mds(ci, mds); in ceph_add_cap()
659 cap->mds = mds; in ceph_add_cap()
[all …]
Ddebugfs.c277 int mds; in mds_sessions_show() local
288 for (mds = 0; mds < mdsc->max_sessions; mds++) { in mds_sessions_show()
290 __ceph_lookup_mds_session(mdsc, mds); in mds_sessions_show()
Dsuper.h163 int mds; /* mds index for this cap */ member
252 int mds; /* -1 if same authority as parent */ member
1124 int mds);
1148 int mds, int drop, int unless, int force);
1151 int mds, int drop, int unless);
Dmds_client.h485 __ceph_lookup_mds_session(struct ceph_mds_client *, int mds);
494 struct ceph_msg *msg, int mds);
Dinode.c154 frag->mds = -1; in __get_or_create_frag()
254 int mds = le32_to_cpu(dirinfo->auth); in ceph_fill_dirfrag() local
262 diri_auth = ci->i_auth_cap->mds; in ceph_fill_dirfrag()
265 if (mds == -1) /* CDIR_AUTH_PARENT */ in ceph_fill_dirfrag()
266 mds = diri_auth; in ceph_fill_dirfrag()
269 if (ndist == 0 && mds == diri_auth) { in ceph_fill_dirfrag()
284 frag->mds = -1; in ceph_fill_dirfrag()
302 frag->mds = mds; in ceph_fill_dirfrag()
Dsnap.c879 int mds = session->s_mds; in ceph_handle_snap() local
904 dout("handle_snap from mds%d op %s split %llx tracelen %d\n", mds, in ceph_handle_snap()
1047 pr_err("corrupt snap message from mds%d\n", mds); in ceph_handle_snap()
/fs/nfs/
Dwrite.c832 list_for_each_entry_safe(freq, t, &cinfo.mds->list, wb_list) { in nfs_page_search_commits_for_head_request_locked()
859 atomic_long_inc(&cinfo->mds->ncommit); in nfs_request_add_commit_list_locked()
879 nfs_request_add_commit_list_locked(req, &cinfo->mds->list, cinfo); in nfs_request_add_commit_list()
904 atomic_long_dec(&cinfo->mds->ncommit); in nfs_request_remove_commit_list()
912 cinfo->mds = &NFS_I(inode)->commit_info; in nfs_init_cinfo_from_inode()
1019 return atomic_long_read(&cinfo->mds->ncommit); in nfs_reqs_to_commit()
1063 if (!atomic_long_read(&cinfo->mds->ncommit)) in nfs_scan_commit()
1066 if (atomic_long_read(&cinfo->mds->ncommit) > 0) { in nfs_scan_commit()
1069 ret = nfs_scan_commit_list(&cinfo->mds->list, dst, in nfs_scan_commit()
1751 nfs_commit_begin(cinfo->mds); in nfs_init_commit()
[all …]
Ddirect.c190 cinfo->mds = &dreq->mds_cinfo; in nfs_init_cinfo_from_dreq()
563 nfs_scan_commit_list(&cinfo->mds->list, list, cinfo, 0); in nfs_direct_write_scan_commit_list()
653 if (nfs_commit_end(cinfo.mds)) in nfs_direct_commit_complete()