| /drivers/mailbox/ |
| D | mtk-cmdq-mailbox.c | 72 struct cmdq_thread *thread; member
82 struct cmdq_thread *thread; member
116 static int cmdq_thread_suspend(struct cmdq *cmdq, struct cmdq_thread *thread) in cmdq_thread_suspend() argument
120 writel(CMDQ_THR_SUSPEND, thread->base + CMDQ_THR_SUSPEND_TASK); in cmdq_thread_suspend()
123 if (!(readl(thread->base + CMDQ_THR_ENABLE_TASK) & CMDQ_THR_ENABLED)) in cmdq_thread_suspend()
126 if (readl_poll_timeout_atomic(thread->base + CMDQ_THR_CURR_STATUS, in cmdq_thread_suspend()
129 (u32)(thread->base - cmdq->base)); in cmdq_thread_suspend()
136 static void cmdq_thread_resume(struct cmdq_thread *thread) in cmdq_thread_resume() argument
138 writel(CMDQ_THR_RESUME, thread->base + CMDQ_THR_SUSPEND_TASK); in cmdq_thread_resume()
155 static int cmdq_thread_reset(struct cmdq *cmdq, struct cmdq_thread *thread) in cmdq_thread_reset() argument
[all …]
|
| /drivers/md/dm-vdo/ |
| D | thread-utils.c | 21 struct thread { struct
37 struct thread *thread = arg; in thread_starter() local
39 thread->thread_task = current; in thread_starter()
41 hlist_add_head(&thread->thread_links, &thread_list); in thread_starter()
44 thread->thread_function(thread->thread_data); in thread_starter()
46 complete(&thread->thread_done); in thread_starter()
51 const char *name, struct thread **new_thread) in vdo_create_thread()
56 struct thread *thread; in vdo_create_thread() local
59 result = vdo_allocate(1, struct thread, __func__, &thread); in vdo_create_thread()
65 thread->thread_function = thread_function; in vdo_create_thread()
[all …]
|
| D | thread-registry.c | 28 struct registered_thread *thread; in vdo_register_thread() local
36 list_for_each_entry(thread, ®istry->links, links) { in vdo_register_thread()
37 if (thread->task == current) { in vdo_register_thread()
39 list_del_rcu(&thread->links); in vdo_register_thread()
51 INIT_LIST_HEAD(&thread->links); in vdo_register_thread()
57 struct registered_thread *thread; in vdo_unregister_thread() local
61 list_for_each_entry(thread, ®istry->links, links) { in vdo_unregister_thread()
62 if (thread->task == current) { in vdo_unregister_thread()
63 list_del_rcu(&thread->links); in vdo_unregister_thread()
74 INIT_LIST_HEAD(&thread->links); in vdo_unregister_thread()
[all …]
|
| D | thread-utils.h | 13 struct thread;
17 const char *name, struct thread **new_thread);
18 void vdo_join_threads(struct thread *thread);
|
| D | funnel-workqueue.c | 62 struct task_struct *thread; member
319 struct task_struct *thread = NULL; in make_simple_work_queue() local
350 thread = kthread_run(work_queue_runner, queue, "%s:%s", thread_name_prefix, in make_simple_work_queue()
352 if (IS_ERR(thread)) { in make_simple_work_queue()
354 return (int) PTR_ERR(thread); in make_simple_work_queue()
357 queue->thread = thread; in make_simple_work_queue()
446 if (queue->thread == NULL) in finish_simple_work_queue()
450 kthread_stop(queue->thread); in finish_simple_work_queue()
451 queue->thread = NULL; in finish_simple_work_queue()
483 if (queue->thread != NULL) { in dump_simple_work_queue()
[all …]
|
| D | vdo.c | 132 struct vdo_thread *thread = vdo_get_work_queue_owner(vdo_get_current_work_queue()); in start_vdo_request_queue() local
134 vdo_register_allocating_thread(&thread->allocating_thread, in start_vdo_request_queue()
135 &thread->vdo->allocations_allowed); in start_vdo_request_queue()
412 struct vdo_thread *thread = &vdo->threads[thread_id]; in vdo_make_thread() local
418 if (thread->queue != NULL) { in vdo_make_thread()
419 return VDO_ASSERT(vdo_work_queue_type_is(thread->queue, type), in vdo_make_thread()
424 thread->vdo = vdo; in vdo_make_thread()
425 thread->thread_id = thread_id; in vdo_make_thread()
427 return vdo_make_work_queue(vdo->thread_name_prefix, queue_name, thread, in vdo_make_thread()
428 type, queue_count, contexts, &thread->queue); in vdo_make_thread()
[all …]
|
| /drivers/android/ |
| D | binder.c | 464 binder_enqueue_deferred_thread_work_ilocked(struct binder_thread *thread, in binder_enqueue_deferred_thread_work_ilocked() argument
467 WARN_ON(!list_empty(&thread->waiting_thread_node)); in binder_enqueue_deferred_thread_work_ilocked()
468 binder_enqueue_work_ilocked(work, &thread->todo); in binder_enqueue_deferred_thread_work_ilocked()
482 binder_enqueue_thread_work_ilocked(struct binder_thread *thread, in binder_enqueue_thread_work_ilocked() argument
485 WARN_ON(!list_empty(&thread->waiting_thread_node)); in binder_enqueue_thread_work_ilocked()
486 binder_enqueue_work_ilocked(work, &thread->todo); in binder_enqueue_thread_work_ilocked()
493 if (thread->looper & BINDER_LOOPER_STATE_POLL && in binder_enqueue_thread_work_ilocked()
494 thread->pid == current->pid && !thread->process_todo) in binder_enqueue_thread_work_ilocked()
495 wake_up_interruptible_sync(&thread->wait); in binder_enqueue_thread_work_ilocked()
497 thread->process_todo = true; in binder_enqueue_thread_work_ilocked()
[all …]
|
| /drivers/acpi/acpica/ |
| D | exmutex.c | 21 struct acpi_thread_state *thread);
37 struct acpi_thread_state *thread = obj_desc->mutex.owner_thread; in acpi_ex_unlink_mutex() local
39 if (!thread) { in acpi_ex_unlink_mutex()
61 thread->acquired_mutex_list = obj_desc->mutex.next; in acpi_ex_unlink_mutex()
80 struct acpi_thread_state *thread) in acpi_ex_link_mutex() argument
84 list_head = thread->acquired_mutex_list; in acpi_ex_link_mutex()
99 thread->acquired_mutex_list = obj_desc; in acpi_ex_link_mutex()
205 if (!walk_state->thread) { in acpi_ex_acquire_mutex()
216 if (walk_state->thread->current_sync_level > obj_desc->mutex.sync_level) { in acpi_ex_acquire_mutex()
221 walk_state->thread->current_sync_level)); in acpi_ex_acquire_mutex()
[all …]
|
| D | dswstate.c | 413 *thread) in acpi_ds_get_current_walk_state()
417 if (!thread) { in acpi_ds_get_current_walk_state()
422 thread->walk_state_list)); in acpi_ds_get_current_walk_state()
424 return (thread->walk_state_list); in acpi_ds_get_current_walk_state()
442 struct acpi_thread_state *thread) in acpi_ds_push_walk_state() argument
446 walk_state->next = thread->walk_state_list; in acpi_ds_push_walk_state()
447 thread->walk_state_list = walk_state; in acpi_ds_push_walk_state()
466 struct acpi_walk_state *acpi_ds_pop_walk_state(struct acpi_thread_state *thread) in acpi_ds_pop_walk_state() argument
472 walk_state = thread->walk_state_list; in acpi_ds_pop_walk_state()
478 thread->walk_state_list = walk_state->next; in acpi_ds_pop_walk_state()
[all …]
|
| D | psparse.c | 411 struct acpi_thread_state *thread; in acpi_ps_parse_aml() local
428 thread = acpi_ut_create_thread_state(); in acpi_ps_parse_aml()
429 if (!thread) { in acpi_ps_parse_aml()
443 walk_state->thread = thread; in acpi_ps_parse_aml()
450 walk_state->thread->current_sync_level = in acpi_ps_parse_aml()
454 acpi_ds_push_walk_state(walk_state, thread); in acpi_ps_parse_aml()
460 acpi_gbl_current_walk_list = thread; in acpi_ps_parse_aml()
503 acpi_ds_call_control_method(thread, walk_state, in acpi_ps_parse_aml()
514 walk_state = acpi_ds_get_current_walk_state(thread); in acpi_ps_parse_aml()
553 walk_state = acpi_ds_pop_walk_state(thread); in acpi_ps_parse_aml()
[all …]
|
| D | dsdebug.c | 94 struct acpi_thread_state *thread; in acpi_ds_dump_method_stack() local
120 thread = walk_state->thread; in acpi_ds_dump_method_stack()
121 if (!thread) { in acpi_ds_dump_method_stack()
137 next_walk_state = thread->walk_state_list; in acpi_ds_dump_method_stack()
|
| D | dsmethod.c | 344 && (walk_state->thread->current_sync_level > in acpi_ds_begin_method_execution()
350 walk_state->thread->current_sync_level)); in acpi_ds_begin_method_execution()
361 (walk_state->thread->thread_id != in acpi_ds_begin_method_execution()
380 walk_state->thread->current_sync_level; in acpi_ds_begin_method_execution()
383 walk_state->thread->thread_id; in acpi_ds_begin_method_execution()
394 walk_state->thread->current_sync_level = in acpi_ds_begin_method_execution()
456 acpi_ds_call_control_method(struct acpi_thread_state *thread, in acpi_ds_call_control_method() argument
506 thread); in acpi_ds_call_control_method()
589 acpi_ds_pop_walk_state(thread); in acpi_ds_call_control_method()
771 walk_state->thread->current_sync_level = in acpi_ds_terminate_control_method()
|
| /drivers/of/ |
| D | cpu.c | 14 u64 of_get_cpu_hwid(struct device_node *cpun, unsigned int thread) in of_get_cpu_hwid() argument
21 if (!cell || !ac || ((sizeof(*cell) * ac * (thread + 1)) > len)) in of_get_cpu_hwid()
24 cell += ac * thread; in of_get_cpu_hwid()
53 const char *prop_name, int cpu, unsigned int *thread) in __of_find_n_match_cpu_property() argument
69 if (thread) in __of_find_n_match_cpu_property()
70 *thread = tid; in __of_find_n_match_cpu_property()
85 int cpu, unsigned int *thread) in arch_find_n_match_cpu_physical_id() argument
94 cpu, thread)) in arch_find_n_match_cpu_physical_id()
97 return __of_find_n_match_cpu_property(cpun, "reg", cpu, thread); in arch_find_n_match_cpu_physical_id()
119 struct device_node *of_get_cpu_node(int cpu, unsigned int *thread) in of_get_cpu_node() argument
[all …]
|
| /drivers/dma/ |
| D | dmatest.c | 257 struct dmatest_thread *thread; in is_threaded_test_run() local
259 list_for_each_entry(thread, &dtc->threads, node) { in is_threaded_test_run()
260 if (!thread->done && !thread->pending) in is_threaded_test_run()
273 struct dmatest_thread *thread; in is_threaded_test_pending() local
275 list_for_each_entry(thread, &dtc->threads, node) { in is_threaded_test_pending()
276 if (thread->pending) in is_threaded_test_pending()
437 struct dmatest_thread *thread = in dmatest_callback() local
439 if (!thread->done) { in dmatest_callback()
576 struct dmatest_thread *thread = data; in dmatest_func() local
577 struct dmatest_done *done = &thread->test_done; in dmatest_func()
[all …]
|
| /drivers/media/pci/saa7134/ |
| D | saa7134-tvaudio.c | 304 if (dev->thread.scan1 == dev->thread.scan2 && in tvaudio_sleep()
314 return dev->thread.scan1 != dev->thread.scan2; in tvaudio_sleep()
477 dev->thread.scan1 = dev->thread.scan2; in tvaudio_thread()
479 dev->thread.scan1); in tvaudio_thread()
518 if (dev->thread.scan1 != dev->thread.scan2) in tvaudio_thread()
592 if (UNSET == dev->thread.mode) { in tvaudio_thread()
596 mode = dev->thread.mode; in tvaudio_thread()
606 dev->thread.stopped = 1; in tvaudio_thread()
773 dev->thread.scan1 = dev->thread.scan2; in tvaudio_thread_ddep()
775 dev->thread.scan1); in tvaudio_thread_ddep()
[all …]
|
| /drivers/android/binder/ |
| D | process.rs | 50 thread::{PushWorkRes, Thread},
150 if let Some(thread) = self.ready_threads.pop_front() { in push_work()
151 work.on_thread_selected(&thread); in push_work()
155 match thread.push_work(work) { in push_work()
179 for thread in self.threads.values() { in push_work()
180 thread.notify_if_poll_ready(sync); in push_work()
205 if let Some(thread) = othread { in update_node_refcount()
206 thread.push_work_deferred(node); in update_node_refcount()
219 thread: Option<&Thread>, in new_node_ref()
221 self.update_node_refcount(&node, true, strong, 1, thread); in new_node_ref()
[all …]
|
| D | rust_binder_events.h | 55 TP_PROTO(struct task_struct *thread, int desired_prio, int new_prio),
56 TP_ARGS(thread, desired_prio, new_prio),
60 __field(int, thread)
66 __entry->proc = thread->tgid;
67 __entry->thread = thread->pid;
68 __entry->old_prio = thread->normal_prio;
73 __entry->proc, __entry->thread, __entry->old_prio,
129 TP_PROTO(rust_binder_transaction t, rust_binder_thread thread),
130 TP_ARGS(t, thread),
137 __entry->to_thread = rust_binder_thread_id(thread);
|
| /drivers/base/ |
| D | devtmpfs.c | 40 static struct task_struct *thread; variable
106 wake_up_process(thread); in devtmpfs_submit_req()
119 if (!thread) in devtmpfs_create_node()
146 if (!thread) in devtmpfs_delete_node()
172 d_inode(dentry)->i_private = &thread; in dev_mkdir()
233 d_inode(dentry)->i_private = &thread; in handle_create()
249 if (d_inode(dentry)->i_private == &thread) in dev_rmdir()
291 if (inode->i_private != &thread) in dev_mynode()
367 if (!thread) in devtmpfs_mount()
465 thread = kthread_run(devtmpfsd, &err, "kdevtmpfs"); in devtmpfs_init()
[all …]
|
| /drivers/net/wireless/rsi/ |
| D | rsi_common.h | 60 struct rsi_thread *thread, in rsi_create_kthread() argument
64 init_completion(&thread->completion); in rsi_create_kthread()
65 atomic_set(&thread->thread_done, 0); in rsi_create_kthread()
66 thread->task = kthread_run(func_ptr, common, "%s", name); in rsi_create_kthread()
67 if (IS_ERR(thread->task)) in rsi_create_kthread()
68 return (int)PTR_ERR(thread->task); in rsi_create_kthread()
|
| /drivers/vfio/ |
| D | virqfd.c | 52 virqfd->thread) in virqfd_wakeup()
100 if (virqfd->thread) in virqfd_inject()
101 virqfd->thread(virqfd->opaque, virqfd->data); in virqfd_inject()
113 void (*thread)(void *, void *), in vfio_virqfd_enable()
129 virqfd->thread = thread; in vfio_virqfd_enable()
181 if ((!handler || handler(opaque, data)) && thread) in vfio_virqfd_enable()
230 if (*pvirqfd && (*pvirqfd)->thread) in vfio_virqfd_flush_thread()
|
| /drivers/scsi/bnx2i/ |
| D | bnx2i_init.c | 414 struct task_struct *thread; in bnx2i_cpu_online() local
418 thread = kthread_create_on_node(bnx2i_percpu_io_thread, (void *)p, in bnx2i_cpu_online()
421 if (IS_ERR(thread)) in bnx2i_cpu_online()
422 return PTR_ERR(thread); in bnx2i_cpu_online()
425 kthread_bind(thread, cpu); in bnx2i_cpu_online()
426 p->iothread = thread; in bnx2i_cpu_online()
427 wake_up_process(thread); in bnx2i_cpu_online()
434 struct task_struct *thread; in bnx2i_cpu_offline() local
440 thread = p->iothread; in bnx2i_cpu_offline()
452 if (thread) in bnx2i_cpu_offline()
[all …]
|
| /drivers/net/ethernet/marvell/mvpp2/ |
| D | mvpp2_main.c | 158 static void mvpp2_thread_write(struct mvpp2 *priv, unsigned int thread, in mvpp2_thread_write() argument
161 writel(data, priv->swth_base[thread] + offset); in mvpp2_thread_write()
164 static u32 mvpp2_thread_read(struct mvpp2 *priv, unsigned int thread, in mvpp2_thread_read() argument
167 return readl(priv->swth_base[thread] + offset); in mvpp2_thread_read()
170 static void mvpp2_thread_write_relaxed(struct mvpp2 *priv, unsigned int thread, in mvpp2_thread_write_relaxed() argument
173 writel_relaxed(data, priv->swth_base[thread] + offset); in mvpp2_thread_write_relaxed()
176 static u32 mvpp2_thread_read_relaxed(struct mvpp2 *priv, unsigned int thread, in mvpp2_thread_read_relaxed() argument
179 return readl_relaxed(priv->swth_base[thread] + offset); in mvpp2_thread_read_relaxed()
466 unsigned int thread = mvpp2_cpu_to_thread(priv, get_cpu()); in mvpp2_bm_bufs_get_addrs() local
468 *dma_addr = mvpp2_thread_read(priv, thread, in mvpp2_bm_bufs_get_addrs()
[all …]
|
| /drivers/iio/buffer/ |
| D | industrialio-triggered-buffer.c | 41 irqreturn_t (*thread)(int irq, void *p), in iio_triggered_buffer_setup_ext()
66 thread, in iio_triggered_buffer_setup_ext()
120 irqreturn_t (*thread)(int irq, void *p), in devm_iio_triggered_buffer_setup_ext()
127 ret = iio_triggered_buffer_setup_ext(indio_dev, h, thread, direction, in devm_iio_triggered_buffer_setup_ext()
|
| /drivers/media/pci/pt3/ |
| D | pt3.c | 439 adap->thread->comm); in pt3_fetch_thread()
454 adap->thread->comm); in pt3_fetch_thread()
460 struct task_struct *thread; in pt3_start_streaming() local
463 thread = kthread_run(pt3_fetch_thread, adap, "pt3-ad%i-dmx%i", in pt3_start_streaming()
465 if (IS_ERR(thread)) { in pt3_start_streaming()
466 int ret = PTR_ERR(thread); in pt3_start_streaming()
468 adap->thread = NULL; in pt3_start_streaming()
474 adap->thread = thread; in pt3_start_streaming()
490 ret = kthread_stop(adap->thread); in pt3_stop_streaming()
491 adap->thread = NULL; in pt3_stop_streaming()
[all …]
|
| /drivers/w1/ |
| D | w1_int.c | 135 dev->thread = kthread_run(&w1_process, dev, "%s", dev->name); in w1_add_master_device()
136 if (IS_ERR(dev->thread)) { in w1_add_master_device()
137 retval = PTR_ERR(dev->thread); in w1_add_master_device()
158 kthread_stop(dev->thread); in w1_add_master_device()
179 kthread_stop(dev->thread); in __w1_remove_master_device()
|