Commit a830ffd2 authored by Pavel Begunkov's avatar Pavel Begunkov Committed by Jens Axboe
Browse files

io_uring: move io_eventfd_signal() 



Move io_eventfd_signal() in the sources without any changes and kill its
forward declaration.

Signed-off-by: default avatarPavel Begunkov <asml.silence@gmail.com>
Link: https://lore.kernel.org/r/9ebebb3f6f56f5a5448a621e0b6a537720c43334.1655637157.git.asml.silence@gmail.com


Signed-off-by: default avatarJens Axboe <axboe@kernel.dk>
parent 9046c641

io_uring/io_uring.c

+14 −16
Original line number Diff line number Diff line
@@ -142,8 +142,6 @@ static void io_queue_sqe(struct io_kiocb *req); 


static void __io_submit_flush_completions(struct io_ring_ctx *ctx);



static void io_eventfd_signal(struct io_ring_ctx *ctx);



static struct kmem_cache *req_cachep;



struct sock *io_uring_get_socket(struct file *file)
@@ -472,20 +470,6 @@ static __cold void io_queue_deferred(struct io_ring_ctx *ctx) 
	}

}



void __io_commit_cqring_flush(struct io_ring_ctx *ctx)

{

	if (ctx->off_timeout_used || ctx->drain_active) {

		spin_lock(&ctx->completion_lock);

		if (ctx->off_timeout_used)

			io_flush_timeouts(ctx);

		if (ctx->drain_active)

			io_queue_deferred(ctx);

		spin_unlock(&ctx->completion_lock);

	}

	if (ctx->has_evfd)

		io_eventfd_signal(ctx);

}



static void io_eventfd_signal(struct io_ring_ctx *ctx)

{

	struct io_ev_fd *ev_fd;
@@ -513,6 +497,20 @@ static void io_eventfd_signal(struct io_ring_ctx *ctx) 
	rcu_read_unlock();

}



void __io_commit_cqring_flush(struct io_ring_ctx *ctx)

{

	if (ctx->off_timeout_used || ctx->drain_active) {

		spin_lock(&ctx->completion_lock);

		if (ctx->off_timeout_used)

			io_flush_timeouts(ctx);

		if (ctx->drain_active)

			io_queue_deferred(ctx);

		spin_unlock(&ctx->completion_lock);

	}

	if (ctx->has_evfd)

		io_eventfd_signal(ctx);

}



/*

 * This should only get called when at least one event has been posted.

 * Some applications rely on the eventfd notification count only changing