File tree Expand file tree Collapse file tree 3 files changed +25
-26
lines changed Expand file tree Collapse file tree 3 files changed +25
-26
lines changed Original file line number Diff line number Diff line change 2
2
#define INTERNAL_IO_WQ_H
3
3
4
4
#include <linux/refcount.h>
5
- #include <linux/io_uring.h>
6
5
7
6
struct io_wq ;
8
7
@@ -21,6 +20,15 @@ enum io_wq_cancel {
21
20
IO_WQ_CANCEL_NOTFOUND , /* work not found */
22
21
};
23
22
23
+ struct io_wq_work_node {
24
+ struct io_wq_work_node * next ;
25
+ };
26
+
27
+ struct io_wq_work_list {
28
+ struct io_wq_work_node * first ;
29
+ struct io_wq_work_node * last ;
30
+ };
31
+
24
32
static inline void wq_list_add_after (struct io_wq_work_node * node ,
25
33
struct io_wq_work_node * pos ,
26
34
struct io_wq_work_list * list )
Original file line number Diff line number Diff line change @@ -456,6 +456,22 @@ struct io_ring_ctx {
456
456
struct list_head tctx_list ;
457
457
};
458
458
459
+ struct io_uring_task {
460
+ /* submission side */
461
+ struct xarray xa ;
462
+ struct wait_queue_head wait ;
463
+ void * last ;
464
+ void * io_wq ;
465
+ struct percpu_counter inflight ;
466
+ atomic_t in_idle ;
467
+ bool sqpoll ;
468
+
469
+ spinlock_t task_lock ;
470
+ struct io_wq_work_list task_list ;
471
+ unsigned long task_state ;
472
+ struct callback_head task_work ;
473
+ };
474
+
459
475
/*
460
476
* First field must be the file pointer in all the
461
477
* iocb unions! See also 'struct kiocb' in <linux/fs.h>
Original file line number Diff line number Diff line change 5
5
#include <linux/sched.h>
6
6
#include <linux/xarray.h>
7
7
8
- struct io_wq_work_node {
9
- struct io_wq_work_node * next ;
10
- };
11
-
12
- struct io_wq_work_list {
13
- struct io_wq_work_node * first ;
14
- struct io_wq_work_node * last ;
15
- };
16
-
17
- struct io_uring_task {
18
- /* submission side */
19
- struct xarray xa ;
20
- struct wait_queue_head wait ;
21
- void * last ;
22
- void * io_wq ;
23
- struct percpu_counter inflight ;
24
- atomic_t in_idle ;
25
- bool sqpoll ;
26
-
27
- spinlock_t task_lock ;
28
- struct io_wq_work_list task_list ;
29
- unsigned long task_state ;
30
- struct callback_head task_work ;
31
- };
32
-
33
8
#if defined(CONFIG_IO_URING )
34
9
struct sock * io_uring_get_socket (struct file * file );
35
10
void __io_uring_task_cancel (void );
You can’t perform that action at this time.
0 commit comments