Home
last modified time | relevance | path

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

12345678910>>...122

/linux/fs/smb/server/
H A Dksmbd_work.c21 struct ksmbd_work *work = kmem_cache_zalloc(work_cache, KSMBD_DEFAULT_GFP); in ksmbd_alloc_work_struct() local
23 if (work) { in ksmbd_alloc_work_struct()
24 work->compound_fid = KSMBD_NO_FID; in ksmbd_alloc_work_struct()
25 work->compound_pfid = KSMBD_NO_FID; in ksmbd_alloc_work_struct()
26 INIT_LIST_HEAD(&work->request_entry); in ksmbd_alloc_work_struct()
27 INIT_LIST_HEAD(&work->async_request_entry); in ksmbd_alloc_work_struct()
28 INIT_LIST_HEAD(&work->fp_entry); in ksmbd_alloc_work_struct()
29 INIT_LIST_HEAD(&work->aux_read_list); in ksmbd_alloc_work_struct()
30 work->iov_alloc_cnt = 4; in ksmbd_alloc_work_struct()
31 work->iov = kzalloc_objs(struct kvec, work->iov_alloc_cnt, in ksmbd_alloc_work_struct()
[all …]
H A Dserver.c93 static inline int check_conn_state(struct ksmbd_work *work) in check_conn_state() argument
97 if (ksmbd_conn_exiting(work->conn) || in check_conn_state()
98 ksmbd_conn_need_reconnect(work->conn)) { in check_conn_state()
99 rsp_hdr = smb_get_msg(work->response_buf); in check_conn_state()
109 static int __process_request(struct ksmbd_work *work, struct ksmbd_conn *conn, in __process_request() argument
116 if (check_conn_state(work)) in __process_request()
119 if (ksmbd_verify_smb_message(work)) { in __process_request()
120 conn->ops->set_rsp_status(work, STATUS_INVALID_PARAMETER); in __process_request()
124 command = conn->ops->get_cmd_val(work); in __process_request()
129 conn->ops->set_rsp_status(work, STATUS_INVALID_PARAMETER); in __process_request()
[all …]
H A Dsmb2pdu.h330 bool is_smb2_neg_cmd(struct ksmbd_work *work);
331 bool is_smb2_rsp(struct ksmbd_work *work);
333 u16 get_smb2_cmd_val(struct ksmbd_work *work);
334 void set_smb2_rsp_status(struct ksmbd_work *work, __le32 err);
335 int init_smb2_rsp_hdr(struct ksmbd_work *work);
336 int smb2_allocate_rsp_buf(struct ksmbd_work *work);
337 bool is_chained_smb2_message(struct ksmbd_work *work);
338 int init_smb2_neg_rsp(struct ksmbd_work *work);
339 void smb2_set_err_rsp(struct ksmbd_work *work);
340 int smb2_check_user_session(struct ksmbd_work *work);
[all …]
H A Dsmb2pdu.c46 static void __wbuf(struct ksmbd_work *work, void **req, void **rsp) in __wbuf() argument
48 if (work->next_smb2_rcv_hdr_off) { in __wbuf()
49 *req = ksmbd_req_buf_next(work); in __wbuf()
50 *rsp = ksmbd_resp_buf_next(work); in __wbuf()
52 *req = smb_get_msg(work->request_buf); in __wbuf()
53 *rsp = smb_get_msg(work->response_buf); in __wbuf()
95 * @work: smb work
100 int smb2_get_ksmbd_tcon(struct ksmbd_work *work) in smb2_get_ksmbd_tcon() argument
102 struct smb2_hdr *req_hdr = ksmbd_req_buf_next(work); in smb2_get_ksmbd_tcon()
152 smb2_set_err_rsp(struct ksmbd_work * work) smb2_set_err_rsp() argument
183 is_smb2_neg_cmd(struct ksmbd_work * work) is_smb2_neg_cmd() argument
207 is_smb2_rsp(struct ksmbd_work * work) is_smb2_rsp() argument
228 get_smb2_cmd_val(struct ksmbd_work * work) get_smb2_cmd_val() argument
244 set_smb2_rsp_status(struct ksmbd_work * work,__le32 err) set_smb2_rsp_status() argument
264 init_smb2_neg_rsp(struct ksmbd_work * work) init_smb2_neg_rsp() argument
325 smb2_set_rsp_credits(struct ksmbd_work * work) smb2_set_rsp_credits() argument
387 init_chained_smb2_rsp(struct ksmbd_work * work) init_chained_smb2_rsp() argument
457 is_chained_smb2_message(struct ksmbd_work * work) is_chained_smb2_message() argument
508 init_smb2_rsp_hdr(struct ksmbd_work * work) init_smb2_rsp_hdr() argument
538 smb2_allocate_rsp_buf(struct ksmbd_work * work) smb2_allocate_rsp_buf() argument
582 smb2_check_user_session(struct ksmbd_work * work) smb2_check_user_session() argument
663 setup_async_work(struct ksmbd_work * work,void (* fn)(void **),void ** arg) setup_async_work() argument
692 release_async_work(struct ksmbd_work * work) release_async_work() argument
710 smb2_send_interim_resp(struct ksmbd_work * work,__le32 status) smb2_send_interim_resp() argument
1103 smb2_handle_negotiate(struct ksmbd_work * work) smb2_handle_negotiate() argument
1301 generate_preauth_hash(struct ksmbd_work * work) generate_preauth_hash() argument
1349 ntlm_negotiate(struct ksmbd_work * work,struct negotiate_message * negblob,size_t negblob_len,struct smb2_sess_setup_rsp * rsp) ntlm_negotiate() argument
1458 ntlm_authenticate(struct ksmbd_work * work,struct smb2_sess_setup_req * req,struct smb2_sess_setup_rsp * rsp) ntlm_authenticate() argument
1598 krb5_authenticate(struct ksmbd_work * work,struct smb2_sess_setup_req * req,struct smb2_sess_setup_rsp * rsp) krb5_authenticate() argument
1692 krb5_authenticate(struct ksmbd_work * work,struct smb2_sess_setup_req * req,struct smb2_sess_setup_rsp * rsp) krb5_authenticate() argument
1700 smb2_sess_setup(struct ksmbd_work * work) smb2_sess_setup() argument
1977 smb2_tree_connect(struct ksmbd_work * work) smb2_tree_connect() argument
2178 smb2_tree_disconnect(struct ksmbd_work * work) smb2_tree_disconnect() argument
2239 smb2_session_logoff(struct ksmbd_work * work) smb2_session_logoff() argument
2295 create_smb2_pipe(struct ksmbd_work * work) create_smb2_pipe() argument
2606 smb2_creat(struct ksmbd_work * work,struct path * path,char * name,int open_flags,umode_t posix_mode,bool is_dir) smb2_creat() argument
2644 smb2_create_sd_buffer(struct ksmbd_work * work,struct smb2_create_req * req,const struct path * path) smb2_create_sd_buffer() argument
2708 parse_durable_handle_context(struct ksmbd_work * work,struct smb2_create_req * req,struct lease_ctx_info * lc,struct durable_info * dh_info) parse_durable_handle_context() argument
2883 smb2_open(struct ksmbd_work * work) smb2_open() argument
4133 struct ksmbd_work *work; global() member
4352 smb2_resp_buf_len(struct ksmbd_work * work,unsigned short hdr2_len) smb2_resp_buf_len() argument
4361 smb2_calc_max_out_buf_len(struct ksmbd_work * work,unsigned short hdr2_len,unsigned int out_buf_len) smb2_calc_max_out_buf_len() argument
4377 smb2_query_dir(struct ksmbd_work * work) smb2_query_dir() argument
4681 smb2_get_ea(struct ksmbd_work * work,struct ksmbd_file * fp,struct smb2_query_info_req * req,struct smb2_query_info_rsp * rsp,void * rsp_org) smb2_get_ea() argument
4923 get_file_all_info(struct ksmbd_work * work,struct smb2_query_info_rsp * rsp,struct ksmbd_file * fp,void * rsp_org) get_file_all_info() argument
4999 get_file_alternate_info(struct ksmbd_work * work,struct smb2_query_info_rsp * rsp,struct ksmbd_file * fp,void * rsp_org) get_file_alternate_info() argument
5020 get_file_stream_info(struct ksmbd_work * work,struct smb2_query_info_rsp * rsp,struct ksmbd_file * fp,void * rsp_org) get_file_stream_info() argument
5342 smb2_get_info_file(struct ksmbd_work * work,struct smb2_query_info_req * req,struct smb2_query_info_rsp * rsp) smb2_get_info_file() argument
5458 smb2_get_info_filesystem(struct ksmbd_work * work,struct smb2_query_info_req * req,struct smb2_query_info_rsp * rsp) smb2_get_info_filesystem() argument
5684 smb2_get_info_sec(struct ksmbd_work * work,struct smb2_query_info_req * req,struct smb2_query_info_rsp * rsp) smb2_get_info_sec() argument
5766 smb2_query_info(struct ksmbd_work * work) smb2_query_info() argument
5836 smb2_close_pipe(struct ksmbd_work * work) smb2_close_pipe() argument
5868 smb2_close(struct ksmbd_work * work) smb2_close() argument
5993 smb2_echo(struct ksmbd_work * work) smb2_echo() argument
6007 smb2_rename(struct ksmbd_work * work,struct ksmbd_file * fp,struct smb2_file_rename_info * file_info,struct nls_table * local_nls) smb2_rename() argument
6079 smb2_create_link(struct ksmbd_work * work,struct ksmbd_share_config * share,struct smb2_file_link_info * file_info,unsigned int buf_len,struct file * filp,struct nls_table * local_nls) smb2_create_link() argument
6226 set_file_allocation_info(struct ksmbd_work * work,struct ksmbd_file * fp,struct smb2_file_alloc_info * file_alloc_info) set_file_allocation_info() argument
6285 set_end_of_file_info(struct ksmbd_work * work,struct ksmbd_file * fp,struct smb2_file_eof_info * file_eof_info) set_end_of_file_info() argument
6319 set_rename_info(struct ksmbd_work * work,struct ksmbd_file * fp,struct smb2_file_rename_info * rename_info,unsigned int buf_len) set_rename_info() argument
6419 smb2_set_info_file(struct ksmbd_work * work,struct ksmbd_file * fp,struct smb2_set_info_req * req,struct ksmbd_share_config * share) smb2_set_info_file() argument
6528 smb2_set_info(struct ksmbd_work * work) smb2_set_info() argument
6636 smb2_read_pipe(struct ksmbd_work * work) smb2_read_pipe() argument
6697 smb2_set_remote_key_for_rdma(struct ksmbd_work * work,struct smbdirect_buffer_descriptor_v1 * desc,__le32 Channel,__le16 ChannelInfoLength) smb2_set_remote_key_for_rdma() argument
6727 smb2_read_rdma_channel(struct ksmbd_work * work,struct smb2_read_req * req,void * data_buf,size_t length) smb2_read_rdma_channel() argument
6749 smb2_read(struct ksmbd_work * work) smb2_read() argument
6930 smb2_write_pipe(struct ksmbd_work * work) smb2_write_pipe() argument
6991 smb2_write_rdma_channel(struct ksmbd_work * work,struct smb2_write_req * req,struct ksmbd_file * fp,loff_t offset,size_t length,bool sync) smb2_write_rdma_channel() argument
7027 smb2_write(struct ksmbd_work * work) smb2_write() argument
7178 smb2_flush(struct ksmbd_work * work) smb2_flush() argument
7208 smb2_cancel(struct ksmbd_work * work) smb2_cancel() argument
7376 smb2_lock(struct ksmbd_work * work) smb2_lock() argument
7733 fsctl_copychunk(struct ksmbd_work * work,struct copychunk_ioctl_req * ci_req,unsigned int cnt_code,unsigned int input_count,unsigned long long volatile_id,unsigned long long persistent_id,struct smb2_ioctl_rsp * rsp) fsctl_copychunk() argument
8015 fsctl_query_allocated_ranges(struct ksmbd_work * work,u64 id,struct file_allocated_range_buffer * qar_req,struct file_allocated_range_buffer * qar_rsp,unsigned int in_count,unsigned int * out_count) fsctl_query_allocated_ranges() argument
8047 fsctl_pipe_transceive(struct ksmbd_work * work,u64 id,unsigned int out_buf_len,struct smb2_ioctl_req * req,struct smb2_ioctl_rsp * rsp) fsctl_pipe_transceive() argument
8092 fsctl_set_sparse(struct ksmbd_work * work,u64 id,struct file_sparse * sparse) fsctl_set_sparse() argument
8134 fsctl_request_resume_key(struct ksmbd_work * work,struct smb2_ioctl_req * req,struct resume_key_ioctl_rsp * key_rsp) fsctl_request_resume_key() argument
8158 smb2_ioctl(struct ksmbd_work * work) smb2_ioctl() argument
8511 smb20_oplock_break_ack(struct ksmbd_work * work) smb20_oplock_break_ack() argument
8651 smb21_lease_break_ack(struct ksmbd_work * work) smb21_lease_break_ack() argument
8783 smb2_oplock_break(struct ksmbd_work * work) smb2_oplock_break() argument
8816 smb2_notify(struct ksmbd_work * work) smb2_notify() argument
8843 smb2_is_sign_req(struct ksmbd_work * work,unsigned int command) smb2_is_sign_req() argument
8862 smb2_check_sign_req(struct ksmbd_work * work) smb2_check_sign_req() argument
8904 smb2_set_sign_rsp(struct ksmbd_work * work) smb2_set_sign_rsp() argument
8933 smb3_check_sign_req(struct ksmbd_work * work) smb3_check_sign_req() argument
8992 smb3_set_sign_rsp(struct ksmbd_work * work) smb3_set_sign_rsp() argument
9038 smb3_preauth_hash_rsp(struct ksmbd_work * work) smb3_preauth_hash_rsp() argument
9094 smb3_encrypt_resp(struct ksmbd_work * work) smb3_encrypt_resp() argument
9121 smb3_decrypt_req(struct ksmbd_work * work) smb3_decrypt_req() argument
9165 smb3_11_final_sess_setup_resp(struct ksmbd_work * work) smb3_11_final_sess_setup_resp() argument
[all...]
H A Dksmbd_work.h86 struct work_struct work; member
98 static inline void *ksmbd_resp_buf_next(struct ksmbd_work *work) in ksmbd_resp_buf_next() argument
100 return work->response_buf + work->next_smb2_rsp_hdr_off + 4; in ksmbd_resp_buf_next()
107 static inline void *ksmbd_resp_buf_curr(struct ksmbd_work *work) in ksmbd_resp_buf_curr() argument
109 return work->response_buf + work->curr_smb2_rsp_hdr_off + 4; in ksmbd_resp_buf_curr()
116 static inline void *ksmbd_req_buf_next(struct ksmbd_work *work) in ksmbd_req_buf_next() argument
118 return work->request_buf + work->next_smb2_rcv_hdr_off + 4; in ksmbd_req_buf_next()
122 void ksmbd_free_work_struct(struct ksmbd_work *work);
129 bool ksmbd_queue_work(struct ksmbd_work *work);
130 int ksmbd_iov_pin_rsp_read(struct ksmbd_work *work, void *ib, int len,
[all …]
H A Dsmb_common.c159 int ksmbd_verify_smb_message(struct ksmbd_work *work) in ksmbd_verify_smb_message() argument
161 struct smb2_hdr *smb2_hdr = ksmbd_req_buf_next(work); in ksmbd_verify_smb_message()
165 return ksmbd_smb2_check_message(work); in ksmbd_verify_smb_message()
167 hdr = smb_get_msg(work->request_buf); in ksmbd_verify_smb_message()
170 work->conn->outstanding_credits++; in ksmbd_verify_smb_message()
333 static u16 get_smb1_cmd_val(struct ksmbd_work *work) in get_smb1_cmd_val() argument
344 static int init_smb1_rsp_hdr(struct ksmbd_work *work) in init_smb1_rsp_hdr() argument
346 struct smb_hdr *rsp_hdr = (struct smb_hdr *)smb_get_msg(work->response_buf); in init_smb1_rsp_hdr()
347 struct smb_hdr *rcv_hdr = (struct smb_hdr *)smb_get_msg(work->request_buf); in init_smb1_rsp_hdr()
365 static int smb1_check_user_session(struct ksmbd_work *work) in smb1_check_user_session() argument
[all …]
/linux/virt/kvm/
H A Dasync_pf.c45 static void async_pf_execute(struct work_struct *work) in async_pf_execute() argument
48 container_of(work, struct kvm_async_pf, work); in async_pf_execute()
63 * work item is fully processed. in async_pf_execute()
99 static void kvm_flush_and_free_async_pf_work(struct kvm_async_pf *work) in kvm_flush_and_free_async_pf_work() argument
102 * The async #PF is "done", but KVM must wait for the work item itself, in kvm_flush_and_free_async_pf_work()
105 * after the last call to module_put(). Note, flushing the work item in kvm_flush_and_free_async_pf_work()
111 * need to be flushed (but sanity check that the work wasn't queued). in kvm_flush_and_free_async_pf_work()
113 if (work->wakeup_all) in kvm_flush_and_free_async_pf_work()
114 WARN_ON_ONCE(work in kvm_flush_and_free_async_pf_work()
124 struct kvm_async_pf *work = kvm_clear_async_pf_completion_queue() local
139 struct kvm_async_pf *work = kvm_clear_async_pf_completion_queue() local
155 struct kvm_async_pf *work; kvm_check_async_pf_completion() local
182 struct kvm_async_pf *work; kvm_setup_async_pf() local
218 struct kvm_async_pf *work; kvm_async_pf_wakeup_all() local
[all...]
/linux/drivers/gpu/drm/
H A Ddrm_flip_work.c47 static void drm_flip_work_queue_task(struct drm_flip_work *work, struct drm_flip_task *task) in drm_flip_work_queue_task() argument
51 spin_lock_irqsave(&work->lock, flags); in drm_flip_work_queue_task()
52 list_add_tail(&task->node, &work->queued); in drm_flip_work_queue_task()
53 spin_unlock_irqrestore(&work->lock, flags); in drm_flip_work_queue_task()
64 void drm_flip_work_queue(struct drm_flip_work *work, void *val) in drm_flip_work_queue() argument
71 drm_flip_work_queue_task(work, task); in drm_flip_work_queue()
73 DRM_ERROR("%s could not allocate task!\n", work->name); in drm_flip_work_queue()
74 work->func(work, val); in drm_flip_work_queue()
89 void drm_flip_work_commit(struct drm_flip_work *work, in drm_flip_work_commit() argument
94 spin_lock_irqsave(&work->lock, flags); in drm_flip_work_commit()
[all …]
/linux/include/trace/events/
H A Dworkqueue.h14 * workqueue_queue_work - called when a work gets queued
17 * @work: pointer to struct work_struct
19 * This event occurs when a work is queued immediately or once a
20 * delayed work is actually queued on a workqueue (ie: once the delay
26 struct work_struct *work),
28 TP_ARGS(req_cpu, pwq, work),
31 __field( void *, work )
39 __entry->work = work;
40 __entry->function = work
[all...]
/linux/tools/perf/
H A Dbuiltin-kwork.c315 struct kwork_work *work; in work_search() local
319 work = container_of(node, struct kwork_work, node); in work_search()
320 cmp = work_cmp(sort_list, key, work); in work_search()
326 if (work->name == NULL) in work_search()
327 work->name = key->name; in work_search()
328 return work; in work_search()
362 struct kwork_work *work = zalloc(sizeof(*work)); in work_new() local
364 if (work == NULL) { in work_new()
370 INIT_LIST_HEAD(&work->atom_list[i]); in work_new()
372 work->id = key->id; in work_new()
[all …]
/linux/include/linux/
H A Dcompletion.h35 #define COMPLETION_INITIALIZER(work) \ argument
36 { 0, __SWAIT_QUEUE_HEAD_INITIALIZER((work).wait) }
38 #define COMPLETION_INITIALIZER_ONSTACK_MAP(work, map) \ 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)
[all …]
H A Dworkqueue.h3 * workqueue.h --- work queue handling for Linux.
21 * The first word is the work queue pointer and the flags rolled into
24 #define work_data_bits(work) ((unsigned long *)(&(work)->data)) argument
27 WORK_STRUCT_PENDING_BIT = 0, /* work item is pending execution */
28 WORK_STRUCT_INACTIVE_BIT, /* work item is inactive */
30 WORK_STRUCT_LINKED_BIT, /* next work is linked to this one */
67 * When a work item is off queue, the high bits encode off-queue flags
115 struct work_struct work; member
118 /* target workqueue and CPU ->timer uses to queue ->work */
124 struct work_struct work; global() member
212 to_delayed_work(struct work_struct * work) to_delayed_work() argument
217 to_rcu_work(struct work_struct * work) to_rcu_work() argument
223 struct work_struct work; global() member
264 work_static(struct work_struct * work) work_static() argument
269 __init_work(struct work_struct * work,int onstack) __init_work() argument
270 destroy_work_on_stack(struct work_struct * work) destroy_work_on_stack() argument
271 destroy_delayed_work_on_stack(struct delayed_work * work) destroy_delayed_work_on_stack() argument
272 work_static(struct work_struct * work) work_static() argument
355 work_pending(work) global() argument
667 queue_work(struct workqueue_struct * wq,struct work_struct * work) queue_work() argument
709 schedule_work_on(int cpu,struct work_struct * work) schedule_work_on() argument
728 schedule_work(struct work_struct * work) schedule_work() argument
750 enable_and_queue_work(struct workqueue_struct * wq,struct work_struct * work) enable_and_queue_work() argument
[all...]
H 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 …]
/linux/fs/btrfs/
H A Dasync-thread.c55 struct btrfs_fs_info * __pure btrfs_work_owner(const struct btrfs_work *work) in btrfs_work_owner() argument
57 return work->wq->fs_info; in btrfs_work_owner()
213 struct btrfs_work *work; in run_ordered_work() local
222 work = list_first_entry(list, struct btrfs_work, ordered_list); in run_ordered_work()
223 if (!test_bit(WORK_DONE_BIT, &work->flags)) in run_ordered_work()
239 if (test_and_set_bit(WORK_ORDER_DONE_BIT, &work->flags)) in run_ordered_work()
241 trace_btrfs_ordered_sched(work); in run_ordered_work()
243 work->ordered_func(work, false); in run_ordered_work()
247 list_del(&work->ordered_list); in run_ordered_work()
250 if (work == self) { in run_ordered_work()
[all …]
/linux/drivers/staging/octeon/
H A Dethernet-rx.c63 static inline int cvm_oct_check_rcv_error(struct cvmx_wqe *work) in cvm_oct_check_rcv_error() argument
68 port = work->word0.pip.cn68xx.pknd; in cvm_oct_check_rcv_error()
70 port = work->word1.cn38xx.ipprt; in cvm_oct_check_rcv_error()
72 if ((work->word2.snoip.err_code == 10) && (work->word1.len <= 64)) in cvm_oct_check_rcv_error()
81 if (work->word2.snoip.err_code == 5 || in cvm_oct_check_rcv_error()
82 work->word2.snoip.err_code == 7) { in cvm_oct_check_rcv_error()
99 cvmx_phys_to_ptr(work->packet_ptr.s.addr); in cvm_oct_check_rcv_error()
102 while (i < work->word1.len - 1) { in cvm_oct_check_rcv_error()
111 work->packet_ptr.s.addr += i + 1; in cvm_oct_check_rcv_error()
112 work->word1.len -= i + 5; in cvm_oct_check_rcv_error()
[all …]
/linux/kernel/
H A Dkthread.c988 struct kthread_work *work; in kthread_worker_fn() local
1011 work = NULL; in kthread_worker_fn()
1014 work = list_first_entry(&worker->work_list, in kthread_worker_fn()
1016 list_del_init(&work->node); in kthread_worker_fn()
1018 worker->current_work = work; in kthread_worker_fn()
1021 if (work) { in kthread_worker_fn()
1022 kthread_work_func_t func = work->func; in kthread_worker_fn()
1024 trace_sched_kthread_work_execute_start(work); in kthread_worker_fn()
1025 work->func(work); in kthread_worker_fn()
1030 trace_sched_kthread_work_execute_end(work, func); in kthread_worker_fn()
[all …]
H A Dworkqueue.c616 struct work_struct *work = addr; in work_is_static_object() local
618 return test_bit(WORK_STRUCT_STATIC_BIT, work_data_bits(work)); in work_is_static_object()
627 struct work_struct *work = addr; in work_fixup_init() local
631 cancel_work_sync(work); in work_fixup_init()
632 debug_object_init(work, &work_debug_descr); in work_fixup_init()
645 struct work_struct *work = addr; in work_fixup_free() local
649 cancel_work_sync(work); in work_fixup_free()
650 debug_object_free(work, &work_debug_descr); in work_fixup_free()
665 static inline void debug_work_activate(struct work_struct *work) in debug_work_activate() argument
667 debug_object_activate(work, &work_debug_descr); in debug_work_activate()
[all …]
/linux/tools/testing/selftests/bpf/progs/
H A Dtask_work.c45 struct elem *work = value; in process_work() local
47 bpf_copy_from_user_str(work->data, sizeof(work->data), (const void *)user_ptr, 0); in process_work()
57 struct elem *work; in oncpu_hash_map() local
65 work = bpf_map_lookup_elem(&hmap, &key); in oncpu_hash_map()
66 if (!work) in oncpu_hash_map()
68 bpf_task_work_schedule_resume(task, &work->tw, &hmap, process_work); in oncpu_hash_map()
75 struct elem *work; in oncpu_array_map()
79 work = bpf_map_lookup_elem(&arrmap, &key); in oncpu_array_map()
80 if (!work) in oncpu_array_map()
76 struct elem *work; oncpu_array_map() local
91 struct elem *work; oncpu_lru_map() local
[all...]
/linux/net/wireless/
H A Ddebugfs.c148 struct wiphy_work work; in wiphy_locked_debugfs_read()
164 struct wiphy_work *work) in wiphy_locked_debugfs_read()
166 struct debugfs_read_work *w = container_of(work, typeof(*w), work); in wiphy_locked_debugfs_read()
177 wiphy_work_cancel(w->wiphy, &w->work); in wiphy_locked_debugfs_read()
192 struct debugfs_read_work work = {
200 .completion = COMPLETION_INITIALIZER_ONSTACK(work.completion),
204 .cancel_data = &work,
210 wiphy_work_init(&work.work, wiphy_locked_debugfs_read_wor
115 struct wiphy_work work; global() member
131 wiphy_locked_debugfs_read_work(struct wiphy * wiphy,struct wiphy_work * work) wiphy_locked_debugfs_read_work() argument
159 struct debugfs_read_work work = { wiphy_locked_debugfs_read() local
195 struct wiphy_work work; global() member
211 wiphy_locked_debugfs_write_work(struct wiphy * wiphy,struct wiphy_work * work) wiphy_locked_debugfs_write_work() argument
238 struct debugfs_write_work work = { wiphy_locked_debugfs_write() local
[all...]
/linux/kernel/unwind/
H A Ddeferred.c152 struct unwind_work *work; in process_unwind_deferred() local
177 list_for_each_entry_srcu(work, &callbacks, list, in process_unwind_deferred()
179 if (test_bit(work->bit, &bits)) { in process_unwind_deferred()
180 work->func(work, &trace, cookie); in process_unwind_deferred()
182 info->cache->unwind_completed |= BIT(work->bit); in process_unwind_deferred()
201 task_work_cancel(task, &info->work); in unwind_deferred_task_exit()
229 int unwind_deferred_request(struct unwind_work *work, u64 *cookie) in unwind_deferred_request() argument
255 bit = READ_ONCE(work->bit); in unwind_deferred_request()
290 ret = task_work_add(current, &info->work, twa_mode); in unwind_deferred_request()
298 void unwind_deferred_cancel(struct unwind_work *work) in unwind_deferred_cancel() argument
[all …]
/linux/drivers/accessibility/speakup/
H 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/drivers/infiniband/core/
H A Dcm.c95 struct cm_work *work);
187 struct delayed_work work; member
198 struct cm_work work; member
269 static void cm_work_handler(struct work_struct *work);
710 __be32 remote_id = timewait_info->work.remote_id; in cm_insert_remote_id()
716 if (be32_lt(remote_id, cur_timewait_info->work.remote_id)) in cm_insert_remote_id()
718 else if (be32_gt(remote_id, cur_timewait_info->work.remote_id)) in cm_insert_remote_id()
744 if (be32_lt(remote_id, timewait_info->work.remote_id)) in cm_find_remote_id()
746 else if (be32_gt(remote_id, timewait_info->work.remote_id)) in cm_find_remote_id()
753 res = cm_acquire_id(timewait_info->work.local_id, in cm_find_remote_id()
[all …]
/linux/drivers/net/wireless/st/cw1200/
H A Dsta.h60 void cw1200_event_handler(struct work_struct *work);
61 void cw1200_bss_loss_work(struct work_struct *work);
62 void cw1200_bss_params_work(struct work_struct *work);
63 void cw1200_keep_alive_work(struct work_struct *work);
64 void cw1200_tx_failure_work(struct work_struct *work);
80 void cw1200_join_timeout(struct work_struct *work);
81 void cw1200_unjoin_work(struct work_struct *work);
82 void cw1200_join_complete_work(struct work_struct *work);
83 void cw1200_wep_key_work(struct work_struct *work);
86 void cw1200_update_filtering_work(struct work_struct *work);
[all …]
/linux/fs/
H A Dfs-writeback.c50 struct list_head list; /* pending work list */
151 * We have to be careful not to postpone flush work if it is scheduled for
165 static void finish_writeback_work(struct wb_writeback_work *work) in finish_writeback_work() argument
167 struct wb_completion *done = work->done; in finish_writeback_work()
169 if (work->auto_free) in finish_writeback_work()
170 kfree(work); in finish_writeback_work()
181 struct wb_writeback_work *work) in wb_queue_work() argument
183 trace_writeback_queue(wb, work); in wb_queue_work()
185 if (work->done) in wb_queue_work()
186 atomic_inc(&work in wb_queue_work()
566 inode_switch_wbs_work_fn(struct work_struct * work) inode_switch_wbs_work_fn() argument
1060 struct wb_writeback_work *work; bdi_split_work_to_wbs() local
1133 struct wb_writeback_work *work; cgroup_writeback_by_id() local
1558 queue_io(struct bdi_writeback * wb,struct wb_writeback_work * work,unsigned long dirtied_before) queue_io() argument
1907 writeback_chunk_size(struct super_block * sb,struct bdi_writeback * wb,struct wb_writeback_work * work) writeback_chunk_size() argument
1945 writeback_sb_inodes(struct super_block * sb,struct bdi_writeback * wb,struct wb_writeback_work * work) writeback_sb_inodes() argument
2100 __writeback_inodes_wb(struct bdi_writeback * wb,struct wb_writeback_work * work) __writeback_inodes_wb() argument
2136 struct wb_writeback_work work = { writeback_inodes_wb() local
2171 wb_writeback(struct bdi_writeback * wb,struct wb_writeback_work * work) wb_writeback() argument
2275 struct wb_writeback_work *work = NULL; get_next_work_item() local
2291 struct wb_writeback_work work = { wb_check_background_flush() local
2325 struct wb_writeback_work work = { wb_check_old_data_flush() local
2348 struct wb_writeback_work work = { wb_check_start_all() local
2368 struct wb_writeback_work *work; wb_do_writeback() local
2397 wb_workfn(struct work_struct * work) wb_workfn() argument
2824 struct wb_writeback_work work = { __writeback_inodes_sb_nr() local
2902 struct wb_writeback_work work = { sync_inodes_sb() local
[all...]
/linux/io_uring/
H A Dio-wq.c68 struct delayed_work work; member
160 static inline unsigned int io_get_work_hash(struct io_wq_work *work) in io_get_work_hash() argument
162 return __io_get_work_hash(atomic_read(&work->flags)); in io_get_work_hash()
433 static bool io_wq_hash_defer(struct io_wq_work *work, struct io_wq_acct *acct) in io_wq_hash_defer() argument
440 work_flags = atomic_read(&work->flags); in io_wq_hash_defer()
529 struct io_wq_work *work, *tail; in io_get_next_work() local
536 work = container_of(node, struct io_wq_work, list); in io_get_next_work()
539 work_flags = atomic_read(&work->flags); in io_get_next_work()
542 return work; in io_get_next_work()
553 return work; in io_get_next_work()
[all …]

12345678910>>...122