fs/ceph/caps.c

1685 		struct ceph_cap_flush *cf = NULL, *iter;
1697 				cf = iter;
1705 		first_tid = cf->tid + 1;
1707 		capsnap = container_of(cf, struct ceph_cap_snap, cap_flush);
1712 		      ceph_vinop(inode), capsnap, cf->tid,
1720 				      ceph_vinop(inode), cf->tid,
1854 	struct ceph_cap_flush *cf;
1856 	cf = kmem_cache_alloc(ceph_cap_flush_cachep, GFP_KERNEL);
1857 	if (!cf)
1860 	cf->is_capsnap = false;
1861 	return cf;
1864 void ceph_free_cap_flush(struct ceph_cap_flush *cf)
1866 	if (cf)
1867 		kmem_cache_free(ceph_cap_flush_cachep, cf);
1873 		struct ceph_cap_flush *cf =
1876 		return cf->tid;
1886 					 struct ceph_cap_flush *cf)
1889 	bool wake = cf->wake;
1891 	if (wake && cf->g_list.prev != &mdsc->cap_flush_list) {
1892 		prev = list_prev_entry(cf, g_list);
1896 	list_del_init(&cf->g_list);
1901 				       struct ceph_cap_flush *cf)
1904 	bool wake = cf->wake;
1906 	if (wake && cf->i_list.prev != &ci->i_cap_flush_list) {
1907 		prev = list_prev_entry(cf, i_list);
1911 	list_del_init(&cf->i_list);
1928 	struct ceph_cap_flush *cf = NULL;
1945 	swap(cf, ci->i_prealloc_cap_flush);
1946 	cf->caps = flushing;
1947 	cf->wake = wake;
1952 	cf->tid = ++mdsc->last_cap_flush_tid;
1953 	list_add_tail(&cf->g_list, &mdsc->cap_flush_list);
1962 	list_add_tail(&cf->i_list, &ci->i_cap_flush_list);
1964 	return cf->tid;
2327 			struct ceph_cap_flush *cf =
2330 			cf->wake = true;
2331 			flush_tid = cf->tid;
2351 		struct ceph_cap_flush * cf =
2354 		if (cf->tid <= flush_tid)
2575 	struct ceph_cap_flush *cf;
2586 	list_for_each_entry_reverse(cf, &ci->i_cap_flush_list, i_list) {
2587 		if (cf->is_capsnap) {
2588 			last_snap_flush = cf->tid;
2593 	list_for_each_entry(cf, &ci->i_cap_flush_list, i_list) {
2594 		if (cf->tid < first_tid)
2604 		first_tid = cf->tid + 1;
2606 		if (!cf->is_capsnap) {
2610 			      inode, ceph_vinop(inode), cap, cf->tid,
2611 			      ceph_cap_string(cf->caps));
2613 					 (cf->tid < last_snap_flush ?
2618 					  cf->caps, cf->tid, oldest_flush_tid);
2623 					container_of(cf, struct ceph_cap_snap,
2626 			      inode, ceph_vinop(inode), capsnap, cf->tid,
2637 					      inode, ceph_vinop(inode), cf->tid,
3813 	struct ceph_cap_flush *cf, *tmp_cf;
3822 	list_for_each_entry_safe(cf, tmp_cf, &ci->i_cap_flush_list, i_list) {
3824 		if (cf->tid == flush_tid)
3825 			cleaned = cf->caps;
3828 		if (cf->is_capsnap)
3831 		if (cf->tid <= flush_tid) {
3836 			wake_ci |= __detach_cap_flush_from_ci(ci, cf);
3837 			list_add_tail(&cf->i_list, &to_remove);
3843 			cleaned &= ~cf->caps;
3862 	list_for_each_entry(cf, &to_remove, i_list)
3863 		wake_mdsc |= __detach_cap_flush_from_mdsc(mdsc, cf);
3902 		cf = list_first_entry(&to_remove,
3904 		list_del_init(&cf->i_list);
3905 		if (!cf->is_capsnap)
3906 			ceph_free_cap_flush(cf);
5000 		struct ceph_cap_flush *cf;
5013 			cf = list_first_entry(&ci->i_cap_flush_list,
5015 			list_del_init(&cf->g_list);
5016 			list_del_init(&cf->i_list);
5017 			if (!cf->is_capsnap)
5018 				ceph_free_cap_flush(cf);
5063 			cf = ci->i_prealloc_cap_flush;
5065 			if (!cf->is_capsnap)
5066 				ceph_free_cap_flush(cf);