Lines Matching refs:realm
66 struct ceph_snap_realm *realm) in ceph_get_snap_realm() argument
68 dout("get_realm %p %d -> %d\n", realm, in ceph_get_snap_realm()
69 atomic_read(&realm->nref), atomic_read(&realm->nref)+1); in ceph_get_snap_realm()
76 if (atomic_inc_return(&realm->nref) == 1) { in ceph_get_snap_realm()
78 list_del_init(&realm->empty_item); in ceph_get_snap_realm()
114 struct ceph_snap_realm *realm; in ceph_create_snap_realm() local
116 realm = kzalloc(sizeof(*realm), GFP_NOFS); in ceph_create_snap_realm()
117 if (!realm) in ceph_create_snap_realm()
120 atomic_set(&realm->nref, 1); /* for caller */ in ceph_create_snap_realm()
121 realm->ino = ino; in ceph_create_snap_realm()
122 INIT_LIST_HEAD(&realm->children); in ceph_create_snap_realm()
123 INIT_LIST_HEAD(&realm->child_item); in ceph_create_snap_realm()
124 INIT_LIST_HEAD(&realm->empty_item); in ceph_create_snap_realm()
125 INIT_LIST_HEAD(&realm->dirty_item); in ceph_create_snap_realm()
126 INIT_LIST_HEAD(&realm->inodes_with_caps); in ceph_create_snap_realm()
127 spin_lock_init(&realm->inodes_with_caps_lock); in ceph_create_snap_realm()
128 __insert_snap_realm(&mdsc->snap_realms, realm); in ceph_create_snap_realm()
131 dout("create_snap_realm %llx %p\n", realm->ino, realm); in ceph_create_snap_realm()
132 return realm; in ceph_create_snap_realm()
171 struct ceph_snap_realm *realm);
177 struct ceph_snap_realm *realm) in __destroy_snap_realm() argument
179 dout("__destroy_snap_realm %p %llx\n", realm, realm->ino); in __destroy_snap_realm()
181 rb_erase(&realm->node, &mdsc->snap_realms); in __destroy_snap_realm()
184 if (realm->parent) { in __destroy_snap_realm()
185 list_del_init(&realm->child_item); in __destroy_snap_realm()
186 __put_snap_realm(mdsc, realm->parent); in __destroy_snap_realm()
189 kfree(realm->prior_parent_snaps); in __destroy_snap_realm()
190 kfree(realm->snaps); in __destroy_snap_realm()
191 ceph_put_snap_context(realm->cached_context); in __destroy_snap_realm()
192 kfree(realm); in __destroy_snap_realm()
199 struct ceph_snap_realm *realm) in __put_snap_realm() argument
201 dout("__put_snap_realm %llx %p %d -> %d\n", realm->ino, realm, in __put_snap_realm()
202 atomic_read(&realm->nref), atomic_read(&realm->nref)-1); in __put_snap_realm()
203 if (atomic_dec_and_test(&realm->nref)) in __put_snap_realm()
204 __destroy_snap_realm(mdsc, realm); in __put_snap_realm()
211 struct ceph_snap_realm *realm) in ceph_put_snap_realm() argument
213 dout("put_snap_realm %llx %p %d -> %d\n", realm->ino, realm, in ceph_put_snap_realm()
214 atomic_read(&realm->nref), atomic_read(&realm->nref)-1); in ceph_put_snap_realm()
215 if (!atomic_dec_and_test(&realm->nref)) in ceph_put_snap_realm()
219 __destroy_snap_realm(mdsc, realm); in ceph_put_snap_realm()
223 list_add(&realm->empty_item, &mdsc->snap_empty); in ceph_put_snap_realm()
237 struct ceph_snap_realm *realm; in __cleanup_empty_realms() local
241 realm = list_first_entry(&mdsc->snap_empty, in __cleanup_empty_realms()
243 list_del(&realm->empty_item); in __cleanup_empty_realms()
245 __destroy_snap_realm(mdsc, realm); in __cleanup_empty_realms()
267 struct ceph_snap_realm *realm, in adjust_snap_realm_parent() argument
272 if (realm->parent_ino == parentino) in adjust_snap_realm_parent()
282 realm->ino, realm, realm->parent_ino, realm->parent, in adjust_snap_realm_parent()
284 if (realm->parent) { in adjust_snap_realm_parent()
285 list_del_init(&realm->child_item); in adjust_snap_realm_parent()
286 ceph_put_snap_realm(mdsc, realm->parent); in adjust_snap_realm_parent()
288 realm->parent_ino = parentino; in adjust_snap_realm_parent()
289 realm->parent = parent; in adjust_snap_realm_parent()
290 list_add(&realm->child_item, &parent->children); in adjust_snap_realm_parent()
308 static int build_snap_context(struct ceph_snap_realm *realm, in build_snap_context() argument
311 struct ceph_snap_realm *parent = realm->parent; in build_snap_context()
314 u32 num = realm->num_prior_parent_snaps + realm->num_snaps; in build_snap_context()
334 if (realm->cached_context && in build_snap_context()
335 realm->cached_context->seq == realm->seq && in build_snap_context()
337 realm->cached_context->seq >= parent->cached_context->seq)) { in build_snap_context()
340 realm->ino, realm, realm->cached_context, in build_snap_context()
341 realm->cached_context->seq, in build_snap_context()
342 (unsigned int)realm->cached_context->num_snaps); in build_snap_context()
356 snapc->seq = realm->seq; in build_snap_context()
364 realm->parent_since) in build_snap_context()
370 memcpy(snapc->snaps + num, realm->snaps, in build_snap_context()
371 sizeof(u64)*realm->num_snaps); in build_snap_context()
372 num += realm->num_snaps; in build_snap_context()
373 memcpy(snapc->snaps + num, realm->prior_parent_snaps, in build_snap_context()
374 sizeof(u64)*realm->num_prior_parent_snaps); in build_snap_context()
375 num += realm->num_prior_parent_snaps; in build_snap_context()
380 realm->ino, realm, snapc, snapc->seq, in build_snap_context()
383 ceph_put_snap_context(realm->cached_context); in build_snap_context()
384 realm->cached_context = snapc; in build_snap_context()
386 list_add_tail(&realm->dirty_item, dirty_realms); in build_snap_context()
394 if (realm->cached_context) { in build_snap_context()
395 ceph_put_snap_context(realm->cached_context); in build_snap_context()
396 realm->cached_context = NULL; in build_snap_context()
398 pr_err("build_snap_context %llx %p fail %d\n", realm->ino, in build_snap_context()
399 realm, err); in build_snap_context()
406 static void rebuild_snap_realms(struct ceph_snap_realm *realm, in rebuild_snap_realms() argument
411 dout("rebuild_snap_realms %llx %p\n", realm->ino, realm); in rebuild_snap_realms()
412 build_snap_context(realm, dirty_realms); in rebuild_snap_realms()
414 list_for_each_entry(child, &realm->children, child_item) in rebuild_snap_realms()
643 static void queue_realm_cap_snaps(struct ceph_snap_realm *realm) in queue_realm_cap_snaps() argument
648 dout("queue_realm_cap_snaps %p %llx inodes\n", realm, realm->ino); in queue_realm_cap_snaps()
650 spin_lock(&realm->inodes_with_caps_lock); in queue_realm_cap_snaps()
651 list_for_each_entry(ci, &realm->inodes_with_caps, i_snap_realm_item) { in queue_realm_cap_snaps()
655 spin_unlock(&realm->inodes_with_caps_lock); in queue_realm_cap_snaps()
661 spin_lock(&realm->inodes_with_caps_lock); in queue_realm_cap_snaps()
663 spin_unlock(&realm->inodes_with_caps_lock); in queue_realm_cap_snaps()
666 dout("queue_realm_cap_snaps %p %llx done\n", realm, realm->ino); in queue_realm_cap_snaps()
683 struct ceph_snap_realm *realm = NULL; in ceph_update_snap_trace() local
701 realm = ceph_lookup_snap_realm(mdsc, le64_to_cpu(ri->ino)); in ceph_update_snap_trace()
702 if (!realm) { in ceph_update_snap_trace()
703 realm = ceph_create_snap_realm(mdsc, le64_to_cpu(ri->ino)); in ceph_update_snap_trace()
704 if (IS_ERR(realm)) { in ceph_update_snap_trace()
705 err = PTR_ERR(realm); in ceph_update_snap_trace()
711 err = adjust_snap_realm_parent(mdsc, realm, le64_to_cpu(ri->parent)); in ceph_update_snap_trace()
716 if (le64_to_cpu(ri->seq) > realm->seq) { in ceph_update_snap_trace()
718 realm->ino, realm, realm->seq, le64_to_cpu(ri->seq)); in ceph_update_snap_trace()
720 realm->seq = le64_to_cpu(ri->seq); in ceph_update_snap_trace()
721 realm->created = le64_to_cpu(ri->created); in ceph_update_snap_trace()
722 realm->parent_since = le64_to_cpu(ri->parent_since); in ceph_update_snap_trace()
724 realm->num_snaps = le32_to_cpu(ri->num_snaps); in ceph_update_snap_trace()
725 err = dup_array(&realm->snaps, snaps, realm->num_snaps); in ceph_update_snap_trace()
729 realm->num_prior_parent_snaps = in ceph_update_snap_trace()
731 err = dup_array(&realm->prior_parent_snaps, prior_parent_snaps, in ceph_update_snap_trace()
732 realm->num_prior_parent_snaps); in ceph_update_snap_trace()
736 if (realm->seq > mdsc->last_snap_seq) in ceph_update_snap_trace()
737 mdsc->last_snap_seq = realm->seq; in ceph_update_snap_trace()
740 } else if (!realm->cached_context) { in ceph_update_snap_trace()
742 realm->ino, realm, realm->seq); in ceph_update_snap_trace()
746 realm->ino, realm, realm->seq); in ceph_update_snap_trace()
749 dout("done with %llx %p, invalidated=%d, %p %p\n", realm->ino, in ceph_update_snap_trace()
750 realm, invalidate, p, e); in ceph_update_snap_trace()
754 rebuild_snap_realms(realm, &dirty_realms); in ceph_update_snap_trace()
757 first_realm = realm; in ceph_update_snap_trace()
759 ceph_put_snap_realm(mdsc, realm); in ceph_update_snap_trace()
769 realm = list_first_entry(&dirty_realms, struct ceph_snap_realm, in ceph_update_snap_trace()
771 list_del_init(&realm->dirty_item); in ceph_update_snap_trace()
772 queue_realm_cap_snaps(realm); in ceph_update_snap_trace()
786 if (realm && !IS_ERR(realm)) in ceph_update_snap_trace()
787 ceph_put_snap_realm(mdsc, realm); in ceph_update_snap_trace()
851 struct ceph_snap_realm *realm = NULL; in ceph_handle_snap() local
901 realm = ceph_lookup_snap_realm(mdsc, split); in ceph_handle_snap()
902 if (!realm) { in ceph_handle_snap()
903 realm = ceph_create_snap_realm(mdsc, split); in ceph_handle_snap()
904 if (IS_ERR(realm)) in ceph_handle_snap()
908 dout("splitting snap_realm %llx %p\n", realm->ino, realm); in ceph_handle_snap()
940 inode, realm->ino, realm); in ceph_handle_snap()
949 spin_lock(&realm->inodes_with_caps_lock); in ceph_handle_snap()
951 &realm->inodes_with_caps); in ceph_handle_snap()
952 ci->i_snap_realm = realm; in ceph_handle_snap()
953 if (realm->ino == ci->i_vino.ino) in ceph_handle_snap()
954 realm->inode = inode; in ceph_handle_snap()
955 spin_unlock(&realm->inodes_with_caps_lock); in ceph_handle_snap()
959 ceph_get_snap_realm(mdsc, realm); in ceph_handle_snap()
979 adjust_snap_realm_parent(mdsc, child, realm->ino); in ceph_handle_snap()
992 ceph_put_snap_realm(mdsc, realm); in ceph_handle_snap()