io_uring
fch->io_uring = 1;
(fch->io_uring && fch->connected && !fuse_uring_ready(fch));
if (!enable_uring && !fch->io_uring) {
fch->io_uring = 0;
unsigned int io_uring;
if (current->io_uring)
if (current->io_uring)
if (tsk->io_uring || tsk->io_uring_restrict)
struct io_uring sq, cq;
struct io_uring_task *io_uring;
#define TRACE_SYSTEM io_uring
.io_uring = NULL,
WARN_ON_ONCE(!io_wq_current_is_worker() && tctx != current->io_uring);
ret = io_async_cancel_one(node->task->io_uring, cd);
ret = __io_sync_cancel(current->io_uring, &cd, sc.fd);
ret = __io_sync_cancel(current->io_uring, &cd, sc.fd);
struct io_uring_task *tctx = node->task->io_uring;
struct io_uring_task *tctx = current->io_uring;
if (!current->io_uring)
current->io_uring,
current->io_uring,
req->tctx = current->io_uring;
current->io_uring->cached_refs++;
current->io_uring->cached_refs += left;
struct io_uring_task *tctx = current->io_uring;
if (tsk && tsk->io_uring && tsk->io_uring->io_wq)
io_wq_cancel_cb(tsk->io_uring->io_wq,
struct io_uring_task *tctx = current->io_uring;
tctx = current->io_uring;
struct io_uring_task *tctx = task->io_uring;
struct io_uring_task *tctx = current->io_uring;
notif->tctx = current->io_uring;
e->rq_hdr_size = sizeof(struct io_uring);
ret = io_wq_cpu_affinity(current->io_uring, new_mask);
tctx = tsk->io_uring;
tctx = current->io_uring;
tctx = node->task->io_uring;
struct io_uring_task *tctx = current->io_uring;
struct io_uring_task *tctx = current->io_uring;
if (!current->io_uring) {
tsk->io_uring = tctx;
ret = io_wq_cpu_affinity(tsk->io_uring, mask);
struct io_uring_task *tctx = current->io_uring;
current->io_uring = tctx;
current->io_uring = NULL;
current->io_uring->last = ctx;
struct io_uring_task *tctx = current->io_uring;
struct io_uring_task *tctx = current->io_uring;
tctx = current->io_uring;
struct io_uring_task *tctx = current->io_uring;
struct io_uring_task *tctx = tsk->io_uring;
tsk->io_uring = NULL;
struct io_uring_task *tctx = current->io_uring;
current->io_uring == tctx)
if (current->io_uring) {
tctx_task_work_run(current->io_uring, UINT_MAX, &count);
struct io_uring_task *tctx = current->io_uring;
offsets->head = offsetof(struct io_uring, head);
offsets->tail = offsetof(struct io_uring, tail);
offsets->rqes = ALIGN(sizeof(struct io_uring), L1_CACHE_BYTES);
ifq->rq.ring = (struct io_uring *)ptr;
struct io_uring *ring;
p->io_uring = NULL;
struct io_uring *ring,
struct io_uring *ring,
static inline struct io_uring_sqe *io_uring_get_sqe(struct io_uring *ring)
static inline int io_uring_wait_cqe(struct io_uring *ring,
static inline int io_uring_submit(struct io_uring *ring)
static inline void io_uring_queue_exit(struct io_uring *ring)
static inline int io_uring_register_buffers(struct io_uring *ring,
static inline void io_uring_cqe_seen(struct io_uring *ring)
struct io_uring ring;
static void setup_zcrx(struct io_uring *ring)
static void add_accept(struct io_uring *ring, int sockfd)
static void add_recvzc(struct io_uring *ring, int sockfd)
static void add_recvzc_oneshot(struct io_uring *ring, int sockfd, size_t len)
static void process_accept(struct io_uring *ring, struct io_uring_cqe *cqe)
static void process_recvzc(struct io_uring *ring, struct io_uring_cqe *cqe)
static void server_loop(struct io_uring *ring)
struct io_uring ring;
struct io_uring ring;
struct io_uring ring;
struct io_uring ring;
static inline int ublk_setup_ring(struct io_uring *r, int depth,
struct io_uring ring;
struct io_uring ring;
struct io_uring *ring = &t->ring;
struct io_uring ring;
struct io_uring ring;