Lines Matching refs:cap
126 struct ceph_cap *cap; in ceph_caps_finalize() local
130 cap = list_first_entry(&mdsc->caps_list, in ceph_caps_finalize()
132 list_del(&cap->caps_item); in ceph_caps_finalize()
133 kmem_cache_free(ceph_cap_cachep, cap); in ceph_caps_finalize()
155 struct ceph_cap *cap; in ceph_reserve_caps() local
176 cap = kmem_cache_alloc(ceph_cap_cachep, GFP_NOFS); in ceph_reserve_caps()
177 if (!cap) in ceph_reserve_caps()
179 list_add(&cap->caps_item, &newcaps); in ceph_reserve_caps()
227 struct ceph_cap *cap = NULL; in ceph_get_cap() local
231 cap = kmem_cache_alloc(ceph_cap_cachep, GFP_NOFS); in ceph_get_cap()
232 if (cap) { in ceph_get_cap()
238 return cap; in ceph_get_cap()
253 cap = list_first_entry(&mdsc->caps_list, struct ceph_cap, caps_item); in ceph_get_cap()
254 list_del(&cap->caps_item); in ceph_get_cap()
259 return cap; in ceph_get_cap()
262 void ceph_put_cap(struct ceph_mds_client *mdsc, struct ceph_cap *cap) in ceph_put_cap() argument
266 cap, mdsc->caps_total_count, mdsc->caps_use_count, in ceph_put_cap()
276 kmem_cache_free(ceph_cap_cachep, cap); in ceph_put_cap()
279 list_add(&cap->caps_item, &mdsc->caps_list); in ceph_put_cap()
312 struct ceph_cap *cap; in __get_cap_for_mds() local
316 cap = rb_entry(n, struct ceph_cap, ci_node); in __get_cap_for_mds()
317 if (mds < cap->mds) in __get_cap_for_mds()
319 else if (mds > cap->mds) in __get_cap_for_mds()
322 return cap; in __get_cap_for_mds()
329 struct ceph_cap *cap; in ceph_get_cap_for_mds() local
332 cap = __get_cap_for_mds(ci, mds); in ceph_get_cap_for_mds()
334 return cap; in ceph_get_cap_for_mds()
342 struct ceph_cap *cap; in __ceph_get_cap_mds() local
348 cap = rb_entry(p, struct ceph_cap, ci_node); in __ceph_get_cap_mds()
349 mds = cap->mds; in __ceph_get_cap_mds()
350 if (cap->issued & (CEPH_CAP_FILE_WR | in __ceph_get_cap_mds()
376 struct ceph_cap *cap = NULL; in __insert_cap_node() local
380 cap = rb_entry(parent, struct ceph_cap, ci_node); in __insert_cap_node()
381 if (new->mds < cap->mds) in __insert_cap_node()
383 else if (new->mds > cap->mds) in __insert_cap_node()
473 static void __check_cap_issue(struct ceph_inode_info *ci, struct ceph_cap *cap, in __check_cap_issue() argument
519 struct ceph_cap *cap; in ceph_add_cap() local
533 cap = __get_cap_for_mds(ci, mds); in ceph_add_cap()
534 if (!cap) { in ceph_add_cap()
535 cap = *new_cap; in ceph_add_cap()
538 cap->issued = 0; in ceph_add_cap()
539 cap->implemented = 0; in ceph_add_cap()
540 cap->mds = mds; in ceph_add_cap()
541 cap->mds_wanted = 0; in ceph_add_cap()
542 cap->mseq = 0; in ceph_add_cap()
544 cap->ci = ci; in ceph_add_cap()
545 __insert_cap_node(ci, cap); in ceph_add_cap()
548 cap->session = session; in ceph_add_cap()
550 list_add_tail(&cap->session_caps, &session->s_caps); in ceph_add_cap()
563 if (ceph_seq_cmp(seq, cap->seq) <= 0) { in ceph_add_cap()
564 WARN_ON(cap != ci->i_auth_cap); in ceph_add_cap()
565 WARN_ON(cap->cap_id != cap_id); in ceph_add_cap()
566 seq = cap->seq; in ceph_add_cap()
567 mseq = cap->mseq; in ceph_add_cap()
568 issued |= cap->issued; in ceph_add_cap()
592 __check_cap_issue(ci, cap, issued); in ceph_add_cap()
611 ci->i_auth_cap = cap; in ceph_add_cap()
612 cap->mds_wanted = wanted; in ceph_add_cap()
615 WARN_ON(ci->i_auth_cap == cap); in ceph_add_cap()
619 inode, ceph_vinop(inode), cap, ceph_cap_string(issued), in ceph_add_cap()
620 ceph_cap_string(issued|cap->issued), seq, mds); in ceph_add_cap()
621 cap->cap_id = cap_id; in ceph_add_cap()
622 cap->issued = issued; in ceph_add_cap()
623 cap->implemented |= issued; in ceph_add_cap()
624 if (ceph_seq_cmp(mseq, cap->mseq) > 0) in ceph_add_cap()
625 cap->mds_wanted = wanted; in ceph_add_cap()
627 cap->mds_wanted |= wanted; in ceph_add_cap()
628 cap->seq = seq; in ceph_add_cap()
629 cap->issue_seq = seq; in ceph_add_cap()
630 cap->mseq = mseq; in ceph_add_cap()
631 cap->cap_gen = session->s_cap_gen; in ceph_add_cap()
642 static int __cap_is_valid(struct ceph_cap *cap) in __cap_is_valid() argument
647 spin_lock(&cap->session->s_gen_ttl_lock); in __cap_is_valid()
648 gen = cap->session->s_cap_gen; in __cap_is_valid()
649 ttl = cap->session->s_cap_ttl; in __cap_is_valid()
650 spin_unlock(&cap->session->s_gen_ttl_lock); in __cap_is_valid()
652 if (cap->cap_gen < gen || time_after_eq(jiffies, ttl)) { in __cap_is_valid()
654 "but STALE (gen %u vs %u)\n", &cap->ci->vfs_inode, in __cap_is_valid()
655 cap, ceph_cap_string(cap->issued), cap->cap_gen, gen); in __cap_is_valid()
670 struct ceph_cap *cap; in __ceph_caps_issued() local
676 cap = rb_entry(p, struct ceph_cap, ci_node); in __ceph_caps_issued()
677 if (!__cap_is_valid(cap)) in __ceph_caps_issued()
680 &ci->vfs_inode, cap, ceph_cap_string(cap->issued)); in __ceph_caps_issued()
681 have |= cap->issued; in __ceph_caps_issued()
683 *implemented |= cap->implemented; in __ceph_caps_issued()
691 cap = ci->i_auth_cap; in __ceph_caps_issued()
692 have &= ~cap->implemented | cap->issued; in __ceph_caps_issued()
703 struct ceph_cap *cap; in __ceph_caps_issued_other() local
707 cap = rb_entry(p, struct ceph_cap, ci_node); in __ceph_caps_issued_other()
708 if (cap == ocap) in __ceph_caps_issued_other()
710 if (!__cap_is_valid(cap)) in __ceph_caps_issued_other()
712 have |= cap->issued; in __ceph_caps_issued_other()
721 static void __touch_cap(struct ceph_cap *cap) in __touch_cap() argument
723 struct ceph_mds_session *s = cap->session; in __touch_cap()
727 dout("__touch_cap %p cap %p mds%d\n", &cap->ci->vfs_inode, cap, in __touch_cap()
729 list_move_tail(&cap->session_caps, &s->s_caps); in __touch_cap()
732 &cap->ci->vfs_inode, cap, s->s_mds); in __touch_cap()
744 struct ceph_cap *cap; in __ceph_caps_issued_mask() local
757 cap = rb_entry(p, struct ceph_cap, ci_node); in __ceph_caps_issued_mask()
758 if (!__cap_is_valid(cap)) in __ceph_caps_issued_mask()
760 if ((cap->issued & mask) == mask) { in __ceph_caps_issued_mask()
762 " (mask %s)\n", &ci->vfs_inode, cap, in __ceph_caps_issued_mask()
763 ceph_cap_string(cap->issued), in __ceph_caps_issued_mask()
766 __touch_cap(cap); in __ceph_caps_issued_mask()
771 have |= cap->issued; in __ceph_caps_issued_mask()
775 ceph_cap_string(cap->issued), in __ceph_caps_issued_mask()
781 __touch_cap(cap); in __ceph_caps_issued_mask()
784 cap = rb_entry(q, struct ceph_cap, in __ceph_caps_issued_mask()
786 if (!__cap_is_valid(cap)) in __ceph_caps_issued_mask()
788 __touch_cap(cap); in __ceph_caps_issued_mask()
804 struct ceph_cap *cap; in __ceph_caps_revoking_other() local
808 cap = rb_entry(p, struct ceph_cap, ci_node); in __ceph_caps_revoking_other()
809 if (cap != ocap && in __ceph_caps_revoking_other()
810 (cap->implemented & ~cap->issued & mask)) in __ceph_caps_revoking_other()
865 struct ceph_cap *cap; in __ceph_caps_mds_wanted() local
870 cap = rb_entry(p, struct ceph_cap, ci_node); in __ceph_caps_mds_wanted()
871 if (!__cap_is_valid(cap)) in __ceph_caps_mds_wanted()
873 if (cap == ci->i_auth_cap) in __ceph_caps_mds_wanted()
874 mds_wanted |= cap->mds_wanted; in __ceph_caps_mds_wanted()
876 mds_wanted |= (cap->mds_wanted & ~CEPH_CAP_ANY_FILE_WR); in __ceph_caps_mds_wanted()
919 void __ceph_remove_cap(struct ceph_cap *cap, bool queue_release) in __ceph_remove_cap() argument
921 struct ceph_mds_session *session = cap->session; in __ceph_remove_cap()
922 struct ceph_inode_info *ci = cap->ci; in __ceph_remove_cap()
927 dout("__ceph_remove_cap %p from %p\n", cap, &ci->vfs_inode); in __ceph_remove_cap()
931 if (session->s_cap_iterator == cap) { in __ceph_remove_cap()
934 cap, cap->session); in __ceph_remove_cap()
936 list_del_init(&cap->session_caps); in __ceph_remove_cap()
938 cap->session = NULL; in __ceph_remove_cap()
942 cap->ci = NULL; in __ceph_remove_cap()
949 (!session->s_cap_reconnect || cap->cap_gen == session->s_cap_gen)) { in __ceph_remove_cap()
950 cap->queue_release = 1; in __ceph_remove_cap()
952 list_add_tail(&cap->session_caps, in __ceph_remove_cap()
958 cap->queue_release = 0; in __ceph_remove_cap()
960 cap->cap_ino = ci->i_vino.ino; in __ceph_remove_cap()
965 rb_erase(&cap->ci_node, &ci->i_caps); in __ceph_remove_cap()
966 if (ci->i_auth_cap == cap) in __ceph_remove_cap()
970 ceph_put_cap(mdsc, cap); in __ceph_remove_cap()
1085 struct ceph_cap *cap = rb_entry(p, struct ceph_cap, ci_node); in ceph_queue_caps_release() local
1087 __ceph_remove_cap(cap, true); in ceph_queue_caps_release()
1108 static int __send_cap(struct ceph_mds_client *mdsc, struct ceph_cap *cap, in __send_cap() argument
1111 __releases(cap->ci->i_ceph_lock) in __send_cap()
1113 struct ceph_inode_info *ci = cap->ci; in __send_cap()
1115 u64 cap_id = cap->cap_id; in __send_cap()
1131 held = cap->issued | cap->implemented; in __send_cap()
1132 revoking = cap->implemented & ~cap->issued; in __send_cap()
1134 dropping = cap->issued & ~retain; in __send_cap()
1137 inode, cap, cap->session, in __send_cap()
1142 session = cap->session; in __send_cap()
1148 ceph_cap_string(cap->issued), in __send_cap()
1149 ceph_cap_string(cap->issued & retain), in __send_cap()
1150 ceph_cap_string(cap->mds_wanted), in __send_cap()
1152 want |= cap->mds_wanted; in __send_cap()
1153 retain |= cap->issued; in __send_cap()
1158 cap->issued &= retain; /* drop bits we don't want */ in __send_cap()
1159 if (cap->implemented & ~cap->issued) { in __send_cap()
1168 cap->implemented &= cap->issued | used; in __send_cap()
1169 cap->mds_wanted = want; in __send_cap()
1173 keep = cap->implemented; in __send_cap()
1174 seq = cap->seq; in __send_cap()
1175 issue_seq = cap->issue_seq; in __send_cap()
1176 mseq = cap->mseq; in __send_cap()
1575 struct ceph_cap *cap; in ceph_check_caps() local
1682 cap = rb_entry(p, struct ceph_cap, ci_node); in ceph_check_caps()
1686 if (mds >= cap->mds || in ceph_check_caps()
1687 ((flags & CHECK_CAPS_AUTHONLY) && cap != ci->i_auth_cap)) in ceph_check_caps()
1693 if (ci->i_auth_cap && cap != ci->i_auth_cap) in ceph_check_caps()
1696 revoking = cap->implemented & ~cap->issued; in ceph_check_caps()
1698 cap->mds, cap, ceph_cap_string(cap->issued), in ceph_check_caps()
1700 ceph_cap_string(cap->implemented), in ceph_check_caps()
1703 if (cap == ci->i_auth_cap && in ceph_check_caps()
1704 (cap->issued & CEPH_CAP_FILE_WR)) { in ceph_check_caps()
1720 if (cap == ci->i_auth_cap && (flags & CHECK_CAPS_FLUSH) && in ceph_check_caps()
1729 ceph_cap_string(cap->implemented & ~cap->issued)); in ceph_check_caps()
1734 if (want & ~(cap->mds_wanted | cap->issued)) in ceph_check_caps()
1738 if ((cap->issued & ~retain) == 0 && in ceph_check_caps()
1739 cap->mds_wanted == want) in ceph_check_caps()
1749 ceph_cap_string(cap->issued), in ceph_check_caps()
1750 ceph_cap_string(cap->issued & retain), in ceph_check_caps()
1751 ceph_cap_string(cap->mds_wanted), in ceph_check_caps()
1763 if (session && session != cap->session) { in ceph_check_caps()
1769 session = cap->session; in ceph_check_caps()
1795 if (cap == ci->i_auth_cap && ci->i_dirty_caps) { in ceph_check_caps()
1807 mds = cap->mds; /* remember mds, so we don't repeat */ in ceph_check_caps()
1811 delayed += __send_cap(mdsc, cap, CEPH_CAP_OP_UPDATE, cap_used, in ceph_check_caps()
1857 struct ceph_cap *cap = ci->i_auth_cap; in try_flush_caps() local
1862 if (!session || session != cap->session) { in try_flush_caps()
1866 session = cap->session; in try_flush_caps()
1870 if (cap->session->s_state < CEPH_MDS_SESSION_OPEN) in try_flush_caps()
1877 delayed = __send_cap(mdsc, cap, CEPH_CAP_OP_FLUSH, used, want, in try_flush_caps()
1878 (cap->issued | cap->implemented), in try_flush_caps()
2103 struct ceph_cap *cap; in kick_flushing_capsnaps() local
2106 cap = ci->i_auth_cap; in kick_flushing_capsnaps()
2107 if (cap && cap->session == session) { in kick_flushing_capsnaps()
2109 cap, capsnap); in kick_flushing_capsnaps()
2113 cap, session->s_mds); in kick_flushing_capsnaps()
2124 struct ceph_cap *cap; in __kick_flushing_caps() local
2137 cap = ci->i_auth_cap; in __kick_flushing_caps()
2138 if (!(cap && cap->session == session)) { in __kick_flushing_caps()
2140 cap, session->s_mds); in __kick_flushing_caps()
2160 cap, cf->tid, ceph_cap_string(cf->caps)); in __kick_flushing_caps()
2161 delayed |= __send_cap(mdsc, cap, CEPH_CAP_OP_FLUSH, in __kick_flushing_caps()
2164 cap->issued | cap->implemented, in __kick_flushing_caps()
2174 struct ceph_cap *cap; in ceph_early_kick_flushing_caps() local
2179 cap = ci->i_auth_cap; in ceph_early_kick_flushing_caps()
2180 if (!(cap && cap->session == session)) { in ceph_early_kick_flushing_caps()
2182 &ci->vfs_inode, cap, session->s_mds); in ceph_early_kick_flushing_caps()
2194 if ((cap->issued & ci->i_flushing_caps) != in ceph_early_kick_flushing_caps()
2229 struct ceph_cap *cap; in kick_flushing_inode_caps() local
2232 cap = ci->i_auth_cap; in kick_flushing_inode_caps()
2243 &cap->session->s_cap_flushing); in kick_flushing_inode_caps()
2756 struct ceph_cap *cap, int issued) in handle_cap_grant() argument
2778 inode, cap, mds, seq, ceph_cap_string(newcaps)); in handle_cap_grant()
2791 if (ceph_seq_cmp(seq, cap->seq) <= 0) { in handle_cap_grant()
2792 WARN_ON(cap != ci->i_auth_cap); in handle_cap_grant()
2793 WARN_ON(cap->cap_id != le64_to_cpu(grant->cap_id)); in handle_cap_grant()
2794 seq = cap->seq; in handle_cap_grant()
2795 newcaps |= cap->issued; in handle_cap_grant()
2804 ((cap->issued & ~newcaps) & CEPH_CAP_FILE_CACHE) && in handle_cap_grant()
2820 cap->cap_gen = session->s_cap_gen; in handle_cap_grant()
2821 cap->seq = seq; in handle_cap_grant()
2823 __check_cap_issue(ci, cap, newcaps); in handle_cap_grant()
2882 if (ci->i_auth_cap == cap && max_size != ci->i_max_size) { in handle_cap_grant()
2912 if (cap->issued & ~newcaps) { in handle_cap_grant()
2913 int revoking = cap->issued & ~newcaps; in handle_cap_grant()
2916 ceph_cap_string(cap->issued), in handle_cap_grant()
2925 else if (cap == ci->i_auth_cap) in handle_cap_grant()
2929 cap->issued = newcaps; in handle_cap_grant()
2930 cap->implemented |= newcaps; in handle_cap_grant()
2931 } else if (cap->issued == newcaps) { in handle_cap_grant()
2933 ceph_cap_string(cap->issued), ceph_cap_string(newcaps)); in handle_cap_grant()
2935 dout("grant: %s -> %s\n", ceph_cap_string(cap->issued), in handle_cap_grant()
2938 if (cap == ci->i_auth_cap && in handle_cap_grant()
2939 __ceph_caps_revoking_other(ci, cap, newcaps)) in handle_cap_grant()
2942 cap->issued = newcaps; in handle_cap_grant()
2943 cap->implemented |= newcaps; /* add bits only, to in handle_cap_grant()
2948 BUG_ON(cap->issued & ~cap->implemented); in handle_cap_grant()
3005 struct ceph_cap *cap) in handle_cap_flush_ack() argument
3195 struct ceph_cap *cap, *tcap, *new_cap = NULL; in handle_cap_export() local
3217 cap = __get_cap_for_mds(ci, mds); in handle_cap_export()
3218 if (!cap || cap->cap_id != le64_to_cpu(ex->cap_id)) in handle_cap_export()
3222 __ceph_remove_cap(cap, false); in handle_cap_export()
3231 issued = cap->issued; in handle_cap_export()
3232 WARN_ON(issued != cap->implemented); in handle_cap_export()
3246 if (cap == ci->i_auth_cap) in handle_cap_export()
3255 __ceph_remove_cap(cap, false); in handle_cap_export()
3259 int flag = (cap == ci->i_auth_cap) ? CEPH_CAP_FLAG_AUTH : 0; in handle_cap_export()
3263 __ceph_remove_cap(cap, false); in handle_cap_export()
3314 struct ceph_cap *cap, *ocap, *new_cap = NULL; in handle_cap_import() local
3339 cap = __get_cap_for_mds(ci, mds); in handle_cap_import()
3340 if (!cap) { in handle_cap_import()
3346 cap = new_cap; in handle_cap_import()
3382 *target_cap = cap; in handle_cap_import()
3398 struct ceph_cap *cap; in ceph_handle_caps() local
3481 cap = ceph_get_cap(mdsc, NULL); in ceph_handle_caps()
3482 cap->cap_ino = vino.ino; in ceph_handle_caps()
3483 cap->queue_release = 1; in ceph_handle_caps()
3484 cap->cap_id = cap_id; in ceph_handle_caps()
3485 cap->mseq = mseq; in ceph_handle_caps()
3486 cap->seq = seq; in ceph_handle_caps()
3488 list_add_tail(&cap->session_caps, in ceph_handle_caps()
3518 &cap, &issued); in ceph_handle_caps()
3521 msg->middle, session, cap, issued); in ceph_handle_caps()
3529 cap = __get_cap_for_mds(ceph_inode(inode), mds); in ceph_handle_caps()
3530 if (!cap) { in ceph_handle_caps()
3545 msg->middle, session, cap, issued); in ceph_handle_caps()
3549 handle_cap_flush_ack(inode, tid, h, session, cap); in ceph_handle_caps()
3670 struct ceph_cap *cap; in ceph_encode_inode_release() local
3686 cap = __get_cap_for_mds(ci, mds); in ceph_encode_inode_release()
3687 if (cap && __cap_is_valid(cap)) { in ceph_encode_inode_release()
3689 ((cap->issued & drop) && in ceph_encode_inode_release()
3690 (cap->issued & unless) == 0)) { in ceph_encode_inode_release()
3691 if ((cap->issued & drop) && in ceph_encode_inode_release()
3692 (cap->issued & unless) == 0) { in ceph_encode_inode_release()
3695 wanted |= cap->mds_wanted; in ceph_encode_inode_release()
3697 "%s -> %s, wanted %s -> %s\n", inode, cap, in ceph_encode_inode_release()
3698 ceph_cap_string(cap->issued), in ceph_encode_inode_release()
3699 ceph_cap_string(cap->issued & ~drop), in ceph_encode_inode_release()
3700 ceph_cap_string(cap->mds_wanted), in ceph_encode_inode_release()
3703 cap->issued &= ~drop; in ceph_encode_inode_release()
3704 cap->implemented &= ~drop; in ceph_encode_inode_release()
3705 cap->mds_wanted = wanted; in ceph_encode_inode_release()
3708 " (force)\n", inode, cap, in ceph_encode_inode_release()
3709 ceph_cap_string(cap->issued)); in ceph_encode_inode_release()
3713 rel->cap_id = cpu_to_le64(cap->cap_id); in ceph_encode_inode_release()
3714 rel->seq = cpu_to_le32(cap->seq); in ceph_encode_inode_release()
3715 rel->issue_seq = cpu_to_le32(cap->issue_seq); in ceph_encode_inode_release()
3716 rel->mseq = cpu_to_le32(cap->mseq); in ceph_encode_inode_release()
3717 rel->caps = cpu_to_le32(cap->implemented); in ceph_encode_inode_release()
3718 rel->wanted = cpu_to_le32(cap->mds_wanted); in ceph_encode_inode_release()
3725 inode, cap, ceph_cap_string(cap->issued)); in ceph_encode_inode_release()