Commit 96601e8a authored by Christian König's avatar Christian König

dma-buf: use new iterator in dma_resv_copy_fences

This makes the function much simpler since the complex
retry logic is now handled else where.
Signed-off-by: default avatarChristian König <christian.koenig@amd.com>
Reviewed-by: default avatarDaniel Vetter <daniel.vetter@ffwll.ch>
Link: https://patchwork.freedesktop.org/patch/msgid/20211005113742.1101-5-christian.koenig@amd.com
parent c921ff37
...@@ -432,74 +432,54 @@ EXPORT_SYMBOL(dma_resv_iter_next_unlocked); ...@@ -432,74 +432,54 @@ EXPORT_SYMBOL(dma_resv_iter_next_unlocked);
*/ */
int dma_resv_copy_fences(struct dma_resv *dst, struct dma_resv *src) int dma_resv_copy_fences(struct dma_resv *dst, struct dma_resv *src)
{ {
struct dma_resv_list *src_list, *dst_list; struct dma_resv_iter cursor;
struct dma_fence *old, *new; struct dma_resv_list *list;
unsigned int i; struct dma_fence *f, *excl;
dma_resv_assert_held(dst); dma_resv_assert_held(dst);
rcu_read_lock(); list = NULL;
src_list = dma_resv_shared_list(src); excl = NULL;
retry: dma_resv_iter_begin(&cursor, src, true);
if (src_list) { dma_resv_for_each_fence_unlocked(&cursor, f) {
unsigned int shared_count = src_list->shared_count;
rcu_read_unlock(); if (dma_resv_iter_is_restarted(&cursor)) {
dma_resv_list_free(list);
dma_fence_put(excl);
dst_list = dma_resv_list_alloc(shared_count); if (cursor.fences) {
if (!dst_list) unsigned int cnt = cursor.fences->shared_count;
return -ENOMEM;
rcu_read_lock(); list = dma_resv_list_alloc(cnt);
src_list = dma_resv_shared_list(src); if (!list) {
if (!src_list || src_list->shared_count > shared_count) { dma_resv_iter_end(&cursor);
kfree(dst_list); return -ENOMEM;
goto retry; }
}
dst_list->shared_count = 0;
for (i = 0; i < src_list->shared_count; ++i) {
struct dma_fence __rcu **dst;
struct dma_fence *fence;
fence = rcu_dereference(src_list->shared[i]); list->shared_count = 0;
if (test_bit(DMA_FENCE_FLAG_SIGNALED_BIT,
&fence->flags))
continue;
if (!dma_fence_get_rcu(fence)) { } else {
dma_resv_list_free(dst_list); list = NULL;
src_list = dma_resv_shared_list(src);
goto retry;
} }
excl = NULL;
if (dma_fence_is_signaled(fence)) {
dma_fence_put(fence);
continue;
}
dst = &dst_list->shared[dst_list->shared_count++];
rcu_assign_pointer(*dst, fence);
} }
} else {
dst_list = NULL;
}
new = dma_fence_get_rcu_safe(&src->fence_excl); dma_fence_get(f);
rcu_read_unlock(); if (dma_resv_iter_is_exclusive(&cursor))
excl = f;
src_list = dma_resv_shared_list(dst); else
old = dma_resv_excl_fence(dst); RCU_INIT_POINTER(list->shared[list->shared_count++], f);
}
dma_resv_iter_end(&cursor);
write_seqcount_begin(&dst->seq); write_seqcount_begin(&dst->seq);
/* write_seqcount_begin provides the necessary memory barrier */ excl = rcu_replace_pointer(dst->fence_excl, excl, dma_resv_held(dst));
RCU_INIT_POINTER(dst->fence_excl, new); list = rcu_replace_pointer(dst->fence, list, dma_resv_held(dst));
RCU_INIT_POINTER(dst->fence, dst_list);
write_seqcount_end(&dst->seq); write_seqcount_end(&dst->seq);
dma_resv_list_free(src_list); dma_resv_list_free(list);
dma_fence_put(old); dma_fence_put(excl);
return 0; return 0;
} }
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment