Lines Matching refs:issued

350 		if (cap->issued & (CEPH_CAP_FILE_WR |  in __ceph_get_cap_mds()
474 unsigned issued) in __check_cap_issue() argument
482 if ((issued & (CEPH_CAP_FILE_CACHE|CEPH_CAP_FILE_LAZYIO)) && in __check_cap_issue()
492 if ((issued & CEPH_CAP_FILE_SHARED) && in __check_cap_issue()
513 int fmode, unsigned issued, unsigned wanted, in ceph_add_cap() argument
524 session->s_mds, cap_id, ceph_cap_string(issued), seq); in ceph_add_cap()
538 cap->issued = 0; in ceph_add_cap()
568 issued |= cap->issued; in ceph_add_cap()
592 __check_cap_issue(ci, cap, issued); in ceph_add_cap()
601 (issued & ~actual_wanted & CEPH_CAP_ANY_WR)) { in ceph_add_cap()
603 ceph_cap_string(issued), ceph_cap_string(wanted), 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()
622 cap->issued = issued; in ceph_add_cap()
623 cap->implemented |= issued; in ceph_add_cap()
655 cap, ceph_cap_string(cap->issued), cap->cap_gen, gen); in __cap_is_valid()
680 &ci->vfs_inode, cap, ceph_cap_string(cap->issued)); in __ceph_caps_issued()
681 have |= cap->issued; in __ceph_caps_issued()
692 have &= ~cap->implemented | cap->issued; in __ceph_caps_issued()
712 have |= cap->issued; in __ceph_caps_issued_other()
760 if ((cap->issued & mask) == mask) { in __ceph_caps_issued_mask()
763 ceph_cap_string(cap->issued), 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()
810 (cap->implemented & ~cap->issued & mask)) in __ceph_caps_revoking_other()
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()
1148 ceph_cap_string(cap->issued), in __send_cap()
1149 ceph_cap_string(cap->issued & retain), 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()
1319 CEPH_CAP_OP_FLUSHSNAP, capsnap->issued, 0, in __ceph_flush_snaps()
1579 int issued, implemented, want, retain, revoking, flushing = 0; in ceph_check_caps() local
1606 issued = __ceph_caps_issued(ci, &implemented); in ceph_check_caps()
1607 revoking = implemented & ~issued; in ceph_check_caps()
1615 (issued & CEPH_CAP_FILE_SHARED) && in ceph_check_caps()
1643 ceph_cap_string(issued), ceph_cap_string(revoking), in ceph_check_caps()
1694 cap_used &= ~ci->i_auth_cap->issued; 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()
1704 (cap->issued & CEPH_CAP_FILE_WR)) { 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()
1749 ceph_cap_string(cap->issued), in ceph_check_caps()
1750 ceph_cap_string(cap->issued & retain), in ceph_check_caps()
1878 (cap->issued | cap->implemented), in try_flush_caps()
2164 cap->issued | cap->implemented, in __kick_flushing_caps()
2194 if ((cap->issued & ci->i_flushing_caps) != in ceph_early_kick_flushing_caps()
2452 (ci->i_auth_cap->issued & CEPH_CAP_FILE_WR) && in check_max_size()
2756 struct ceph_cap *cap, int issued) in handle_cap_grant() argument
2795 newcaps |= cap->issued; in handle_cap_grant()
2804 ((cap->issued & ~newcaps) & CEPH_CAP_FILE_CACHE) && in handle_cap_grant()
2826 (issued & CEPH_CAP_AUTH_EXCL) == 0) { in handle_cap_grant()
2836 (issued & CEPH_CAP_LINK_EXCL) == 0) { in handle_cap_grant()
2843 if ((issued & CEPH_CAP_XATTR_EXCL) == 0 && grant->xattr_len) { in handle_cap_grant()
2860 if ((issued & CEPH_CAP_FILE_CACHE) && ci->i_rdcache_gen > 1) in handle_cap_grant()
2868 ceph_fill_file_time(inode, issued, in handle_cap_grant()
2877 queue_trunc = ceph_fill_file_size(inode, issued, 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()
2929 cap->issued = 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()
2942 cap->issued = newcaps; in handle_cap_grant()
2948 BUG_ON(cap->issued & ~cap->implemented); in handle_cap_grant()
2962 if (newcaps & ~issued) in handle_cap_grant()
3164 int issued = __ceph_caps_issued(ceph_inode(inode), &implemented); in handle_cap_trunc() local
3167 issued |= implemented | dirty; in handle_cap_trunc()
3171 queue_trunc = ceph_fill_file_size(inode, issued, in handle_cap_trunc()
3200 int target, issued; in handle_cap_export() local
3231 issued = cap->issued; in handle_cap_export()
3232 WARN_ON(issued != cap->implemented); in handle_cap_export()
3244 tcap->issued |= issued; in handle_cap_export()
3245 tcap->implemented |= issued; in handle_cap_export()
3260 ceph_add_cap(inode, tsession, t_cap_id, -1, issued, 0, in handle_cap_export()
3316 int issued; in handle_cap_import() local
3354 __ceph_caps_issued(ci, &issued); in handle_cap_import()
3355 issued |= __ceph_caps_dirty(ci); in handle_cap_import()
3381 *old_issued = issued; in handle_cap_import()
3403 int op, issued; in ceph_handle_caps() local
3518 &cap, &issued); in ceph_handle_caps()
3521 msg->middle, session, cap, issued); in ceph_handle_caps()
3541 __ceph_caps_issued(ci, &issued); in ceph_handle_caps()
3542 issued |= __ceph_caps_dirty(ci); in ceph_handle_caps()
3545 msg->middle, session, cap, issued); in ceph_handle_caps()
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()
3698 ceph_cap_string(cap->issued), in ceph_encode_inode_release()
3699 ceph_cap_string(cap->issued & ~drop), in ceph_encode_inode_release()
3703 cap->issued &= ~drop; in ceph_encode_inode_release()
3709 ceph_cap_string(cap->issued)); in ceph_encode_inode_release()
3725 inode, cap, ceph_cap_string(cap->issued)); in ceph_encode_inode_release()