/linux-master/drivers/md/dm-vdo/ |
H A D | data-vio.h | 172 struct vdo_waiter waiter; member in struct:reference_updater 178 struct vdo_waiter waiter; member in struct:data_vio 292 static inline struct data_vio *vdo_waiter_as_data_vio(struct vdo_waiter *waiter) argument 294 if (waiter == NULL) 297 return container_of(waiter, struct data_vio, waiter);
|
H A D | block-map.c | 88 struct vdo_waiter waiter; member in struct:cursor 163 static inline struct vdo_page_completion *page_completion_from_waiter(struct vdo_waiter *waiter) argument 167 if (waiter == NULL) 170 completion = container_of(waiter, struct vdo_page_completion, waiter); 502 * @waiter: The page completion, as a waiter. 507 static void complete_waiter_with_error(struct vdo_waiter *waiter, void *result_ptr) argument 511 vdo_fail_completion(&page_completion_from_waiter(waiter)->completion, *result); 516 * @waiter 521 complete_waiter_with_page(struct vdo_waiter *waiter, void *page_info) argument 875 completion_needs_page(struct vdo_waiter *waiter, void *context) argument 1499 write_page_callback(struct vdo_waiter *waiter, void *context) argument 1504 acquire_vio(struct vdo_waiter *waiter, struct block_map_zone *zone) argument 1534 write_page_if_not_dirtied(struct vdo_waiter *waiter, void *context) argument 1724 abort_lookup_for_waiter(struct vdo_waiter *waiter, void *context) argument 1814 continue_load_for_waiter(struct vdo_waiter *waiter, void *context) argument 1872 load_page(struct vdo_waiter *waiter, void *context) argument 1949 continue_allocation_for_waiter(struct vdo_waiter *waiter, void *context) argument 2629 launch_cursor(struct vdo_waiter *waiter, void *context) argument [all...] |
H A D | slab-depot.c | 126 static void release_journal_locks(struct vdo_waiter *waiter, void *context); 353 * @waiter: The waiter that is updating the summary. 359 static void update_slab_summary_entry(struct vdo_slab *slab, struct vdo_waiter *waiter, argument 372 waiter->callback(waiter, &result); 379 waiter->callback(waiter, &result); 390 vdo_waitq_enqueue_waiter(&block->next_update_waiters, waiter); 444 * flush_for_reaping() - A waiter callbac 449 flush_for_reaping(struct vdo_waiter *waiter, void *context) argument 558 release_journal_locks(struct vdo_waiter *waiter, void *context) argument 742 write_slab_journal_block(struct vdo_waiter *waiter, void *context) argument 1015 finish_summary_update(struct vdo_waiter *waiter, void *context) argument 1041 launch_reference_block_write(struct vdo_waiter *waiter, void *context) argument 1185 write_reference_block(struct vdo_waiter *waiter, void *context) argument 1689 add_entry_from_waiter(struct vdo_waiter *waiter, void *context) argument 1755 struct vdo_waiter *waiter = vdo_waitq_get_first_waiter(&journal->entry_waiters); local 2269 load_reference_block(struct vdo_waiter *waiter, void *context) argument 2294 struct vdo_waiter *waiter = &slab->reference_blocks[i].waiter; local 2465 read_slab_journal_tail(struct vdo_waiter *waiter, void *context) argument 3063 abort_waiter(struct vdo_waiter *waiter, void *context __always_unused) argument 3219 vdo_enqueue_clean_slab_waiter(struct block_allocator *allocator, struct vdo_waiter *waiter) argument [all...] |
H A D | flush.c | 92 * @waiter: The wait queue entry to convert. 96 static struct vdo_flush *vdo_waiter_as_flush(struct vdo_waiter *waiter) argument 98 return container_of(waiter, struct vdo_flush, waiter); 285 vdo_waitq_enqueue_waiter(&flusher->notifiers, &flush->waiter);
|
H A D | physical-zone.c | 517 * @waiter: The allocating_vio that was waiting to allocate. 520 static void retry_allocation(struct vdo_waiter *waiter, void *context __always_unused) argument 522 struct data_vio *data_vio = vdo_waiter_as_data_vio(waiter); 560 data_vio->waiter.callback = retry_allocation; 562 &data_vio->waiter);
|
H A D | vio.c | 400 * @waiter: Object that is requesting a vio. 402 void acquire_vio_from_pool(struct vio_pool *pool, struct vdo_waiter *waiter) argument 410 vdo_waitq_enqueue_waiter(&pool->waiting, waiter); 417 (*waiter->callback)(waiter, pooled);
|
H A D | recovery-journal.c | 267 static void continue_waiter(struct vdo_waiter *waiter, void *context) argument 269 continue_data_vio_with_error(vdo_waiter_as_data_vio(waiter), *((int *) context)); 276 * Return: true if any block has a waiter. 1080 * assign_entry() - Assign an entry waiter to the active block. 1084 static void assign_entry(struct vdo_waiter *waiter, void *context) argument 1086 struct data_vio *data_vio = vdo_waiter_as_data_vio(waiter); 1102 vdo_waitq_enqueue_waiter(&block->entry_waiters, &data_vio->waiter); 1171 static void continue_committed_waiter(struct vdo_waiter *waiter, void *context) argument 1173 struct data_vio *data_vio = vdo_waiter_as_data_vio(waiter); 1180 "DataVIOs released from recovery journal in order. Recovery journal point is (%llu, %u), but commit waiter poin 1368 write_block(struct vdo_waiter *waiter, void *context __always_unused) argument [all...] |
H A D | block-map.h | 170 /* The waiter for the pending list */ 171 struct vdo_waiter waiter; member in struct:vdo_page_completion 185 struct vdo_waiter waiter; member in struct:tree_page
|
H A D | slab-depot.h | 68 /* A waiter object for getting a VIO pool entry */ 70 /* A waiter object for updating the slab summary */ 72 /* A waiter object for getting a vio with which to flush */ 158 struct vdo_waiter waiter; member in struct:reference_block 254 /* A waiter object for updating the slab summary */ 531 struct vdo_waiter *waiter);
|
H A D | vio.h | 196 void acquire_vio_from_pool(struct vio_pool *pool, struct vdo_waiter *waiter);
|
H A D | vdo.c | 1086 if (notifier->waiter != NULL) { 1093 notifier->waiter = parent; 1098 if (notifier->waiter == NULL) { 1134 if (notifier->waiter != NULL) 1135 vdo_continue_completion(vdo_forget(notifier->waiter), 1214 if (notifier->waiter != NULL) { 1225 notifier->waiter = parent; 1230 if (notifier->waiter == NULL) {
|
H A D | vdo.h | 112 struct vdo_completion *waiter; member in struct:read_only_notifier
|
H A D | dedupe.c | 427 * Return: The first (oldest) waiter in the queue, or NULL if the queue is empty. 522 * retire_lock_agent() - Retire the active lock agent, replacing it with the first lock waiter, and 526 * Return: The new lock agent (which will be NULL if there was no waiter) 547 vdo_waitq_enqueue_waiter(&lock->waiters, &data_vio->waiter); 570 * @waiter: The data_vio's waiter link. 573 static void abort_waiter(struct vdo_waiter *waiter, void *context __always_unused) argument 575 write_data_vio(vdo_waiter_as_data_vio(waiter)); 657 * need to be re-verified if a waiter arrived. 664 * agent was releasing the PBN lock. The current agent exits and the waiter ha 928 enter_forked_lock(struct vdo_waiter *waiter, void *context) argument [all...] |
/linux-master/fs/ |
H A D | locks.c | 675 static void locks_insert_global_blocked(struct file_lock_core *waiter) argument 679 hash_add(blocked_hash, &waiter->flc_link, posix_owner_key(waiter)); 682 static void locks_delete_global_blocked(struct file_lock_core *waiter) argument 686 hash_del(&waiter->flc_link); 689 /* Remove waiter from blocker's block list. 694 static void __locks_unlink_block(struct file_lock_core *waiter) argument 696 locks_delete_global_blocked(waiter); 697 list_del_init(&waiter->flc_blocked_member); 703 struct file_lock_core *waiter; local 726 __locks_delete_block(struct file_lock_core *waiter) argument 776 locks_delete_block(struct file_lock *waiter) argument 797 __locks_insert_block(struct file_lock_core *blocker, struct file_lock_core *waiter, bool conflict(struct file_lock_core *, struct file_lock_core *)) argument 826 locks_insert_block(struct file_lock_core *blocker, struct file_lock_core *waiter, bool conflict(struct file_lock_core *, struct file_lock_core *)) argument [all...] |
H A D | direct-io.c | 137 struct task_struct *waiter; /* waiting task (NULL if none) */ member in struct:dio 347 if (remaining == 1 && dio->waiter) 348 wake_up_process(dio->waiter); 389 if (--dio->refcount == 1 && dio->waiter) 390 wake_up_process(dio->waiter); 482 dio->waiter = current; 487 dio->waiter = NULL;
|
/linux-master/tools/testing/selftests/futex/functional/ |
H A D | futex_waitv.c | 62 pthread_t waiter; local 97 if (pthread_create(&waiter, NULL, waiterfn, NULL)) 130 if (pthread_create(&waiter, NULL, waiterfn, NULL)) 148 /* Testing a waiter without FUTEX_32 flag */ 166 /* Testing a waiter with an unaligned address */
|
H A D | futex_requeue_pi.c | 128 info("waiter %ld woke with %d %s\n", args->id, args->ret, 285 pthread_t waiter[THREAD_MAX], waker, blocker; local 322 if (create_rt_thread(&waiter[i], waiterfn, (void *)&args[i], 341 pthread_join(waiter[i],
|
/linux-master/fs/iomap/ |
H A D | direct-io.c | 45 struct task_struct *waiter; member in struct:iomap_dio::__anon1795::__anon1796 175 struct task_struct *waiter = dio->submit.waiter; local 177 WRITE_ONCE(dio->submit.waiter, NULL); 178 blk_wake_io_task(waiter); 578 dio->submit.waiter = current; 724 if (!READ_ONCE(dio->submit.waiter))
|
/linux-master/drivers/md/persistent-data/ |
H A D | dm-block-manager.c | 55 struct waiter { struct 122 static void __wait(struct waiter *w) 136 static void __wake_waiter(struct waiter *w) 152 struct waiter *w, *tmp; 196 struct waiter w; 259 struct waiter w;
|
/linux-master/block/ |
H A D | fops.c | 113 struct task_struct *waiter; member in union:blkdev_dio::__anon310 148 struct task_struct *waiter = dio->waiter; local 150 WRITE_ONCE(dio->waiter, NULL); 151 blk_wake_io_task(waiter); 193 dio->waiter = current; 263 if (!READ_ONCE(dio->waiter))
|
/linux-master/tools/testing/kunit/ |
H A D | kunit_kernel.py | 356 waiter = threading.Thread(target=_wait_proc) 357 waiter.start() 372 waiter.join()
|
/linux-master/include/linux/ |
H A D | filelock.h | 329 static inline int locks_delete_block(struct file_lock *waiter) argument
|
H A D | blkdev.h | 1446 static inline void blk_wake_io_task(struct task_struct *waiter) argument 1453 if (waiter == current) 1456 wake_up_process(waiter);
|
/linux-master/kernel/printk/ |
H A D | printk.c | 1850 * there may be a waiter spinning (like a spinlock). Also it must be 1872 /* The waiter may spin on us after setting console_owner */ 1878 * thread was able to busy wait and check if there is a waiter 1884 * there is a busy waiter and passes the lock rights to her. 1887 * there was a busy waiter. They must not touch items synchronized by 1894 int waiter; local 1901 * in the first place. If there has been a waiter then non panic CPUs 1913 waiter = READ_ONCE(console_waiter); 1917 if (!waiter) { 1922 /* The waiter i 1954 bool waiter; local [all...] |
/linux-master/drivers/gpu/drm/i915/ |
H A D | i915_scheduler.c | 340 dep->waiter = node;
|