Lines Matching refs:issued
563 unsigned issued)
574 (issued & (CEPH_CAP_FILE_CACHE|CEPH_CAP_FILE_LAZYIO)) &&
580 * If FILE_SHARED is newly issued, mark dir not complete. We don't
585 if ((issued & CEPH_CAP_FILE_SHARED) != (had & CEPH_CAP_FILE_SHARED)) {
586 if (issued & CEPH_CAP_FILE_SHARED)
596 !(issued & CEPH_CAP_DIR_CREATE)) {
634 unsigned issued, unsigned wanted,
648 session->s_mds, cap_id, ceph_cap_string(issued), seq);
657 cap->issued = 0;
679 cap->issued = cap->implemented = CEPH_CAP_PIN;
695 issued |= cap->issued;
716 __check_cap_issue(ci, cap, issued);
719 * If we are issued caps we don't want, or the mds' wanted
725 (issued & ~actual_wanted & CEPH_CAP_ANY_WR)) {
726 dout(" issued %s, mds wanted %s, actual %s, queueing\n",
727 ceph_cap_string(issued), ceph_cap_string(wanted),
746 inode, ceph_vinop(inode), cap, ceph_cap_string(issued),
747 ceph_cap_string(issued|cap->issued), seq, mds);
749 cap->issued = issued;
750 cap->implemented |= issued;
776 dout("__cap_is_valid %p cap %p issued %s "
778 cap, ceph_cap_string(cap->issued), cap->cap_gen, gen);
786 * Return set of valid cap bits issued to us. Note that caps time
802 dout("__ceph_caps_issued %p cap %p issued %s\n",
803 &ci->netfs.inode, cap, ceph_cap_string(cap->issued));
804 have |= cap->issued;
809 * exclude caps issued by non-auth MDS, but are been revoking
815 have &= ~cap->implemented | cap->issued;
821 * Get cap bits issued by caps other than @ocap
835 have |= cap->issued;
872 dout("__ceph_caps_issued_mask ino 0x%llx snap issued %s"
883 if ((cap->issued & mask) == mask) {
884 dout("__ceph_caps_issued_mask ino 0x%llx cap %p issued %s"
886 ceph_cap_string(cap->issued),
894 have |= cap->issued;
896 dout("__ceph_caps_issued_mask ino 0x%llx combo issued %s"
898 ceph_cap_string(cap->issued),
911 if (cap->issued & mask)
948 (cap->implemented & ~cap->issued & mask))
1377 held = cap->issued | cap->implemented;
1378 revoking = cap->implemented & ~cap->issued;
1389 cap->issued &= retain; /* drop bits we don't want */
1395 arg->wake = cap->implemented & ~cap->issued;
1396 cap->implemented &= cap->issued | used;
1549 arg.caps = capsnap->issued;
1976 int issued, implemented, want, retain, revoking, flushing = 0;
2004 * "issued" represents the current caps that the MDS wants us to have.
2009 issued = __ceph_caps_issued(ci, &implemented);
2010 revoking = implemented & ~issued;
2020 (issued & CEPH_CAP_FILE_SHARED) &&
2048 " issued %s revoking %s retain %s %s%s%s\n", ceph_vinop(inode),
2052 ceph_cap_string(issued), ceph_cap_string(revoking),
2098 cap_used &= ~ci->i_auth_cap->issued;
2100 revoking = cap->implemented & ~cap->issued;
2101 dout(" mds%d cap %p used %s issued %s implemented %s revoking %s\n",
2103 ceph_cap_string(cap->issued),
2108 (cap->issued & CEPH_CAP_FILE_WR)) {
2138 ceph_cap_string(cap->implemented & ~cap->issued));
2160 if (want & ~(cap->mds_wanted | cap->issued))
2167 if ((cap->issued & ~retain) == 0)
2268 (cap->issued | cap->implemented),
2557 (cap->issued | cap->implemented),
2619 if ((cap->issued & ci->i_flushing_caps) !=
2914 (ci->i_auth_cap->issued & CEPH_CAP_FILE_WR) &&
3392 /* currently issued */
3393 int issued;
3450 ((cap->issued & ~newcaps) & CEPH_CAP_FILE_CACHE) &&
3464 cap->issued = cap->implemented = CEPH_CAP_PIN;
3478 newcaps |= cap->issued;
3490 (extra_info->issued & CEPH_CAP_AUTH_EXCL) == 0) {
3515 (extra_info->issued & CEPH_CAP_LINK_EXCL) == 0) {
3521 if ((extra_info->issued & CEPH_CAP_XATTR_EXCL) == 0 &&
3544 ceph_fill_file_time(inode, extra_info->issued,
3571 queue_trunc = ceph_fill_file_size(inode, extra_info->issued,
3606 * want are already issued. If mds revokes caps, cap message
3615 if (cap->issued & ~newcaps) {
3616 int revoking = cap->issued & ~newcaps;
3619 ceph_cap_string(cap->issued),
3634 if (~cap->issued & newcaps)
3636 cap->issued = newcaps;
3638 } else if (cap->issued == newcaps) {
3640 ceph_cap_string(cap->issued), ceph_cap_string(newcaps));
3642 dout("grant: %s -> %s\n", ceph_cap_string(cap->issued),
3649 cap->issued = newcaps;
3655 BUG_ON(cap->issued & ~cap->implemented);
3676 if (newcaps & ~extra_info->issued)
3939 int issued = __ceph_caps_issued(ceph_inode(inode), &implemented);
3944 issued |= implemented | dirty;
3956 queue_trunc = ceph_fill_file_size(inode, issued,
3980 int target, issued;
4012 issued = cap->issued;
4013 if (issued != cap->implemented)
4014 pr_err_ratelimited("handle_cap_export: issued != implemented: "
4016 "issued %s implemented %s\n",
4018 ceph_cap_string(issued),
4031 tcap->issued |= issued;
4032 tcap->implemented |= issued;
4044 ceph_add_cap(inode, tsession, t_cap_id, issued, 0,
4110 int issued;
4147 __ceph_caps_issued(ci, &issued);
4148 issued |= __ceph_caps_dirty(ci);
4171 *old_issued = issued;
4402 &cap, &extra_info.issued);
4433 __ceph_caps_issued(ci, &extra_info.issued);
4434 extra_info.issued |= __ceph_caps_dirty(ci);
4714 unless &= cap->issued;
4726 if (force || (cap->issued & drop)) {
4727 if (cap->issued & drop) {
4731 ceph_cap_string(cap->issued),
4732 ceph_cap_string(cap->issued & ~drop),
4736 cap->issued &= ~drop;
4745 ceph_cap_string(cap->issued));
4761 inode, cap, ceph_cap_string(cap->issued));