| /linux/fs/smb/server/ |
| H A D | ksmbd_work.c | 21 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 in ksmbd_alloc_work_struct() 41 ksmbd_free_work_struct(struct ksmbd_work * work) ksmbd_free_work_struct() argument 93 ksmbd_queue_work(struct ksmbd_work * work) ksmbd_queue_work() argument 98 __ksmbd_iov_pin(struct ksmbd_work * work,void * ib,unsigned int ib_len) __ksmbd_iov_pin() argument 106 __ksmbd_iov_pin_rsp(struct ksmbd_work * work,void * ib,int len,void * aux_buf,unsigned int aux_size) __ksmbd_iov_pin_rsp() argument 156 ksmbd_iov_pin_rsp(struct ksmbd_work * work,void * ib,int len) ksmbd_iov_pin_rsp() argument 161 ksmbd_iov_pin_rsp_read(struct ksmbd_work * work,void * ib,int len,void * aux_buf,unsigned int aux_size) ksmbd_iov_pin_rsp_read() argument 167 allocate_interim_rsp_buf(struct ksmbd_work * work) allocate_interim_rsp_buf() argument [all...] |
| H A D | server.c | 90 * @work: smb work containing server thread information 94 static inline int check_conn_state(struct ksmbd_work *work) in check_conn_state() 98 if (ksmbd_conn_exiting(work->conn) || in check_conn_state() 99 ksmbd_conn_need_reconnect(work->conn)) { in check_conn_state() 100 rsp_hdr = smb_get_msg(work->response_buf); in check_conn_state() 110 static int __process_request(struct ksmbd_work *work, struct ksmbd_conn *conn, in __process_request() 117 if (check_conn_state(work)) in __process_request() 120 if (ksmbd_verify_smb_message(work)) { in __process_request() 121 conn->ops->set_rsp_status(work, STATUS_INVALID_PARAMETE in __process_request() 93 check_conn_state(struct ksmbd_work * work) check_conn_state() argument 109 __process_request(struct ksmbd_work * work,struct ksmbd_conn * conn,u16 * cmd) __process_request() argument 166 __handle_ksmbd_work(struct ksmbd_work * work,struct ksmbd_conn * conn) __handle_ksmbd_work() argument 267 struct ksmbd_work *work = container_of(wk, struct ksmbd_work, work); handle_ksmbd_work() local 288 struct ksmbd_work *work; queue_ksmbd_work() local 386 server_ctrl_handle_work(struct work_struct * work) server_ctrl_handle_work() argument [all...] |
| H A D | smb2pdu.h | 318 bool is_smb2_neg_cmd(struct ksmbd_work *work); 319 bool is_smb2_rsp(struct ksmbd_work *work); 321 u16 get_smb2_cmd_val(struct ksmbd_work *work); 322 void set_smb2_rsp_status(struct ksmbd_work *work, __le32 err); 323 int init_smb2_rsp_hdr(struct ksmbd_work *work); 324 int smb2_allocate_rsp_buf(struct ksmbd_work *work); 325 bool is_chained_smb2_message(struct ksmbd_work *work); 326 int init_smb2_neg_rsp(struct ksmbd_work *work); 327 void smb2_set_err_rsp(struct ksmbd_work *work); 328 int smb2_check_user_session(struct ksmbd_work *work); [all...] |
| H A D | smb2pdu.c | 47 static void __wbuf(struct ksmbd_work *work, void **req, void **rsp) in __wbuf() 49 if (work->next_smb2_rcv_hdr_off) { in __wbuf() 50 *req = ksmbd_req_buf_next(work); in __wbuf() 51 *rsp = ksmbd_resp_buf_next(work); in __wbuf() 53 *req = smb_get_msg(work->request_buf); in __wbuf() 54 *rsp = smb_get_msg(work->response_buf); in __wbuf() 96 * @work: smb work 101 int smb2_get_ksmbd_tcon(struct ksmbd_work *work) in smb2_get_ksmbd_tcon() 103 struct smb2_hdr *req_hdr = ksmbd_req_buf_next(work); in smb2_get_ksmbd_tcon() 45 __wbuf(struct ksmbd_work * work,void ** req,void ** rsp) __wbuf() argument 99 smb2_get_ksmbd_tcon(struct ksmbd_work * work) smb2_get_ksmbd_tcon() argument 151 smb2_set_err_rsp(struct ksmbd_work * work) smb2_set_err_rsp() argument 182 is_smb2_neg_cmd(struct ksmbd_work * work) is_smb2_neg_cmd() argument 206 is_smb2_rsp(struct ksmbd_work * work) is_smb2_rsp() argument 227 get_smb2_cmd_val(struct ksmbd_work * work) get_smb2_cmd_val() argument 243 set_smb2_rsp_status(struct ksmbd_work * work,__le32 err) set_smb2_rsp_status() argument 263 init_smb2_neg_rsp(struct ksmbd_work * work) init_smb2_neg_rsp() argument 324 smb2_set_rsp_credits(struct ksmbd_work * work) smb2_set_rsp_credits() argument 386 init_chained_smb2_rsp(struct ksmbd_work * work) init_chained_smb2_rsp() argument 456 is_chained_smb2_message(struct ksmbd_work * work) is_chained_smb2_message() argument 507 init_smb2_rsp_hdr(struct ksmbd_work * work) init_smb2_rsp_hdr() argument 537 smb2_allocate_rsp_buf(struct ksmbd_work * work) smb2_allocate_rsp_buf() argument 581 smb2_check_user_session(struct ksmbd_work * work) smb2_check_user_session() argument 662 setup_async_work(struct ksmbd_work * work,void (* fn)(void **),void ** arg) setup_async_work() argument 691 release_async_work(struct ksmbd_work * work) release_async_work() argument 709 smb2_send_interim_resp(struct ksmbd_work * work,__le32 status) smb2_send_interim_resp() argument 1102 smb2_handle_negotiate(struct ksmbd_work * work) smb2_handle_negotiate() argument 1300 generate_preauth_hash(struct ksmbd_work * work) generate_preauth_hash() argument 1348 ntlm_negotiate(struct ksmbd_work * work,struct negotiate_message * negblob,size_t negblob_len,struct smb2_sess_setup_rsp * rsp) ntlm_negotiate() argument 1457 ntlm_authenticate(struct ksmbd_work * work,struct smb2_sess_setup_req * req,struct smb2_sess_setup_rsp * rsp) ntlm_authenticate() argument 1597 krb5_authenticate(struct ksmbd_work * work,struct smb2_sess_setup_req * req,struct smb2_sess_setup_rsp * rsp) krb5_authenticate() argument 1691 krb5_authenticate(struct ksmbd_work * work,struct smb2_sess_setup_req * req,struct smb2_sess_setup_rsp * rsp) krb5_authenticate() argument 1699 smb2_sess_setup(struct ksmbd_work * work) smb2_sess_setup() argument 1982 smb2_tree_connect(struct ksmbd_work * work) smb2_tree_connect() argument 2183 smb2_tree_disconnect(struct ksmbd_work * work) smb2_tree_disconnect() argument 2244 smb2_session_logoff(struct ksmbd_work * work) smb2_session_logoff() argument 2300 create_smb2_pipe(struct ksmbd_work * work) create_smb2_pipe() argument 2611 smb2_creat(struct ksmbd_work * work,struct path * path,char * name,int open_flags,umode_t posix_mode,bool is_dir) smb2_creat() argument 2649 smb2_create_sd_buffer(struct ksmbd_work * work,struct smb2_create_req * req,const struct path * path) smb2_create_sd_buffer() argument 2713 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 2890 smb2_open(struct ksmbd_work * work) smb2_open() argument 4161 struct ksmbd_work *work; global() member 4380 smb2_resp_buf_len(struct ksmbd_work * work,unsigned short hdr2_len) smb2_resp_buf_len() argument 4389 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 4405 smb2_query_dir(struct ksmbd_work * work) smb2_query_dir() argument 4710 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 4960 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 5048 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 5069 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 5392 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 5515 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 5747 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 5860 smb2_query_info(struct ksmbd_work * work) smb2_query_info() argument 5927 smb2_close_pipe(struct ksmbd_work * work) smb2_close_pipe() argument 5959 smb2_close(struct ksmbd_work * work) smb2_close() argument 6084 smb2_echo(struct ksmbd_work * work) smb2_echo() argument 6098 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 6170 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 6317 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 6376 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 6410 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 6510 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 6619 smb2_set_info(struct ksmbd_work * work) smb2_set_info() argument 6727 smb2_read_pipe(struct ksmbd_work * work) smb2_read_pipe() argument 6788 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 6818 smb2_read_rdma_channel(struct ksmbd_work * work,struct smb2_read_req * req,void * data_buf,size_t length) smb2_read_rdma_channel() argument 6840 smb2_read(struct ksmbd_work * work) smb2_read() argument 7021 smb2_write_pipe(struct ksmbd_work * work) smb2_write_pipe() argument 7082 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 7118 smb2_write(struct ksmbd_work * work) smb2_write() argument 7269 smb2_flush(struct ksmbd_work * work) smb2_flush() argument 7299 smb2_cancel(struct ksmbd_work * work) smb2_cancel() argument 7478 smb2_lock(struct ksmbd_work * work) smb2_lock() argument 7849 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 8131 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 8163 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 8208 fsctl_set_sparse(struct ksmbd_work * work,u64 id,struct file_sparse * sparse) fsctl_set_sparse() argument 8261 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 8285 smb2_ioctl(struct ksmbd_work * work) smb2_ioctl() argument 8639 smb20_oplock_break_ack(struct ksmbd_work * work) smb20_oplock_break_ack() argument 8779 smb21_lease_break_ack(struct ksmbd_work * work) smb21_lease_break_ack() argument 8911 smb2_oplock_break(struct ksmbd_work * work) smb2_oplock_break() argument 8944 smb2_notify(struct ksmbd_work * work) smb2_notify() argument 8971 smb2_is_sign_req(struct ksmbd_work * work,unsigned int command) smb2_is_sign_req() argument 8990 smb2_check_sign_req(struct ksmbd_work * work) smb2_check_sign_req() argument 9032 smb2_set_sign_rsp(struct ksmbd_work * work) smb2_set_sign_rsp() argument 9061 smb3_check_sign_req(struct ksmbd_work * work) smb3_check_sign_req() argument 9119 smb3_set_sign_rsp(struct ksmbd_work * work) smb3_set_sign_rsp() argument 9164 smb3_preauth_hash_rsp(struct ksmbd_work * work) smb3_preauth_hash_rsp() argument 9220 smb3_encrypt_resp(struct ksmbd_work * work) smb3_encrypt_resp() argument 9247 smb3_decrypt_req(struct ksmbd_work * work) smb3_decrypt_req() argument 9291 smb3_11_final_sess_setup_resp(struct ksmbd_work * work) smb3_11_final_sess_setup_resp() argument [all...] |
| H A D | ksmbd_work.h | 70 /* Contiguous SMB2 compression transform owned by this work item. */ 90 struct work_struct work; 100 * @work: smb work containing response buffer in ksmbd_resp_buf_next() 102 static inline void *ksmbd_resp_buf_next(struct ksmbd_work *work) 104 return work->response_buf + work->next_smb2_rsp_hdr_off + 4; 109 * @work: smb work containing response buffer in ksmbd_resp_buf_curr() 111 static inline void *ksmbd_resp_buf_curr(struct ksmbd_work *work) 86 struct work_struct work; global() member 98 ksmbd_resp_buf_next(struct ksmbd_work * work) ksmbd_resp_buf_next() argument 107 ksmbd_resp_buf_curr(struct ksmbd_work * work) ksmbd_resp_buf_curr() argument 116 ksmbd_req_buf_next(struct ksmbd_work * work) ksmbd_req_buf_next() argument [all...] |
| H A D | smb_common.c | 150 * @work: smb work 156 int ksmbd_verify_smb_message(struct ksmbd_work *work) 158 struct smb2_hdr *smb2_hdr = ksmbd_req_buf_next(work); 162 return ksmbd_smb2_check_message(work); in ksmbd_verify_smb_message() 164 hdr = smb_get_msg(work->request_buf); in ksmbd_verify_smb_message() 167 work->conn->outstanding_credits++; in ksmbd_verify_smb_message() 321 * @work: smb work containing smb header in ksmbd_negotiate_smb_dialect() 325 static u16 get_smb1_cmd_val(struct ksmbd_work *work) 159 ksmbd_verify_smb_message(struct ksmbd_work * work) ksmbd_verify_smb_message() argument 333 get_smb1_cmd_val(struct ksmbd_work * work) get_smb1_cmd_val() argument 344 init_smb1_rsp_hdr(struct ksmbd_work * work) init_smb1_rsp_hdr() argument 365 smb1_check_user_session(struct ksmbd_work * work) smb1_check_user_session() argument 381 smb1_allocate_rsp_buf(struct ksmbd_work * work) smb1_allocate_rsp_buf() argument 401 set_smb1_rsp_status(struct ksmbd_work * work,__le32 err) set_smb1_rsp_status() argument 418 smb1_negotiate(struct ksmbd_work * work) smb1_negotiate() argument 453 ksmbd_populate_dot_dotdot_entries(struct ksmbd_work * work,int info_level,struct ksmbd_file * dir,struct ksmbd_dir_info * d_info,char * search_pattern,int (* fn)(struct ksmbd_conn *,int,struct ksmbd_dir_info *,struct ksmbd_kstat *)) ksmbd_populate_dot_dotdot_entries() argument 597 smb_handle_negotiate(struct ksmbd_work * work) smb_handle_negotiate() argument 614 ksmbd_smb_negotiate_common(struct ksmbd_work * work,unsigned int command) ksmbd_smb_negotiate_common() argument 763 __ksmbd_override_fsids(struct ksmbd_work * work,struct ksmbd_share_config * share) __ksmbd_override_fsids() argument 811 ksmbd_override_fsids(struct ksmbd_work * work) ksmbd_override_fsids() argument 816 ksmbd_revert_fsids(struct ksmbd_work * work) ksmbd_revert_fsids() argument [all...] |
| /linux/drivers/gpu/drm/ |
| H A D | drm_flip_work.c | 47 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() 57 * drm_flip_work_queue - queue work 58 * @work: the flip-work 61 * Queues work, that will later be run (passed back to drm_flip_func_t 62 * func) on a work queue after drm_flip_work_commit() is called. 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() [all …]
|
| /linux/include/trace/events/ |
| H A D | workqueue.h | 14 * 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/virt/kvm/ |
| H A D | async_pf.c | 45 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/fs/btrfs/ |
| H A D | async-thread.c | 29 /* List head pointing to ordered work list */ 55 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() 163 * Hook for threshold which will be called before executing the work, 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() 229 * updates from ordinary work function. in run_ordered_work() 235 * we leave the work item on the list as a barrier so in run_ordered_work() 236 * that later work items that are done don't have their in run_ordered_work() [all …]
|
| /linux/kernel/ |
| H A D | irq_work.c | 57 static bool irq_work_claim(struct irq_work *work) in irq_work_claim() argument 61 oflags = atomic_fetch_or(IRQ_WORK_CLAIMED | CSD_TYPE_IRQ_WORK, &work->node.a_flags); in irq_work_claim() 63 * If the work is already pending, no need to raise the IPI. in irq_work_claim() 79 static __always_inline void irq_work_raise(struct irq_work *work) in irq_work_raise() argument 82 trace_call__ipi_send_cpu(smp_processor_id(), _RET_IP_, work->func); in irq_work_raise() 87 /* Enqueue on current CPU, work must already be claimed and preempt disabled */ 88 static void __irq_work_queue_local(struct irq_work *work) in __irq_work_queue_local() argument 95 work_flags = atomic_read(&work->node.a_flags); in __irq_work_queue_local() 107 if (!llist_add(&work->node.llist, list)) in __irq_work_queue_local() 110 /* If the work is "lazy", handle it from next tick if any */ in __irq_work_queue_local() [all …]
|
| H A D | kthread.c | 979 * when they finish. There is defined a safe point for freezing when one work 988 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 in kthread_worker_fn() 1156 queuing_blocked(struct kthread_worker * worker,struct kthread_work * work) queuing_blocked() argument 1164 kthread_insert_work_sanity_check(struct kthread_worker * worker,struct kthread_work * work) kthread_insert_work_sanity_check() argument 1174 kthread_insert_work(struct kthread_worker * worker,struct kthread_work * work,struct list_head * pos) kthread_insert_work() argument 1200 kthread_queue_work(struct kthread_worker * worker,struct kthread_work * work) kthread_queue_work() argument 1227 struct kthread_work *work = &dwork->work; kthread_delayed_work_timer_fn() local 1257 struct kthread_work *work = &dwork->work; __kthread_queue_delayed_work() local 1300 struct kthread_work *work = &dwork->work; kthread_queue_delayed_work() local 1317 struct kthread_work work; global() member 1321 kthread_flush_work_fn(struct kthread_work * work) kthread_flush_work_fn() argument 1334 kthread_flush_work(struct kthread_work * work) kthread_flush_work() argument 1373 kthread_cancel_delayed_work_timer(struct kthread_work * work,unsigned long * flags) kthread_cancel_delayed_work_timer() argument 1406 __kthread_cancel_work(struct kthread_work * work) __kthread_cancel_work() argument 1447 struct kthread_work *work = &dwork->work; kthread_mod_delayed_work() local 1490 __kthread_cancel_work_sync(struct kthread_work * work,bool is_dwork) __kthread_cancel_work_sync() argument 1543 kthread_cancel_work_sync(struct kthread_work * work) kthread_cancel_work_sync() argument [all...] |
| H A D | workqueue.c | 18 * This is the generic async execution mechanism. Work items as are 21 * normal work items and the other for high priority ones) and some extra 251 PWQ_STAT_STARTED, /* work items started execution */ 252 PWQ_STAT_COMPLETED, /* work items completed execution */ 258 PWQ_STAT_RESCUED, /* linked work items executed by rescuer */ 282 * When pwq->nr_active >= max_active, new work item is queued to 286 * All work items marked with WORK_STRUCT_INACTIVE do not participate in 287 * nr_active and all work items in pwq->inactive_works are marked with 288 * WORK_STRUCT_INACTIVE. But not all WORK_STRUCT_INACTIVE work items are 290 * pool->worklist or worker->scheduled. Those work itme 631 struct work_struct *work = addr; work_is_static_object() local 642 struct work_struct *work = addr; work_fixup_init() local 660 struct work_struct *work = addr; work_fixup_free() local 680 debug_work_activate(struct work_struct * work) debug_work_activate() argument 685 debug_work_deactivate(struct work_struct * work) debug_work_deactivate() argument 690 __init_work(struct work_struct * work,int onstack) __init_work() argument 699 destroy_work_on_stack(struct work_struct * work) destroy_work_on_stack() argument 705 destroy_delayed_work_on_stack(struct delayed_work * work) destroy_delayed_work_on_stack() argument 713 debug_work_activate(struct work_struct * work) debug_work_activate() argument 714 debug_work_deactivate(struct work_struct * work) debug_work_deactivate() argument 804 set_work_data(struct work_struct * work,unsigned long data) set_work_data() argument 810 set_work_pwq(struct work_struct * work,struct pool_workqueue * pwq,unsigned long flags) set_work_pwq() argument 817 set_work_pool_and_keep_pending(struct work_struct * work,int pool_id,unsigned long flags) set_work_pool_and_keep_pending() argument 824 set_work_pool_and_clear_pending(struct work_struct * work,int pool_id,unsigned long flags) set_work_pool_and_clear_pending() argument 872 get_work_pwq(struct work_struct * work) get_work_pwq() argument 897 get_work_pool(struct work_struct * work) get_work_pool() argument 1128 find_worker_executing_work(struct worker_pool * pool,struct work_struct * work) find_worker_executing_work() argument 1141 mayday_cursor_func(struct work_struct * work) mayday_cursor_func() argument 1161 move_linked_works(struct work_struct * work,struct list_head * head,struct work_struct ** nextp) move_linked_works() argument 1201 assign_work(struct work_struct * work,struct worker * worker,struct work_struct ** nextp) assign_work() argument 1303 struct work_struct *work = list_first_entry(&pool->worklist, kick_pool() local 1708 __pwq_activate_work(struct pool_workqueue * pwq,struct work_struct * work) __pwq_activate_work() argument 1821 struct work_struct *work = pwq_activate_first_inactive() local 1898 struct work_struct *work; node_activate_pending_pwq() local 2090 try_to_grab_pending(struct work_struct * work,u32 cflags,unsigned long * irq_flags) try_to_grab_pending() argument 2194 work_grab_pending(struct work_struct * work,u32 cflags,unsigned long * irq_flags) work_grab_pending() argument 2220 insert_work(struct pool_workqueue * pwq,struct work_struct * work,struct list_head * head,unsigned int extra_flags) insert_work() argument 2276 __queue_work(int cpu,struct workqueue_struct * wq,struct work_struct * work) __queue_work() argument 2405 clear_pending_if_disabled(struct work_struct * work) clear_pending_if_disabled() argument 2435 queue_work_on(int cpu,struct workqueue_struct * wq,struct work_struct * work) queue_work_on() argument 2503 queue_work_node(int node,struct workqueue_struct * wq,struct work_struct * work) queue_work_node() argument 2547 struct work_struct *work = &dwork->work; __queue_delayed_work() local 2603 struct work_struct *work = &dwork->work; queue_delayed_work_on() local 2677 struct work_struct *work = &rwork->work; queue_rcu_work() local 3000 idle_cull_fn(struct work_struct * work) idle_cull_fn() argument 3062 struct work_struct *work; pool_mayday_timeout() local 3212 process_one_work(struct worker * worker,struct work_struct * work) process_one_work() argument 3388 struct work_struct *work; process_scheduled_works() local 3473 struct work_struct *work = worker_thread() local 3501 struct work_struct *work, *n; assign_rescuer_work() local 3695 struct work_struct *work = bh_worker() local 3732 struct work_struct work; global() member 3737 drain_dead_softirq_workfn(struct work_struct * work) drain_dead_softirq_workfn() argument 3847 struct work_struct work; global() member 3852 wq_barrier_func(struct work_struct * work) wq_barrier_func() argument 4037 touch_work_lockdep_map(struct work_struct * work,struct workqueue_struct * wq) touch_work_lockdep_map() argument 4264 start_flush_work(struct work_struct * work,struct wq_barrier * barr,bool from_cancel) start_flush_work() argument 4320 __flush_work(struct work_struct * work,bool from_cancel) __flush_work() argument 4384 flush_work(struct work_struct * work) flush_work() argument 4451 __cancel_work(struct work_struct * work,u32 cflags) __cancel_work() argument 4470 __cancel_work_sync(struct work_struct * work,u32 cflags) __cancel_work_sync() argument 4497 cancel_work(struct work_struct * work) cancel_work() argument 4521 cancel_work_sync(struct work_struct * work) cancel_work_sync() argument 4576 disable_work(struct work_struct * work) disable_work() argument 4595 disable_work_sync(struct work_struct * work) disable_work_sync() argument 4611 enable_work(struct work_struct * work) enable_work() argument 4689 struct work_struct *work = per_cpu_ptr(works, cpu); schedule_on_each_cpu() local 5189 pwq_release_workfn(struct kthread_work * work) pwq_release_workfn() argument 6252 work_busy(struct work_struct * work) work_busy() argument 6399 pr_cont_work(bool comma,struct work_struct * work,struct pr_cont_work_struct * pcwsp) pr_cont_work() argument 6420 struct work_struct *work; show_pwq() local 6912 struct work_struct work; global() member 6918 work_for_cpu_fn(struct work_struct * work) work_for_cpu_fn() argument [all...] |
| /linux/LICENSES/dual/ |
| H A D | copyleft-next-0.3.1 | 26 of, publicly perform and publicly display My Work. 40 Legal Notices contained in My Work (to the extent they remain 47 If You Distribute a Derived Work, You must license the entire Derived 48 Work as a whole under this License, with prominent notice of such 50 separate Distribution of portions of the Derived Work. 52 If the Derived Work includes material licensed under the GPL, You may 53 instead license the Derived Work under the GPL. 57 When Distributing a Covered Work, You may not impose further 58 restrictions on the exercise of rights in the Covered Work granted under 64 However, You may Distribute a Covered Work incorporating material [all …]
|
| H A D | Apache-2.0 | 49 "Work" shall mean the work of authorship, whether in Source or Object form, 51 is included in or attached to the work (an example is provided in the 54 "Derivative Works" shall mean any work, whether in Source or Object form, 55 that is based on (or derived from) the Work and for which the editorial 57 a whole, an original work of authorship. For the purposes of this License, 59 merely link (or bind by name) to the interfaces of, the Work and Derivative 62 "Contribution" shall mean any work of authorship, including the original 63 version of the Work and any modifications or additions to that Work or 65 inclusion in the Work by the copyright owner or by an individual or Legal 72 and improving the Work, but excluding communication that is conspicuously [all …]
|
| /linux/tools/perf/ |
| H A D | builtin-kwork.c | 316 struct kwork_work *work; in work_search() 320 work = container_of(node, struct kwork_work, node); in work_search() 321 cmp = work_cmp(sort_list, key, work); in work_search() 327 if (work->name == NULL && key->name != NULL) in work_search() 328 work->name = strdup(key->name); in work_search() 329 return work; in work_search() 363 struct kwork_work *work = zalloc(sizeof(*work)); in work_new() 365 if (work == NULL) { in work_new() 366 pr_err("Failed to zalloc kwork work\ in work_new() 315 struct kwork_work *work; work_search() local 362 struct kwork_work *work = zalloc(sizeof(*work)); work_new() local 383 struct kwork_work *work = work_search(root, key, sort_list); work_findnew() local 409 profile_name_match(struct perf_kwork * kwork,struct kwork_work * work) profile_name_match() argument 420 profile_event_match(struct perf_kwork * kwork,struct kwork_work * work,struct perf_sample * sample) profile_event_match() argument 458 struct kwork_work *work, key; work_push_atom() local 516 struct kwork_work *work, key; work_pop_atom() local 551 struct kwork_work *work; find_work_by_id() local 579 report_update_exit_event(struct kwork_work * work,struct kwork_atom * atom,struct perf_sample * sample) report_update_exit_event() argument 618 struct kwork_work *work = NULL; report_exit_event() local 634 latency_update_entry_event(struct kwork_work * work,struct kwork_atom * atom,struct perf_sample * sample) latency_update_entry_event() argument 673 struct kwork_work *work = NULL; latency_entry_event() local 739 timehist_print_event(struct perf_kwork * kwork,struct kwork_work * work,struct kwork_atom * atom,struct perf_sample * sample,struct addr_location * al) timehist_print_event() argument 832 struct kwork_work *work = NULL; timehist_entry_event() local 853 struct kwork_work *work = NULL; timehist_exit_event() local 883 top_update_runtime(struct kwork_work * work,struct kwork_atom * atom,struct perf_sample * sample) top_update_runtime() argument 914 struct kwork_work *work, *sched_work; top_exit_event() local 945 struct kwork_work *work; top_sched_switch_event() local 1007 irq_work_init(struct perf_kwork * kwork,struct kwork_class * class,struct kwork_work * work,enum kwork_trace_type src_type __maybe_unused,struct evsel * evsel,struct perf_sample * sample,struct machine * machine __maybe_unused) irq_work_init() argument 1025 irq_work_name(struct kwork_work * work,char * buf,int len) irq_work_name() argument 1135 softirq_work_init(struct perf_kwork * kwork,struct kwork_class * class,struct kwork_work * work,enum kwork_trace_type src_type __maybe_unused,struct evsel * evsel,struct perf_sample * sample,struct machine * machine __maybe_unused) softirq_work_init() argument 1156 softirq_work_name(struct kwork_work * work,char * buf,int len) softirq_work_name() argument 1235 workqueue_work_init(struct perf_kwork * kwork __maybe_unused,struct kwork_class * class,struct kwork_work * work,enum kwork_trace_type src_type __maybe_unused,struct evsel * evsel,struct perf_sample * sample,struct machine * machine) workqueue_work_init() argument 1252 workqueue_work_name(struct kwork_work * work,char * buf,int len) workqueue_work_name() argument 1303 sched_work_init(struct perf_kwork * kwork __maybe_unused,struct kwork_class * class,struct kwork_work * work,enum kwork_trace_type src_type,struct evsel * evsel,struct perf_sample * sample,struct machine * machine __maybe_unused) sched_work_init() argument 1321 sched_work_name(struct kwork_work * work,char * buf,int len) sched_work_name() argument 1348 report_print_work(struct perf_kwork * kwork,struct kwork_work * work) report_print_work() argument 1639 top_print_work(struct perf_kwork * kwork __maybe_unused,struct kwork_work * work) top_print_work() argument 1839 process_skipped_events(struct perf_kwork * kwork,struct kwork_work * work) process_skipped_events() argument 1855 struct kwork_work *work = NULL; perf_kwork_add_work() local 1907 struct kwork_work *work; perf_kwork__report() local 2000 struct kwork_work *work; top_calc_total_runtime() local 2019 top_calc_idle_time(struct perf_kwork * kwork,struct kwork_work * work) top_calc_idle_time() argument 2031 top_calc_irq_runtime(struct perf_kwork * kwork,enum kwork_class_type type,struct kwork_work * work) top_calc_irq_runtime() argument 2045 top_subtract_irq_runtime(struct perf_kwork * kwork,struct kwork_work * work) top_subtract_irq_runtime() argument 2072 struct kwork_work *work; top_calc_cpu_usage() local 2101 top_calc_load_runtime(struct perf_kwork * kwork,struct kwork_work * work) top_calc_load_runtime() argument 2152 struct kwork_work *work; perf_kwork__top_report() local [all...] |
| /linux/include/linux/ |
| H A D | completion.h | 35 #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; })) 46 * @work: identifier for the completion structure 52 #define DECLARE_COMPLETION(work) \ argument 53 struct completion work = COMPLETION_INITIALIZER(work) 62 * @work: identifier for the completion structure [all …]
|
| /linux/net/wireless/ |
| H A D | debugfs.c | 148 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/LICENSES/deprecated/ |
| H A D | CC0-1.0 | 26 and subsequent owner(s) (each and all, an "owner") of an original work of 27 authorship and/or a database (each, a "Work"). 29 Certain owners wish to permanently relinquish those rights to a Work for 37 works, or to gain reputation or greater distribution for their Work in 42 associating CC0 with a Work (the "Affirmer"), to the extent that he or she 43 is an owner of Copyright and Related Rights in the Work, voluntarily 44 elects to apply CC0 to the Work and publicly distribute the Work under its 46 Work and the meaning and intended legal effect of CC0 on those rights. 48 1. Copyright and Related Rights. A Work made available under CC0 may be 54 communicate, and translate a Work; [all …]
|
| /linux/tools/testing/selftests/bpf/progs/ |
| H A D | task_work.c | 45 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/io_uring/ |
| H A D | io-wq.c | 68 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() 274 * If there's work to do, returns true with acct->lock acquired. If not, 308 * starting work or finishing work. In either case, if it does in io_acct_activate_free_worker() 309 * to go sleep, we'll kick off a new task for this work anyway. in io_acct_activate_free_worker() 326 * Most likely an attempt to queue unbounded work on an io_wq that in io_wq_create_worker() 415 * work item after we canceled in io_wq_exit_workers(). in io_queue_worker_create() 432 /* Defer if current and next work ar 433 io_wq_hash_defer(struct io_wq_work * work,struct io_wq_acct * acct) io_wq_hash_defer() argument 529 struct io_wq_work *work, *tail; io_get_next_work() local 583 io_assign_current_work(struct io_worker * worker,struct io_wq_work * work) io_assign_current_work() argument 606 struct io_wq_work *work; io_worker_handle_work() local 801 io_wq_work_match_all(struct io_wq_work * work,void * data) io_wq_work_match_all() argument 883 io_workqueue_create(struct work_struct * work) io_workqueue_create() argument 990 io_run_cancel(struct io_wq_work * work,struct io_wq * wq) io_run_cancel() argument 1000 io_wq_insert_work(struct io_wq * wq,struct io_wq_acct * acct,struct io_wq_work * work,unsigned int work_flags) io_wq_insert_work() argument 1020 io_wq_work_match_item(struct io_wq_work * work,void * data) io_wq_work_match_item() argument 1025 io_wq_enqueue(struct io_wq * wq,struct io_wq_work * work) io_wq_enqueue() argument 1079 io_wq_hash_work(struct io_wq_work * work,void * val) io_wq_hash_work() argument 1089 __io_wq_worker_cancel(struct io_worker * worker,struct io_cb_cancel_data * match,struct io_wq_work * work) __io_wq_worker_cancel() argument 1118 io_wq_remove_pending(struct io_wq * wq,struct io_wq_acct * acct,struct io_wq_work * work,struct io_wq_work_node * prev) io_wq_remove_pending() argument 1141 struct io_wq_work *work; io_acct_cancel_pending_work() local [all...] |
| /linux/drivers/infiniband/core/ |
| H A D | cm.c | 95 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); 711 __be32 remote_id = timewait_info->work.remote_id; in cm_insert_remote_id() 717 if (be32_lt(remote_id, cur_timewait_info->work.remote_id)) in cm_insert_remote_id() 719 else if (be32_gt(remote_id, cur_timewait_info->work.remote_id)) in cm_insert_remote_id() 745 if (be32_lt(remote_id, timewait_info->work.remote_id)) in cm_find_remote_id() 747 else if (be32_gt(remote_id, timewait_info->work.remote_id)) in cm_find_remote_id() 754 res = cm_acquire_id(timewait_info->work in cm_find_remote_id() 888 struct cm_work *work; cm_dequeue_work() local 898 cm_free_work(struct cm_work * work) cm_free_work() argument 906 cm_queue_work_unlock(struct cm_id_private * cm_id_priv,struct cm_work * work) cm_queue_work_unlock() argument 1060 struct cm_work *work; cm_destroy_id() local 1771 cm_get_bth_pkey(struct cm_work * work) cm_get_bth_pkey() argument 1798 cm_opa_to_ib_sgid(struct cm_work * work,struct sa_path_rec * path) cm_opa_to_ib_sgid() argument 1818 cm_format_req_event(struct cm_work * work,struct cm_id_private * cm_id_priv,struct ib_cm_id * listen_id) cm_format_req_event() argument 1863 cm_process_work(struct cm_id_private * cm_id_priv,struct cm_work * work) cm_process_work() argument 1952 cm_dup_req_handler(struct cm_work * work,struct cm_id_private * cm_id_priv) cm_dup_req_handler() argument 2001 cm_match_req(struct cm_work * work,struct cm_id_private * cm_id_priv) cm_match_req() argument 2094 cm_req_handler(struct cm_work * work) cm_req_handler() argument 2416 cm_format_rep_event(struct cm_work * work,enum ib_qp_type qp_type) cm_format_rep_event() argument 2444 cm_dup_rep_handler(struct cm_work * work) cm_dup_rep_handler() argument 2489 cm_rep_handler(struct cm_work * work) cm_rep_handler() argument 2594 cm_establish_handler(struct cm_work * work) cm_establish_handler() argument 2617 cm_rtu_handler(struct cm_work * work) cm_rtu_handler() argument 2839 cm_dreq_handler(struct cm_work * work) cm_dreq_handler() argument 2913 cm_drep_handler(struct cm_work * work) cm_drep_handler() argument 3017 cm_format_rej_event(struct cm_work * work) cm_format_rej_event() argument 3055 cm_rej_handler(struct cm_work * work) cm_rej_handler() argument 3171 cm_mra_handler(struct cm_work * work) cm_mra_handler() argument 3284 cm_lap_handler(struct cm_work * work) cm_lap_handler() argument 3382 cm_apr_handler(struct cm_work * work) cm_apr_handler() argument 3426 cm_timewait_handler(struct cm_work * work) cm_timewait_handler() argument 3525 cm_format_sidr_req_event(struct cm_work * work,const struct cm_id_private * rx_cm_id,struct ib_cm_id * listen_id) cm_format_sidr_req_event() argument 3546 cm_sidr_req_handler(struct cm_work * work) cm_sidr_req_handler() argument 3702 cm_format_sidr_rep_event(struct cm_work * work,const struct cm_id_private * cm_id_priv) cm_format_sidr_rep_event() argument 3723 cm_sidr_rep_handler(struct cm_work * work) cm_sidr_rep_handler() argument 3841 struct cm_work *work = container_of(_work, struct cm_work, work.work); cm_work_handler() local 3896 struct cm_work *work; cm_establish() local 4000 struct cm_work *work; cm_recv_handler() local [all...] |
| /linux/LICENSES/preferred/ |
| H A D | LGPL-2.1 | 94 work, a derivative of the original library. The ordinary General Public 127 follow. Pay close attention to the difference between a "work based on the 128 library" and a "work that uses the library". The former contains code 144 The "Library", below, refers to any such software library or work which 145 has been distributed under these terms. A "work based on the Library" 146 means either the Library or any derivative work under copyright law: 147 that is to say, a work containing the Library or a portion of it, either 152 "Source code" for a work means the preferred form of the work for making 161 program is covered only if its contents constitute a work based on the 177 thus forming a work based on the Library, and copy and distribute such [all …]
|
| H A D | LGPL-2.0 | 88 a textual and legal sense, the linked executable is a combined work, a 108 follow. Pay close attention to the difference between a "work based on the 109 library" and a "work that uses the library". The former contains code 128 The "Library", below, refers to any such software library or work which 129 has been distributed under these terms. A "work based on the Library" 130 means either the Library or any derivative work under copyright law: 131 that is to say, a work containing the Library or a portion of it, either 136 "Source code" for a work means the preferred form of the work for making 145 program is covered only if its contents constitute a work based on the 161 thus forming a work based on the Library, and copy and distribute such [all …]
|
| /linux/kernel/unwind/ |
| H A D | deferred.c | 152 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() 206 * @work: Unwind descriptor requesting the trace 209 * Schedule a user space unwind to be done in task work before exiting the 218 * It's valid to call this function multiple times for the same @work within 229 int unwind_deferred_request(struct unwind_work *work, u64 *cookie) in unwind_deferred_request() argument [all …]
|