| /drivers/md/dm-vdo/ |
| A D | completion.h | 21 if ((completion->result != VDO_SUCCESS) && (completion->error_handler != NULL)) { in vdo_run_completion()
22 completion->error_handler(completion); in vdo_run_completion()
26 completion->callback(completion); in vdo_run_completion()
40 completion->result = VDO_SUCCESS; in vdo_reset_completion()
41 completion->complete = false; in vdo_reset_completion()
65 vdo_launch_completion(completion); in vdo_continue_completion()
77 vdo_finish_completion(completion); in vdo_fail_completion()
90 completion->type); in vdo_assert_completion_type()
97 completion->callback = callback; in vdo_set_completion_callback()
125 completion->parent = parent; in vdo_prepare_completion()
[all …]
|
| A D | completion.c | 55 memset(completion, 0, sizeof(*completion)); in vdo_initialize_completion()
56 completion->vdo = vdo; in vdo_initialize_completion()
57 completion->type = type; in vdo_initialize_completion()
58 vdo_reset_completion(completion); in vdo_initialize_completion()
73 assert_incomplete(completion); in vdo_set_completion_result()
75 completion->result = result; in vdo_set_completion_result()
96 vdo_run_completion(completion); in vdo_launch_completion_with_priority()
102 assert_incomplete(completion); in vdo_finish_completion()
103 completion->complete = true; in vdo_finish_completion()
120 completion->requeue = false; in vdo_enqueue_completion()
[all …]
|
| A D | repair.c | 200 return container_of(completion, struct repair_completion, completion); in as_repair_completion()
206 struct vdo_completion *completion = &repair->completion; in prepare_repair_completion() local
359 completion); in flush_block_map_updates()
374 vdo_set_completion_result(&repair->completion, completion->result); in handle_page_load_error()
836 completion)) in add_slab_journal_entries()
853 struct vdo_completion *completion = &allocator->completion; in vdo_replay_into_slab_journals() local
1049 completion++; in get_next_page_completion()
1052 return completion; in get_next_page_completion()
1092 completion = &page_completion->completion; in recover_ready_pages()
1676 vdo_set_completion_result(&repair->completion, completion->result); in handle_journal_load_error()
[all …]
|
| A D | flush.c | 24 struct vdo_completion completion; member
75 return container_of(completion, struct flusher, completion); in as_flusher()
87 return container_of(completion, struct vdo_flush, completion); in completion_as_vdo_flush()
194 struct flusher *flusher = as_flusher(completion); in finish_notification()
214 struct flusher *flusher = as_flusher(completion); in flush_packer_callback()
230 struct flusher *flusher = as_flusher(completion); in increment_generation()
256 flusher->completion.requeue = true; in notify_flush()
270 struct flusher *flusher = completion->vdo->flusher; in flush_vdo()
377 struct vdo_completion *completion = &flush->completion; in launch_flush() local
463 struct vdo *vdo = completion->vdo; in vdo_complete_flush_callback()
[all …]
|
| A D | data-vio.c | 160 struct vdo_completion completion; member
218 return container_of(completion, struct data_vio_pool, completion); in as_data_vio_pool()
464 complete_data_vio(completion); in attempt_logical_block_lock()
488 struct vdo_completion *completion = &data_vio->vio.completion; in launch_data_vio() local
1248 struct vdo_completion *completion = &data_vio->vio.completion; in finish_cleanup() local
1269 completion->requeue = true; in finish_cleanup()
1339 vdo_enter_read_only_mode(completion->vdo, completion->result); in enter_read_only_mode()
1350 complete_data_vio(completion); in handle_data_vio_error()
1494 complete_data_vio(completion); in complete_read()
1528 complete_read(completion); in complete_zero_read()
[all …]
|
| A D | action-manager.c | 54 struct vdo_completion completion; member
69 return container_of(completion, struct action_manager, completion); in as_action_manager()
81 vdo_finish_completion(completion); in no_preamble()
153 if (completion->parent != NULL) in preserve_error()
154 vdo_set_completion_result(completion->parent, completion->result); in preserve_error()
156 vdo_reset_completion(completion); in preserve_error()
157 vdo_run_completion(completion); in preserve_error()
201 completion->callback = finish_action_callback; in handle_preamble_error()
202 preserve_error(completion); in handle_preamble_error()
216 finish_action_callback(&manager->completion); in launch_current_action()
[all …]
|
| A D | funnel-workqueue.c | 64 struct completion *started;
115 completion, completion->callback, queue, completion->my_queue); in enqueue_work_queue_completion()
121 completion->priority = 0; in enqueue_work_queue_completion()
194 if (completion != NULL) in wait_for_next_completion()
212 if (completion != NULL) in wait_for_next_completion()
219 return completion; in wait_for_next_completion()
227 completion, queue, completion->my_queue) == VDO_SUCCESS) in process_completion()
228 completion->my_queue = NULL; in process_completion()
240 if (completion == NULL) in service_work_queue()
243 if (completion == NULL) { in service_work_queue()
[all …]
|
| A D | dm-vdo-target.c | 1175 struct vdo_completion *completion = &vdo->admin.completion; in prepare_admin_completion() local
1184 completion->requeue = true; in prepare_admin_completion()
1185 return completion; in prepare_admin_completion()
2056 completion); in suspend_callback()
2066 completion); in suspend_callback()
2212 vdo_repair(completion); in load_callback()
2219 completion, NULL); in load_callback()
2231 completion); in load_callback()
2259 completion); in load_callback()
2303 load_callback(completion); in handle_load_error()
[all …]
|
| A D | data-vio.h | 289 return vio_as_data_vio(as_vio(completion)); in as_data_vio()
315 return data_vio->vio.completion.vdo; in vdo_from_data_vio()
348 vdo_launch_completion(&data_vio->vio.completion); in continue_data_vio()
392 vdo_launch_completion(&data_vio->vio.completion); in launch_data_vio_hash_zone_callback()
420 vdo_launch_completion(&data_vio->vio.completion); in launch_data_vio_logical_callback()
450 vdo_launch_completion(&data_vio->vio.completion); in launch_data_vio_allocated_zone_callback()
480 vdo_launch_completion(&data_vio->vio.completion); in launch_data_vio_duplicate_zone_callback()
545 vdo_launch_completion(&data_vio->vio.completion); in launch_data_vio_journal_callback()
636 struct vdo_completion *completion = &data_vio->vio.completion; in launch_data_vio_on_bio_ack_queue() local
637 struct vdo *vdo = completion->vdo; in launch_data_vio_on_bio_ack_queue()
[all …]
|
| A D | block-map.c | 171 vdo_assert_completion_type(&completion->completion, VDO_PAGE_COMPLETION); in page_completion_from_waiter()
172 return completion; in page_completion_from_waiter()
602 result = VDO_ASSERT(completion->info->pbn == completion->pbn, in validate_completed_page()
1111 struct vdo_completion *completion = &info->vio->completion; in write_pages() local
1214 struct vdo_completion *completion = &page_completion->completion; in vdo_get_page() local
1649 struct vdo_completion *completion = &vio->vio.completion; in write_page() local
2499 struct vdo_completion *completion = cursors->completion; in finish_cursor() local
2691 cursors->completion = completion; in vdo_traverse_forest()
3072 finish_processing_page(completion, completion->result); in handle_page_error()
3170 finish_processing_page(completion, completion->result); in get_mapping_from_fetched_page()
[all …]
|
| A D | vdo.c | 64 struct completion completion; member
907 vdo_continue_completion(vdo_forget(completion->parent), completion->result); in continue_super_block_parent()
932 completion->callback(completion); in handle_save_error()
1108 return container_of(completion, struct read_only_notifier, completion); in as_notifier()
1127 completion->result); in finish_entering_read_only_mode()
1136 struct vdo *vdo = completion->vdo; in make_thread_read_only()
1183 vdo_launch_completion(completion); in make_thread_read_only()
1335 vdo_completion)->completion)); in complete_synchronous_action()
1351 init_completion(&sync.completion); in perform_synchronous_action()
1364 struct vdo *vdo = completion->vdo; in set_compression_callback()
[all …]
|
| A D | slab-depot.c | 297 vdo_enter_read_only_mode(completion->vdo, completion->result); in handle_write_error()
429 vdo_enter_read_only_mode(completion->vdo, completion->result); in handle_flush_error()
430 complete_reaping(completion); in handle_flush_error()
1189 struct vdo_completion *completion = &pooled->vio.completion; in write_reference_block() local
1197 completion->parent = block; in write_reference_block()
2840 completion->result); in handle_scrubber_error()
2997 slab_scrubbed(completion); in start_scrubbing()
3012 struct vdo_completion *completion = &scrubber->vio.completion; in scrub_next_slab() local
3391 actor->callback(completion); in slab_action_callback()
3405 completion->callback(completion); in handle_operation_error()
[all …]
|
| A D | io-submitter.c | 76 struct atomic_statistics *stats = &vio->completion.vdo->stats; in count_all_bios()
109 struct vdo *vdo = vio->completion.vdo; in send_bio_to_device()
122 void vdo_submit_vio(struct vdo_completion *completion) in vdo_submit_vio() argument
124 struct vio *vio = as_vio(completion); in vdo_submit_vio()
167 struct vio *vio = as_vio(completion); in submit_data_vio()
206 if (vio->completion.priority != vio_merge->completion.priority) in get_mergeable_locked()
273 struct vdo *vdo = vio->completion.vdo; in try_bio_map_merge()
345 struct vdo_completion *completion = &vio->completion; in __submit_metadata_vio() local
351 vdo_reset_completion(completion); in __submit_metadata_vio()
352 completion->error_handler = error_handler; in __submit_metadata_vio()
[all …]
|
| A D | logical-zone.c | 32 static struct logical_zone *as_logical_zone(struct vdo_completion *completion) in as_logical_zone() argument
34 vdo_assert_completion_type(completion, VDO_GENERATION_FLUSHED_COMPLETION); in as_logical_zone()
35 return container_of(completion, struct logical_zone, completion); in as_logical_zone()
65 vdo_initialize_completion(&zone->completion, vdo, in initialize_zone()
285 static void notify_flusher(struct vdo_completion *completion) in notify_flusher() argument
287 struct logical_zone *zone = as_logical_zone(completion); in notify_flusher()
290 vdo_launch_completion_callback(completion, in notify_flusher()
300 static void attempt_generation_complete_notification(struct vdo_completion *completion) in attempt_generation_complete_notification() argument
302 struct logical_zone *zone = as_logical_zone(completion); in attempt_generation_complete_notification()
313 vdo_launch_completion_callback(&zone->completion, notify_flusher, in attempt_generation_complete_notification()
[all …]
|
| A D | block-map.h | 167 struct vdo_completion completion; member
291 struct vdo_completion *completion);
293 static inline struct vdo_page_completion *as_vdo_page_completion(struct vdo_completion *completion) in as_vdo_page_completion() argument
295 vdo_assert_completion_type(completion, VDO_PAGE_COMPLETION); in as_vdo_page_completion()
296 return container_of(completion, struct vdo_page_completion, completion); in as_vdo_page_completion()
299 void vdo_release_page_completion(struct vdo_completion *completion);
306 void vdo_request_page_write(struct vdo_completion *completion);
308 int __must_check vdo_get_cached_page(struct vdo_completion *completion,
331 struct vdo_completion *completion);
|
| A D | vio.h | 43 static inline struct vio *as_vio(struct vdo_completion *completion) in as_vio() argument
45 vdo_assert_completion_type(completion, VIO_COMPLETION); in as_vio()
46 return container_of(completion, struct vio, completion); in as_vio()
58 return vio->completion.vdo->thread_config.bio_threads[vio->bio_zone]; in get_vio_bio_zone_thread_id()
120 vdo_initialize_completion(&vio->completion, vdo, VIO_COMPLETION); in initialize_vio()
165 vdo_set_completion_result(&vio->completion, result); in continue_vio()
167 vdo_enqueue_completion(&vio->completion, VDO_WORK_Q_DEFAULT_PRIORITY); in continue_vio()
180 vdo_set_completion_callback(&vio->completion, callback, thread); in continue_vio_after_io()
|
| A D | dedupe.c | 286 struct vdo_completion completion; member
312 return container_of(completion, struct hash_zone, completion); in as_hash_zone()
318 return container_of(completion, struct hash_zones, completion); in as_hash_zones()
631 struct data_vio *agent = as_data_vio(completion); in finish_unlocking()
687 struct data_vio *agent = as_data_vio(completion); in unlock_duplicate_pbn()
697 complete_data_vio(completion); in unlock_duplicate_pbn()
744 struct data_vio *agent = as_data_vio(completion); in finish_updating()
1075 struct data_vio *agent = as_data_vio(completion); in finish_verifying()
1150 verify_callback(completion); in uncompress_and_verify()
2344 vdo_launch_completion(&zone->completion); in timeout_index_operations()
[all …]
|
| A D | packer.c | 275 static void finish_compressed_write(struct vdo_completion *completion) in finish_compressed_write() argument
277 struct data_vio *agent = as_data_vio(completion); in finish_compressed_write()
291 completion->error_handler = handle_data_vio_error; in finish_compressed_write()
295 static void handle_compressed_write_error(struct vdo_completion *completion) in handle_compressed_write_error() argument
297 struct data_vio *agent = as_data_vio(completion); in handle_compressed_write_error()
304 update_vio_error_stats(as_vio(completion), in handle_compressed_write_error()
314 vdo_reset_completion(completion); in handle_compressed_write_error()
315 completion->error_handler = handle_data_vio_error; in handle_compressed_write_error()
461 agent->vio.completion.error_handler = handle_compressed_write_error; in write_bin()
661 void vdo_remove_lock_holder_from_packer(struct vdo_completion *completion) in vdo_remove_lock_holder_from_packer() argument
[all …]
|
| /drivers/net/wwan/iosm/ |
| A D | iosm_ipc_task_queue.c | 28 if (args->completion) in ipc_task_queue_handler()
29 complete(args->completion); in ipc_task_queue_handler()
42 args->completion = NULL; in ipc_task_queue_handler()
64 if (args->completion) in ipc_task_queue_cleanup()
65 complete(args->completion); in ipc_task_queue_cleanup()
85 struct completion completion; in ipc_task_queue_add_task() local
90 init_completion(&completion); in ipc_task_queue_add_task()
111 ipc_task->args[pos].completion = wait ? &completion : NULL; in ipc_task_queue_add_task()
130 wait_for_completion(&completion); in ipc_task_queue_add_task()
|
| /drivers/scsi/aic94xx/ |
| A D | aic94xx_tmf.c | 67 complete(ascb->completion); in asd_clear_nexus_tasklet_complete()
78 complete(ascb->completion); in asd_clear_nexus_timedout()
94 ascb->completion = &completion; \
106 wait_for_completion(&completion); \
252 complete(ascb->completion); in asd_tmf_timedout()
320 complete(ascb->completion); in asd_tmf_tasklet_complete()
332 tascb->completion = &completion; in asd_clear_nexus()
341 tascb->completion = NULL; in asd_clear_nexus()
415 ascb->completion = &completion; in asd_abort_task()
526 tascb->completion = NULL; in asd_abort_task()
[all …]
|
| /drivers/char/hw_random/ |
| A D | timeriomem-rng.c | 39 struct completion completion; member
61 wait_for_completion(&priv->completion); in timeriomem_rng_read()
85 reinit_completion(&priv->completion); in timeriomem_rng_read()
98 complete(&priv->completion); in timeriomem_rng_trigger()
154 init_completion(&priv->completion); in timeriomem_rng_probe()
162 complete(&priv->completion); in timeriomem_rng_probe()
|
| /drivers/s390/char/ |
| A D | sclp_ftp.c | 39 struct completion *completion = data; in sclp_ftp_txcb() local
45 complete(completion); in sclp_ftp_txcb()
90 struct completion completion; in sclp_ftp_et7() local
131 req->callback_data = &completion; in sclp_ftp_et7()
133 init_completion(&completion); in sclp_ftp_et7()
140 wait_for_completion(&completion); in sclp_ftp_et7()
|
| /drivers/net/wireless/ath/ath11k/ |
| A D | core.h | 659 struct completion started;
660 struct completion completed;
661 struct completion on_channel;
713 struct completion peer_assoc_done;
760 struct completion target_suspend;
770 struct completion fw_mode_reset;
790 struct completion fw_stats_done;
912 struct completion fw_ready;
1009 struct completion reset_complete;
1011 struct completion recovery_start;
[all …]
|
| /drivers/rpmsg/ |
| A D | qcom_glink_ssr.c | 55 struct completion completion; member
93 complete(&ssr->completion); in qcom_glink_ssr_callback()
108 reinit_completion(&ssr->completion); in qcom_glink_ssr_notifier_call()
120 ret = wait_for_completion_timeout(&ssr->completion, HZ); in qcom_glink_ssr_notifier_call()
135 init_completion(&ssr->completion); in qcom_glink_ssr_probe()
|
| /drivers/leds/trigger/ |
| A D | ledtrig-tty.c | 16 struct completion sysfs;
62 int completion; in ttyname_show() local
65 completion = ledtrig_tty_wait_for_completion(dev); in ttyname_show()
66 if (completion < 0) in ttyname_show()
67 return completion; in ttyname_show()
82 int completion; in ttyname_store() local
96 completion = ledtrig_tty_wait_for_completion(dev); in ttyname_store()
97 if (completion < 0) in ttyname_store()
98 return completion; in ttyname_store()
|