io_uring/io-wq.c

1087

static bool __io_wq_worker_cancel(struct io_worker *worker,

io_uring/io-wq.c

1100

static bool io_wq_worker_cancel(struct io_worker *worker, void *data)

io_uring/io-wq.c

1307

struct io_worker *worker;

io_uring/io-wq.c

1311

worker = container_of(cb, struct io_worker, create_work);

io_uring/io-wq.c

1325

struct io_worker *worker;

io_uring/io-wq.c

1327

worker = container_of(cb, struct io_worker, create_work);

io_uring/io-wq.c

1407

static bool io_wq_worker_affinity(struct io_worker *worker, void *data)

io_uring/io-wq.c

148

static void io_wq_dec_running(struct io_worker *worker);

io_uring/io-wq.c

165

static bool io_worker_get(struct io_worker *worker)

io_uring/io-wq.c

170

static void io_worker_release(struct io_worker *worker)

io_uring/io-wq.c

187

static inline struct io_wq_acct *io_wq_get_acct(struct io_worker *worker)

io_uring/io-wq.c

200

struct io_worker *worker = current->worker_private;

io_uring/io-wq.c

208

static void io_worker_cancel_cb(struct io_worker *worker)

io_uring/io-wq.c

224

struct io_worker *worker;

io_uring/io-wq.c

228

worker = container_of(cb, struct io_worker, create_work);

io_uring/io-wq.c

232

static void io_worker_exit(struct io_worker *worker)

io_uring/io-wq.c

296

struct io_worker *worker;

io_uring/io-wq.c

344

static void io_wq_inc_running(struct io_worker *worker)

io_uring/io-wq.c

353

struct io_worker *worker;

io_uring/io-wq.c

359

worker = container_of(cb, struct io_worker, create_work);

io_uring/io-wq.c

387

static bool io_queue_worker_create(struct io_worker *worker,

io_uring/io-wq.c

456

static void io_wq_dec_running(struct io_worker *worker)

io_uring/io-wq.c

485

static void __io_worker_busy(struct io_wq_acct *acct, struct io_worker *worker)

io_uring/io-wq.c

498

static void __io_worker_idle(struct io_wq_acct *acct, struct io_worker *worker)

io_uring/io-wq.c

582

static void io_assign_current_work(struct io_worker *worker,

io_uring/io-wq.c

599

struct io_worker *worker)

io_uring/io-wq.c

684

struct io_worker *worker = data;

io_uring/io-wq.c

755

struct io_worker *worker = tsk->worker_private;

io_uring/io-wq.c

773

struct io_worker *worker = tsk->worker_private;

io_uring/io-wq.c

786

static void io_init_new_worker(struct io_wq *wq, struct io_wq_acct *acct, struct io_worker *worker,

io_uring/io-wq.c

806

static inline bool io_should_retry_thread(struct io_worker *worker, long err)

io_uring/io-wq.c

829

static void queue_create_worker_retry(struct io_worker *worker)

io_uring/io-wq.c

843

struct io_worker *worker;

io_uring/io-wq.c

848

worker = container_of(cb, struct io_worker, create_work);

io_uring/io-wq.c

885

struct io_worker *worker = container_of(work, struct io_worker,

io_uring/io-wq.c

895

struct io_worker *worker;

io_uring/io-wq.c

936

bool (*func)(struct io_worker *, void *),

io_uring/io-wq.c

939

struct io_worker *worker;

io_uring/io-wq.c

957

bool (*func)(struct io_worker *, void *),

io_uring/io-wq.c

965

static bool io_wq_worker_wake(struct io_worker *worker, void *data)