Searched refs:mask (Results 1 – 15 of 15) sorted by relevance
/io_uring/ |
A D | poll.c | 197 io_req_set_res(req, mask, 0); in __io_poll_execute() 403 if (mask && !(mask & (poll->events & ~IO_ASYNC_POLL_COMMON))) in io_poll_wake() 412 if (mask & EPOLL_URING_WAKE) in io_poll_wake() 553 ipt->pt._key = mask; in __io_arm_poll_handler() 590 ipt->result_mask = mask; in __io_arm_poll_handler() 596 if (mask && in __io_arm_poll_handler() 603 ipt->result_mask = mask; in __io_arm_poll_handler() 676 mask |= EPOLLET; in io_arm_apoll() 680 mask |= EPOLLONESHOT; in io_arm_apoll() 713 mask &= ~EPOLLIN; in io_arm_poll_handler() [all …]
|
A D | statx.c | 17 unsigned int mask; member 34 sx->mask = READ_ONCE(sqe->len); in io_statx_prep() 60 ret = do_statx(sx->dfd, sx->filename, sx->flags, sx->mask, sx->buffer); in io_statx()
|
A D | mock_file.c | 170 __poll_t mask = 0; in io_mock_poll() local 174 mask |= EPOLLOUT | EPOLLWRNORM; in io_mock_poll() 175 mask |= EPOLLIN | EPOLLRDNORM; in io_mock_poll() 176 return mask; in io_mock_poll()
|
A D | kbuf.c | 24 #define io_ring_head_to_buf(br, head, mask) &(br)->bufs[(head) & (mask)] argument 41 buf = io_ring_head_to_buf(bl->buf_ring, bl->head, bl->mask); in io_kbuf_inc_commit() 170 buf = io_ring_head_to_buf(br, head, bl->mask); in io_ring_buffer_select() 233 buf = io_ring_head_to_buf(br, head, bl->mask); in io_ring_buffers_peek() 290 buf = io_ring_head_to_buf(br, ++head, bl->mask); in io_ring_buffers_peek() 645 bl->mask = reg.ring_entries - 1; in io_register_pbuf_ring()
|
A D | uring_cmd.h | 26 unsigned int issue_flags, __poll_t mask);
|
A D | sqpoll.h | 31 int io_sqpoll_wq_cpu_affinity(struct io_ring_ctx *ctx, cpumask_var_t mask);
|
A D | uring_cmd.c | 311 unsigned int issue_flags, __poll_t mask) in io_cmd_poll_multishot() argument 320 mask &= ~EPOLLONESHOT; in io_cmd_poll_multishot() 322 ret = io_arm_apoll(req, issue_flags, mask); in io_cmd_poll_multishot()
|
A D | poll.h | 44 int io_arm_apoll(struct io_kiocb *req, unsigned issue_flags, __poll_t mask);
|
A D | io-wq.h | 48 int io_wq_cpu_affinity(struct io_uring_task *tctx, cpumask_var_t mask);
|
A D | kbuf.h | 33 __u16 mask; member
|
A D | sqpoll.c | 520 cpumask_var_t mask) in io_sqpoll_wq_cpu_affinity() argument 532 ret = io_wq_cpu_affinity(tsk->io_uring, mask); in io_sqpoll_wq_cpu_affinity()
|
A D | io-wq.c | 1402 int io_wq_cpu_affinity(struct io_uring_task *tctx, cpumask_var_t mask) in io_wq_cpu_affinity() argument 1415 if (mask) { in io_wq_cpu_affinity() 1416 if (cpumask_subset(mask, allowed_mask)) in io_wq_cpu_affinity() 1417 cpumask_copy(tctx->io_wq->cpu_mask, mask); in io_wq_cpu_affinity()
|
A D | zcrx.c | 743 unsigned mask) in io_zcrx_get_rqe() argument 745 unsigned int idx = ifq->cached_rq_head++ & mask; in io_zcrx_get_rqe() 753 unsigned int mask = ifq->rq_entries - 1; in io_zcrx_ring_refill() local 767 struct io_uring_zcrx_rqe *rqe = io_zcrx_get_rqe(ifq, mask); in io_zcrx_ring_refill()
|
A D | rw.c | 37 static bool io_file_supports_nowait(struct io_kiocb *req, __poll_t mask) in io_file_supports_nowait() argument 44 struct poll_table_struct pt = { ._key = mask }; in io_file_supports_nowait() 46 return vfs_poll(req->file, &pt) & mask; in io_file_supports_nowait()
|
A D | io_uring.c | 2338 unsigned mask = ctx->sq_entries - 1; in io_get_sqe() local 2339 unsigned head = ctx->cached_sq_head++ & mask; in io_get_sqe() 2870 __poll_t mask = 0; in io_uring_poll() local 2881 mask |= EPOLLOUT | EPOLLWRNORM; in io_uring_poll() 2898 mask |= EPOLLIN | EPOLLRDNORM; in io_uring_poll() 2900 return mask; in io_uring_poll()
|
Completed in 31 milliseconds