Home
last modified time | relevance | path

Searched refs:work (Results 1 – 25 of 2707) sorted by relevance

12345678910>>...109

/linux-6.3-rc2/virt/kvm/
A Dasync_pf.c48 container_of(work, struct kvm_async_pf, work); in async_pf_execute()
109 if (!work->vcpu) in kvm_clear_async_pf_completion_queue()
114 flush_work(&work->work); in kvm_clear_async_pf_completion_queue()
116 if (cancel_work_sync(&work->work)) { in kvm_clear_async_pf_completion_queue()
117 mmput(work->mm); in kvm_clear_async_pf_completion_queue()
144 work = list_first_entry(&vcpu->async_pf.done, typeof(*work), in kvm_check_async_pf_completion()
180 if (!work) in kvm_setup_async_pf()
189 mmget(work->mm); in kvm_setup_async_pf()
192 INIT_WORK(&work->work, async_pf_execute); in kvm_setup_async_pf()
198 schedule_work(&work->work); in kvm_setup_async_pf()
[all …]
/linux-6.3-rc2/drivers/gpu/drm/
A Ddrm_flip_work.c86 work->func(work, val); in drm_flip_work_queue()
107 list_splice_tail(&work->queued, &work->commited); in drm_flip_work_commit()
108 INIT_LIST_HEAD(&work->queued); in drm_flip_work_commit()
110 queue_work(wq, &work->worker); in drm_flip_work_commit()
133 work->func(work, task->data); in flip_worker()
150 work->name = name; in drm_flip_work_init()
151 INIT_LIST_HEAD(&work->queued); in drm_flip_work_init()
152 INIT_LIST_HEAD(&work->commited); in drm_flip_work_init()
153 spin_lock_init(&work->lock); in drm_flip_work_init()
154 work->func = func; in drm_flip_work_init()
[all …]
A Ddrm_vblank_work.c58 list_del_init(&work->node); in drm_handle_vblank_works()
77 list_del_init(&work->node); in drm_vblank_cancel_pending_works()
117 if (work->cancelling) in drm_vblank_work_schedule()
126 if (list_empty(&work->node)) { in drm_vblank_work_schedule()
137 work->count = count; in drm_vblank_work_schedule()
150 list_del_init(&work->node); in drm_vblank_work_schedule()
189 if (!list_empty(&work->node)) { in drm_vblank_work_cancel_sync()
190 list_del_init(&work->node); in drm_vblank_work_cancel_sync()
195 work->cancelling++; in drm_vblank_work_cancel_sync()
204 work->cancelling--; in drm_vblank_work_cancel_sync()
[all …]
/linux-6.3-rc2/include/trace/events/
A Dworkqueue.h31 __field( void *, work )
39 __entry->work = work;
63 TP_ARGS(work),
66 __field( void *, work )
70 __entry->work = work;
86 TP_ARGS(work),
89 __field( void *, work )
94 __entry->work = work;
112 TP_ARGS(work, function),
115 __field( void *, work )
[all …]
/linux-6.3-rc2/fs/ksmbd/
A Dksmbd_work.c23 if (work) { in ksmbd_alloc_work_struct()
24 work->compound_fid = KSMBD_NO_FID; in ksmbd_alloc_work_struct()
28 INIT_LIST_HEAD(&work->fp_entry); in ksmbd_alloc_work_struct()
31 return work; in ksmbd_alloc_work_struct()
38 kvfree(work->response_buf); in ksmbd_free_work_struct()
39 kvfree(work->aux_payload_buf); in ksmbd_free_work_struct()
40 kfree(work->tr_buf); in ksmbd_free_work_struct()
41 kvfree(work->request_buf); in ksmbd_free_work_struct()
42 if (work->async_id) in ksmbd_free_work_struct()
43 ksmbd_release_id(&work->conn->async_ida, work->async_id); in ksmbd_free_work_struct()
[all …]
A Dserver.c96 if (ksmbd_conn_exiting(work) || ksmbd_conn_need_reconnect(work)) { in check_conn_state()
136 if (work->sess && conn->ops->is_sign_req(work, command)) { in __process_request()
144 ret = cmds->proc(work); in __process_request()
224 if (work->sess && in __handle_ksmbd_work()
225 (work->sess->sign || smb3_11_final_sess_setup_resp(work) || in __handle_ksmbd_work()
235 if (work->sess && work->sess->enc && work->encrypted && in __handle_ksmbd_work()
242 ksmbd_conn_write(work); in __handle_ksmbd_work()
253 struct ksmbd_work *work = container_of(wk, struct ksmbd_work, work); in handle_ksmbd_work() local
283 if (!work) { in queue_ksmbd_work()
288 work->conn = conn; in queue_ksmbd_work()
[all …]
A Dsmb2pdu.h468 bool is_smb2_rsp(struct ksmbd_work *work);
510 int smb2_open(struct ksmbd_work *work);
513 int smb2_close(struct ksmbd_work *work);
514 int smb2_echo(struct ksmbd_work *work);
515 int smb2_set_info(struct ksmbd_work *work);
516 int smb2_read(struct ksmbd_work *work);
517 int smb2_write(struct ksmbd_work *work);
518 int smb2_flush(struct ksmbd_work *work);
519 int smb2_cancel(struct ksmbd_work *work);
520 int smb2_lock(struct ksmbd_work *work);
[all …]
A Dsmb2pdu.c94 work->tcon = NULL; in smb2_get_ksmbd_tcon()
108 work->tcon = ksmbd_tree_conn_lookup(work->sess, tree_id); in smb2_get_ksmbd_tcon()
109 if (!work->tcon) { in smb2_get_ksmbd_tcon()
579 if (work->sess) in smb2_check_user_session()
3942 query_dir_private.work = work; in smb2_query_dir()
4805 rc = get_file_all_info(work, rsp, fp, work->response_buf); in smb2_get_info_file()
4810 get_file_alternate_info(work, rsp, fp, work->response_buf); in smb2_get_info_file()
4815 get_file_stream_info(work, rsp, fp, work->response_buf); in smb2_get_info_file()
4835 rc = smb2_get_ea(work, fp, req, rsp, work->response_buf); in smb2_get_info_file()
5935 return smb2_create_link(work, work->tcon->share_conf, in smb2_set_info_file()
[all …]
A Dconnection.h149 int ksmbd_conn_write(struct ksmbd_work *work);
158 void ksmbd_conn_enqueue_request(struct ksmbd_work *work);
171 static inline bool ksmbd_conn_good(struct ksmbd_work *work) in ksmbd_conn_good() argument
173 return work->conn->status == KSMBD_SESS_GOOD; in ksmbd_conn_good()
178 return work->conn->status == KSMBD_SESS_NEED_NEGOTIATE; in ksmbd_conn_need_negotiate()
183 return work->conn->status == KSMBD_SESS_NEED_RECONNECT; in ksmbd_conn_need_reconnect()
188 return work->conn->status == KSMBD_SESS_EXITING; in ksmbd_conn_exiting()
193 work->conn->status = KSMBD_SESS_GOOD; in ksmbd_conn_set_good()
198 work->conn->status = KSMBD_SESS_NEED_NEGOTIATE; in ksmbd_conn_set_need_negotiate()
203 work->conn->status = KSMBD_SESS_NEED_RECONNECT; in ksmbd_conn_set_need_reconnect()
[all …]
A Dconnection.c117 work->synchronous = true; in ksmbd_conn_enqueue_request()
137 if (!work->multiRsp) in ksmbd_conn_try_dequeue_request()
140 if (!work->multiRsp) { in ksmbd_conn_try_dequeue_request()
142 if (!work->synchronous) in ksmbd_conn_try_dequeue_request()
175 if (!work->response_buf) { in ksmbd_conn_write()
180 if (work->tr_buf) { in ksmbd_conn_write()
186 if (work->aux_payload_sz) { in ksmbd_conn_write()
187 iov[iov_idx] = (struct kvec) { work->response_buf, work->resp_hdr_sz }; in ksmbd_conn_write()
189 iov[iov_idx] = (struct kvec) { work->aux_payload_buf, work->aux_payload_sz }; in ksmbd_conn_write()
192 if (work->tr_buf) in ksmbd_conn_write()
[all …]
/linux-6.3-rc2/kernel/
A Dirq_work.c109 if (!irq_work_claim(work)) in irq_work_queue()
114 __irq_work_queue_local(work); in irq_work_queue()
130 return irq_work_queue(work); in irq_work_queue_on()
137 if (!irq_work_claim(work)) in irq_work_queue_on()
159 if (!irq_work_claim(work)) in irq_work_queue_on()
165 __irq_work_queue_local(work); in irq_work_queue_on()
193 struct irq_work *work = arg; in irq_work_single() local
211 work->func(work); in irq_work_single()
227 struct irq_work *work, *tmp; in irq_work_run_list() local
242 irq_work_single(work); in irq_work_run_list()
[all …]
A Dtask_work.c54 work->next = head; in task_work_add()
104 while (work) { in task_work_cancel_match()
106 pprev = &work->next; in task_work_cancel_match()
108 } else if (try_cmpxchg(pprev, &work, work->next)) in task_work_cancel_match()
113 return work; in task_work_cancel_match()
159 if (!work) { in task_work_run()
167 if (!work) in task_work_run()
178 next = work->next; in task_work_run()
179 work->func(work); in task_work_run()
180 work = next; in task_work_run()
[all …]
A Dkthread.c809 work = NULL; in kthread_worker_fn()
819 if (work) { in kthread_worker_fn()
823 work->func(work); in kthread_worker_fn()
956 return !list_empty(&work->node) || work->canceling; in queuing_blocked()
965 WARN_ON_ONCE(work->worker && work->worker != worker); in kthread_insert_work_sanity_check()
1022 struct kthread_work *work = &dwork->work; in kthread_delayed_work_timer_fn() local
1052 struct kthread_work *work = &dwork->work; in __kthread_queue_delayed_work() local
1095 struct kthread_work *work = &dwork->work; in kthread_queue_delayed_work() local
1119 container_of(work, struct kthread_flush_work, work); in kthread_flush_work_fn()
1172 container_of(work, struct kthread_delayed_work, work); in kthread_cancel_delayed_work_timer()
[all …]
/linux-6.3-rc2/include/linux/
A Dcompletion.h35 #define COMPLETION_INITIALIZER(work) \ argument
39 (*({ init_completion_map(&(work), &(map)); &(work); }))
41 #define COMPLETION_INITIALIZER_ONSTACK(work) \ argument
42 (*({ init_completion(&work); &work; }))
52 #define DECLARE_COMPLETION(work) \ argument
53 struct completion work = COMPLETION_INITIALIZER(work)
68 # define DECLARE_COMPLETION_ONSTACK(work) \ argument
69 struct completion work = COMPLETION_INITIALIZER_ONSTACK(work)
71 struct completion work = COMPLETION_INITIALIZER_ONSTACK_MAP(work, map)
73 # define DECLARE_COMPLETION_ONSTACK(work) DECLARE_COMPLETION(work) argument
[all …]
A Dworkqueue.h28 #define work_data_bits(work) ((unsigned long *)(&(work)->data)) argument
111 struct work_struct work; member
120 struct work_struct work; member
155 return container_of(work, struct delayed_work, work); in to_delayed_work()
160 return container_of(work, struct rcu_work, work); in to_rcu_work()
164 struct work_struct work; member
187 .work = __WORK_INITIALIZER((n).work, (f)), \
288 #define work_pending(work) \ argument
297 work_pending(&(w)->work)
440 struct work_struct *work);
[all …]
A Djump_label_ratelimit.h12 struct delayed_work work; member
18 struct delayed_work work; member
24 struct delayed_work work; member
28 __static_key_slow_dec_deferred(&(x)->key, &(x)->work, (x)->timeout)
30 __static_key_slow_dec_deferred(&(x)->key.key, &(x)->work, (x)->timeout)
33 __static_key_deferred_flush((x), &(x)->work)
37 struct delayed_work *work,
39 extern void __static_key_deferred_flush(void *key, struct delayed_work *work);
43 extern void jump_label_update_timeout(struct work_struct *work);
49 .work = __DELAYED_WORK_INITIALIZER((name).work, \
[all …]
A Dkthread.h140 struct kthread_work work; member
144 #define KTHREAD_WORK_INIT(work, fn) { \ argument
145 .node = LIST_HEAD_INIT((work).node), \
150 .work = KTHREAD_WORK_INIT((dwork).work, (fn)), \
155 #define DEFINE_KTHREAD_WORK(work, fn) \ argument
156 struct kthread_work work = KTHREAD_WORK_INIT(work, fn)
171 #define kthread_init_work(work, fn) \ argument
174 INIT_LIST_HEAD(&(work)->node); \
175 (work)->func = (fn); \
180 kthread_init_work(&(dwork)->work, (fn)); \
[all …]
A Dirq_work.h37 void init_irq_work(struct irq_work *work, void (*func)(struct irq_work *)) in init_irq_work() argument
39 *work = IRQ_WORK_INIT(func); in init_irq_work()
42 static inline bool irq_work_is_pending(struct irq_work *work) in irq_work_is_pending() argument
44 return atomic_read(&work->node.a_flags) & IRQ_WORK_PENDING; in irq_work_is_pending()
47 static inline bool irq_work_is_busy(struct irq_work *work) in irq_work_is_busy() argument
49 return atomic_read(&work->node.a_flags) & IRQ_WORK_BUSY; in irq_work_is_busy()
52 static inline bool irq_work_is_hard(struct irq_work *work) in irq_work_is_hard() argument
54 return atomic_read(&work->node.a_flags) & IRQ_WORK_HARD_IRQ; in irq_work_is_hard()
57 bool irq_work_queue(struct irq_work *work);
58 bool irq_work_queue_on(struct irq_work *work, int cpu);
[all …]
/linux-6.3-rc2/fs/btrfs/
A Dasync-thread.c57 return work->wq->fs_info; in btrfs_work_owner()
180 struct btrfs_work *work; in run_ordered_work() local
211 work->ordered_func(work); in run_ordered_work()
218 if (work == self) { in run_ordered_work()
246 work->ordered_free(work); in run_ordered_work()
275 if (work->ordered_func) in btrfs_work_helper()
280 work->func(work); in btrfs_work_helper()
300 work->func = func; in btrfs_init_work()
305 work->flags = 0; in btrfs_init_work()
312 work->wq = wq; in btrfs_queue_work()
[all …]
/linux-6.3-rc2/drivers/staging/octeon/
A Dethernet-rx.c72 if ((work->word2.snoip.err_code == 10) && (work->word1.len <= 64)) in cvm_oct_check_rcv_error()
112 work->word1.len -= i + 5; in cvm_oct_check_rcv_error()
119 work->word1.len -= i + 4; in cvm_oct_check_rcv_error()
131 cvm_oct_free_work(work); in cvm_oct_check_rcv_error()
138 cvm_oct_free_work(work); in cvm_oct_check_rcv_error()
146 int len = work->word1.len; in copy_segments_to_skb()
222 struct cvmx_wqe *work; in cvm_oct_poll() local
230 prefetch(work); in cvm_oct_poll()
232 if (!work) { in cvm_oct_poll()
299 cvm_oct_free_work(work); in cvm_oct_poll()
[all …]
A Dethernet-tx.c516 if (unlikely(!work)) { in cvm_oct_xmit_pow()
560 work->word1.len = skb->len; in cvm_oct_xmit_pow()
567 work->word2.u64 = 0; in cvm_oct_xmit_pow()
568 work->word2.s.bufs = 1; in cvm_oct_xmit_pow()
569 work->packet_ptr.u64 = 0; in cvm_oct_xmit_pow()
590 work->word2.s.is_v6 = 0; in cvm_oct_xmit_pow()
601 work->word2.s.IP_exc = 0; in cvm_oct_xmit_pow()
607 work->word2.s.not_IP = 0; in cvm_oct_xmit_pow()
641 memcpy(work->packet_data, skb->data, sizeof(work->packet_data)); in cvm_oct_xmit_pow()
645 cvmx_pow_work_submit(work, work->word1.tag, work->word1.tag_type, in cvm_oct_xmit_pow()
[all …]
/linux-6.3-rc2/tools/perf/
A Dbuiltin-kwork.c284 return work; in work_search()
318 struct kwork_work *work = zalloc(sizeof(*work)); in work_new() local
332 return work; in work_new()
342 return work; in work_findnew()
345 if (work) in work_findnew()
348 return work; in work_findnew()
662 if (work->class && work->class->work_name) { in timehist_print_event()
663 work->class->work_name(work, kwork_name, in timehist_print_event()
1075 if (work->class && work->class->work_name) { in report_print_work()
1076 work->class->work_name(work, kwork_name, in report_print_work()
[all …]
/linux-6.3-rc2/drivers/accessibility/speakup/
A Dselection.c20 struct work_struct work; member
25 static void __speakup_set_selection(struct work_struct *work) in __speakup_set_selection() argument
28 container_of(work, struct speakup_selection_work, work); in __speakup_set_selection()
58 .work = __WORK_INITIALIZER(speakup_sel_work.work,
87 schedule_work_on(WORK_CPU_UNBOUND, &speakup_sel_work.work); in speakup_set_selection()
96 cancel_work_sync(&speakup_sel_work.work); in speakup_cancel_selection()
106 static void __speakup_paste_selection(struct work_struct *work) in __speakup_paste_selection() argument
109 container_of(work, struct speakup_selection_work, work); in __speakup_paste_selection()
117 .work = __WORK_INITIALIZER(speakup_paste_work.work,
129 schedule_work_on(WORK_CPU_UNBOUND, &speakup_paste_work.work); in speakup_paste_selection()
[all …]
/linux-6.3-rc2/drivers/net/wireless/st/cw1200/
A Dsta.h59 void cw1200_event_handler(struct work_struct *work);
60 void cw1200_bss_loss_work(struct work_struct *work);
61 void cw1200_bss_params_work(struct work_struct *work);
62 void cw1200_keep_alive_work(struct work_struct *work);
63 void cw1200_tx_failure_work(struct work_struct *work);
79 void cw1200_join_timeout(struct work_struct *work);
80 void cw1200_unjoin_work(struct work_struct *work);
82 void cw1200_wep_key_work(struct work_struct *work);
91 void cw1200_ba_work(struct work_struct *work);
114 void cw1200_set_tim_work(struct work_struct *work);
[all …]
/linux-6.3-rc2/io_uring/
A Dio-wq.c483 return work; in io_get_next_work()
494 return work; in io_get_next_work()
526 if (work) { in io_assign_current_work()
559 if (work) { in io_worker_handle_work()
593 work = linked; in io_worker_handle_work()
609 } while (work); in io_worker_handle_work()
878 wq->do_work(work); in io_run_cancel()
879 work = wq->free_work(work); in io_run_cancel()
880 } while (work); in io_run_cancel()
985 if (work && match->fn(work, match->data)) { in __io_wq_worker_cancel()
[all …]

Completed in 72 milliseconds

12345678910>>...109