Lines Matching refs:match
142 struct io_cb_cancel_data *match);
776 struct io_cb_cancel_data match = { in create_worker_cont() local
781 while (io_acct_cancel_pending_work(wqe, acct, &match)) in create_worker_cont()
951 struct io_cb_cancel_data match = { in io_wqe_enqueue() local
957 if (io_acct_cancel_pending_work(wqe, acct, &match)) in io_wqe_enqueue()
985 struct io_cb_cancel_data *match = data; in io_wq_worker_cancel() local
993 match->fn(worker->cur_work, match->data)) { in io_wq_worker_cancel()
995 match->nr_running++; in io_wq_worker_cancel()
999 return match->nr_running && !match->cancel_all; in io_wq_worker_cancel()
1023 struct io_cb_cancel_data *match) in io_acct_cancel_pending_work() argument
1031 if (!match->fn(work, match->data)) in io_acct_cancel_pending_work()
1036 match->nr_pending++; in io_acct_cancel_pending_work()
1045 struct io_cb_cancel_data *match) in io_wqe_cancel_pending_work() argument
1053 if (io_acct_cancel_pending_work(wqe, acct, match)) { in io_wqe_cancel_pending_work()
1054 if (match->cancel_all) in io_wqe_cancel_pending_work()
1063 struct io_cb_cancel_data *match) in io_wqe_cancel_running_work() argument
1066 io_wq_for_each_worker(wqe, io_wq_worker_cancel, match); in io_wqe_cancel_running_work()
1073 struct io_cb_cancel_data match = { in io_wq_cancel_cb() local
1088 io_wqe_cancel_pending_work(wqe, &match); in io_wq_cancel_cb()
1089 if (match.nr_pending && !match.cancel_all) in io_wq_cancel_cb()
1102 io_wqe_cancel_running_work(wqe, &match); in io_wq_cancel_cb()
1103 if (match.nr_running && !match.cancel_all) in io_wq_cancel_cb()
1107 if (match.nr_running) in io_wq_cancel_cb()
1109 if (match.nr_pending) in io_wq_cancel_cb()
1275 struct io_cb_cancel_data match = { in io_wq_destroy() local
1279 io_wqe_cancel_pending_work(wqe, &match); in io_wq_destroy()