Searched refs:waiter (Results 26 - 50 of 56) sorted by relevance

123

/linux-master/drivers/md/dm-vdo/
H A Ddata-vio.h172 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 Dblock-map.c88 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 Dslab-depot.c126 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 Dflush.c92 * @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 Dphysical-zone.c517 * @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 Dvio.c400 * @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 Drecovery-journal.c267 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 Dblock-map.h170 /* 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 Dslab-depot.h68 /* 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 Dvio.h196 void acquire_vio_from_pool(struct vio_pool *pool, struct vdo_waiter *waiter);
H A Dvdo.c1086 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 Dvdo.h112 struct vdo_completion *waiter; member in struct:read_only_notifier
H A Ddedupe.c427 * 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 Dlocks.c675 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 Ddirect-io.c137 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 Dfutex_waitv.c62 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 Dfutex_requeue_pi.c128 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 Ddirect-io.c45 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 Ddm-block-manager.c55 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 Dfops.c113 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 Dkunit_kernel.py356 waiter = threading.Thread(target=_wait_proc)
357 waiter.start()
372 waiter.join()
/linux-master/include/linux/
H A Dfilelock.h329 static inline int locks_delete_block(struct file_lock *waiter) argument
H A Dblkdev.h1446 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 Dprintk.c1850 * 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 Di915_scheduler.c340 dep->waiter = node;

Completed in 279 milliseconds

123