Lines Matching full:realm
31 * of the files contained by each realm share the same set of
32 * snapshots. An individual realm's snap set contains snapshots
33 * explicitly created on that realm, as well as any snaps in its
40 * realm relationship, and for each realm has an explicit list of snaps
44 * with an open cap in the system. (The needed snap realm information is
46 * version number is used to ensure that as realm parameters change (new
47 * snapshot, new parent, etc.) the client's realm hierarchy is updated.
49 * The realm hierarchy drives the generation of a 'snap context' for each
50 * realm, which simply lists the resulting set of snaps for the realm. This
55 * update, but don't have enough memory to update our realm hierarchy,
62 * increase ref count for the realm
67 struct ceph_snap_realm *realm) in ceph_get_snap_realm() argument
77 if (atomic_inc_not_zero(&realm->nref)) in ceph_get_snap_realm()
81 if (atomic_inc_return(&realm->nref) == 1) in ceph_get_snap_realm()
82 list_del_init(&realm->empty_item); in ceph_get_snap_realm()
109 * create and get the realm rooted at @ino and bump its ref count.
117 struct ceph_snap_realm *realm; in ceph_create_snap_realm() local
121 realm = kzalloc(sizeof(*realm), GFP_NOFS); in ceph_create_snap_realm()
122 if (!realm) in ceph_create_snap_realm()
127 atomic_set(&realm->nref, 2); in ceph_create_snap_realm()
129 atomic_set(&realm->nref, 1); in ceph_create_snap_realm()
130 realm->ino = ino; in ceph_create_snap_realm()
131 INIT_LIST_HEAD(&realm->children); in ceph_create_snap_realm()
132 INIT_LIST_HEAD(&realm->child_item); in ceph_create_snap_realm()
133 INIT_LIST_HEAD(&realm->empty_item); in ceph_create_snap_realm()
134 INIT_LIST_HEAD(&realm->dirty_item); in ceph_create_snap_realm()
135 INIT_LIST_HEAD(&realm->rebuild_item); in ceph_create_snap_realm()
136 INIT_LIST_HEAD(&realm->inodes_with_caps); in ceph_create_snap_realm()
137 spin_lock_init(&realm->inodes_with_caps_lock); in ceph_create_snap_realm()
138 __insert_snap_realm(&mdsc->snap_realms, realm); in ceph_create_snap_realm()
141 doutc(mdsc->fsc->client, "%llx %p\n", realm->ino, realm); in ceph_create_snap_realm()
142 return realm; in ceph_create_snap_realm()
146 * lookup the realm rooted at @ino.
184 struct ceph_snap_realm *realm);
190 struct ceph_snap_realm *realm) in __destroy_snap_realm() argument
195 doutc(cl, "%p %llx\n", realm, realm->ino); in __destroy_snap_realm()
197 rb_erase(&realm->node, &mdsc->snap_realms); in __destroy_snap_realm()
200 if (realm->parent) { in __destroy_snap_realm()
201 list_del_init(&realm->child_item); in __destroy_snap_realm()
202 __put_snap_realm(mdsc, realm->parent); in __destroy_snap_realm()
205 kfree(realm->prior_parent_snaps); in __destroy_snap_realm()
206 kfree(realm->snaps); in __destroy_snap_realm()
207 ceph_put_snap_context(realm->cached_context); in __destroy_snap_realm()
208 kfree(realm); in __destroy_snap_realm()
215 struct ceph_snap_realm *realm) in __put_snap_realm() argument
223 if (atomic_dec_and_test(&realm->nref)) in __put_snap_realm()
224 __destroy_snap_realm(mdsc, realm); in __put_snap_realm()
231 struct ceph_snap_realm *realm) in ceph_put_snap_realm() argument
233 if (!atomic_dec_and_lock(&realm->nref, &mdsc->snap_empty_lock)) in ceph_put_snap_realm()
238 __destroy_snap_realm(mdsc, realm); in ceph_put_snap_realm()
241 list_add(&realm->empty_item, &mdsc->snap_empty); in ceph_put_snap_realm()
255 struct ceph_snap_realm *realm; in __cleanup_empty_realms() local
261 realm = list_first_entry(&mdsc->snap_empty, in __cleanup_empty_realms()
263 list_del(&realm->empty_item); in __cleanup_empty_realms()
265 __destroy_snap_realm(mdsc, realm); in __cleanup_empty_realms()
284 * adjust the parent realm of a given @realm. adjust child list, and parent
292 struct ceph_snap_realm *realm, in adjust_snap_realm_parent() argument
300 if (realm->parent_ino == parentino) in adjust_snap_realm_parent()
309 doutc(cl, "%llx %p: %llx %p -> %llx %p\n", realm->ino, realm, in adjust_snap_realm_parent()
310 realm->parent_ino, realm->parent, parentino, parent); in adjust_snap_realm_parent()
311 if (realm->parent) { in adjust_snap_realm_parent()
312 list_del_init(&realm->child_item); in adjust_snap_realm_parent()
313 ceph_put_snap_realm(mdsc, realm->parent); in adjust_snap_realm_parent()
315 realm->parent_ino = parentino; in adjust_snap_realm_parent()
316 realm->parent = parent; in adjust_snap_realm_parent()
317 list_add(&realm->child_item, &parent->children); in adjust_snap_realm_parent()
333 * build the snap context for a given realm.
336 struct ceph_snap_realm *realm, in build_snap_context() argument
341 struct ceph_snap_realm *parent = realm->parent; in build_snap_context()
344 u32 num = realm->num_prior_parent_snaps + realm->num_snaps; in build_snap_context()
361 matches realm seq, and my parents' does to. (this works in build_snap_context()
364 if (realm->cached_context && in build_snap_context()
365 realm->cached_context->seq == realm->seq && in build_snap_context()
367 realm->cached_context->seq >= parent->cached_context->seq)) { in build_snap_context()
369 realm->ino, realm, realm->cached_context, in build_snap_context()
370 realm->cached_context->seq, in build_snap_context()
371 (unsigned int)realm->cached_context->num_snaps); in build_snap_context()
385 snapc->seq = realm->seq; in build_snap_context()
393 realm->parent_since) in build_snap_context()
399 memcpy(snapc->snaps + num, realm->snaps, in build_snap_context()
400 sizeof(u64)*realm->num_snaps); in build_snap_context()
401 num += realm->num_snaps; in build_snap_context()
402 memcpy(snapc->snaps + num, realm->prior_parent_snaps, in build_snap_context()
403 sizeof(u64)*realm->num_prior_parent_snaps); in build_snap_context()
404 num += realm->num_prior_parent_snaps; in build_snap_context()
408 doutc(cl, "%llx %p: %p seq %lld (%u snaps)\n", realm->ino, realm, in build_snap_context()
411 ceph_put_snap_context(realm->cached_context); in build_snap_context()
412 realm->cached_context = snapc; in build_snap_context()
413 /* queue realm for cap_snap creation */ in build_snap_context()
414 list_add_tail(&realm->dirty_item, dirty_realms); in build_snap_context()
422 if (realm->cached_context) { in build_snap_context()
423 ceph_put_snap_context(realm->cached_context); in build_snap_context()
424 realm->cached_context = NULL; in build_snap_context()
426 pr_err_client(cl, "%llx %p fail %d\n", realm->ino, realm, err); in build_snap_context()
431 * rebuild snap context for the given realm and all of its children.
434 struct ceph_snap_realm *realm, in rebuild_snap_realms() argument
442 list_add_tail(&realm->rebuild_item, &realm_queue); in rebuild_snap_realms()
463 doutc(cl, "%llx %p, %s\n", realm->ino, realm, in rebuild_snap_realms()
527 * Caller must hold snap_rwsem for read (i.e., the realm topology won't
719 * Queue cap_snaps for snap writeback for this realm and its children.
720 * Called under snap_rwsem, so realm topology won't change.
723 struct ceph_snap_realm *realm) in queue_realm_cap_snaps() argument
730 doutc(cl, "%p %llx inode\n", realm, realm->ino); in queue_realm_cap_snaps()
732 spin_lock(&realm->inodes_with_caps_lock); in queue_realm_cap_snaps()
733 list_for_each_entry(ci, &realm->inodes_with_caps, i_snap_realm_item) { in queue_realm_cap_snaps()
737 spin_unlock(&realm->inodes_with_caps_lock); in queue_realm_cap_snaps()
762 spin_lock(&realm->inodes_with_caps_lock); in queue_realm_cap_snaps()
764 spin_unlock(&realm->inodes_with_caps_lock); in queue_realm_cap_snaps()
769 doutc(cl, "%p %llx done\n", realm, realm->ino); in queue_realm_cap_snaps()
774 * the snap realm parameters from a given realm and all of its ancestors,
787 struct ceph_snap_realm *realm; in ceph_update_snap_trace() local
800 realm = NULL; in ceph_update_snap_trace()
812 realm = ceph_lookup_snap_realm(mdsc, le64_to_cpu(ri->ino)); in ceph_update_snap_trace()
813 if (!realm) { in ceph_update_snap_trace()
814 realm = ceph_create_snap_realm(mdsc, le64_to_cpu(ri->ino)); in ceph_update_snap_trace()
815 if (IS_ERR(realm)) { in ceph_update_snap_trace()
816 err = PTR_ERR(realm); in ceph_update_snap_trace()
822 err = adjust_snap_realm_parent(mdsc, realm, le64_to_cpu(ri->parent)); in ceph_update_snap_trace()
827 if (le64_to_cpu(ri->seq) > realm->seq) { in ceph_update_snap_trace()
828 doutc(cl, "updating %llx %p %lld -> %lld\n", realm->ino, in ceph_update_snap_trace()
829 realm, realm->seq, le64_to_cpu(ri->seq)); in ceph_update_snap_trace()
830 /* update realm parameters, snap lists */ in ceph_update_snap_trace()
831 realm->seq = le64_to_cpu(ri->seq); in ceph_update_snap_trace()
832 realm->created = le64_to_cpu(ri->created); in ceph_update_snap_trace()
833 realm->parent_since = le64_to_cpu(ri->parent_since); in ceph_update_snap_trace()
835 realm->num_snaps = le32_to_cpu(ri->num_snaps); in ceph_update_snap_trace()
836 err = dup_array(&realm->snaps, snaps, realm->num_snaps); in ceph_update_snap_trace()
840 realm->num_prior_parent_snaps = in ceph_update_snap_trace()
842 err = dup_array(&realm->prior_parent_snaps, prior_parent_snaps, in ceph_update_snap_trace()
843 realm->num_prior_parent_snaps); in ceph_update_snap_trace()
847 if (realm->seq > mdsc->last_snap_seq) in ceph_update_snap_trace()
848 mdsc->last_snap_seq = realm->seq; in ceph_update_snap_trace()
851 } else if (!realm->cached_context) { in ceph_update_snap_trace()
852 doutc(cl, "%llx %p seq %lld new\n", realm->ino, realm, in ceph_update_snap_trace()
853 realm->seq); in ceph_update_snap_trace()
856 doutc(cl, "%llx %p seq %lld unchanged\n", realm->ino, realm, in ceph_update_snap_trace()
857 realm->seq); in ceph_update_snap_trace()
860 doutc(cl, "done with %llx %p, rebuild_snapcs=%d, %p %p\n", realm->ino, in ceph_update_snap_trace()
861 realm, rebuild_snapcs, p, e); in ceph_update_snap_trace()
864 * this will always track the uppest parent realm from which in ceph_update_snap_trace()
869 realm_to_rebuild = realm; in ceph_update_snap_trace()
876 first_realm = realm; in ceph_update_snap_trace()
878 ceph_put_snap_realm(mdsc, realm); in ceph_update_snap_trace()
888 realm = list_first_entry(&dirty_realms, struct ceph_snap_realm, in ceph_update_snap_trace()
890 list_del_init(&realm->dirty_item); in ceph_update_snap_trace()
891 queue_realm_cap_snaps(mdsc, realm); in ceph_update_snap_trace()
905 if (realm && !IS_ERR(realm)) in ceph_update_snap_trace()
906 ceph_put_snap_realm(mdsc, realm); in ceph_update_snap_trace()
969 * @inode: inode to move to new snap realm
970 * @realm: new realm to move inode into (may be NULL)
973 * the new snaprealm (if any). The old snap realm reference held by
974 * the inode is put. If realm is non-NULL, then the caller's reference
977 void ceph_change_snap_realm(struct inode *inode, struct ceph_snap_realm *realm) in ceph_change_snap_realm() argument
994 ci->i_snap_realm = realm; in ceph_change_snap_realm()
996 if (realm) { in ceph_change_snap_realm()
997 spin_lock(&realm->inodes_with_caps_lock); in ceph_change_snap_realm()
998 list_add(&ci->i_snap_realm_item, &realm->inodes_with_caps); in ceph_change_snap_realm()
999 if (realm->ino == ci->i_vino.ino) in ceph_change_snap_realm()
1000 realm->inode = inode; in ceph_change_snap_realm()
1001 spin_unlock(&realm->inodes_with_caps_lock); in ceph_change_snap_realm()
1009 * or deletion notification on an existing realm. This should update the
1010 * realm and its children.
1012 * The more difficult case is realm creation, due to snap creation at a
1014 * directory into another realm.
1026 struct ceph_snap_realm *realm = NULL; in ceph_handle_snap() local
1045 * existing realm */ in ceph_handle_snap()
1061 * A "split" breaks part of an existing realm off into in ceph_handle_snap()
1062 * a new realm. The MDS provides a list of inodes in ceph_handle_snap()
1071 /* we will peek at realm info here, but will _not_ in ceph_handle_snap()
1072 * advance p, as the realm update will occur below in in ceph_handle_snap()
1076 realm = ceph_lookup_snap_realm(mdsc, split); in ceph_handle_snap()
1077 if (!realm) { in ceph_handle_snap()
1078 realm = ceph_create_snap_realm(mdsc, split); in ceph_handle_snap()
1079 if (IS_ERR(realm)) in ceph_handle_snap()
1083 doutc(cl, "splitting snap_realm %llx %p\n", realm->ino, realm); in ceph_handle_snap()
1100 * If this inode belongs to a realm that was in ceph_handle_snap()
1101 * created after our new realm, we experienced in ceph_handle_snap()
1108 doutc(cl, " leaving %p %llx.%llx in newer realm %llx %p\n", in ceph_handle_snap()
1113 doutc(cl, " will move %p %llx.%llx to split realm %llx %p\n", in ceph_handle_snap()
1114 inode, ceph_vinop(inode), realm->ino, realm); in ceph_handle_snap()
1116 ceph_get_snap_realm(mdsc, realm); in ceph_handle_snap()
1117 ceph_change_snap_realm(inode, realm); in ceph_handle_snap()
1127 /* we may have taken some of the old realm's children. */ in ceph_handle_snap()
1134 adjust_snap_realm_parent(mdsc, child, realm->ino); in ceph_handle_snap()
1144 * positioned at the start of realm info, as expected by in ceph_handle_snap()
1163 /* we took a reference when we created the realm, above */ in ceph_handle_snap()
1164 ceph_put_snap_realm(mdsc, realm); in ceph_handle_snap()