| // SPDX-License-Identifier: GPL-2.0 |
| #include <linux/ceph/ceph_debug.h> |
| |
| #include <linux/fs.h> |
| #include <linux/kernel.h> |
| #include <linux/sched/signal.h> |
| #include <linux/slab.h> |
| #include <linux/vmalloc.h> |
| #include <linux/wait.h> |
| #include <linux/writeback.h> |
| |
| #include "super.h" |
| #include "mds_client.h" |
| #include "cache.h" |
| #include <linux/ceph/decode.h> |
| #include <linux/ceph/messenger.h> |
| |
| /* |
| * Capability management |
| * |
| * The Ceph metadata servers control client access to inode metadata |
| * and file data by issuing capabilities, granting clients permission |
| * to read and/or write both inode field and file data to OSDs |
| * (storage nodes). Each capability consists of a set of bits |
| * indicating which operations are allowed. |
| * |
| * If the client holds a *_SHARED cap, the client has a coherent value |
| * that can be safely read from the cached inode. |
| * |
| * In the case of a *_EXCL (exclusive) or FILE_WR capabilities, the |
| * client is allowed to change inode attributes (e.g., file size, |
| * mtime), note its dirty state in the ceph_cap, and asynchronously |
| * flush that metadata change to the MDS. |
| * |
| * In the event of a conflicting operation (perhaps by another |
| * client), the MDS will revoke the conflicting client capabilities. |
| * |
| * In order for a client to cache an inode, it must hold a capability |
| * with at least one MDS server. When inodes are released, release |
| * notifications are batched and periodically sent en masse to the MDS |
| * cluster to release server state. |
| */ |
| |
| static u64 __get_oldest_flush_tid(struct ceph_mds_client *mdsc); |
| static void __kick_flushing_caps(struct ceph_mds_client *mdsc, |
| struct ceph_mds_session *session, |
| struct ceph_inode_info *ci, |
| u64 oldest_flush_tid); |
| |
| /* |
| * Generate readable cap strings for debugging output. |
| */ |
| #define MAX_CAP_STR 20 |
| static char cap_str[MAX_CAP_STR][40]; |
| static DEFINE_SPINLOCK(cap_str_lock); |
| static int last_cap_str; |
| |
| static char *gcap_string(char *s, int c) |
| { |
| if (c & CEPH_CAP_GSHARED) |
| *s++ = 's'; |
| if (c & CEPH_CAP_GEXCL) |
| *s++ = 'x'; |
| if (c & CEPH_CAP_GCACHE) |
| *s++ = 'c'; |
| if (c & CEPH_CAP_GRD) |
| *s++ = 'r'; |
| if (c & CEPH_CAP_GWR) |
| *s++ = 'w'; |
| if (c & CEPH_CAP_GBUFFER) |
| *s++ = 'b'; |
| if (c & CEPH_CAP_GLAZYIO) |
| *s++ = 'l'; |
| return s; |
| } |
| |
| const char *ceph_cap_string(int caps) |
| { |
| int i; |
| char *s; |
| int c; |
| |
| spin_lock(&cap_str_lock); |
| i = last_cap_str++; |
| if (last_cap_str == MAX_CAP_STR) |
| last_cap_str = 0; |
| spin_unlock(&cap_str_lock); |
| |
| s = cap_str[i]; |
| |
| if (caps & CEPH_CAP_PIN) |
| *s++ = 'p'; |
| |
| c = (caps >> CEPH_CAP_SAUTH) & 3; |
| if (c) { |
| *s++ = 'A'; |
| s = gcap_string(s, c); |
| } |
| |
| c = (caps >> CEPH_CAP_SLINK) & 3; |
| if (c) { |
| *s++ = 'L'; |
| s = gcap_string(s, c); |
| } |
| |
| c = (caps >> CEPH_CAP_SXATTR) & 3; |
| if (c) { |
| *s++ = 'X'; |
| s = gcap_string(s, c); |
| } |
| |
| c = caps >> CEPH_CAP_SFILE; |
| if (c) { |
| *s++ = 'F'; |
| s = gcap_string(s, c); |
| } |
| |
| if (s == cap_str[i]) |
| *s++ = '-'; |
| *s = 0; |
| return cap_str[i]; |
| } |
| |
| void ceph_caps_init(struct ceph_mds_client *mdsc) |
| { |
| INIT_LIST_HEAD(&mdsc->caps_list); |
| spin_lock_init(&mdsc->caps_list_lock); |
| } |
| |
| void ceph_caps_finalize(struct ceph_mds_client *mdsc) |
| { |
| struct ceph_cap *cap; |
| |
| spin_lock(&mdsc->caps_list_lock); |
| while (!list_empty(&mdsc->caps_list)) { |
| cap = list_first_entry(&mdsc->caps_list, |
| struct ceph_cap, caps_item); |
| list_del(&cap->caps_item); |
| kmem_cache_free(ceph_cap_cachep, cap); |
| } |
| mdsc->caps_total_count = 0; |
| mdsc->caps_avail_count = 0; |
| mdsc->caps_use_count = 0; |
| mdsc->caps_reserve_count = 0; |
| mdsc->caps_min_count = 0; |
| spin_unlock(&mdsc->caps_list_lock); |
| } |
| |
| void ceph_adjust_min_caps(struct ceph_mds_client *mdsc, int delta) |
| { |
| spin_lock(&mdsc->caps_list_lock); |
| mdsc->caps_min_count += delta; |
| BUG_ON(mdsc->caps_min_count < 0); |
| spin_unlock(&mdsc->caps_list_lock); |
| } |
| |
| void ceph_reserve_caps(struct ceph_mds_client *mdsc, |
| struct ceph_cap_reservation *ctx, int need) |
| { |
| int i; |
| struct ceph_cap *cap; |
| int have; |
| int alloc = 0; |
| LIST_HEAD(newcaps); |
| |
| dout("reserve caps ctx=%p need=%d\n", ctx, need); |
| |
| /* first reserve any caps that are already allocated */ |
| spin_lock(&mdsc->caps_list_lock); |
| if (mdsc->caps_avail_count >= need) |
| have = need; |
| else |
| have = mdsc->caps_avail_count; |
| mdsc->caps_avail_count -= have; |
| mdsc->caps_reserve_count += have; |
| BUG_ON(mdsc->caps_total_count != mdsc->caps_use_count + |
| mdsc->caps_reserve_count + |
| mdsc->caps_avail_count); |
| spin_unlock(&mdsc->caps_list_lock); |
| |
| for (i = have; i < need; i++) { |
| cap = kmem_cache_alloc(ceph_cap_cachep, GFP_NOFS); |
| if (!cap) |
| break; |
| list_add(&cap->caps_item, &newcaps); |
| alloc++; |
| } |
| /* we didn't manage to reserve as much as we needed */ |
| if (have + alloc != need) |
| pr_warn("reserve caps ctx=%p ENOMEM need=%d got=%d\n", |
| ctx, need, have + alloc); |
| |
| spin_lock(&mdsc->caps_list_lock); |
| mdsc->caps_total_count += alloc; |
| mdsc->caps_reserve_count += alloc; |
| list_splice(&newcaps, &mdsc->caps_list); |
| |
| BUG_ON(mdsc->caps_total_count != mdsc->caps_use_count + |
| mdsc->caps_reserve_count + |
| mdsc->caps_avail_count); |
| spin_unlock(&mdsc->caps_list_lock); |
| |
| ctx->count = need; |
| dout("reserve caps ctx=%p %d = %d used + %d resv + %d avail\n", |
| ctx, mdsc->caps_total_count, mdsc->caps_use_count, |
| mdsc->caps_reserve_count, mdsc->caps_avail_count); |
| } |
| |
| int ceph_unreserve_caps(struct ceph_mds_client *mdsc, |
| struct ceph_cap_reservation *ctx) |
| { |
| dout("unreserve caps ctx=%p count=%d\n", ctx, ctx->count); |
| if (ctx->count) { |
| spin_lock(&mdsc->caps_list_lock); |
| BUG_ON(mdsc->caps_reserve_count < ctx->count); |
| mdsc->caps_reserve_count -= ctx->count; |
| mdsc->caps_avail_count += ctx->count; |
| ctx->count = 0; |
| dout("unreserve caps %d = %d used + %d resv + %d avail\n", |
| mdsc->caps_total_count, mdsc->caps_use_count, |
| mdsc->caps_reserve_count, mdsc->caps_avail_count); |
| BUG_ON(mdsc->caps_total_count != mdsc->caps_use_count + |
| mdsc->caps_reserve_count + |
| mdsc->caps_avail_count); |
| spin_unlock(&mdsc->caps_list_lock); |
| } |
| return 0; |
| } |
| |
| struct ceph_cap *ceph_get_cap(struct ceph_mds_client *mdsc, |
| struct ceph_cap_reservation *ctx) |
| { |
| struct ceph_cap *cap = NULL; |
| |
| /* temporary, until we do something about cap import/export */ |
| if (!ctx) { |
| cap = kmem_cache_alloc(ceph_cap_cachep, GFP_NOFS); |
| if (cap) { |
| spin_lock(&mdsc->caps_list_lock); |
| mdsc->caps_use_count++; |
| mdsc->caps_total_count++; |
| spin_unlock(&mdsc->caps_list_lock); |
| } |
| return cap; |
| } |
| |
| spin_lock(&mdsc->caps_list_lock); |
| dout("get_cap ctx=%p (%d) %d = %d used + %d resv + %d avail\n", |
| ctx, ctx->count, mdsc->caps_total_count, mdsc->caps_use_count, |
| mdsc->caps_reserve_count, mdsc->caps_avail_count); |
| BUG_ON(!ctx->count); |
| BUG_ON(ctx->count > mdsc->caps_reserve_count); |
| BUG_ON(list_empty(&mdsc->caps_list)); |
| |
| ctx->count--; |
| mdsc->caps_reserve_count--; |
| mdsc->caps_use_count++; |
| |
| cap = list_first_entry(&mdsc->caps_list, struct ceph_cap, caps_item); |
| list_del(&cap->caps_item); |
| |
| BUG_ON(mdsc->caps_total_count != mdsc->caps_use_count + |
| mdsc->caps_reserve_count + mdsc->caps_avail_count); |
| spin_unlock(&mdsc->caps_list_lock); |
| return cap; |
| } |
| |
| void ceph_put_cap(struct ceph_mds_client *mdsc, struct ceph_cap *cap) |
| { |
| spin_lock(&mdsc->caps_list_lock); |
| dout("put_cap %p %d = %d used + %d resv + %d avail\n", |
| cap, mdsc->caps_total_count, mdsc->caps_use_count, |
| mdsc->caps_reserve_count, mdsc->caps_avail_count); |
| mdsc->caps_use_count--; |
| /* |
| * Keep some preallocated caps around (ceph_min_count), to |
| * avoid lots of free/alloc churn. |
| */ |
| if (mdsc->caps_avail_count >= mdsc->caps_reserve_count + |
| mdsc->caps_min_count) { |
| mdsc->caps_total_count--; |
| kmem_cache_free(ceph_cap_cachep, cap); |
| } else { |
| mdsc->caps_avail_count++; |
| list_add(&cap->caps_item, &mdsc->caps_list); |
| } |
| |
| BUG_ON(mdsc->caps_total_count != mdsc->caps_use_count + |
| mdsc->caps_reserve_count + mdsc->caps_avail_count); |
| spin_unlock(&mdsc->caps_list_lock); |
| } |
| |
| void ceph_reservation_status(struct ceph_fs_client *fsc, |
| int *total, int *avail, int *used, int *reserved, |
| int *min) |
| { |
| struct ceph_mds_client *mdsc = fsc->mdsc; |
| |
| if (total) |
| *total = mdsc->caps_total_count; |
| if (avail) |
| *avail = mdsc->caps_avail_count; |
| if (used) |
| *used = mdsc->caps_use_count; |
| if (reserved) |
| *reserved = mdsc->caps_reserve_count; |
| if (min) |
| *min = mdsc->caps_min_count; |
| } |
| |
| /* |
| * Find ceph_cap for given mds, if any. |
| * |
| * Called with i_ceph_lock held. |
| */ |
| static struct ceph_cap *__get_cap_for_mds(struct ceph_inode_info *ci, int mds) |
| { |
| struct ceph_cap *cap; |
| struct rb_node *n = ci->i_caps.rb_node; |
| |
| while (n) { |
| cap = rb_entry(n, struct ceph_cap, ci_node); |
| if (mds < cap->mds) |
| n = n->rb_left; |
| else if (mds > cap->mds) |
| n = n->rb_right; |
| else |
| return cap; |
| } |
| return NULL; |
| } |
| |
| struct ceph_cap *ceph_get_cap_for_mds(struct ceph_inode_info *ci, int mds) |
| { |
| struct ceph_cap *cap; |
| |
| spin_lock(&ci->i_ceph_lock); |
| cap = __get_cap_for_mds(ci, mds); |
| spin_unlock(&ci->i_ceph_lock); |
| return cap; |
| } |
| |
| /* |
| * Return id of any MDS with a cap, preferably FILE_WR|BUFFER|EXCL, else -1. |
| */ |
| static int __ceph_get_cap_mds(struct ceph_inode_info *ci) |
| { |
| struct ceph_cap *cap; |
| int mds = -1; |
| struct rb_node *p; |
| |
| /* prefer mds with WR|BUFFER|EXCL caps */ |
| for (p = rb_first(&ci->i_caps); p; p = rb_next(p)) { |
| cap = rb_entry(p, struct ceph_cap, ci_node); |
| mds = cap->mds; |
| if (cap->issued & (CEPH_CAP_FILE_WR | |
| CEPH_CAP_FILE_BUFFER | |
| CEPH_CAP_FILE_EXCL)) |
| break; |
| } |
| return mds; |
| } |
| |
| int ceph_get_cap_mds(struct inode *inode) |
| { |
| struct ceph_inode_info *ci = ceph_inode(inode); |
| int mds; |
| spin_lock(&ci->i_ceph_lock); |
| mds = __ceph_get_cap_mds(ceph_inode(inode)); |
| spin_unlock(&ci->i_ceph_lock); |
| return mds; |
| } |
| |
| /* |
| * Called under i_ceph_lock. |
| */ |
| static void __insert_cap_node(struct ceph_inode_info *ci, |
| struct ceph_cap *new) |
| { |
| struct rb_node **p = &ci->i_caps.rb_node; |
| struct rb_node *parent = NULL; |
| struct ceph_cap *cap = NULL; |
| |
| while (*p) { |
| parent = *p; |
| cap = rb_entry(parent, struct ceph_cap, ci_node); |
| if (new->mds < cap->mds) |
| p = &(*p)->rb_left; |
| else if (new->mds > cap->mds) |
| p = &(*p)->rb_right; |
| else |
| BUG(); |
| } |
| |
| rb_link_node(&new->ci_node, parent, p); |
| rb_insert_color(&new->ci_node, &ci->i_caps); |
| } |
| |
| /* |
| * (re)set cap hold timeouts, which control the delayed release |
| * of unused caps back to the MDS. Should be called on cap use. |
| */ |
| static void __cap_set_timeouts(struct ceph_mds_client *mdsc, |
| struct ceph_inode_info *ci) |
| { |
| struct ceph_mount_options *ma = mdsc->fsc->mount_options; |
| |
| ci->i_hold_caps_min = round_jiffies(jiffies + |
| ma->caps_wanted_delay_min * HZ); |
| ci->i_hold_caps_max = round_jiffies(jiffies + |
| ma->caps_wanted_delay_max * HZ); |
| dout("__cap_set_timeouts %p min %lu max %lu\n", &ci->vfs_inode, |
| ci->i_hold_caps_min - jiffies, ci->i_hold_caps_max - jiffies); |
| } |
| |
| /* |
| * (Re)queue cap at the end of the delayed cap release list. |
| * |
| * If I_FLUSH is set, leave the inode at the front of the list. |
| * |
| * Caller holds i_ceph_lock |
| * -> we take mdsc->cap_delay_lock |
| */ |
| static void __cap_delay_requeue(struct ceph_mds_client *mdsc, |
| struct ceph_inode_info *ci) |
| { |
| __cap_set_timeouts(mdsc, ci); |
| dout("__cap_delay_requeue %p flags %d at %lu\n", &ci->vfs_inode, |
| ci->i_ceph_flags, ci->i_hold_caps_max); |
| if (!mdsc->stopping) { |
| spin_lock(&mdsc->cap_delay_lock); |
| if (!list_empty(&ci->i_cap_delay_list)) { |
| if (ci->i_ceph_flags & CEPH_I_FLUSH) |
| goto no_change; |
| list_del_init(&ci->i_cap_delay_list); |
| } |
| list_add_tail(&ci->i_cap_delay_list, &mdsc->cap_delay_list); |
| no_change: |
| spin_unlock(&mdsc->cap_delay_lock); |
| } |
| } |
| |
| /* |
| * Queue an inode for immediate writeback. Mark inode with I_FLUSH, |
| * indicating we should send a cap message to flush dirty metadata |
| * asap, and move to the front of the delayed cap list. |
| */ |
| static void __cap_delay_requeue_front(struct ceph_mds_client *mdsc, |
| struct ceph_inode_info *ci) |
| { |
| dout("__cap_delay_requeue_front %p\n", &ci->vfs_inode); |
| spin_lock(&mdsc->cap_delay_lock); |
| ci->i_ceph_flags |= CEPH_I_FLUSH; |
| if (!list_empty(&ci->i_cap_delay_list)) |
| list_del_init(&ci->i_cap_delay_list); |
| list_add(&ci->i_cap_delay_list, &mdsc->cap_delay_list); |
| spin_unlock(&mdsc->cap_delay_lock); |
| } |
| |
| /* |
| * Cancel delayed work on cap. |
| * |
| * Caller must hold i_ceph_lock. |
| */ |
| static void __cap_delay_cancel(struct ceph_mds_client *mdsc, |
| struct ceph_inode_info *ci) |
| { |
| dout("__cap_delay_cancel %p\n", &ci->vfs_inode); |
| if (list_empty(&ci->i_cap_delay_list)) |
| return; |
| spin_lock(&mdsc->cap_delay_lock); |
| list_del_init(&ci->i_cap_delay_list); |
| spin_unlock(&mdsc->cap_delay_lock); |
| } |
| |
| /* |
| * Common issue checks for add_cap, handle_cap_grant. |
| */ |
| static void __check_cap_issue(struct ceph_inode_info *ci, struct ceph_cap *cap, |
| unsigned issued) |
| { |
| unsigned had = __ceph_caps_issued(ci, NULL); |
| |
| /* |
| * Each time we receive FILE_CACHE anew, we increment |
| * i_rdcache_gen. |
| */ |
| if ((issued & (CEPH_CAP_FILE_CACHE|CEPH_CAP_FILE_LAZYIO)) && |
| (had & (CEPH_CAP_FILE_CACHE|CEPH_CAP_FILE_LAZYIO)) == 0) { |
| ci->i_rdcache_gen++; |
| } |
| |
| /* |
| * If FILE_SHARED is newly issued, mark dir not complete. We don't |
| * know what happened to this directory while we didn't have the cap. |
| * If FILE_SHARED is being revoked, also mark dir not complete. It |
| * stops on-going cached readdir. |
| */ |
| if ((issued & CEPH_CAP_FILE_SHARED) != (had & CEPH_CAP_FILE_SHARED)) { |
| if (issued & CEPH_CAP_FILE_SHARED) |
| ci->i_shared_gen++; |
| if (S_ISDIR(ci->vfs_inode.i_mode)) { |
| dout(" marking %p NOT complete\n", &ci->vfs_inode); |
| __ceph_dir_clear_complete(ci); |
| } |
| } |
| } |
| |
| /* |
| * Add a capability under the given MDS session. |
| * |
| * Caller should hold session snap_rwsem (read) and s_mutex. |
| * |
| * @fmode is the open file mode, if we are opening a file, otherwise |
| * it is < 0. (This is so we can atomically add the cap and add an |
| * open file reference to it.) |
| */ |
| void ceph_add_cap(struct inode *inode, |
| struct ceph_mds_session *session, u64 cap_id, |
| int fmode, unsigned issued, unsigned wanted, |
| unsigned seq, unsigned mseq, u64 realmino, int flags, |
| struct ceph_cap **new_cap) |
| { |
| struct ceph_mds_client *mdsc = ceph_inode_to_client(inode)->mdsc; |
| struct ceph_inode_info *ci = ceph_inode(inode); |
| struct ceph_cap *cap; |
| int mds = session->s_mds; |
| int actual_wanted; |
| |
| dout("add_cap %p mds%d cap %llx %s seq %d\n", inode, |
| session->s_mds, cap_id, ceph_cap_string(issued), seq); |
| |
| /* |
| * If we are opening the file, include file mode wanted bits |
| * in wanted. |
| */ |
| if (fmode >= 0) |
| wanted |= ceph_caps_for_mode(fmode); |
| |
| cap = __get_cap_for_mds(ci, mds); |
| if (!cap) { |
| cap = *new_cap; |
| *new_cap = NULL; |
| |
| cap->issued = 0; |
| cap->implemented = 0; |
| cap->mds = mds; |
| cap->mds_wanted = 0; |
| cap->mseq = 0; |
| |
| cap->ci = ci; |
| __insert_cap_node(ci, cap); |
| |
| /* add to session cap list */ |
| cap->session = session; |
| spin_lock(&session->s_cap_lock); |
| list_add_tail(&cap->session_caps, &session->s_caps); |
| session->s_nr_caps++; |
| spin_unlock(&session->s_cap_lock); |
| } else { |
| /* |
| * auth mds of the inode changed. we received the cap export |
| * message, but still haven't received the cap import message. |
| * handle_cap_export() updated the new auth MDS' cap. |
| * |
| * "ceph_seq_cmp(seq, cap->seq) <= 0" means we are processing |
| * a message that was send before the cap import message. So |
| * don't remove caps. |
| */ |
| if (ceph_seq_cmp(seq, cap->seq) <= 0) { |
| WARN_ON(cap != ci->i_auth_cap); |
| WARN_ON(cap->cap_id != cap_id); |
| seq = cap->seq; |
| mseq = cap->mseq; |
| issued |= cap->issued; |
| flags |= CEPH_CAP_FLAG_AUTH; |
| } |
| } |
| |
| if (!ci->i_snap_realm) { |
| /* |
| * add this inode to the appropriate snap realm |
| */ |
| struct ceph_snap_realm *realm = ceph_lookup_snap_realm(mdsc, |
| realmino); |
| if (realm) { |
| spin_lock(&realm->inodes_with_caps_lock); |
| ci->i_snap_realm = realm; |
| list_add(&ci->i_snap_realm_item, |
| &realm->inodes_with_caps); |
| spin_unlock(&realm->inodes_with_caps_lock); |
| } else { |
| pr_err("ceph_add_cap: couldn't find snap realm %llx\n", |
| realmino); |
| WARN_ON(!realm); |
| } |
| } |
| |
| __check_cap_issue(ci, cap, issued); |
| |
| /* |
| * If we are issued caps we don't want, or the mds' wanted |
| * value appears to be off, queue a check so we'll release |
| * later and/or update the mds wanted value. |
| */ |
| actual_wanted = __ceph_caps_wanted(ci); |
| if ((wanted & ~actual_wanted) || |
| (issued & ~actual_wanted & CEPH_CAP_ANY_WR)) { |
| dout(" issued %s, mds wanted %s, actual %s, queueing\n", |
| ceph_cap_string(issued), ceph_cap_string(wanted), |
| ceph_cap_string(actual_wanted)); |
| __cap_delay_requeue(mdsc, ci); |
| } |
| |
| if (flags & CEPH_CAP_FLAG_AUTH) { |
| if (!ci->i_auth_cap || |
| ceph_seq_cmp(ci->i_auth_cap->mseq, mseq) < 0) { |
| ci->i_auth_cap = cap; |
| cap->mds_wanted = wanted; |
| } |
| } else { |
| WARN_ON(ci->i_auth_cap == cap); |
| } |
| |
| dout("add_cap inode %p (%llx.%llx) cap %p %s now %s seq %d mds%d\n", |
| inode, ceph_vinop(inode), cap, ceph_cap_string(issued), |
| ceph_cap_string(issued|cap->issued), seq, mds); |
| cap->cap_id = cap_id; |
| cap->issued = issued; |
| cap->implemented |= issued; |
| if (ceph_seq_cmp(mseq, cap->mseq) > 0) |
| cap->mds_wanted = wanted; |
| else |
| cap->mds_wanted |= wanted; |
| cap->seq = seq; |
| cap->issue_seq = seq; |
| cap->mseq = mseq; |
| cap->cap_gen = session->s_cap_gen; |
| |
| if (fmode >= 0) |
| __ceph_get_fmode(ci, fmode); |
| } |
| |
| /* |
| * Return true if cap has not timed out and belongs to the current |
| * generation of the MDS session (i.e. has not gone 'stale' due to |
| * us losing touch with the mds). |
| */ |
| static int __cap_is_valid(struct ceph_cap *cap) |
| { |
| unsigned long ttl; |
| u32 gen; |
| |
| spin_lock(&cap->session->s_gen_ttl_lock); |
| gen = cap->session->s_cap_gen; |
| ttl = cap->session->s_cap_ttl; |
| spin_unlock(&cap->session->s_gen_ttl_lock); |
| |
| if (cap->cap_gen < gen || time_after_eq(jiffies, ttl)) { |
| dout("__cap_is_valid %p cap %p issued %s " |
| "but STALE (gen %u vs %u)\n", &cap->ci->vfs_inode, |
| cap, ceph_cap_string(cap->issued), cap->cap_gen, gen); |
| return 0; |
| } |
| |
| return 1; |
| } |
| |
| /* |
| * Return set of valid cap bits issued to us. Note that caps time |
| * out, and may be invalidated in bulk if the client session times out |
| * and session->s_cap_gen is bumped. |
| */ |
| int __ceph_caps_issued(struct ceph_inode_info *ci, int *implemented) |
| { |
| int have = ci->i_snap_caps; |
| struct ceph_cap *cap; |
| struct rb_node *p; |
| |
| if (implemented) |
| *implemented = 0; |
| for (p = rb_first(&ci->i_caps); p; p = rb_next(p)) { |
| cap = rb_entry(p, struct ceph_cap, ci_node); |
| if (!__cap_is_valid(cap)) |
| continue; |
| dout("__ceph_caps_issued %p cap %p issued %s\n", |
| &ci->vfs_inode, cap, ceph_cap_string(cap->issued)); |
| have |= cap->issued; |
| if (implemented) |
| *implemented |= cap->implemented; |
| } |
| /* |
| * exclude caps issued by non-auth MDS, but are been revoking |
| * by the auth MDS. The non-auth MDS should be revoking/exporting |
| * these caps, but the message is delayed. |
| */ |
| if (ci->i_auth_cap) { |
| cap = ci->i_auth_cap; |
| have &= ~cap->implemented | cap->issued; |
| } |
| return have; |
| } |
| |
| /* |
| * Get cap bits issued by caps other than @ocap |
| */ |
| int __ceph_caps_issued_other(struct ceph_inode_info *ci, struct ceph_cap *ocap) |
| { |
| int have = ci->i_snap_caps; |
| struct ceph_cap *cap; |
| struct rb_node *p; |
| |
| for (p = rb_first(&ci->i_caps); p; p = rb_next(p)) { |
| cap = rb_entry(p, struct ceph_cap, ci_node); |
| if (cap == ocap) |
| continue; |
| if (!__cap_is_valid(cap)) |
| continue; |
| have |= cap->issued; |
| } |
| return have; |
| } |
| |
| /* |
| * Move a cap to the end of the LRU (oldest caps at list head, newest |
| * at list tail). |
| */ |
| static void __touch_cap(struct ceph_cap *cap) |
| { |
| struct ceph_mds_session *s = cap->session; |
| |
| spin_lock(&s->s_cap_lock); |
| if (!s->s_cap_iterator) { |
| dout("__touch_cap %p cap %p mds%d\n", &cap->ci->vfs_inode, cap, |
| s->s_mds); |
| list_move_tail(&cap->session_caps, &s->s_caps); |
| } else { |
| dout("__touch_cap %p cap %p mds%d NOP, iterating over caps\n", |
| &cap->ci->vfs_inode, cap, s->s_mds); |
| } |
| spin_unlock(&s->s_cap_lock); |
| } |
| |
| /* |
| * Check if we hold the given mask. If so, move the cap(s) to the |
| * front of their respective LRUs. (This is the preferred way for |
| * callers to check for caps they want.) |
| */ |
| int __ceph_caps_issued_mask(struct ceph_inode_info *ci, int mask, int touch) |
| { |
| struct ceph_cap *cap; |
| struct rb_node *p; |
| int have = ci->i_snap_caps; |
| |
| if ((have & mask) == mask) { |
| dout("__ceph_caps_issued_mask %p snap issued %s" |
| " (mask %s)\n", &ci->vfs_inode, |
| ceph_cap_string(have), |
| ceph_cap_string(mask)); |
| return 1; |
| } |
| |
| for (p = rb_first(&ci->i_caps); p; p = rb_next(p)) { |
| cap = rb_entry(p, struct ceph_cap, ci_node); |
| if (!__cap_is_valid(cap)) |
| continue; |
| if ((cap->issued & mask) == mask) { |
| dout("__ceph_caps_issued_mask %p cap %p issued %s" |
| " (mask %s)\n", &ci->vfs_inode, cap, |
| ceph_cap_string(cap->issued), |
| ceph_cap_string(mask)); |
| if (touch) |
| __touch_cap(cap); |
| return 1; |
| } |
| |
| /* does a combination of caps satisfy mask? */ |
| have |= cap->issued; |
| if ((have & mask) == mask) { |
| dout("__ceph_caps_issued_mask %p combo issued %s" |
| " (mask %s)\n", &ci->vfs_inode, |
| ceph_cap_string(cap->issued), |
| ceph_cap_string(mask)); |
| if (touch) { |
| struct rb_node *q; |
| |
| /* touch this + preceding caps */ |
| __touch_cap(cap); |
| for (q = rb_first(&ci->i_caps); q != p; |
| q = rb_next(q)) { |
| cap = rb_entry(q, struct ceph_cap, |
| ci_node); |
| if (!__cap_is_valid(cap)) |
| continue; |
| __touch_cap(cap); |
| } |
| } |
| return 1; |
| } |
| } |
| |
| return 0; |
| } |
| |
| /* |
| * Return true if mask caps are currently being revoked by an MDS. |
| */ |
| int __ceph_caps_revoking_other(struct ceph_inode_info *ci, |
| struct ceph_cap *ocap, int mask) |
| { |
| struct ceph_cap *cap; |
| struct rb_node *p; |
| |
| for (p = rb_first(&ci->i_caps); p; p = rb_next(p)) { |
| cap = rb_entry(p, struct ceph_cap, ci_node); |
| if (cap != ocap && |
| (cap->implemented & ~cap->issued & mask)) |
| return 1; |
| } |
| return 0; |
| } |
| |
| int ceph_caps_revoking(struct ceph_inode_info *ci, int mask) |
| { |
| struct inode *inode = &ci->vfs_inode; |
| int ret; |
| |
| spin_lock(&ci->i_ceph_lock); |
| ret = __ceph_caps_revoking_other(ci, NULL, mask); |
| spin_unlock(&ci->i_ceph_lock); |
| dout("ceph_caps_revoking %p %s = %d\n", inode, |
| ceph_cap_string(mask), ret); |
| return ret; |
| } |
| |
| int __ceph_caps_used(struct ceph_inode_info *ci) |
| { |
| int used = 0; |
| if (ci->i_pin_ref) |
| used |= CEPH_CAP_PIN; |
| if (ci->i_rd_ref) |
| used |= CEPH_CAP_FILE_RD; |
| if (ci->i_rdcache_ref || |
| (!S_ISDIR(ci->vfs_inode.i_mode) && /* ignore readdir cache */ |
| ci->vfs_inode.i_data.nrpages)) |
| used |= CEPH_CAP_FILE_CACHE; |
| if (ci->i_wr_ref) |
| used |= CEPH_CAP_FILE_WR; |
| if (ci->i_wb_ref || ci->i_wrbuffer_ref) |
| used |= CEPH_CAP_FILE_BUFFER; |
| return used; |
| } |
| |
| /* |
| * wanted, by virtue of open file modes |
| */ |
| int __ceph_caps_file_wanted(struct ceph_inode_info *ci) |
| { |
| int i, bits = 0; |
| for (i = 0; i < CEPH_FILE_MODE_BITS; i++) { |
| if (ci->i_nr_by_mode[i]) |
| bits |= 1 << i; |
| } |
| if (bits == 0) |
| return 0; |
| return ceph_caps_for_mode(bits >> 1); |
| } |
| |
| /* |
| * Return caps we have registered with the MDS(s) as 'wanted'. |
| */ |
| int __ceph_caps_mds_wanted(struct ceph_inode_info *ci, bool check) |
| { |
| struct ceph_cap *cap; |
| struct rb_node *p; |
| int mds_wanted = 0; |
| |
| for (p = rb_first(&ci->i_caps); p; p = rb_next(p)) { |
| cap = rb_entry(p, struct ceph_cap, ci_node); |
| if (check && !__cap_is_valid(cap)) |
| continue; |
| if (cap == ci->i_auth_cap) |
| mds_wanted |= cap->mds_wanted; |
| else |
| mds_wanted |= (cap->mds_wanted & ~CEPH_CAP_ANY_FILE_WR); |
| } |
| return mds_wanted; |
| } |
| |
| /* |
| * called under i_ceph_lock |
| */ |
| static int __ceph_is_any_caps(struct ceph_inode_info *ci) |
| { |
| return !RB_EMPTY_ROOT(&ci->i_caps); |
| } |
| |
| int ceph_is_any_caps(struct inode *inode) |
| { |
| struct ceph_inode_info *ci = ceph_inode(inode); |
| int ret; |
| |
| spin_lock(&ci->i_ceph_lock); |
| ret = __ceph_is_any_caps(ci); |
| spin_unlock(&ci->i_ceph_lock); |
| |
| return ret; |
| } |
| |
| static void drop_inode_snap_realm(struct ceph_inode_info *ci) |
| { |
| struct ceph_snap_realm *realm = ci->i_snap_realm; |
| spin_lock(&realm->inodes_with_caps_lock); |
| list_del_init(&ci->i_snap_realm_item); |
| ci->i_snap_realm_counter++; |
| ci->i_snap_realm = NULL; |
| spin_unlock(&realm->inodes_with_caps_lock); |
| ceph_put_snap_realm(ceph_sb_to_client(ci->vfs_inode.i_sb)->mdsc, |
| realm); |
| } |
| |
| /* |
| * Remove a cap. Take steps to deal with a racing iterate_session_caps. |
| * |
| * caller should hold i_ceph_lock. |
| * caller will not hold session s_mutex if called from destroy_inode. |
| */ |
| void __ceph_remove_cap(struct ceph_cap *cap, bool queue_release) |
| { |
| struct ceph_mds_session *session = cap->session; |
| struct ceph_inode_info *ci = cap->ci; |
| struct ceph_mds_client *mdsc = |
| ceph_sb_to_client(ci->vfs_inode.i_sb)->mdsc; |
| int removed = 0; |
| |
| dout("__ceph_remove_cap %p from %p\n", cap, &ci->vfs_inode); |
| |
| /* remove from session list */ |
| spin_lock(&session->s_cap_lock); |
| if (session->s_cap_iterator == cap) { |
| /* not yet, we are iterating over this very cap */ |
| dout("__ceph_remove_cap delaying %p removal from session %p\n", |
| cap, cap->session); |
| } else { |
| list_del_init(&cap->session_caps); |
| session->s_nr_caps--; |
| cap->session = NULL; |
| removed = 1; |
| } |
| /* protect backpointer with s_cap_lock: see iterate_session_caps */ |
| cap->ci = NULL; |
| |
| /* |
| * s_cap_reconnect is protected by s_cap_lock. no one changes |
| * s_cap_gen while session is in the reconnect state. |
| */ |
| if (queue_release && |
| (!session->s_cap_reconnect || cap->cap_gen == session->s_cap_gen)) { |
| cap->queue_release = 1; |
| if (removed) { |
| list_add_tail(&cap->session_caps, |
| &session->s_cap_releases); |
| session->s_num_cap_releases++; |
| removed = 0; |
| } |
| } else { |
| cap->queue_release = 0; |
| } |
| cap->cap_ino = ci->i_vino.ino; |
| |
| spin_unlock(&session->s_cap_lock); |
| |
| /* remove from inode list */ |
| rb_erase(&cap->ci_node, &ci->i_caps); |
| if (ci->i_auth_cap == cap) |
| ci->i_auth_cap = NULL; |
| |
| if (removed) |
| ceph_put_cap(mdsc, cap); |
| |
| /* when reconnect denied, we remove session caps forcibly, |
| * i_wr_ref can be non-zero. If there are ongoing write, |
| * keep i_snap_realm. |
| */ |
| if (!__ceph_is_any_caps(ci) && ci->i_wr_ref == 0 && ci->i_snap_realm) |
| drop_inode_snap_realm(ci); |
| |
| if (!__ceph_is_any_real_caps(ci)) |
| __cap_delay_cancel(mdsc, ci); |
| } |
| |
| struct cap_msg_args { |
| struct ceph_mds_session *session; |
| u64 ino, cid, follows; |
| u64 flush_tid, oldest_flush_tid, size, max_size; |
| u64 xattr_version; |
| struct ceph_buffer *xattr_buf; |
| struct timespec atime, mtime, ctime; |
| int op, caps, wanted, dirty; |
| u32 seq, issue_seq, mseq, time_warp_seq; |
| u32 flags; |
| kuid_t uid; |
| kgid_t gid; |
| umode_t mode; |
| bool inline_data; |
| }; |
| |
| /* |
| * Build and send a cap message to the given MDS. |
| * |
| * Caller should be holding s_mutex. |
| */ |
| static int send_cap_msg(struct cap_msg_args *arg) |
| { |
| struct ceph_mds_caps *fc; |
| struct ceph_msg *msg; |
| void *p; |
| size_t extra_len; |
| struct timespec zerotime = {0}; |
| struct ceph_osd_client *osdc = &arg->session->s_mdsc->fsc->client->osdc; |
| |
| dout("send_cap_msg %s %llx %llx caps %s wanted %s dirty %s" |
| " seq %u/%u tid %llu/%llu mseq %u follows %lld size %llu/%llu" |
| " xattr_ver %llu xattr_len %d\n", ceph_cap_op_name(arg->op), |
| arg->cid, arg->ino, ceph_cap_string(arg->caps), |
| ceph_cap_string(arg->wanted), ceph_cap_string(arg->dirty), |
| arg->seq, arg->issue_seq, arg->flush_tid, arg->oldest_flush_tid, |
| arg->mseq, arg->follows, arg->size, arg->max_size, |
| arg->xattr_version, |
| arg->xattr_buf ? (int)arg->xattr_buf->vec.iov_len : 0); |
| |
| /* flock buffer size + inline version + inline data size + |
| * osd_epoch_barrier + oldest_flush_tid */ |
| extra_len = 4 + 8 + 4 + 4 + 8 + 4 + 4 + 4 + 8 + 8 + 4; |
| msg = ceph_msg_new(CEPH_MSG_CLIENT_CAPS, sizeof(*fc) + extra_len, |
| GFP_NOFS, false); |
| if (!msg) |
| return -ENOMEM; |
| |
| msg->hdr.version = cpu_to_le16(10); |
| msg->hdr.tid = cpu_to_le64(arg->flush_tid); |
| |
| fc = msg->front.iov_base; |
| memset(fc, 0, sizeof(*fc)); |
| |
| fc->cap_id = cpu_to_le64(arg->cid); |
| fc->op = cpu_to_le32(arg->op); |
| fc->seq = cpu_to_le32(arg->seq); |
| fc->issue_seq = cpu_to_le32(arg->issue_seq); |
| fc->migrate_seq = cpu_to_le32(arg->mseq); |
| fc->caps = cpu_to_le32(arg->caps); |
| fc->wanted = cpu_to_le32(arg->wanted); |
| fc->dirty = cpu_to_le32(arg->dirty); |
| fc->ino = cpu_to_le64(arg->ino); |
| fc->snap_follows = cpu_to_le64(arg->follows); |
| |
| fc->size = cpu_to_le64(arg->size); |
| fc->max_size = cpu_to_le64(arg->max_size); |
| ceph_encode_timespec(&fc->mtime, &arg->mtime); |
| ceph_encode_timespec(&fc->atime, &arg->atime); |
| ceph_encode_timespec(&fc->ctime, &arg->ctime); |
| fc->time_warp_seq = cpu_to_le32(arg->time_warp_seq); |
| |
| fc->uid = cpu_to_le32(from_kuid(&init_user_ns, arg->uid)); |
| fc->gid = cpu_to_le32(from_kgid(&init_user_ns, arg->gid)); |
| fc->mode = cpu_to_le32(arg->mode); |
| |
| fc->xattr_version = cpu_to_le64(arg->xattr_version); |
| if (arg->xattr_buf) { |
| msg->middle = ceph_buffer_get(arg->xattr_buf); |
| fc->xattr_len = cpu_to_le32(arg->xattr_buf->vec.iov_len); |
| msg->hdr.middle_len = cpu_to_le32(arg->xattr_buf->vec.iov_len); |
| } |
| |
| p = fc + 1; |
| /* flock buffer size (version 2) */ |
| ceph_encode_32(&p, 0); |
| /* inline version (version 4) */ |
| ceph_encode_64(&p, arg->inline_data ? 0 : CEPH_INLINE_NONE); |
| /* inline data size */ |
| ceph_encode_32(&p, 0); |
| /* |
| * osd_epoch_barrier (version 5) |
| * The epoch_barrier is protected osdc->lock, so READ_ONCE here in |
| * case it was recently changed |
| */ |
| ceph_encode_32(&p, READ_ONCE(osdc->epoch_barrier)); |
| /* oldest_flush_tid (version 6) */ |
| ceph_encode_64(&p, arg->oldest_flush_tid); |
| |
| /* |
| * caller_uid/caller_gid (version 7) |
| * |
| * Currently, we don't properly track which caller dirtied the caps |
| * last, and force a flush of them when there is a conflict. For now, |
| * just set this to 0:0, to emulate how the MDS has worked up to now. |
| */ |
| ceph_encode_32(&p, 0); |
| ceph_encode_32(&p, 0); |
| |
| /* pool namespace (version 8) (mds always ignores this) */ |
| ceph_encode_32(&p, 0); |
| |
| /* |
| * btime and change_attr (version 9) |
| * |
| * We just zero these out for now, as the MDS ignores them unless |
| * the requisite feature flags are set (which we don't do yet). |
| */ |
| ceph_encode_timespec(p, &zerotime); |
| p += sizeof(struct ceph_timespec); |
| ceph_encode_64(&p, 0); |
| |
| /* Advisory flags (version 10) */ |
| ceph_encode_32(&p, arg->flags); |
| |
| ceph_con_send(&arg->session->s_con, msg); |
| return 0; |
| } |
| |
| /* |
| * Queue cap releases when an inode is dropped from our cache. Since |
| * inode is about to be destroyed, there is no need for i_ceph_lock. |
| */ |
| void ceph_queue_caps_release(struct inode *inode) |
| { |
| struct ceph_inode_info *ci = ceph_inode(inode); |
| struct rb_node *p; |
| |
| p = rb_first(&ci->i_caps); |
| while (p) { |
| struct ceph_cap *cap = rb_entry(p, struct ceph_cap, ci_node); |
| p = rb_next(p); |
| __ceph_remove_cap(cap, true); |
| } |
| } |
| |
| /* |
| * Send a cap msg on the given inode. Update our caps state, then |
| * drop i_ceph_lock and send the message. |
| * |
| * Make note of max_size reported/requested from mds, revoked caps |
| * that have now been implemented. |
| * |
| * Make half-hearted attempt ot to invalidate page cache if we are |
| * dropping RDCACHE. Note that this will leave behind locked pages |
| * that we'll then need to deal with elsewhere. |
| * |
| * Return non-zero if delayed release, or we experienced an error |
| * such that the caller should requeue + retry later. |
| * |
| * called with i_ceph_lock, then drops it. |
| * caller should hold snap_rwsem (read), s_mutex. |
| */ |
| static int __send_cap(struct ceph_mds_client *mdsc, struct ceph_cap *cap, |
| int op, bool sync, int used, int want, int retain, |
| int flushing, u64 flush_tid, u64 oldest_flush_tid) |
| __releases(cap->ci->i_ceph_lock) |
| { |
| struct ceph_inode_info *ci = cap->ci; |
| struct inode *inode = &ci->vfs_inode; |
| struct cap_msg_args arg; |
| int held, revoking, dropping; |
| int wake = 0; |
| int delayed = 0; |
| int ret; |
| |
| held = cap->issued | cap->implemented; |
| revoking = cap->implemented & ~cap->issued; |
| retain &= ~revoking; |
| dropping = cap->issued & ~retain; |
| |
| dout("__send_cap %p cap %p session %p %s -> %s (revoking %s)\n", |
| inode, cap, cap->session, |
| ceph_cap_string(held), ceph_cap_string(held & retain), |
| ceph_cap_string(revoking)); |
| BUG_ON((retain & CEPH_CAP_PIN) == 0); |
| |
| arg.session = cap->session; |
| |
| /* don't release wanted unless we've waited a bit. */ |
| if ((ci->i_ceph_flags & CEPH_I_NODELAY) == 0 && |
| time_before(jiffies, ci->i_hold_caps_min)) { |
| dout(" delaying issued %s -> %s, wanted %s -> %s on send\n", |
| ceph_cap_string(cap->issued), |
| ceph_cap_string(cap->issued & retain), |
| ceph_cap_string(cap->mds_wanted), |
| ceph_cap_string(want)); |
| want |= cap->mds_wanted; |
| retain |= cap->issued; |
| delayed = 1; |
| } |
| ci->i_ceph_flags &= ~(CEPH_I_NODELAY | CEPH_I_FLUSH); |
| if (want & ~cap->mds_wanted) { |
| /* user space may open/close single file frequently. |
| * This avoids droping mds_wanted immediately after |
| * requesting new mds_wanted. |
| */ |
| __cap_set_timeouts(mdsc, ci); |
| } |
| |
| cap->issued &= retain; /* drop bits we don't want */ |
| if (cap->implemented & ~cap->issued) { |
| /* |
| * Wake up any waiters on wanted -> needed transition. |
| * This is due to the weird transition from buffered |
| * to sync IO... we need to flush dirty pages _before_ |
| * allowing sync writes to avoid reordering. |
| */ |
| wake = 1; |
| } |
| cap->implemented &= cap->issued | used; |
| cap->mds_wanted = want; |
| |
| arg.ino = ceph_vino(inode).ino; |
| arg.cid = cap->cap_id; |
| arg.follows = flushing ? ci->i_head_snapc->seq : 0; |
| arg.flush_tid = flush_tid; |
| arg.oldest_flush_tid = oldest_flush_tid; |
| |
| arg.size = inode->i_size; |
| ci->i_reported_size = arg.size; |
| arg.max_size = ci->i_wanted_max_size; |
| ci->i_requested_max_size = arg.max_size; |
| |
| if (flushing & CEPH_CAP_XATTR_EXCL) { |
| __ceph_build_xattrs_blob(ci); |
| arg.xattr_version = ci->i_xattrs.version; |
| arg.xattr_buf = ci->i_xattrs.blob; |
| } else { |
| arg.xattr_buf = NULL; |
| } |
| |
| arg.mtime = inode->i_mtime; |
| arg.atime = inode->i_atime; |
| arg.ctime = inode->i_ctime; |
| |
| arg.op = op; |
| arg.caps = cap->implemented; |
| arg.wanted = want; |
| arg.dirty = flushing; |
| |
| arg.seq = cap->seq; |
| arg.issue_seq = cap->issue_seq; |
| arg.mseq = cap->mseq; |
| arg.time_warp_seq = ci->i_time_warp_seq; |
| |
| arg.uid = inode->i_uid; |
| arg.gid = inode->i_gid; |
| arg.mode = inode->i_mode; |
| |
| arg.inline_data = ci->i_inline_version != CEPH_INLINE_NONE; |
| if (list_empty(&ci->i_cap_snaps)) |
| arg.flags = CEPH_CLIENT_CAPS_NO_CAPSNAP; |
| else |
| arg.flags = CEPH_CLIENT_CAPS_PENDING_CAPSNAP; |
| if (sync) |
| arg.flags |= CEPH_CLIENT_CAPS_SYNC; |
| |
| spin_unlock(&ci->i_ceph_lock); |
| |
| ret = send_cap_msg(&arg); |
| if (ret < 0) { |
| dout("error sending cap msg, must requeue %p\n", inode); |
| delayed = 1; |
| } |
| |
| if (wake) |
| wake_up_all(&ci->i_cap_wq); |
| |
| return delayed; |
| } |
| |
| static inline int __send_flush_snap(struct inode *inode, |
| struct ceph_mds_session *session, |
| struct ceph_cap_snap *capsnap, |
| u32 mseq, u64 oldest_flush_tid) |
| { |
| struct cap_msg_args arg; |
| |
| arg.session = session; |
| arg.ino = ceph_vino(inode).ino; |
| arg.cid = 0; |
| arg.follows = capsnap->follows; |
| arg.flush_tid = capsnap->cap_flush.tid; |
| arg.oldest_flush_tid = oldest_flush_tid; |
| |
| arg.size = capsnap->size; |
| arg.max_size = 0; |
| arg.xattr_version = capsnap->xattr_version; |
| arg.xattr_buf = capsnap->xattr_blob; |
| |
| arg.atime = capsnap->atime; |
| arg.mtime = capsnap->mtime; |
| arg.ctime = capsnap->ctime; |
| |
| arg.op = CEPH_CAP_OP_FLUSHSNAP; |
| arg.caps = capsnap->issued; |
| arg.wanted = 0; |
| arg.dirty = capsnap->dirty; |
| |
| arg.seq = 0; |
| arg.issue_seq = 0; |
| arg.mseq = mseq; |
| arg.time_warp_seq = capsnap->time_warp_seq; |
| |
| arg.uid = capsnap->uid; |
| arg.gid = capsnap->gid; |
| arg.mode = capsnap->mode; |
| |
| arg.inline_data = capsnap->inline_data; |
| arg.flags = 0; |
| |
| return send_cap_msg(&arg); |
| } |
| |
| /* |
| * When a snapshot is taken, clients accumulate dirty metadata on |
| * inodes with capabilities in ceph_cap_snaps to describe the file |
| * state at the time the snapshot was taken. This must be flushed |
| * asynchronously back to the MDS once sync writes complete and dirty |
| * data is written out. |
| * |
| * Called under i_ceph_lock. Takes s_mutex as needed. |
| */ |
| static void __ceph_flush_snaps(struct ceph_inode_info *ci, |
| struct ceph_mds_session *session) |
| __releases(ci->i_ceph_lock) |
| __acquires(ci->i_ceph_lock) |
| { |
| struct inode *inode = &ci->vfs_inode; |
| struct ceph_mds_client *mdsc = session->s_mdsc; |
| struct ceph_cap_snap *capsnap; |
| u64 oldest_flush_tid = 0; |
| u64 first_tid = 1, last_tid = 0; |
| |
| dout("__flush_snaps %p session %p\n", inode, session); |
| |
| list_for_each_entry(capsnap, &ci->i_cap_snaps, ci_item) { |
| /* |
| * we need to wait for sync writes to complete and for dirty |
| * pages to be written out. |
| */ |
| if (capsnap->dirty_pages || capsnap->writing) |
| break; |
| |
| /* should be removed by ceph_try_drop_cap_snap() */ |
| BUG_ON(!capsnap->need_flush); |
| |
| /* only flush each capsnap once */ |
| if (capsnap->cap_flush.tid > 0) { |
| dout(" already flushed %p, skipping\n", capsnap); |
| continue; |
| } |
| |
| spin_lock(&mdsc->cap_dirty_lock); |
| capsnap->cap_flush.tid = ++mdsc->last_cap_flush_tid; |
| list_add_tail(&capsnap->cap_flush.g_list, |
| &mdsc->cap_flush_list); |
| if (oldest_flush_tid == 0) |
| oldest_flush_tid = __get_oldest_flush_tid(mdsc); |
| if (list_empty(&ci->i_flushing_item)) { |
| list_add_tail(&ci->i_flushing_item, |
| &session->s_cap_flushing); |
| } |
| spin_unlock(&mdsc->cap_dirty_lock); |
| |
| list_add_tail(&capsnap->cap_flush.i_list, |
| &ci->i_cap_flush_list); |
| |
| if (first_tid == 1) |
| first_tid = capsnap->cap_flush.tid; |
| last_tid = capsnap->cap_flush.tid; |
| } |
| |
| ci->i_ceph_flags &= ~CEPH_I_FLUSH_SNAPS; |
| |
| while (first_tid <= last_tid) { |
| struct ceph_cap *cap = ci->i_auth_cap; |
| struct ceph_cap_flush *cf; |
| int ret; |
| |
| if (!(cap && cap->session == session)) { |
| dout("__flush_snaps %p auth cap %p not mds%d, " |
| "stop\n", inode, cap, session->s_mds); |
| break; |
| } |
| |
| ret = -ENOENT; |
| list_for_each_entry(cf, &ci->i_cap_flush_list, i_list) { |
| if (cf->tid >= first_tid) { |
| ret = 0; |
| break; |
| } |
| } |
| if (ret < 0) |
| break; |
| |
| first_tid = cf->tid + 1; |
| |
| capsnap = container_of(cf, struct ceph_cap_snap, cap_flush); |
| refcount_inc(&capsnap->nref); |
| spin_unlock(&ci->i_ceph_lock); |
| |
| dout("__flush_snaps %p capsnap %p tid %llu %s\n", |
| inode, capsnap, cf->tid, ceph_cap_string(capsnap->dirty)); |
| |
| ret = __send_flush_snap(inode, session, capsnap, cap->mseq, |
| oldest_flush_tid); |
| if (ret < 0) { |
| pr_err("__flush_snaps: error sending cap flushsnap, " |
| "ino (%llx.%llx) tid %llu follows %llu\n", |
| ceph_vinop(inode), cf->tid, capsnap->follows); |
| } |
| |
| ceph_put_cap_snap(capsnap); |
| spin_lock(&ci->i_ceph_lock); |
| } |
| } |
| |
| void ceph_flush_snaps(struct ceph_inode_info *ci, |
| struct ceph_mds_session **psession) |
| { |
| struct inode *inode = &ci->vfs_inode; |
| struct ceph_mds_client *mdsc = ceph_inode_to_client(inode)->mdsc; |
| struct ceph_mds_session *session = NULL; |
| int mds; |
| |
| dout("ceph_flush_snaps %p\n", inode); |
| if (psession) |
| session = *psession; |
| retry: |
| spin_lock(&ci->i_ceph_lock); |
| if (!(ci->i_ceph_flags & CEPH_I_FLUSH_SNAPS)) { |
| dout(" no capsnap needs flush, doing nothing\n"); |
| goto out; |
| } |
| if (!ci->i_auth_cap) { |
| dout(" no auth cap (migrating?), doing nothing\n"); |
| goto out; |
| } |
| |
| mds = ci->i_auth_cap->session->s_mds; |
| if (session && session->s_mds != mds) { |
| dout(" oops, wrong session %p mutex\n", session); |
| mutex_unlock(&session->s_mutex); |
| ceph_put_mds_session(session); |
| session = NULL; |
| } |
| if (!session) { |
| spin_unlock(&ci->i_ceph_lock); |
| mutex_lock(&mdsc->mutex); |
| session = __ceph_lookup_mds_session(mdsc, mds); |
| mutex_unlock(&mdsc->mutex); |
| if (session) { |
| dout(" inverting session/ino locks on %p\n", session); |
| mutex_lock(&session->s_mutex); |
| } |
| goto retry; |
| } |
| |
| // make sure flushsnap messages are sent in proper order. |
| if (ci->i_ceph_flags & CEPH_I_KICK_FLUSH) { |
| __kick_flushing_caps(mdsc, session, ci, 0); |
| ci->i_ceph_flags &= ~CEPH_I_KICK_FLUSH; |
| } |
| |
| __ceph_flush_snaps(ci, session); |
| out: |
| spin_unlock(&ci->i_ceph_lock); |
| |
| if (psession) { |
| *psession = session; |
| } else if (session) { |
| mutex_unlock(&session->s_mutex); |
| ceph_put_mds_session(session); |
| } |
| /* we flushed them all; remove this inode from the queue */ |
| spin_lock(&mdsc->snap_flush_lock); |
| list_del_init(&ci->i_snap_flush_item); |
| spin_unlock(&mdsc->snap_flush_lock); |
| } |
| |
| /* |
| * Mark caps dirty. If inode is newly dirty, return the dirty flags. |
| * Caller is then responsible for calling __mark_inode_dirty with the |
| * returned flags value. |
| */ |
| int __ceph_mark_dirty_caps(struct ceph_inode_info *ci, int mask, |
| struct ceph_cap_flush **pcf) |
| { |
| struct ceph_mds_client *mdsc = |
| ceph_sb_to_client(ci->vfs_inode.i_sb)->mdsc; |
| struct inode *inode = &ci->vfs_inode; |
| int was = ci->i_dirty_caps; |
| int dirty = 0; |
| |
| if (!ci->i_auth_cap) { |
| pr_warn("__mark_dirty_caps %p %llx mask %s, " |
| "but no auth cap (session was closed?)\n", |
| inode, ceph_ino(inode), ceph_cap_string(mask)); |
| return 0; |
| } |
| |
| dout("__mark_dirty_caps %p %s dirty %s -> %s\n", &ci->vfs_inode, |
| ceph_cap_string(mask), ceph_cap_string(was), |
| ceph_cap_string(was | mask)); |
| ci->i_dirty_caps |= mask; |
| if (was == 0) { |
| WARN_ON_ONCE(ci->i_prealloc_cap_flush); |
| swap(ci->i_prealloc_cap_flush, *pcf); |
| |
| if (!ci->i_head_snapc) { |
| WARN_ON_ONCE(!rwsem_is_locked(&mdsc->snap_rwsem)); |
| ci->i_head_snapc = ceph_get_snap_context( |
| ci->i_snap_realm->cached_context); |
| } |
| dout(" inode %p now dirty snapc %p auth cap %p\n", |
| &ci->vfs_inode, ci->i_head_snapc, ci->i_auth_cap); |
| BUG_ON(!list_empty(&ci->i_dirty_item)); |
| spin_lock(&mdsc->cap_dirty_lock); |
| list_add(&ci->i_dirty_item, &mdsc->cap_dirty); |
| spin_unlock(&mdsc->cap_dirty_lock); |
| if (ci->i_flushing_caps == 0) { |
| ihold(inode); |
| dirty |= I_DIRTY_SYNC; |
| } |
| } else { |
| WARN_ON_ONCE(!ci->i_prealloc_cap_flush); |
| } |
| BUG_ON(list_empty(&ci->i_dirty_item)); |
| if (((was | ci->i_flushing_caps) & CEPH_CAP_FILE_BUFFER) && |
| (mask & CEPH_CAP_FILE_BUFFER)) |
| dirty |= I_DIRTY_DATASYNC; |
| __cap_delay_requeue(mdsc, ci); |
| return dirty; |
| } |
| |
| struct ceph_cap_flush *ceph_alloc_cap_flush(void) |
| { |
| return kmem_cache_alloc(ceph_cap_flush_cachep, GFP_KERNEL); |
| } |
| |
| void ceph_free_cap_flush(struct ceph_cap_flush *cf) |
| { |
| if (cf) |
| kmem_cache_free(ceph_cap_flush_cachep, cf); |
| } |
| |
| static u64 __get_oldest_flush_tid(struct ceph_mds_client *mdsc) |
| { |
| if (!list_empty(&mdsc->cap_flush_list)) { |
| struct ceph_cap_flush *cf = |
| list_first_entry(&mdsc->cap_flush_list, |
| struct ceph_cap_flush, g_list); |
| return cf->tid; |
| } |
| return 0; |
| } |
| |
| /* |
| * Remove cap_flush from the mdsc's or inode's flushing cap list. |
| * Return true if caller needs to wake up flush waiters. |
| */ |
| static bool __finish_cap_flush(struct ceph_mds_client *mdsc, |
| struct ceph_inode_info *ci, |
| struct ceph_cap_flush *cf) |
| { |
| struct ceph_cap_flush *prev; |
| bool wake = cf->wake; |
| if (mdsc) { |
| /* are there older pending cap flushes? */ |
| if (wake && cf->g_list.prev != &mdsc->cap_flush_list) { |
| prev = list_prev_entry(cf, g_list); |
| prev->wake = true; |
| wake = false; |
| } |
| list_del(&cf->g_list); |
| } else if (ci) { |
| if (wake && cf->i_list.prev != &ci->i_cap_flush_list) { |
| prev = list_prev_entry(cf, i_list); |
| prev->wake = true; |
| wake = false; |
| } |
| list_del(&cf->i_list); |
| } else { |
| BUG_ON(1); |
| } |
| return wake; |
| } |
| |
| /* |
| * Add dirty inode to the flushing list. Assigned a seq number so we |
| * can wait for caps to flush without starving. |
| * |
| * Called under i_ceph_lock. |
| */ |
| static int __mark_caps_flushing(struct inode *inode, |
| struct ceph_mds_session *session, bool wake, |
| u64 *flush_tid, u64 *oldest_flush_tid) |
| { |
| struct ceph_mds_client *mdsc = ceph_sb_to_client(inode->i_sb)->mdsc; |
| struct ceph_inode_info *ci = ceph_inode(inode); |
| struct ceph_cap_flush *cf = NULL; |
| int flushing; |
| |
| BUG_ON(ci->i_dirty_caps == 0); |
| BUG_ON(list_empty(&ci->i_dirty_item)); |
| BUG_ON(!ci->i_prealloc_cap_flush); |
| |
| flushing = ci->i_dirty_caps; |
| dout("__mark_caps_flushing flushing %s, flushing_caps %s -> %s\n", |
| ceph_cap_string(flushing), |
| ceph_cap_string(ci->i_flushing_caps), |
| ceph_cap_string(ci->i_flushing_caps | flushing)); |
| ci->i_flushing_caps |= flushing; |
| ci->i_dirty_caps = 0; |
| dout(" inode %p now !dirty\n", inode); |
| |
| swap(cf, ci->i_prealloc_cap_flush); |
| cf->caps = flushing; |
| cf->wake = wake; |
| |
| spin_lock(&mdsc->cap_dirty_lock); |
| list_del_init(&ci->i_dirty_item); |
| |
| cf->tid = ++mdsc->last_cap_flush_tid; |
| list_add_tail(&cf->g_list, &mdsc->cap_flush_list); |
| *oldest_flush_tid = __get_oldest_flush_tid(mdsc); |
| |
| if (list_empty(&ci->i_flushing_item)) { |
| list_add_tail(&ci->i_flushing_item, &session->s_cap_flushing); |
| mdsc->num_cap_flushing++; |
| } |
| spin_unlock(&mdsc->cap_dirty_lock); |
| |
| list_add_tail(&cf->i_list, &ci->i_cap_flush_list); |
| |
| *flush_tid = cf->tid; |
| return flushing; |
| } |
| |
| /* |
| * try to invalidate mapping pages without blocking. |
| */ |
| static int try_nonblocking_invalidate(struct inode *inode) |
| { |
| struct ceph_inode_info *ci = ceph_inode(inode); |
| u32 invalidating_gen = ci->i_rdcache_gen; |
| |
| spin_unlock(&ci->i_ceph_lock); |
| invalidate_mapping_pages(&inode->i_data, 0, -1); |
| spin_lock(&ci->i_ceph_lock); |
| |
| if (inode->i_data.nrpages == 0 && |
| invalidating_gen == ci->i_rdcache_gen) { |
| /* success. */ |
| dout("try_nonblocking_invalidate %p success\n", inode); |
| /* save any racing async invalidate some trouble */ |
| ci->i_rdcache_revoking = ci->i_rdcache_gen - 1; |
| return 0; |
| } |
| dout("try_nonblocking_invalidate %p failed\n", inode); |
| return -1; |
| } |
| |
| bool __ceph_should_report_size(struct ceph_inode_info *ci) |
| { |
| loff_t size = ci->vfs_inode.i_size; |
| /* mds will adjust max size according to the reported size */ |
| if (ci->i_flushing_caps & CEPH_CAP_FILE_WR) |
| return false; |
| if (size >= ci->i_max_size) |
| return true; |
| /* half of previous max_size increment has been used */ |
| if (ci->i_max_size > ci->i_reported_size && |
| (size << 1) >= ci->i_max_size + ci->i_reported_size) |
| return true; |
| return false; |
| } |
| |
| /* |
| * Swiss army knife function to examine currently used and wanted |
| * versus held caps. Release, flush, ack revoked caps to mds as |
| * appropriate. |
| * |
| * CHECK_CAPS_NODELAY - caller is delayed work and we should not delay |
| * cap release further. |
| * CHECK_CAPS_AUTHONLY - we should only check the auth cap |
| * CHECK_CAPS_FLUSH - we should flush any dirty caps immediately, without |
| * further delay. |
| */ |
| void ceph_check_caps(struct ceph_inode_info *ci, int flags, |
| struct ceph_mds_session *session) |
| { |
| struct ceph_fs_client *fsc = ceph_inode_to_client(&ci->vfs_inode); |
| struct ceph_mds_client *mdsc = fsc->mdsc; |
| struct inode *inode = &ci->vfs_inode; |
| struct ceph_cap *cap; |
| u64 flush_tid, oldest_flush_tid; |
| int file_wanted, used, cap_used; |
| int took_snap_rwsem = 0; /* true if mdsc->snap_rwsem held */ |
| int issued, implemented, want, retain, revoking, flushing = 0; |
| int mds = -1; /* keep track of how far we've gone through i_caps list |
| to avoid an infinite loop on retry */ |
| struct rb_node *p; |
| int delayed = 0, sent = 0, num; |
| bool is_delayed = flags & CHECK_CAPS_NODELAY; |
| bool queue_invalidate = false; |
| bool force_requeue = false; |
| bool tried_invalidate = false; |
| |
| /* if we are unmounting, flush any unused caps immediately. */ |
| if (mdsc->stopping) |
| is_delayed = 1; |
| |
| spin_lock(&ci->i_ceph_lock); |
| |
| if (ci->i_ceph_flags & CEPH_I_FLUSH) |
| flags |= CHECK_CAPS_FLUSH; |
| |
| goto retry_locked; |
| retry: |
| spin_lock(&ci->i_ceph_lock); |
| retry_locked: |
| file_wanted = __ceph_caps_file_wanted(ci); |
| used = __ceph_caps_used(ci); |
| issued = __ceph_caps_issued(ci, &implemented); |
| revoking = implemented & ~issued; |
| |
| want = file_wanted; |
| retain = file_wanted | used | CEPH_CAP_PIN; |
| if (!mdsc->stopping && inode->i_nlink > 0) { |
| if (file_wanted) { |
| retain |= CEPH_CAP_ANY; /* be greedy */ |
| } else if (S_ISDIR(inode->i_mode) && |
| (issued & CEPH_CAP_FILE_SHARED) && |
| __ceph_dir_is_complete(ci)) { |
| /* |
| * If a directory is complete, we want to keep |
| * the exclusive cap. So that MDS does not end up |
| * revoking the shared cap on every create/unlink |
| * operation. |
| */ |
| want = CEPH_CAP_ANY_SHARED | CEPH_CAP_FILE_EXCL; |
| retain |= want; |
| } else { |
| |
| retain |= CEPH_CAP_ANY_SHARED; |
| /* |
| * keep RD only if we didn't have the file open RW, |
| * because then the mds would revoke it anyway to |
| * journal max_size=0. |
| */ |
| if (ci->i_max_size == 0) |
| retain |= CEPH_CAP_ANY_RD; |
| } |
| } |
| |
| dout("check_caps %p file_want %s used %s dirty %s flushing %s" |
| " issued %s revoking %s retain %s %s%s%s\n", inode, |
| ceph_cap_string(file_wanted), |
| ceph_cap_string(used), ceph_cap_string(ci->i_dirty_caps), |
| ceph_cap_string(ci->i_flushing_caps), |
| ceph_cap_string(issued), ceph_cap_string(revoking), |
| ceph_cap_string(retain), |
| (flags & CHECK_CAPS_AUTHONLY) ? " AUTHONLY" : "", |
| (flags & CHECK_CAPS_NODELAY) ? " NODELAY" : "", |
| (flags & CHECK_CAPS_FLUSH) ? " FLUSH" : ""); |
| |
| /* |
| * If we no longer need to hold onto old our caps, and we may |
| * have cached pages, but don't want them, then try to invalidate. |
| * If we fail, it's because pages are locked.... try again later. |
| */ |
| if ((!is_delayed || mdsc->stopping) && |
| !S_ISDIR(inode->i_mode) && /* ignore readdir cache */ |
| !(ci->i_wb_ref || ci->i_wrbuffer_ref) && /* no dirty pages... */ |
| inode->i_data.nrpages && /* have cached pages */ |
| (revoking & (CEPH_CAP_FILE_CACHE| |
| CEPH_CAP_FILE_LAZYIO)) && /* or revoking cache */ |
| !tried_invalidate) { |
| dout("check_caps trying to invalidate on %p\n", inode); |
| if (try_nonblocking_invalidate(inode) < 0) { |
| if (revoking & (CEPH_CAP_FILE_CACHE| |
| CEPH_CAP_FILE_LAZYIO)) { |
| dout("check_caps queuing invalidate\n"); |
| queue_invalidate = true; |
| ci->i_rdcache_revoking = ci->i_rdcache_gen; |
| } else { |
| dout("check_caps failed to invalidate pages\n"); |
| /* we failed to invalidate pages. check these |
| caps again later. */ |
| force_requeue = true; |
| __cap_set_timeouts(mdsc, ci); |
| } |
| } |
| tried_invalidate = true; |
| goto retry_locked; |
| } |
| |
| num = 0; |
| for (p = rb_first(&ci->i_caps); p; p = rb_next(p)) { |
| cap = rb_entry(p, struct ceph_cap, ci_node); |
| num++; |
| |
| /* avoid looping forever */ |
| if (mds >= cap->mds || |
| ((flags & CHECK_CAPS_AUTHONLY) && cap != ci->i_auth_cap)) |
| continue; |
| |
| /* NOTE: no side-effects allowed, until we take s_mutex */ |
| |
| cap_used = used; |
| if (ci->i_auth_cap && cap != ci->i_auth_cap) |
| cap_used &= ~ci->i_auth_cap->issued; |
| |
| revoking = cap->implemented & ~cap->issued; |
| dout(" mds%d cap %p used %s issued %s implemented %s revoking %s\n", |
| cap->mds, cap, ceph_cap_string(cap_used), |
| ceph_cap_string(cap->issued), |
| ceph_cap_string(cap->implemented), |
| ceph_cap_string(revoking)); |
| |
| if (cap == ci->i_auth_cap && |
| (cap->issued & CEPH_CAP_FILE_WR)) { |
| /* request larger max_size from MDS? */ |
| if (ci->i_wanted_max_size > ci->i_max_size && |
| ci->i_wanted_max_size > ci->i_requested_max_size) { |
| dout("requesting new max_size\n"); |
| goto ack; |
| } |
| |
| /* approaching file_max? */ |
| if (__ceph_should_report_size(ci)) { |
| dout("i_size approaching max_size\n"); |
| goto ack; |
| } |
| } |
| /* flush anything dirty? */ |
| if (cap == ci->i_auth_cap) { |
| if ((flags & CHECK_CAPS_FLUSH) && ci->i_dirty_caps) { |
| dout("flushing dirty caps\n"); |
| goto ack; |
| } |
| if (ci->i_ceph_flags & CEPH_I_FLUSH_SNAPS) { |
| dout("flushing snap caps\n"); |
| goto ack; |
| } |
| } |
| |
| /* completed revocation? going down and there are no caps? */ |
| if (revoking && (revoking & cap_used) == 0) { |
| dout("completed revocation of %s\n", |
| ceph_cap_string(cap->implemented & ~cap->issued)); |
| goto ack; |
| } |
| |
| /* want more caps from mds? */ |
| if (want & ~(cap->mds_wanted | cap->issued)) |
| goto ack; |
| |
| /* things we might delay */ |
| if ((cap->issued & ~retain) == 0 && |
| cap->mds_wanted == want) |
| continue; /* nope, all good */ |
| |
| if (is_delayed) |
| goto ack; |
| |
| /* delay? */ |
| if ((ci->i_ceph_flags & CEPH_I_NODELAY) == 0 && |
| time_before(jiffies, ci->i_hold_caps_max)) { |
| dout(" delaying issued %s -> %s, wanted %s -> %s\n", |
| ceph_cap_string(cap->issued), |
| ceph_cap_string(cap->issued & retain), |
| ceph_cap_string(cap->mds_wanted), |
| ceph_cap_string(want)); |
| delayed++; |
| continue; |
| } |
| |
| ack: |
| if (ci->i_ceph_flags & CEPH_I_NOFLUSH) { |
| dout(" skipping %p I_NOFLUSH set\n", inode); |
| continue; |
| } |
| |
| if (session && session != cap->session) { |
| dout("oops, wrong session %p mutex\n", session); |
| mutex_unlock(&session->s_mutex); |
| session = NULL; |
| } |
| if (!session) { |
| session = cap->session; |
| if (mutex_trylock(&session->s_mutex) == 0) { |
| dout("inverting session/ino locks on %p\n", |
| session); |
| spin_unlock(&ci->i_ceph_lock); |
| if (took_snap_rwsem) { |
| up_read(&mdsc->snap_rwsem); |
| took_snap_rwsem = 0; |
| } |
| mutex_lock(&session->s_mutex); |
| goto retry; |
| } |
| } |
| |
| /* kick flushing and flush snaps before sending normal |
| * cap message */ |
| if (cap == ci->i_auth_cap && |
| (ci->i_ceph_flags & |
| (CEPH_I_KICK_FLUSH | CEPH_I_FLUSH_SNAPS))) { |
| if (ci->i_ceph_flags & CEPH_I_KICK_FLUSH) { |
| __kick_flushing_caps(mdsc, session, ci, 0); |
| ci->i_ceph_flags &= ~CEPH_I_KICK_FLUSH; |
| } |
| if (ci->i_ceph_flags & CEPH_I_FLUSH_SNAPS) |
| __ceph_flush_snaps(ci, session); |
| |
| goto retry_locked; |
| } |
| |
| /* take snap_rwsem after session mutex */ |
| if (!took_snap_rwsem) { |
| if (down_read_trylock(&mdsc->snap_rwsem) == 0) { |
| dout("inverting snap/in locks on %p\n", |
| inode); |
| spin_unlock(&ci->i_ceph_lock); |
| down_read(&mdsc->snap_rwsem); |
| took_snap_rwsem = 1; |
| goto retry; |
| } |
| took_snap_rwsem = 1; |
| } |
| |
| if (cap == ci->i_auth_cap && ci->i_dirty_caps) { |
| flushing = __mark_caps_flushing(inode, session, false, |
| &flush_tid, |
| &oldest_flush_tid); |
| } else { |
| flushing = 0; |
| flush_tid = 0; |
| spin_lock(&mdsc->cap_dirty_lock); |
| oldest_flush_tid = __get_oldest_flush_tid(mdsc); |
| spin_unlock(&mdsc->cap_dirty_lock); |
| } |
| |
| mds = cap->mds; /* remember mds, so we don't repeat */ |
| sent++; |
| |
| /* __send_cap drops i_ceph_lock */ |
| delayed += __send_cap(mdsc, cap, CEPH_CAP_OP_UPDATE, false, |
| cap_used, want, retain, flushing, |
| flush_tid, oldest_flush_tid); |
| goto retry; /* retake i_ceph_lock and restart our cap scan. */ |
| } |
| |
| /* |
| * Reschedule delayed caps release if we delayed anything, |
| * otherwise cancel. |
| */ |
| if (delayed && is_delayed) |
| force_requeue = true; /* __send_cap delayed release; requeue */ |
| if (!delayed && !is_delayed) |
| __cap_delay_cancel(mdsc, ci); |
| else if (!is_delayed || force_requeue) |
| __cap_delay_requeue(mdsc, ci); |
| |
| spin_unlock(&ci->i_ceph_lock); |
| |
| if (queue_invalidate) |
| ceph_queue_invalidate(inode); |
| |
| if (session) |
| mutex_unlock(&session->s_mutex); |
| if (took_snap_rwsem) |
| up_read(&mdsc->snap_rwsem); |
| } |
| |
| /* |
| * Try to flush dirty caps back to the auth mds. |
| */ |
| static int try_flush_caps(struct inode *inode, u64 *ptid) |
| { |
| struct ceph_mds_client *mdsc = ceph_sb_to_client(inode->i_sb)->mdsc; |
| struct ceph_inode_info *ci = ceph_inode(inode); |
| struct ceph_mds_session *session = NULL; |
| int flushing = 0; |
| u64 flush_tid = 0, oldest_flush_tid = 0; |
| |
| retry: |
| spin_lock(&ci->i_ceph_lock); |
| if (ci->i_ceph_flags & CEPH_I_NOFLUSH) { |
| spin_unlock(&ci->i_ceph_lock); |
| dout("try_flush_caps skipping %p I_NOFLUSH set\n", inode); |
| goto out; |
| } |
| if (ci->i_dirty_caps && ci->i_auth_cap) { |
| struct ceph_cap *cap = ci->i_auth_cap; |
| int used = __ceph_caps_used(ci); |
| int want = __ceph_caps_wanted(ci); |
| int delayed; |
| |
| if (!session || session != cap->session) { |
| spin_unlock(&ci->i_ceph_lock); |
| if (session) |
| mutex_unlock(&session->s_mutex); |
| session = cap->session; |
| mutex_lock(&session->s_mutex); |
| goto retry; |
| } |
| if (cap->session->s_state < CEPH_MDS_SESSION_OPEN) { |
| spin_unlock(&ci->i_ceph_lock); |
| goto out; |
| } |
| |
| flushing = __mark_caps_flushing(inode, session, true, |
| &flush_tid, &oldest_flush_tid); |
| |
| /* __send_cap drops i_ceph_lock */ |
| delayed = __send_cap(mdsc, cap, CEPH_CAP_OP_FLUSH, true, |
| used, want, (cap->issued | cap->implemented), |
| flushing, flush_tid, oldest_flush_tid); |
| |
| if (delayed) { |
| spin_lock(&ci->i_ceph_lock); |
| __cap_delay_requeue(mdsc, ci); |
| spin_unlock(&ci->i_ceph_lock); |
| } |
| } else { |
| if (!list_empty(&ci->i_cap_flush_list)) { |
| struct ceph_cap_flush *cf = |
| list_last_entry(&ci->i_cap_flush_list, |
| struct ceph_cap_flush, i_list); |
| cf->wake = true; |
| flush_tid = cf->tid; |
| } |
| flushing = ci->i_flushing_caps; |
| spin_unlock(&ci->i_ceph_lock); |
| } |
| out: |
| if (session) |
| mutex_unlock(&session->s_mutex); |
| |
| *ptid = flush_tid; |
| return flushing; |
| } |
| |
| /* |
| * Return true if we've flushed caps through the given flush_tid. |
| */ |
| static int caps_are_flushed(struct inode *inode, u64 flush_tid) |
| { |
| struct ceph_inode_info *ci = ceph_inode(inode); |
| int ret = 1; |
| |
| spin_lock(&ci->i_ceph_lock); |
| if (!list_empty(&ci->i_cap_flush_list)) { |
| struct ceph_cap_flush * cf = |
| list_first_entry(&ci->i_cap_flush_list, |
| struct ceph_cap_flush, i_list); |
| if (cf->tid <= flush_tid) |
| ret = 0; |
| } |
| spin_unlock(&ci->i_ceph_lock); |
| return ret; |
| } |
| |
| /* |
| * wait for any unsafe requests to complete. |
| */ |
| static int unsafe_request_wait(struct inode *inode) |
| { |
| struct ceph_inode_info *ci = ceph_inode(inode); |
| struct ceph_mds_request *req1 = NULL, *req2 = NULL; |
| int ret, err = 0; |
| |
| spin_lock(&ci->i_unsafe_lock); |
| if (S_ISDIR(inode->i_mode) && !list_empty(&ci->i_unsafe_dirops)) { |
| req1 = list_last_entry(&ci->i_unsafe_dirops, |
| struct ceph_mds_request, |
| r_unsafe_dir_item); |
| ceph_mdsc_get_request(req1); |
| } |
| if (!list_empty(&ci->i_unsafe_iops)) { |
| req2 = list_last_entry(&ci->i_unsafe_iops, |
| struct ceph_mds_request, |
| r_unsafe_target_item); |
| ceph_mdsc_get_request(req2); |
| } |
| spin_unlock(&ci->i_unsafe_lock); |
| |
| dout("unsafe_request_wait %p wait on tid %llu %llu\n", |
| inode, req1 ? req1->r_tid : 0ULL, req2 ? req2->r_tid : 0ULL); |
| if (req1) { |
| ret = !wait_for_completion_timeout(&req1->r_safe_completion, |
| ceph_timeout_jiffies(req1->r_timeout)); |
| if (ret) |
| err = -EIO; |
| ceph_mdsc_put_request(req1); |
| } |
| if (req2) { |
| ret = !wait_for_completion_timeout(&req2->r_safe_completion, |
| ceph_timeout_jiffies(req2->r_timeout)); |
| if (ret) |
| err = -EIO; |
| ceph_mdsc_put_request(req2); |
| } |
| return err; |
| } |
| |
| int ceph_fsync(struct file *file, loff_t start, loff_t end, int datasync) |
| { |
| struct inode *inode = file->f_mapping->host; |
| struct ceph_inode_info *ci = ceph_inode(inode); |
| u64 flush_tid; |
| int ret; |
| int dirty; |
| |
| dout("fsync %p%s\n", inode, datasync ? " datasync" : ""); |
| |
| ret = file_write_and_wait_range(file, start, end); |
| if (ret < 0) |
| goto out; |
| |
| if (datasync) |
| goto out; |
| |
| inode_lock(inode); |
| |
| dirty = try_flush_caps(inode, &flush_tid); |
| dout("fsync dirty caps are %s\n", ceph_cap_string(dirty)); |
| |
| ret = unsafe_request_wait(inode); |
| |
| /* |
| * only wait on non-file metadata writeback (the mds |
| * can recover size and mtime, so we don't need to |
| * wait for that) |
| */ |
| if (!ret && (dirty & ~CEPH_CAP_ANY_FILE_WR)) { |
| ret = wait_event_interruptible(ci->i_cap_wq, |
| caps_are_flushed(inode, flush_tid)); |
| } |
| inode_unlock(inode); |
| out: |
| dout("fsync %p%s result=%d\n", inode, datasync ? " datasync" : "", ret); |
| return ret; |
| } |
| |
| /* |
| * Flush any dirty caps back to the mds. If we aren't asked to wait, |
| * queue inode for flush but don't do so immediately, because we can |
| * get by with fewer MDS messages if we wait for data writeback to |
| * complete first. |
| */ |
| int ceph_write_inode(struct inode *inode, struct writeback_control *wbc) |
| { |
| struct ceph_inode_info *ci = ceph_inode(inode); |
| u64 flush_tid; |
| int err = 0; |
| int dirty; |
| int wait = wbc->sync_mode == WB_SYNC_ALL; |
| |
| dout("write_inode %p wait=%d\n", inode, wait); |
| if (wait) { |
| dirty = try_flush_caps(inode, &flush_tid); |
| if (dirty) |
| err = wait_event_interruptible(ci->i_cap_wq, |
| caps_are_flushed(inode, flush_tid)); |
| } else { |
| struct ceph_mds_client *mdsc = |
| ceph_sb_to_client(inode->i_sb)->mdsc; |
| |
| spin_lock(&ci->i_ceph_lock); |
| if (__ceph_caps_dirty(ci)) |
| __cap_delay_requeue_front(mdsc, ci); |
| spin_unlock(&ci->i_ceph_lock); |
| } |
| return err; |
| } |
| |
| static void __kick_flushing_caps(struct ceph_mds_client *mdsc, |
| struct ceph_mds_session *session, |
| struct ceph_inode_info *ci, |
| u64 oldest_flush_tid) |
| __releases(ci->i_ceph_lock) |
| __acquires(ci->i_ceph_lock) |
| { |
| struct inode *inode = &ci->vfs_inode; |
| struct ceph_cap *cap; |
| struct ceph_cap_flush *cf; |
| int ret; |
| u64 first_tid = 0; |
| |
| list_for_each_entry(cf, &ci->i_cap_flush_list, i_list) { |
| if (cf->tid < first_tid) |
| continue; |
| |
| cap = ci->i_auth_cap; |
| if (!(cap && cap->session == session)) { |
| pr_err("%p auth cap %p not mds%d ???\n", |
| inode, cap, session->s_mds); |
| break; |
| } |
| |
| first_tid = cf->tid + 1; |
| |
| if (cf->caps) { |
| dout("kick_flushing_caps %p cap %p tid %llu %s\n", |
| inode, cap, cf->tid, ceph_cap_string(cf->caps)); |
| ci->i_ceph_flags |= CEPH_I_NODELAY; |
| ret = __send_cap(mdsc, cap, CEPH_CAP_OP_FLUSH, |
| false, __ceph_caps_used(ci), |
| __ceph_caps_wanted(ci), |
| cap->issued | cap->implemented, |
| cf->caps, cf->tid, oldest_flush_tid); |
| if (ret) { |
| pr_err("kick_flushing_caps: error sending " |
| "cap flush, ino (%llx.%llx) " |
| "tid %llu flushing %s\n", |
| ceph_vinop(inode), cf->tid, |
| ceph_cap_string(cf->caps)); |
| } |
| } else { |
| struct ceph_cap_snap *capsnap = |
| container_of(cf, struct ceph_cap_snap, |
| cap_flush); |
| dout("kick_flushing_caps %p capsnap %p tid %llu %s\n", |
| inode, capsnap, cf->tid, |
| ceph_cap_string(capsnap->dirty)); |
| |
| refcount_inc(&capsnap->nref); |
| spin_unlock(&ci->i_ceph_lock); |
| |
| ret = __send_flush_snap(inode, session, capsnap, cap->mseq, |
| oldest_flush_tid); |
| if (ret < 0) { |
| pr_err("kick_flushing_caps: error sending " |
| "cap flushsnap, ino (%llx.%llx) " |
| "tid %llu follows %llu\n", |
| ceph_vinop(inode), cf->tid, |
| capsnap->follows); |
| } |
| |
| ceph_put_cap_snap(capsnap); |
| } |
| |
| spin_lock(&ci->i_ceph_lock); |
| } |
| } |
| |
| void ceph_early_kick_flushing_caps(struct ceph_mds_client *mdsc, |
| struct ceph_mds_session *session) |
| { |
| struct ceph_inode_info *ci; |
| struct ceph_cap *cap; |
| u64 oldest_flush_tid; |
| |
| dout("early_kick_flushing_caps mds%d\n", session->s_mds); |
| |
| spin_lock(&mdsc->cap_dirty_lock); |
| oldest_flush_tid = __get_oldest_flush_tid(mdsc); |
| spin_unlock(&mdsc->cap_dirty_lock); |
| |
| list_for_each_entry(ci, &session->s_cap_flushing, i_flushing_item) { |
| spin_lock(&ci->i_ceph_lock); |
| cap = ci->i_auth_cap; |
| if (!(cap && cap->session == session)) { |
| pr_err("%p auth cap %p not mds%d ???\n", |
| &ci->vfs_inode, cap, session->s_mds); |
| spin_unlock(&ci->i_ceph_lock); |
| continue; |
| } |
| |
| |
| /* |
| * if flushing caps were revoked, we re-send the cap flush |
| * in client reconnect stage. This guarantees MDS * processes |
| * the cap flush message before issuing the flushing caps to |
| * other client. |
| */ |
| if ((cap->issued & ci->i_flushing_caps) != |
| ci->i_flushing_caps) { |
| ci->i_ceph_flags &= ~CEPH_I_KICK_FLUSH; |
| __kick_flushing_caps(mdsc, session, ci, |
| oldest_flush_tid); |
| } else { |
| ci->i_ceph_flags |= CEPH_I_KICK_FLUSH; |
| } |
| |
| spin_unlock(&ci->i_ceph_lock); |
| } |
| } |
| |
| void ceph_kick_flushing_caps(struct ceph_mds_client *mdsc, |
| struct ceph_mds_session *session) |
| { |
| struct ceph_inode_info *ci; |
| struct ceph_cap *cap; |
| u64 oldest_flush_tid; |
| |
| dout("kick_flushing_caps mds%d\n", session->s_mds); |
| |
| spin_lock(&mdsc->cap_dirty_lock); |
| oldest_flush_tid = __get_oldest_flush_tid(mdsc); |
| spin_unlock(&mdsc->cap_dirty_lock); |
| |
| list_for_each_entry(ci, &session->s_cap_flushing, i_flushing_item) { |
| spin_lock(&ci->i_ceph_lock); |
| cap = ci->i_auth_cap; |
| if (!(cap && cap->session == session)) { |
| pr_err("%p auth cap %p not mds%d ???\n", |
| &ci->vfs_inode, cap, session->s_mds); |
| spin_unlock(&ci->i_ceph_lock); |
| continue; |
| } |
| if (ci->i_ceph_flags & CEPH_I_KICK_FLUSH) { |
| ci->i_ceph_flags &= ~CEPH_I_KICK_FLUSH; |
| __kick_flushing_caps(mdsc, session, ci, |
| oldest_flush_tid); |
| } |
| spin_unlock(&ci->i_ceph_lock); |
| } |
| } |
| |
| static void kick_flushing_inode_caps(struct ceph_mds_client *mdsc, |
| struct ceph_mds_session *session, |
| struct inode *inode) |
| __releases(ci->i_ceph_lock) |
| { |
| struct ceph_inode_info *ci = ceph_inode(inode); |
| struct ceph_cap *cap; |
| |
| cap = ci->i_auth_cap; |
| dout("kick_flushing_inode_caps %p flushing %s\n", inode, |
| ceph_cap_string(ci->i_flushing_caps)); |
| |
| if (!list_empty(&ci->i_cap_flush_list)) { |
| u64 oldest_flush_tid; |
| spin_lock(&mdsc->cap_dirty_lock); |
| list_move_tail(&ci->i_flushing_item, |
| &cap->session->s_cap_flushing); |
| oldest_flush_tid = __get_oldest_flush_tid(mdsc); |
| spin_unlock(&mdsc->cap_dirty_lock); |
| |
| ci->i_ceph_flags &= ~CEPH_I_KICK_FLUSH; |
| __kick_flushing_caps(mdsc, session, ci, oldest_flush_tid); |
| spin_unlock(&ci->i_ceph_lock); |
| } else { |
| spin_unlock(&ci->i_ceph_lock); |
| } |
| } |
| |
| |
| /* |
| * Take references to capabilities we hold, so that we don't release |
| * them to the MDS prematurely. |
| * |
| * Protected by i_ceph_lock. |
| */ |
| static void __take_cap_refs(struct ceph_inode_info *ci, int got, |
| bool snap_rwsem_locked) |
| { |
| if (got & CEPH_CAP_PIN) |
| ci->i_pin_ref++; |
| if (got & CEPH_CAP_FILE_RD) |
| ci->i_rd_ref++; |
| if (got & CEPH_CAP_FILE_CACHE) |
| ci->i_rdcache_ref++; |
| if (got & CEPH_CAP_FILE_WR) { |
| if (ci->i_wr_ref == 0 && !ci->i_head_snapc) { |
| BUG_ON(!snap_rwsem_locked); |
| ci->i_head_snapc = ceph_get_snap_context( |
| ci->i_snap_realm->cached_context); |
| } |
| ci->i_wr_ref++; |
| } |
| if (got & CEPH_CAP_FILE_BUFFER) { |
| if (ci->i_wb_ref == 0) |
| ihold(&ci->vfs_inode); |
| ci->i_wb_ref++; |
| dout("__take_cap_refs %p wb %d -> %d (?)\n", |
| &ci->vfs_inode, ci->i_wb_ref-1, ci->i_wb_ref); |
| } |
| } |
| |
| /* |
| * Try to grab cap references. Specify those refs we @want, and the |
| * minimal set we @need. Also include the larger offset we are writing |
| * to (when applicable), and check against max_size here as well. |
| * Note that caller is responsible for ensuring max_size increases are |
| * requested from the MDS. |
| */ |
| static int try_get_cap_refs(struct ceph_inode_info *ci, int need, int want, |
| loff_t endoff, bool nonblock, int *got, int *err) |
| { |
| struct inode *inode = &ci->vfs_inode; |
| struct ceph_mds_client *mdsc = ceph_inode_to_client(inode)->mdsc; |
| int ret = 0; |
| int have, implemented; |
| int file_wanted; |
| bool snap_rwsem_locked = false; |
| |
| dout("get_cap_refs %p need %s want %s\n", inode, |
| ceph_cap_string(need), ceph_cap_string(want)); |
| |
| again: |
| spin_lock(&ci->i_ceph_lock); |
| |
| /* make sure file is actually open */ |
| file_wanted = __ceph_caps_file_wanted(ci); |
| if ((file_wanted & need) != need) { |
| dout("try_get_cap_refs need %s file_wanted %s, EBADF\n", |
| ceph_cap_string(need), ceph_cap_string(file_wanted)); |
| *err = -EBADF; |
| ret = 1; |
| goto out_unlock; |
| } |
| |
| /* finish pending truncate */ |
| while (ci->i_truncate_pending) { |
| spin_unlock(&ci->i_ceph_lock); |
| if (snap_rwsem_locked) { |
| up_read(&mdsc->snap_rwsem); |
| snap_rwsem_locked = false; |
| } |
| __ceph_do_pending_vmtruncate(inode); |
| spin_lock(&ci->i_ceph_lock); |
| } |
| |
| have = __ceph_caps_issued(ci, &implemented); |
| |
| if (have & need & CEPH_CAP_FILE_WR) { |
| if (endoff >= 0 && endoff > (loff_t)ci->i_max_size) { |
| dout("get_cap_refs %p endoff %llu > maxsize %llu\n", |
| inode, endoff, ci->i_max_size); |
| if (endoff > ci->i_requested_max_size) { |
| *err = -EAGAIN; |
| ret = 1; |
| } |
| goto out_unlock; |
| } |
| /* |
| * If a sync write is in progress, we must wait, so that we |
| * can get a final snapshot value for size+mtime. |
| */ |
| if (__ceph_have_pending_cap_snap(ci)) { |
| dout("get_cap_refs %p cap_snap_pending\n", inode); |
| goto out_unlock; |
| } |
| } |
| |
| if ((have & need) == need) { |
| /* |
| * Look at (implemented & ~have & not) so that we keep waiting |
| * on transition from wanted -> needed caps. This is needed |
| * for WRBUFFER|WR -> WR to avoid a new WR sync write from |
| * going before a prior buffered writeback happens. |
| */ |
| int not = want & ~(have & need); |
| int revoking = implemented & ~have; |
| dout("get_cap_refs %p have %s but not %s (revoking %s)\n", |
| inode, ceph_cap_string(have), ceph_cap_string(not), |
| ceph_cap_string(revoking)); |
| if ((revoking & not) == 0) { |
| if (!snap_rwsem_locked && |
| !ci->i_head_snapc && |
| (need & CEPH_CAP_FILE_WR)) { |
| if (!down_read_trylock(&mdsc->snap_rwsem)) { |
| /* |
| * we can not call down_read() when |
| * task isn't in TASK_RUNNING state |
| */ |
| if (nonblock) { |
| *err = -EAGAIN; |
| ret = 1; |
| goto out_unlock; |
| } |
| |
| spin_unlock(&ci->i_ceph_lock); |
| down_read(&mdsc->snap_rwsem); |
| snap_rwsem_locked = true; |
| goto again; |
| } |
| snap_rwsem_locked = true; |
| } |
| *got = need | (have & want); |
| if ((need & CEPH_CAP_FILE_RD) && |
| !(*got & CEPH_CAP_FILE_CACHE)) |
| ceph_disable_fscache_readpage(ci); |
| __take_cap_refs(ci, *got, true); |
| ret = 1; |
| } |
| } else { |
| int session_readonly = false; |
| if ((need & CEPH_CAP_FILE_WR) && ci->i_auth_cap) { |
| struct ceph_mds_session *s = ci->i_auth_cap->session; |
| spin_lock(&s->s_cap_lock); |
| session_readonly = s->s_readonly; |
| spin_unlock(&s->s_cap_lock); |
| } |
| if (session_readonly) { |
| dout("get_cap_refs %p needed %s but mds%d readonly\n", |
| inode, ceph_cap_string(need), ci->i_auth_cap->mds); |
| *err = -EROFS; |
| ret = 1; |
| goto out_unlock; |
| } |
| |
| if (ci->i_ceph_flags & CEPH_I_CAP_DROPPED) { |
| int mds_wanted; |
| if (READ_ONCE(mdsc->fsc->mount_state) == |
| CEPH_MOUNT_SHUTDOWN) { |
| dout("get_cap_refs %p forced umount\n", inode); |
| *err = -EIO; |
| ret = 1; |
| goto out_unlock; |
| } |
| mds_wanted = __ceph_caps_mds_wanted(ci, false); |
| if (need & ~(mds_wanted & need)) { |
| dout("get_cap_refs %p caps were dropped" |
| " (session killed?)\n", inode); |
| *err = -ESTALE; |
| ret = 1; |
| goto out_unlock; |
| } |
| if (!(file_wanted & ~mds_wanted)) |
| ci->i_ceph_flags &= ~CEPH_I_CAP_DROPPED; |
| } |
| |
| dout("get_cap_refs %p have %s needed %s\n", inode, |
| ceph_cap_string(have), ceph_cap_string(need)); |
| } |
| out_unlock: |
| spin_unlock(&ci->i_ceph_lock); |
| if (snap_rwsem_locked) |
| up_read(&mdsc->snap_rwsem); |
| |
| dout("get_cap_refs %p ret %d got %s\n", inode, |
| ret, ceph_cap_string(*got)); |
| return ret; |
| } |
| |
| /* |
| * Check the offset we are writing up to against our current |
| * max_size. If necessary, tell the MDS we want to write to |
| * a larger offset. |
| */ |
| static void check_max_size(struct inode *inode, loff_t endoff) |
| { |
| struct ceph_inode_info *ci = ceph_inode(inode); |
| int check = 0; |
| |
| /* do we need to explicitly request a larger max_size? */ |
| spin_lock(&ci->i_ceph_lock); |
| if (endoff >= ci->i_max_size && endoff > ci->i_wanted_max_size) { |
| dout("write %p at large endoff %llu, req max_size\n", |
| inode, endoff); |
| ci->i_wanted_max_size = endoff; |
| } |
| /* duplicate ceph_check_caps()'s logic */ |
| if (ci->i_auth_cap && |
| (ci->i_auth_cap->issued & CEPH_CAP_FILE_WR) && |
| ci->i_wanted_max_size > ci->i_max_size && |
| ci->i_wanted_max_size > ci->i_requested_max_size) |
| check = 1; |
| spin_unlock(&ci->i_ceph_lock); |
| if (check) |
| ceph_check_caps(ci, CHECK_CAPS_AUTHONLY, NULL); |
| } |
| |
| int ceph_try_get_caps(struct ceph_inode_info *ci, int need, int want, int *got) |
| { |
| int ret, err = 0; |
| |
| BUG_ON(need & ~CEPH_CAP_FILE_RD); |
| BUG_ON(want & ~(CEPH_CAP_FILE_CACHE|CEPH_CAP_FILE_LAZYIO)); |
| ret = ceph_pool_perm_check(ci, need); |
| if (ret < 0) |
| return ret; |
| |
| ret = try_get_cap_refs(ci, need, want, 0, true, got, &err); |
| if (ret) { |
| if (err == -EAGAIN) { |
| ret = 0; |
| } else if (err < 0) { |
| ret = err; |
| } |
| } |
| return ret; |
| } |
| |
| /* |
| * Wait for caps, and take cap references. If we can't get a WR cap |
| * due to a small max_size, make sure we check_max_size (and possibly |
| * ask the mds) so we don't get hung up indefinitely. |
| */ |
| int ceph_get_caps(struct ceph_inode_info *ci, int need, int want, |
| loff_t endoff, int *got, struct page **pinned_page) |
| { |
| int _got, ret, err = 0; |
| |
| ret = ceph_pool_perm_check(ci, need); |
| if (ret < 0) |
| return ret; |
| |
| while (true) { |
| if (endoff > 0) |
| check_max_size(&ci->vfs_inode, endoff); |
| |
| err = 0; |
| _got = 0; |
| ret = try_get_cap_refs(ci, need, want, endoff, |
| false, &_got, &err); |
| if (ret) { |
| if (err == -EAGAIN) |
| continue; |
| if (err < 0) |
| ret = err; |
| } else { |
| DEFINE_WAIT_FUNC(wait, woken_wake_function); |
| add_wait_queue(&ci->i_cap_wq, &wait); |
| |
| while (!try_get_cap_refs(ci, need, want, endoff, |
| true, &_got, &err)) { |
| if (signal_pending(current)) { |
| ret = -ERESTARTSYS; |
| break; |
| } |
| wait_woken(&wait, TASK_INTERRUPTIBLE, MAX_SCHEDULE_TIMEOUT); |
| } |
| |
| remove_wait_queue(&ci->i_cap_wq, &wait); |
| |
| if (err == -EAGAIN) |
| continue; |
| if (err < 0) |
| ret = err; |
| } |
| if (ret < 0) { |
| if (err == -ESTALE) { |
| /* session was killed, try renew caps */ |
| ret = ceph_renew_caps(&ci->vfs_inode); |
| if (ret == 0) |
| continue; |
| } |
| return ret; |
| } |
| |
| if (ci->i_inline_version != CEPH_INLINE_NONE && |
| (_got & (CEPH_CAP_FILE_CACHE|CEPH_CAP_FILE_LAZYIO)) && |
| i_size_read(&ci->vfs_inode) > 0) { |
| struct page *page = |
| find_get_page(ci->vfs_inode.i_mapping, 0); |
| if (page) { |
| if (PageUptodate(page)) { |
| *pinned_page = page; |
| break; |
| } |
| put_page(page); |
| } |
| /* |
| * drop cap refs first because getattr while |
| * holding * caps refs can cause deadlock. |
| */ |
| ceph_put_cap_refs(ci, _got); |
| _got = 0; |
| |
| /* |
| * getattr request will bring inline data into |
| * page cache |
| */ |
| ret = __ceph_do_getattr(&ci->vfs_inode, NULL, |
| CEPH_STAT_CAP_INLINE_DATA, |
| true); |
| if (ret < 0) |
| return ret; |
| continue; |
| } |
| break; |
| } |
| |
| if ((_got & CEPH_CAP_FILE_RD) && (_got & CEPH_CAP_FILE_CACHE)) |
| ceph_fscache_revalidate_cookie(ci); |
| |
| *got = _got; |
| return 0; |
| } |
| |
| /* |
| * Take cap refs. Caller must already know we hold at least one ref |
| * on the caps in question or we don't know this is safe. |
| */ |
| void ceph_get_cap_refs(struct ceph_inode_info *ci, int caps) |
| { |
| spin_lock(&ci->i_ceph_lock); |
| __take_cap_refs(ci, caps, false); |
| spin_unlock(&ci->i_ceph_lock); |
| } |
| |
| |
| /* |
| * drop cap_snap that is not associated with any snapshot. |
| * we don't need to send FLUSHSNAP message for it. |
| */ |
| static int ceph_try_drop_cap_snap(struct ceph_inode_info *ci, |
| struct ceph_cap_snap *capsnap) |
| { |
| if (!capsnap->need_flush && |
| !capsnap->writing && !capsnap->dirty_pages) { |
| dout("dropping cap_snap %p follows %llu\n", |
| capsnap, capsnap->follows); |
| BUG_ON(capsnap->cap_flush.tid > 0); |
| ceph_put_snap_context(capsnap->context); |
| if (!list_is_last(&capsnap->ci_item, &ci->i_cap_snaps)) |
| ci->i_ceph_flags |= CEPH_I_FLUSH_SNAPS; |
| |
| list_del(&capsnap->ci_item); |
| ceph_put_cap_snap(capsnap); |
| return 1; |
| } |
| return 0; |
| } |
| |
| /* |
| * Release cap refs. |
| * |
| * If we released the last ref on any given cap, call ceph_check_caps |
| * to release (or schedule a release). |
| * |
| * If we are releasing a WR cap (from a sync write), finalize any affected |
| * cap_snap, and wake up any waiters. |
| */ |
| void ceph_put_cap_refs(struct ceph_inode_info *ci, int had) |
| { |
| struct inode *inode = &ci->vfs_inode; |
| int last = 0, put = 0, flushsnaps = 0, wake = 0; |
| |
| spin_lock(&ci->i_ceph_lock); |
| if (had & CEPH_CAP_PIN) |
| --ci->i_pin_ref; |
| if (had & CEPH_CAP_FILE_RD) |
| if (--ci->i_rd_ref == 0) |
| last++; |
| if (had & CEPH_CAP_FILE_CACHE) |
| if (--ci->i_rdcache_ref == 0) |
| last++; |
| if (had & CEPH_CAP_FILE_BUFFER) { |
| if (--ci->i_wb_ref == 0) { |
| last++; |
| put++; |
| } |
| dout("put_cap_refs %p wb %d -> %d (?)\n", |
| inode, ci->i_wb_ref+1, ci->i_wb_ref); |
| } |
| if (had & CEPH_CAP_FILE_WR) |
| if (--ci->i_wr_ref == 0) { |
| last++; |
| if (__ceph_have_pending_cap_snap(ci)) { |
| struct ceph_cap_snap *capsnap = |
| list_last_entry(&ci->i_cap_snaps, |
| struct ceph_cap_snap, |
| ci_item); |
| capsnap->writing = 0; |
| if (ceph_try_drop_cap_snap(ci, capsnap)) |
| put++; |
| else if (__ceph_finish_cap_snap(ci, capsnap)) |
| flushsnaps = 1; |
| wake = 1; |
| } |
| if (ci->i_wrbuffer_ref_head == 0 && |
| ci->i_dirty_caps == 0 && |
| ci->i_flushing_caps == 0) { |
| BUG_ON(!ci->i_head_snapc); |
| ceph_put_snap_context(ci->i_head_snapc); |
| ci->i_head_snapc = NULL; |
| } |
| /* see comment in __ceph_remove_cap() */ |
| if (!__ceph_is_any_caps(ci) && ci->i_snap_realm) |
| drop_inode_snap_realm(ci); |
| } |
| spin_unlock(&ci->i_ceph_lock); |
| |
| dout("put_cap_refs %p had %s%s%s\n", inode, ceph_cap_string(had), |
| last ? " last" : "", put ? " put" : ""); |
| |
| if (last && !flushsnaps) |
| ceph_check_caps(ci, 0, NULL); |
| else if (flushsnaps) |
| ceph_flush_snaps(ci, NULL); |
| if (wake) |
| wake_up_all(&ci->i_cap_wq); |
| while (put-- > 0) |
| iput(inode); |
| } |
| |
| /* |
| * Release @nr WRBUFFER refs on dirty pages for the given @snapc snap |
| * context. Adjust per-snap dirty page accounting as appropriate. |
| * Once all dirty data for a cap_snap is flushed, flush snapped file |
| * metadata back to the MDS. If we dropped the last ref, call |
| * ceph_check_caps. |
| */ |
| void ceph_put_wrbuffer_cap_refs(struct ceph_inode_info *ci, int nr, |
| struct ceph_snap_context *snapc) |
| { |
| struct inode *inode = &ci->vfs_inode; |
| struct ceph_cap_snap *capsnap = NULL; |
| int put = 0; |
| bool last = false; |
| bool found = false; |
| bool flush_snaps = false; |
| bool complete_capsnap = false; |
| |
| spin_lock(&ci->i_ceph_lock); |
| ci->i_wrbuffer_ref -= nr; |
| if (ci->i_wrbuffer_ref == 0) { |
| last = true; |
| put++; |
| } |
| |
| if (ci->i_head_snapc == snapc) { |
| ci->i_wrbuffer_ref_head -= nr; |
| if (ci->i_wrbuffer_ref_head == 0 && |
| ci->i_wr_ref == 0 && |
| ci->i_dirty_caps == 0 && |
| ci->i_flushing_caps == 0) { |
| BUG_ON(!ci->i_head_snapc); |
| ceph_put_snap_context(ci->i_head_snapc); |
| ci->i_head_snapc = NULL; |
| } |
| dout("put_wrbuffer_cap_refs on %p head %d/%d -> %d/%d %s\n", |
| inode, |
| ci->i_wrbuffer_ref+nr, ci->i_wrbuffer_ref_head+nr, |
| ci->i_wrbuffer_ref, ci->i_wrbuffer_ref_head, |
| last ? " LAST" : ""); |
| } else { |
| list_for_each_entry(capsnap, &ci->i_cap_snaps, ci_item) { |
| if (capsnap->context == snapc) { |
| found = true; |
| break; |
| } |
| } |
| BUG_ON(!found); |
| capsnap->dirty_pages -= nr; |
| if (capsnap->dirty_pages == 0) { |
| complete_capsnap = true; |
| if (!capsnap->writing) { |
| if (ceph_try_drop_cap_snap(ci, capsnap)) { |
| put++; |
| } else { |
| ci->i_ceph_flags |= CEPH_I_FLUSH_SNAPS; |
| flush_snaps = true; |
| } |
| } |
| } |
| dout("put_wrbuffer_cap_refs on %p cap_snap %p " |
| " snap %lld %d/%d -> %d/%d %s%s\n", |
| inode, capsnap, capsnap->context->seq, |
| ci->i_wrbuffer_ref+nr, capsnap->dirty_pages + nr, |
| ci->i_wrbuffer_ref, capsnap->dirty_pages, |
| last ? " (wrbuffer last)" : "", |
| complete_capsnap ? " (complete capsnap)" : ""); |
| } |
| |
| spin_unlock(&ci->i_ceph_lock); |
| |
| if (last) { |
| ceph_check_caps(ci, CHECK_CAPS_AUTHONLY, NULL); |
| } else if (flush_snaps) { |
| ceph_flush_snaps(ci, NULL); |
| } |
| if (complete_capsnap) |
| wake_up_all(&ci->i_cap_wq); |
| while (put-- > 0) |
| iput(inode); |
| } |
| |
| /* |
| * Invalidate unlinked inode's aliases, so we can drop the inode ASAP. |
| */ |
| static void invalidate_aliases(struct inode *inode) |
| { |
| struct dentry *dn, *prev = NULL; |
| |
| dout("invalidate_aliases inode %p\n", inode); |
| d_prune_aliases(inode); |
| /* |
| * For non-directory inode, d_find_alias() only returns |
| * hashed dentry. After calling d_invalidate(), the |
| * dentry becomes unhashed. |
| * |
| * For directory inode, d_find_alias() can return |
| * unhashed dentry. But directory inode should have |
| * one alias at most. |
| */ |
| while ((dn = d_find_alias(inode))) { |
| if (dn == prev) { |
| dput(dn); |
| break; |
| } |
| d_invalidate(dn); |
| if (prev) |
| dput(prev); |
| prev = dn; |
| } |
| if (prev) |
| dput(prev); |
| } |
| |
| /* |
| * Handle a cap GRANT message from the MDS. (Note that a GRANT may |
| * actually be a revocation if it specifies a smaller cap set.) |
| * |
| * caller holds s_mutex and i_ceph_lock, we drop both. |
| */ |
| static void handle_cap_grant(struct ceph_mds_client *mdsc, |
| struct inode *inode, struct ceph_mds_caps *grant, |
| struct ceph_string **pns, u64 inline_version, |
| void *inline_data, u32 inline_len, |
| struct ceph_buffer *xattr_buf, |
| struct ceph_mds_session *session, |
| struct ceph_cap *cap, int issued) |
| __releases(ci->i_ceph_lock) |
| __releases(mdsc->snap_rwsem) |
| { |
| struct ceph_inode_info *ci = ceph_inode(inode); |
| int mds = session->s_mds; |
| int seq = le32_to_cpu(grant->seq); |
| int newcaps = le32_to_cpu(grant->caps); |
| int used, wanted, dirty; |
| u64 size = le64_to_cpu(grant->size); |
| u64 max_size = le64_to_cpu(grant->max_size); |
| struct timespec mtime, atime, ctime; |
| int check_caps = 0; |
| bool wake = false; |
| bool writeback = false; |
| bool queue_trunc = false; |
| bool queue_invalidate = false; |
| bool deleted_inode = false; |
| bool fill_inline = false; |
| |
| dout("handle_cap_grant inode %p cap %p mds%d seq %d %s\n", |
| inode, cap, mds, seq, ceph_cap_string(newcaps)); |
| dout(" size %llu max_size %llu, i_size %llu\n", size, max_size, |
| inode->i_size); |
| |
| |
| /* |
| * auth mds of the inode changed. we received the cap export message, |
| * but still haven't received the cap import message. handle_cap_export |
| * updated the new auth MDS' cap. |
| * |
| * "ceph_seq_cmp(seq, cap->seq) <= 0" means we are processing a message |
| * that was sent before the cap import message. So don't remove caps. |
| */ |
| if (ceph_seq_cmp(seq, cap->seq) <= 0) { |
| WARN_ON(cap != ci->i_auth_cap); |
| WARN_ON(cap->cap_id != le64_to_cpu(grant->cap_id)); |
| seq = cap->seq; |
| newcaps |= cap->issued; |
| } |
| |
| /* |
| * If CACHE is being revoked, and we have no dirty buffers, |
| * try to invalidate (once). (If there are dirty buffers, we |
| * will invalidate _after_ writeback.) |
| */ |
| if (!S_ISDIR(inode->i_mode) && /* don't invalidate readdir cache */ |
| ((cap->issued & ~newcaps) & CEPH_CAP_FILE_CACHE) && |
| (newcaps & CEPH_CAP_FILE_LAZYIO) == 0 && |
| !(ci->i_wrbuffer_ref || ci->i_wb_ref)) { |
| if (try_nonblocking_invalidate(inode)) { |
| /* there were locked pages.. invalidate later |
| in a separate thread. */ |
| if (ci->i_rdcache_revoking != ci->i_rdcache_gen) { |
| queue_invalidate = true; |
| ci->i_rdcache_revoking = ci->i_rdcache_gen; |
| } |
| } |
| } |
| |
| /* side effects now are allowed */ |
| cap->cap_gen = session->s_cap_gen; |
| cap->seq = seq; |
| |
| __check_cap_issue(ci, cap, newcaps); |
| |
| if ((newcaps & CEPH_CAP_AUTH_SHARED) && |
| (issued & CEPH_CAP_AUTH_EXCL) == 0) { |
| inode->i_mode = le32_to_cpu(grant->mode); |
| inode->i_uid = make_kuid(&init_user_ns, le32_to_cpu(grant->uid)); |
| inode->i_gid = make_kgid(&init_user_ns, le32_to_cpu(grant->gid)); |
| dout("%p mode 0%o uid.gid %d.%d\n", inode, inode->i_mode, |
| from_kuid(&init_user_ns, inode->i_uid), |
| from_kgid(&init_user_ns, inode->i_gid)); |
| } |
| |
| if ((newcaps & CEPH_CAP_AUTH_SHARED) && |
| (issued & CEPH_CAP_LINK_EXCL) == 0) { |
| set_nlink(inode, le32_to_cpu(grant->nlink)); |
| if (inode->i_nlink == 0 && |
| (newcaps & (CEPH_CAP_LINK_SHARED | CEPH_CAP_LINK_EXCL))) |
| deleted_inode = true; |
| } |
| |
| if ((issued & CEPH_CAP_XATTR_EXCL) == 0 && grant->xattr_len) { |
| int len = le32_to_cpu(grant->xattr_len); |
| u64 version = le64_to_cpu(grant->xattr_version); |
| |