Lines Matching refs:cap
134 struct ceph_cap *cap; in ceph_caps_finalize() local
138 cap = list_first_entry(&mdsc->caps_list, in ceph_caps_finalize()
140 list_del(&cap->caps_item); in ceph_caps_finalize()
141 kmem_cache_free(ceph_cap_cachep, cap); in ceph_caps_finalize()
161 struct ceph_cap *cap; in __ceph_unreserve_caps() local
171 cap = list_first_entry(&mdsc->caps_list, in __ceph_unreserve_caps()
173 list_del(&cap->caps_item); in __ceph_unreserve_caps()
174 kmem_cache_free(ceph_cap_cachep, cap); in __ceph_unreserve_caps()
197 struct ceph_cap *cap; in ceph_reserve_caps() local
222 cap = kmem_cache_alloc(ceph_cap_cachep, GFP_NOFS); in ceph_reserve_caps()
223 if (cap) { in ceph_reserve_caps()
224 list_add(&cap->caps_item, &newcaps); in ceph_reserve_caps()
310 struct ceph_cap *cap = NULL; in ceph_get_cap() local
314 cap = kmem_cache_alloc(ceph_cap_cachep, GFP_NOFS); in ceph_get_cap()
315 if (cap) { in ceph_get_cap()
327 cap = list_first_entry(&mdsc->caps_list, in ceph_get_cap()
329 list_del(&cap->caps_item); in ceph_get_cap()
337 return cap; in ceph_get_cap()
352 cap = list_first_entry(&mdsc->caps_list, struct ceph_cap, caps_item); in ceph_get_cap()
353 list_del(&cap->caps_item); in ceph_get_cap()
358 return cap; in ceph_get_cap()
361 void ceph_put_cap(struct ceph_mds_client *mdsc, struct ceph_cap *cap) in ceph_put_cap() argument
365 cap, mdsc->caps_total_count, mdsc->caps_use_count, in ceph_put_cap()
375 kmem_cache_free(ceph_cap_cachep, cap); in ceph_put_cap()
378 list_add(&cap->caps_item, &mdsc->caps_list); in ceph_put_cap()
415 struct ceph_cap *cap; in __get_cap_for_mds() local
419 cap = rb_entry(n, struct ceph_cap, ci_node); in __get_cap_for_mds()
420 if (mds < cap->mds) in __get_cap_for_mds()
422 else if (mds > cap->mds) in __get_cap_for_mds()
425 return cap; in __get_cap_for_mds()
432 struct ceph_cap *cap; in ceph_get_cap_for_mds() local
435 cap = __get_cap_for_mds(ci, mds); in ceph_get_cap_for_mds()
437 return cap; in ceph_get_cap_for_mds()
445 struct ceph_cap *cap; in __ceph_get_cap_mds() local
451 cap = rb_entry(p, struct ceph_cap, ci_node); in __ceph_get_cap_mds()
452 mds = cap->mds; in __ceph_get_cap_mds()
453 if (cap->issued & (CEPH_CAP_FILE_WR | in __ceph_get_cap_mds()
479 struct ceph_cap *cap = NULL; in __insert_cap_node() local
483 cap = rb_entry(parent, struct ceph_cap, ci_node); in __insert_cap_node()
484 if (new->mds < cap->mds) in __insert_cap_node()
486 else if (new->mds > cap->mds) in __insert_cap_node()
576 static void __check_cap_issue(struct ceph_inode_info *ci, struct ceph_cap *cap, in __check_cap_issue() argument
623 struct ceph_cap *cap; in ceph_add_cap() local
637 cap = __get_cap_for_mds(ci, mds); in ceph_add_cap()
638 if (!cap) { in ceph_add_cap()
639 cap = *new_cap; in ceph_add_cap()
642 cap->issued = 0; in ceph_add_cap()
643 cap->implemented = 0; in ceph_add_cap()
644 cap->mds = mds; in ceph_add_cap()
645 cap->mds_wanted = 0; in ceph_add_cap()
646 cap->mseq = 0; in ceph_add_cap()
648 cap->ci = ci; in ceph_add_cap()
649 __insert_cap_node(ci, cap); in ceph_add_cap()
652 cap->session = session; in ceph_add_cap()
654 list_add_tail(&cap->session_caps, &session->s_caps); in ceph_add_cap()
667 if (ceph_seq_cmp(seq, cap->seq) <= 0) { in ceph_add_cap()
668 WARN_ON(cap != ci->i_auth_cap); in ceph_add_cap()
669 WARN_ON(cap->cap_id != cap_id); in ceph_add_cap()
670 seq = cap->seq; in ceph_add_cap()
671 mseq = cap->mseq; in ceph_add_cap()
672 issued |= cap->issued; in ceph_add_cap()
710 __check_cap_issue(ci, cap, issued); in ceph_add_cap()
729 ci->i_auth_cap = cap; in ceph_add_cap()
730 cap->mds_wanted = wanted; in ceph_add_cap()
733 WARN_ON(ci->i_auth_cap == cap); in ceph_add_cap()
737 inode, ceph_vinop(inode), cap, ceph_cap_string(issued), in ceph_add_cap()
738 ceph_cap_string(issued|cap->issued), seq, mds); in ceph_add_cap()
739 cap->cap_id = cap_id; in ceph_add_cap()
740 cap->issued = issued; in ceph_add_cap()
741 cap->implemented |= issued; in ceph_add_cap()
742 if (ceph_seq_cmp(mseq, cap->mseq) > 0) in ceph_add_cap()
743 cap->mds_wanted = wanted; in ceph_add_cap()
745 cap->mds_wanted |= wanted; in ceph_add_cap()
746 cap->seq = seq; in ceph_add_cap()
747 cap->issue_seq = seq; in ceph_add_cap()
748 cap->mseq = mseq; in ceph_add_cap()
749 cap->cap_gen = session->s_cap_gen; in ceph_add_cap()
760 static int __cap_is_valid(struct ceph_cap *cap) in __cap_is_valid() argument
765 spin_lock(&cap->session->s_gen_ttl_lock); in __cap_is_valid()
766 gen = cap->session->s_cap_gen; in __cap_is_valid()
767 ttl = cap->session->s_cap_ttl; in __cap_is_valid()
768 spin_unlock(&cap->session->s_gen_ttl_lock); in __cap_is_valid()
770 if (cap->cap_gen < gen || time_after_eq(jiffies, ttl)) { in __cap_is_valid()
772 "but STALE (gen %u vs %u)\n", &cap->ci->vfs_inode, in __cap_is_valid()
773 cap, ceph_cap_string(cap->issued), cap->cap_gen, gen); in __cap_is_valid()
788 struct ceph_cap *cap; in __ceph_caps_issued() local
794 cap = rb_entry(p, struct ceph_cap, ci_node); in __ceph_caps_issued()
795 if (!__cap_is_valid(cap)) in __ceph_caps_issued()
798 &ci->vfs_inode, cap, ceph_cap_string(cap->issued)); in __ceph_caps_issued()
799 have |= cap->issued; in __ceph_caps_issued()
801 *implemented |= cap->implemented; in __ceph_caps_issued()
809 cap = ci->i_auth_cap; in __ceph_caps_issued()
810 have &= ~cap->implemented | cap->issued; in __ceph_caps_issued()
821 struct ceph_cap *cap; in __ceph_caps_issued_other() local
825 cap = rb_entry(p, struct ceph_cap, ci_node); in __ceph_caps_issued_other()
826 if (cap == ocap) in __ceph_caps_issued_other()
828 if (!__cap_is_valid(cap)) in __ceph_caps_issued_other()
830 have |= cap->issued; in __ceph_caps_issued_other()
839 static void __touch_cap(struct ceph_cap *cap) in __touch_cap() argument
841 struct ceph_mds_session *s = cap->session; in __touch_cap()
845 dout("__touch_cap %p cap %p mds%d\n", &cap->ci->vfs_inode, cap, in __touch_cap()
847 list_move_tail(&cap->session_caps, &s->s_caps); in __touch_cap()
850 &cap->ci->vfs_inode, cap, s->s_mds); in __touch_cap()
862 struct ceph_cap *cap; in __ceph_caps_issued_mask() local
875 cap = rb_entry(p, struct ceph_cap, ci_node); in __ceph_caps_issued_mask()
876 if (!__cap_is_valid(cap)) in __ceph_caps_issued_mask()
878 if ((cap->issued & mask) == mask) { in __ceph_caps_issued_mask()
880 " (mask %s)\n", &ci->vfs_inode, cap, in __ceph_caps_issued_mask()
881 ceph_cap_string(cap->issued), in __ceph_caps_issued_mask()
884 __touch_cap(cap); in __ceph_caps_issued_mask()
889 have |= cap->issued; in __ceph_caps_issued_mask()
893 ceph_cap_string(cap->issued), in __ceph_caps_issued_mask()
899 __touch_cap(cap); in __ceph_caps_issued_mask()
902 cap = rb_entry(q, struct ceph_cap, in __ceph_caps_issued_mask()
904 if (!__cap_is_valid(cap)) in __ceph_caps_issued_mask()
906 __touch_cap(cap); in __ceph_caps_issued_mask()
922 struct ceph_cap *cap; in __ceph_caps_revoking_other() local
926 cap = rb_entry(p, struct ceph_cap, ci_node); in __ceph_caps_revoking_other()
927 if (cap != ocap && in __ceph_caps_revoking_other()
928 (cap->implemented & ~cap->issued & mask)) in __ceph_caps_revoking_other()
985 struct ceph_cap *cap; in __ceph_caps_mds_wanted() local
990 cap = rb_entry(p, struct ceph_cap, ci_node); in __ceph_caps_mds_wanted()
991 if (check && !__cap_is_valid(cap)) in __ceph_caps_mds_wanted()
993 if (cap == ci->i_auth_cap) in __ceph_caps_mds_wanted()
994 mds_wanted |= cap->mds_wanted; in __ceph_caps_mds_wanted()
996 mds_wanted |= (cap->mds_wanted & ~CEPH_CAP_ANY_FILE_WR); in __ceph_caps_mds_wanted()
1044 void __ceph_remove_cap(struct ceph_cap *cap, bool queue_release) in __ceph_remove_cap() argument
1046 struct ceph_mds_session *session = cap->session; in __ceph_remove_cap()
1047 struct ceph_inode_info *ci = cap->ci; in __ceph_remove_cap()
1052 dout("__ceph_remove_cap %p from %p\n", cap, &ci->vfs_inode); in __ceph_remove_cap()
1056 if (session->s_cap_iterator == cap) { in __ceph_remove_cap()
1059 cap, cap->session); in __ceph_remove_cap()
1061 list_del_init(&cap->session_caps); in __ceph_remove_cap()
1063 cap->session = NULL; in __ceph_remove_cap()
1067 cap->ci = NULL; in __ceph_remove_cap()
1074 (!session->s_cap_reconnect || cap->cap_gen == session->s_cap_gen)) { in __ceph_remove_cap()
1075 cap->queue_release = 1; in __ceph_remove_cap()
1077 list_add_tail(&cap->session_caps, in __ceph_remove_cap()
1083 cap->queue_release = 0; in __ceph_remove_cap()
1085 cap->cap_ino = ci->i_vino.ino; in __ceph_remove_cap()
1090 rb_erase(&cap->ci_node, &ci->i_caps); in __ceph_remove_cap()
1091 if (ci->i_auth_cap == cap) in __ceph_remove_cap()
1095 ceph_put_cap(mdsc, cap); in __ceph_remove_cap()
1248 struct ceph_cap *cap = rb_entry(p, struct ceph_cap, ci_node); in ceph_queue_caps_release() local
1250 __ceph_remove_cap(cap, true); in ceph_queue_caps_release()
1271 static int __send_cap(struct ceph_mds_client *mdsc, struct ceph_cap *cap, in __send_cap() argument
1274 __releases(cap->ci->i_ceph_lock) in __send_cap()
1276 struct ceph_inode_info *ci = cap->ci; in __send_cap()
1284 held = cap->issued | cap->implemented; in __send_cap()
1285 revoking = cap->implemented & ~cap->issued; in __send_cap()
1289 inode, cap, cap->session, in __send_cap()
1294 arg.session = cap->session; in __send_cap()
1300 ceph_cap_string(cap->issued), in __send_cap()
1301 ceph_cap_string(cap->issued & retain), in __send_cap()
1302 ceph_cap_string(cap->mds_wanted), in __send_cap()
1304 want |= cap->mds_wanted; in __send_cap()
1305 retain |= cap->issued; in __send_cap()
1309 if (want & ~cap->mds_wanted) { in __send_cap()
1317 cap->issued &= retain; /* drop bits we don't want */ in __send_cap()
1318 if (cap->implemented & ~cap->issued) { in __send_cap()
1327 cap->implemented &= cap->issued | used; in __send_cap()
1328 cap->mds_wanted = want; in __send_cap()
1331 arg.cid = cap->cap_id; in __send_cap()
1354 arg.caps = cap->implemented; in __send_cap()
1358 arg.seq = cap->seq; in __send_cap()
1359 arg.issue_seq = cap->issue_seq; in __send_cap()
1360 arg.mseq = cap->mseq; in __send_cap()
1494 struct ceph_cap *cap = ci->i_auth_cap; in __ceph_flush_snaps() local
1498 if (!(cap && cap->session == session)) { in __ceph_flush_snaps()
1500 "stop\n", inode, cap, session->s_mds); in __ceph_flush_snaps()
1523 ret = __send_flush_snap(inode, session, capsnap, cap->mseq, in __ceph_flush_snaps()
1814 struct ceph_cap *cap; in ceph_check_caps() local
1912 cap = rb_entry(p, struct ceph_cap, ci_node); in ceph_check_caps()
1915 if (mds >= cap->mds || in ceph_check_caps()
1916 ((flags & CHECK_CAPS_AUTHONLY) && cap != ci->i_auth_cap)) in ceph_check_caps()
1922 if (ci->i_auth_cap && cap != ci->i_auth_cap) in ceph_check_caps()
1925 revoking = cap->implemented & ~cap->issued; in ceph_check_caps()
1927 cap->mds, cap, ceph_cap_string(cap_used), in ceph_check_caps()
1928 ceph_cap_string(cap->issued), in ceph_check_caps()
1929 ceph_cap_string(cap->implemented), in ceph_check_caps()
1932 if (cap == ci->i_auth_cap && in ceph_check_caps()
1933 (cap->issued & CEPH_CAP_FILE_WR)) { in ceph_check_caps()
1948 if (cap == ci->i_auth_cap) { in ceph_check_caps()
1962 ceph_cap_string(cap->implemented & ~cap->issued)); in ceph_check_caps()
1967 if (want & ~(cap->mds_wanted | cap->issued)) in ceph_check_caps()
1971 if ((cap->issued & ~retain) == 0 && in ceph_check_caps()
1972 cap->mds_wanted == want) in ceph_check_caps()
1982 ceph_cap_string(cap->issued), in ceph_check_caps()
1983 ceph_cap_string(cap->issued & retain), in ceph_check_caps()
1984 ceph_cap_string(cap->mds_wanted), in ceph_check_caps()
1996 if (session && session != cap->session) { in ceph_check_caps()
2002 session = cap->session; in ceph_check_caps()
2018 if (cap == ci->i_auth_cap && in ceph_check_caps()
2044 if (cap == ci->i_auth_cap && ci->i_dirty_caps) { in ceph_check_caps()
2056 mds = cap->mds; /* remember mds, so we don't repeat */ in ceph_check_caps()
2060 delayed += __send_cap(mdsc, cap, CEPH_CAP_OP_UPDATE, false, in ceph_check_caps()
2100 struct ceph_cap *cap = ci->i_auth_cap; in try_flush_caps() local
2105 if (!session || session != cap->session) { in try_flush_caps()
2109 session = cap->session; in try_flush_caps()
2113 if (cap->session->s_state < CEPH_MDS_SESSION_OPEN) { in try_flush_caps()
2122 delayed = __send_cap(mdsc, cap, CEPH_CAP_OP_FLUSH, true, in try_flush_caps()
2123 used, want, (cap->issued | cap->implemented), in try_flush_caps()
2292 struct ceph_cap *cap; in __kick_flushing_caps() local
2301 cap = ci->i_auth_cap; in __kick_flushing_caps()
2302 if (!(cap && cap->session == session)) { in __kick_flushing_caps()
2304 inode, cap, session->s_mds); in __kick_flushing_caps()
2312 inode, cap, cf->tid, ceph_cap_string(cf->caps)); in __kick_flushing_caps()
2314 ret = __send_cap(mdsc, cap, CEPH_CAP_OP_FLUSH, in __kick_flushing_caps()
2317 cap->issued | cap->implemented, in __kick_flushing_caps()
2337 ret = __send_flush_snap(inode, session, capsnap, cap->mseq, in __kick_flushing_caps()
2358 struct ceph_cap *cap; in ceph_early_kick_flushing_caps() local
2369 cap = ci->i_auth_cap; in ceph_early_kick_flushing_caps()
2370 if (!(cap && cap->session == session)) { in ceph_early_kick_flushing_caps()
2372 &ci->vfs_inode, cap, session->s_mds); in ceph_early_kick_flushing_caps()
2384 if ((cap->issued & ci->i_flushing_caps) != in ceph_early_kick_flushing_caps()
2401 struct ceph_cap *cap; in ceph_kick_flushing_caps() local
2412 cap = ci->i_auth_cap; in ceph_kick_flushing_caps()
2413 if (!(cap && cap->session == session)) { in ceph_kick_flushing_caps()
2415 &ci->vfs_inode, cap, session->s_mds); in ceph_kick_flushing_caps()
2434 struct ceph_cap *cap; in kick_flushing_inode_caps() local
2436 cap = ci->i_auth_cap; in kick_flushing_inode_caps()
2444 &cap->session->s_cap_flushing); in kick_flushing_inode_caps()
3035 struct ceph_cap *cap, in handle_cap_grant() argument
3057 inode, cap, session->s_mds, seq, ceph_cap_string(newcaps)); in handle_cap_grant()
3070 if (ceph_seq_cmp(seq, cap->seq) <= 0) { in handle_cap_grant()
3071 WARN_ON(cap != ci->i_auth_cap); in handle_cap_grant()
3072 WARN_ON(cap->cap_id != le64_to_cpu(grant->cap_id)); in handle_cap_grant()
3073 seq = cap->seq; in handle_cap_grant()
3074 newcaps |= cap->issued; in handle_cap_grant()
3083 ((cap->issued & ~newcaps) & CEPH_CAP_FILE_CACHE) && in handle_cap_grant()
3097 cap->cap_gen = session->s_cap_gen; in handle_cap_grant()
3098 cap->seq = seq; in handle_cap_grant()
3100 __check_cap_issue(ci, cap, newcaps); in handle_cap_grant()
3175 if (ci->i_auth_cap == cap && (newcaps & CEPH_CAP_ANY_FILE_WR)) { in handle_cap_grant()
3210 if (cap->issued & ~newcaps) { in handle_cap_grant()
3211 int revoking = cap->issued & ~newcaps; in handle_cap_grant()
3214 ceph_cap_string(cap->issued), in handle_cap_grant()
3223 else if (cap == ci->i_auth_cap) in handle_cap_grant()
3227 cap->issued = newcaps; in handle_cap_grant()
3228 cap->implemented |= newcaps; in handle_cap_grant()
3229 } else if (cap->issued == newcaps) { in handle_cap_grant()
3231 ceph_cap_string(cap->issued), ceph_cap_string(newcaps)); in handle_cap_grant()
3233 dout("grant: %s -> %s\n", ceph_cap_string(cap->issued), in handle_cap_grant()
3236 if (cap == ci->i_auth_cap && in handle_cap_grant()
3237 __ceph_caps_revoking_other(ci, cap, newcaps)) in handle_cap_grant()
3240 cap->issued = newcaps; in handle_cap_grant()
3241 cap->implemented |= newcaps; /* add bits only, to in handle_cap_grant()
3246 BUG_ON(cap->issued & ~cap->implemented); in handle_cap_grant()
3302 struct ceph_cap *cap) in handle_cap_flush_ack() argument
3512 struct ceph_cap *cap, *tcap, *new_cap = NULL; in handle_cap_export() local
3534 cap = __get_cap_for_mds(ci, mds); in handle_cap_export()
3535 if (!cap || cap->cap_id != le64_to_cpu(ex->cap_id)) in handle_cap_export()
3539 __ceph_remove_cap(cap, false); in handle_cap_export()
3550 issued = cap->issued; in handle_cap_export()
3551 if (issued != cap->implemented) in handle_cap_export()
3555 ceph_vinop(inode), mds, cap->seq, cap->mseq, in handle_cap_export()
3557 ceph_cap_string(cap->implemented)); in handle_cap_export()
3572 if (cap == ci->i_auth_cap) in handle_cap_export()
3583 __ceph_remove_cap(cap, false); in handle_cap_export()
3587 int flag = (cap == ci->i_auth_cap) ? CEPH_CAP_FLAG_AUTH : 0; in handle_cap_export()
3600 __ceph_remove_cap(cap, false); in handle_cap_export()
3651 struct ceph_cap *cap, *ocap, *new_cap = NULL; in handle_cap_import() local
3676 cap = __get_cap_for_mds(ci, mds); in handle_cap_import()
3677 if (!cap) { in handle_cap_import()
3683 cap = new_cap; in handle_cap_import()
3719 *target_cap = cap; in handle_cap_import()
3734 struct ceph_cap *cap; in ceph_handle_caps() local
3855 cap = ceph_get_cap(mdsc, NULL); in ceph_handle_caps()
3856 cap->cap_ino = vino.ino; in ceph_handle_caps()
3857 cap->queue_release = 1; in ceph_handle_caps()
3858 cap->cap_id = le64_to_cpu(h->cap_id); in ceph_handle_caps()
3859 cap->mseq = mseq; in ceph_handle_caps()
3860 cap->seq = seq; in ceph_handle_caps()
3861 cap->issue_seq = seq; in ceph_handle_caps()
3863 list_add_tail(&cap->session_caps, in ceph_handle_caps()
3894 &cap, &extra_info.issued); in ceph_handle_caps()
3895 handle_cap_grant(inode, session, cap, in ceph_handle_caps()
3904 cap = __get_cap_for_mds(ceph_inode(inode), session->s_mds); in ceph_handle_caps()
3905 if (!cap) { in ceph_handle_caps()
3919 handle_cap_grant(inode, session, cap, in ceph_handle_caps()
3925 h, session, cap); in ceph_handle_caps()
4095 struct ceph_cap *cap; in ceph_encode_inode_release() local
4111 cap = __get_cap_for_mds(ci, mds); in ceph_encode_inode_release()
4112 if (cap && __cap_is_valid(cap)) { in ceph_encode_inode_release()
4113 unless &= cap->issued; in ceph_encode_inode_release()
4125 if (force || (cap->issued & drop)) { in ceph_encode_inode_release()
4126 if (cap->issued & drop) { in ceph_encode_inode_release()
4129 wanted |= cap->mds_wanted; in ceph_encode_inode_release()
4131 "%s -> %s, wanted %s -> %s\n", inode, cap, in ceph_encode_inode_release()
4132 ceph_cap_string(cap->issued), in ceph_encode_inode_release()
4133 ceph_cap_string(cap->issued & ~drop), in ceph_encode_inode_release()
4134 ceph_cap_string(cap->mds_wanted), in ceph_encode_inode_release()
4137 cap->issued &= ~drop; in ceph_encode_inode_release()
4138 cap->implemented &= ~drop; in ceph_encode_inode_release()
4139 cap->mds_wanted = wanted; in ceph_encode_inode_release()
4142 " (force)\n", inode, cap, in ceph_encode_inode_release()
4143 ceph_cap_string(cap->issued)); in ceph_encode_inode_release()
4147 rel->cap_id = cpu_to_le64(cap->cap_id); in ceph_encode_inode_release()
4148 rel->seq = cpu_to_le32(cap->seq); in ceph_encode_inode_release()
4149 rel->issue_seq = cpu_to_le32(cap->issue_seq); in ceph_encode_inode_release()
4150 rel->mseq = cpu_to_le32(cap->mseq); in ceph_encode_inode_release()
4151 rel->caps = cpu_to_le32(cap->implemented); in ceph_encode_inode_release()
4152 rel->wanted = cpu_to_le32(cap->mds_wanted); in ceph_encode_inode_release()
4159 inode, cap, ceph_cap_string(cap->issued)); in ceph_encode_inode_release()