[linux-block.git] / include / linux / io_uring.h

/* SPDX-License-Identifier: GPL-2.0-or-later */
#ifndef _LINUX_IO_URING_H
#define _LINUX_IO_URING_H

#include <linux/sched.h>
#include <linux/xarray.h>

enum io_uring_cmd_flags {
	IO_URING_F_COMPLETE_DEFER	= 1,
	IO_URING_F_UNLOCKED		= 2,
	/* int's last bit, sign checks are usually faster than a bit test */
	IO_URING_F_NONBLOCK		= INT_MIN,

	/* ctx state flags, for URING_CMD */
	IO_URING_F_SQE128		= 4,
	IO_URING_F_CQE32		= 8,
	IO_URING_F_IOPOLL		= 16,
};

struct io_uring_cmd {
	struct file	*file;
	const void	*cmd;
	/* callback to defer completions to task context */
	void (*task_work_cb)(struct io_uring_cmd *cmd);
	u32		cmd_op;
	u32		pad;
	u8		pdu[32]; /* available inline for free use */
};

#if defined(CONFIG_IO_URING)
void io_uring_cmd_done(struct io_uring_cmd *cmd, ssize_t ret, ssize_t res2);
void io_uring_cmd_complete_in_task(struct io_uring_cmd *ioucmd,
			void (*task_work_cb)(struct io_uring_cmd *));
struct sock *io_uring_get_socket(struct file *file);
void __io_uring_cancel(bool cancel_all);
void __io_uring_free(struct task_struct *tsk);
void io_uring_unreg_ringfd(void);
const char *io_uring_get_opcode(u8 opcode);

static inline void io_uring_files_cancel(void)
{
	if (current->io_uring) {
		io_uring_unreg_ringfd();
		__io_uring_cancel(false);
	}
}
static inline void io_uring_task_cancel(void)
{
	if (current->io_uring)
		__io_uring_cancel(true);
}
static inline void io_uring_free(struct task_struct *tsk)
{
	if (tsk->io_uring)
		__io_uring_free(tsk);
}
#else
static inline void io_uring_cmd_done(struct io_uring_cmd *cmd, ssize_t ret,
		ssize_t ret2)
{
}
static inline void io_uring_cmd_complete_in_task(struct io_uring_cmd *ioucmd,
			void (*task_work_cb)(struct io_uring_cmd *))
{
}
static inline struct sock *io_uring_get_socket(struct file *file)
{
	return NULL;
}
static inline void io_uring_task_cancel(void)
{
}
static inline void io_uring_files_cancel(void)
{
}
static inline void io_uring_free(struct task_struct *tsk)
{
}
static inline const char *io_uring_get_opcode(u8 opcode)
{
	return "";
}
#endif

#endif
Commit	Line	Data
0f212204 JA	1	/* SPDX-License-Identifier: GPL-2.0-or-later */
	2	#ifndef _LINUX_IO_URING_H
	3	#define _LINUX_IO_URING_H
	4
	5	#include <linux/sched.h>
	6	#include <linux/xarray.h>
98447d65	7
ee692a21 JA	8	enum io_uring_cmd_flags {
	9	IO_URING_F_COMPLETE_DEFER = 1,
	10	IO_URING_F_UNLOCKED = 2,
	11	/* int's last bit, sign checks are usually faster than a bit test */
	12	IO_URING_F_NONBLOCK = INT_MIN,
	13
	14	/* ctx state flags, for URING_CMD */
	15	IO_URING_F_SQE128 = 4,
	16	IO_URING_F_CQE32 = 8,
	17	IO_URING_F_IOPOLL = 16,
	18	};
	19
	20	struct io_uring_cmd {
	21	struct file *file;
	22	const void *cmd;
	23	/* callback to defer completions to task context */
	24	void (task_work_cb)(struct io_uring_cmd cmd);
	25	u32 cmd_op;
	26	u32 pad;
	27	u8 pdu[32]; /* available inline for free use */
	28	};
	29
0f212204	30	#if defined(CONFIG_IO_URING)
ee692a21 JA	31	void io_uring_cmd_done(struct io_uring_cmd *cmd, ssize_t ret, ssize_t res2);
	32	void io_uring_cmd_complete_in_task(struct io_uring_cmd *ioucmd,
	33	void (task_work_cb)(struct io_uring_cmd ));
a3ec6005	34	struct sock io_uring_get_socket(struct file file);
f552a27a	35	void __io_uring_cancel(bool cancel_all);
0f212204	36	void __io_uring_free(struct task_struct *tsk);
e7a6c00d	37	void io_uring_unreg_ringfd(void);
33337d03	38	const char *io_uring_get_opcode(u8 opcode);
0f212204	39
f552a27a	40	static inline void io_uring_files_cancel(void)
0f212204	41	{
e7a6c00d JA	42	if (current->io_uring) {
e7a6c00d JA	43	io_uring_unreg_ringfd();
f552a27a	44	__io_uring_cancel(false);
e7a6c00d	45	}
0f212204	46	}
3f48cf18	47	static inline void io_uring_task_cancel(void)
0f212204	48	{
a4aadd11	49	if (current->io_uring)
f552a27a	50	__io_uring_cancel(true);
0f212204 JA	51	}
	52	static inline void io_uring_free(struct task_struct *tsk)
	53	{
	54	if (tsk->io_uring)
	55	__io_uring_free(tsk);
	56	}
	57	#else
ee692a21 JA	58	static inline void io_uring_cmd_done(struct io_uring_cmd *cmd, ssize_t ret,
	59	ssize_t ret2)
	60	{
	61	}
	62	static inline void io_uring_cmd_complete_in_task(struct io_uring_cmd *ioucmd,
	63	void (task_work_cb)(struct io_uring_cmd ))
	64	{
	65	}
a3ec6005 JA	66	static inline struct sock io_uring_get_socket(struct file file)
	67	{
	68	return NULL;
	69	}
0f212204 JA	70	static inline void io_uring_task_cancel(void)
	71	{
	72	}
f552a27a	73	static inline void io_uring_files_cancel(void)
0f212204 JA	74	{
	75	}
	76	static inline void io_uring_free(struct task_struct *tsk)
	77	{
	78	}
33337d03 DY	79	static inline const char *io_uring_get_opcode(u8 opcode)
	80	{
	81	return "";
	82	}
0f212204 JA	83	#endif
	84
	85	#endif