Lines Matching full:issued
561 unsigned issued) in __check_cap_issue() argument
572 (issued & (CEPH_CAP_FILE_CACHE|CEPH_CAP_FILE_LAZYIO)) && in __check_cap_issue()
578 * If FILE_SHARED is newly issued, mark dir not complete. We don't in __check_cap_issue()
583 if ((issued & CEPH_CAP_FILE_SHARED) != (had & CEPH_CAP_FILE_SHARED)) { in __check_cap_issue()
584 if (issued & CEPH_CAP_FILE_SHARED) in __check_cap_issue()
594 !(issued & CEPH_CAP_DIR_CREATE)) { in __check_cap_issue()
632 unsigned issued, unsigned wanted, in ceph_add_cap() argument
646 session->s_mds, cap_id, ceph_cap_string(issued), seq); in ceph_add_cap()
655 cap->issued = 0; in ceph_add_cap()
677 cap->issued = cap->implemented = CEPH_CAP_PIN; in ceph_add_cap()
693 issued |= cap->issued; in ceph_add_cap()
714 __check_cap_issue(ci, cap, issued); in ceph_add_cap()
717 * If we are issued caps we don't want, or the mds' wanted in ceph_add_cap()
723 (issued & ~actual_wanted & CEPH_CAP_ANY_WR)) { in ceph_add_cap()
724 dout(" issued %s, mds wanted %s, actual %s, queueing\n", in ceph_add_cap()
725 ceph_cap_string(issued), ceph_cap_string(wanted), in ceph_add_cap()
744 inode, ceph_vinop(inode), cap, ceph_cap_string(issued), in ceph_add_cap()
745 ceph_cap_string(issued|cap->issued), seq, mds); in ceph_add_cap()
747 cap->issued = issued; in ceph_add_cap()
748 cap->implemented |= issued; in ceph_add_cap()
774 dout("__cap_is_valid %p cap %p issued %s " in __cap_is_valid()
776 cap, ceph_cap_string(cap->issued), cap->cap_gen, gen); in __cap_is_valid()
784 * Return set of valid cap bits issued to us. Note that caps time
800 dout("__ceph_caps_issued %p cap %p issued %s\n", in __ceph_caps_issued()
801 &ci->netfs.inode, cap, ceph_cap_string(cap->issued)); in __ceph_caps_issued()
802 have |= cap->issued; in __ceph_caps_issued()
807 * exclude caps issued by non-auth MDS, but are been revoking in __ceph_caps_issued()
813 have &= ~cap->implemented | cap->issued; in __ceph_caps_issued()
819 * Get cap bits issued by caps other than @ocap
833 have |= cap->issued; in __ceph_caps_issued_other()
870 dout("__ceph_caps_issued_mask ino 0x%llx snap issued %s" in __ceph_caps_issued_mask()
881 if ((cap->issued & mask) == mask) { in __ceph_caps_issued_mask()
882 dout("__ceph_caps_issued_mask ino 0x%llx cap %p issued %s" in __ceph_caps_issued_mask()
884 ceph_cap_string(cap->issued), in __ceph_caps_issued_mask()
892 have |= cap->issued; in __ceph_caps_issued_mask()
894 dout("__ceph_caps_issued_mask ino 0x%llx combo issued %s" in __ceph_caps_issued_mask()
896 ceph_cap_string(cap->issued), in __ceph_caps_issued_mask()
909 if (cap->issued & mask) in __ceph_caps_issued_mask()
946 (cap->implemented & ~cap->issued & mask)) in __ceph_caps_revoking_other()
1352 held = cap->issued | cap->implemented; in __prep_cap()
1353 revoking = cap->implemented & ~cap->issued; in __prep_cap()
1364 cap->issued &= retain; /* drop bits we don't want */ in __prep_cap()
1370 arg->wake = cap->implemented & ~cap->issued; in __prep_cap()
1371 cap->implemented &= cap->issued | used; in __prep_cap()
1496 arg.caps = capsnap->issued; in __send_flush_snap()
1909 int issued, implemented, want, retain, revoking, flushing = 0; in ceph_check_caps() local
1938 * "issued" represents the current caps that the MDS wants us to have. in ceph_check_caps()
1943 issued = __ceph_caps_issued(ci, &implemented); in ceph_check_caps()
1944 revoking = implemented & ~issued; in ceph_check_caps()
1954 (issued & CEPH_CAP_FILE_SHARED) && in ceph_check_caps()
1982 " issued %s revoking %s retain %s %s%s%s\n", ceph_vinop(inode), in ceph_check_caps()
1986 ceph_cap_string(issued), ceph_cap_string(revoking), in ceph_check_caps()
2032 cap_used &= ~ci->i_auth_cap->issued; in ceph_check_caps()
2034 revoking = cap->implemented & ~cap->issued; in ceph_check_caps()
2035 dout(" mds%d cap %p used %s issued %s implemented %s revoking %s\n", in ceph_check_caps()
2037 ceph_cap_string(cap->issued), in ceph_check_caps()
2042 (cap->issued & CEPH_CAP_FILE_WR)) { in ceph_check_caps()
2072 ceph_cap_string(cap->implemented & ~cap->issued)); in ceph_check_caps()
2094 if (want & ~(cap->mds_wanted | cap->issued)) in ceph_check_caps()
2101 if ((cap->issued & ~retain) == 0) in ceph_check_caps()
2202 (cap->issued | cap->implemented), in try_flush_caps()
2491 (cap->issued | cap->implemented), in __kick_flushing_caps()
2553 if ((cap->issued & ci->i_flushing_caps) != in ceph_early_kick_flushing_caps()
2848 (ci->i_auth_cap->issued & CEPH_CAP_FILE_WR) && in check_max_size()
3312 /* currently issued */
3313 int issued; member
3359 ((cap->issued & ~newcaps) & CEPH_CAP_FILE_CACHE) && in handle_cap_grant()
3373 cap->issued = cap->implemented = CEPH_CAP_PIN; in handle_cap_grant()
3387 newcaps |= cap->issued; in handle_cap_grant()
3399 (extra_info->issued & CEPH_CAP_AUTH_EXCL) == 0) { in handle_cap_grant()
3416 (extra_info->issued & CEPH_CAP_LINK_EXCL) == 0) { in handle_cap_grant()
3422 if ((extra_info->issued & CEPH_CAP_XATTR_EXCL) == 0 && in handle_cap_grant()
3445 ceph_fill_file_time(inode, extra_info->issued, in handle_cap_grant()
3472 queue_trunc = ceph_fill_file_size(inode, extra_info->issued, in handle_cap_grant()
3507 * want are already issued. If mds revokes caps, cap message in handle_cap_grant()
3516 if (cap->issued & ~newcaps) { in handle_cap_grant()
3517 int revoking = cap->issued & ~newcaps; in handle_cap_grant()
3520 ceph_cap_string(cap->issued), in handle_cap_grant()
3535 if (~cap->issued & newcaps) in handle_cap_grant()
3537 cap->issued = newcaps; in handle_cap_grant()
3539 } else if (cap->issued == newcaps) { in handle_cap_grant()
3541 ceph_cap_string(cap->issued), ceph_cap_string(newcaps)); in handle_cap_grant()
3543 dout("grant: %s -> %s\n", ceph_cap_string(cap->issued), in handle_cap_grant()
3550 cap->issued = newcaps; in handle_cap_grant()
3556 BUG_ON(cap->issued & ~cap->implemented); in handle_cap_grant()
3568 if (newcaps & ~extra_info->issued) in handle_cap_grant()
3831 int issued = __ceph_caps_issued(ceph_inode(inode), &implemented); in handle_cap_trunc() local
3836 issued |= implemented | dirty; in handle_cap_trunc()
3840 queue_trunc = ceph_fill_file_size(inode, issued, in handle_cap_trunc()
3864 int target, issued; in handle_cap_export() local
3896 issued = cap->issued; in handle_cap_export()
3897 if (issued != cap->implemented) in handle_cap_export()
3898 pr_err_ratelimited("handle_cap_export: issued != implemented: " in handle_cap_export()
3900 "issued %s implemented %s\n", in handle_cap_export()
3902 ceph_cap_string(issued), in handle_cap_export()
3915 tcap->issued |= issued; in handle_cap_export()
3916 tcap->implemented |= issued; in handle_cap_export()
3928 ceph_add_cap(inode, tsession, t_cap_id, issued, 0, in handle_cap_export()
3994 int issued; in handle_cap_import() local
4031 __ceph_caps_issued(ci, &issued); in handle_cap_import()
4032 issued |= __ceph_caps_dirty(ci); in handle_cap_import()
4055 *old_issued = issued; in handle_cap_import()
4230 &cap, &extra_info.issued); in ceph_handle_caps()
4253 __ceph_caps_issued(ci, &extra_info.issued); in ceph_handle_caps()
4254 extra_info.issued |= __ceph_caps_dirty(ci); in ceph_handle_caps()
4513 unless &= cap->issued; in ceph_encode_inode_release()
4525 if (force || (cap->issued & drop)) { in ceph_encode_inode_release()
4526 if (cap->issued & drop) { in ceph_encode_inode_release()
4530 ceph_cap_string(cap->issued), in ceph_encode_inode_release()
4531 ceph_cap_string(cap->issued & ~drop), in ceph_encode_inode_release()
4535 cap->issued &= ~drop; in ceph_encode_inode_release()
4544 ceph_cap_string(cap->issued)); in ceph_encode_inode_release()
4560 inode, cap, ceph_cap_string(cap->issued)); in ceph_encode_inode_release()